summaryrefslogtreecommitdiffstats
path: root/internal/testbinapi/binapi2001/session
diff options
context:
space:
mode:
Diffstat (limited to 'internal/testbinapi/binapi2001/session')
-rw-r--r--internal/testbinapi/binapi2001/session/session.ba.go2026
-rw-r--r--internal/testbinapi/binapi2001/session/session_rpc.ba.go273
2 files changed, 2299 insertions, 0 deletions
diff --git a/internal/testbinapi/binapi2001/session/session.ba.go b/internal/testbinapi/binapi2001/session/session.ba.go
new file mode 100644
index 0000000..7f5af5c
--- /dev/null
+++ b/internal/testbinapi/binapi2001/session/session.ba.go
@@ -0,0 +1,2026 @@
+// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
+// versions:
+// binapi-generator: v0.4.0-dev
+// VPP: 20.01
+// source: .vppapi/core/session.api.json
+
+// Package session contains generated bindings for API file session.api.
+//
+// Contents:
+// 44 messages
+//
+package session
+
+import (
+ api "git.fd.io/govpp.git/api"
+ codec "git.fd.io/govpp.git/codec"
+)
+
+// This is a compile-time assertion to ensure that this generated file
+// is compatible with the GoVPP api package it is being compiled against.
+// A compilation error at this line likely means your copy of the
+// GoVPP api package needs to be updated.
+const _ = api.GoVppAPIPackageIsVersion2
+
+const (
+ APIFile = "session"
+ APIVersion = "1.7.0"
+ VersionCrc = 0xdf888b15
+)
+
+// AppAddCertKeyPair defines message 'app_add_cert_key_pair'.
+type AppAddCertKeyPair struct {
+ CertLen uint16 `binapi:"u16,name=cert_len" json:"cert_len,omitempty"`
+ CertkeyLen uint16 `binapi:"u16,name=certkey_len" json:"-"`
+ Certkey []byte `binapi:"u8[certkey_len],name=certkey" json:"certkey,omitempty"`
+}
+
+func (m *AppAddCertKeyPair) Reset() { *m = AppAddCertKeyPair{} }
+func (*AppAddCertKeyPair) GetMessageName() string { return "app_add_cert_key_pair" }
+func (*AppAddCertKeyPair) GetCrcString() string { return "02eb8016" }
+func (*AppAddCertKeyPair) GetMessageType() api.MessageType {
+ return api.RequestMessage
+}
+
+func (m *AppAddCertKeyPair) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 2 // m.CertLen
+ size += 2 // m.CertkeyLen
+ size += 1 * len(m.Certkey) // m.Certkey
+ return size
+}
+func (m *AppAddCertKeyPair) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeUint16(m.CertLen)
+ buf.EncodeUint16(uint16(len(m.Certkey)))
+ buf.EncodeBytes(m.Certkey, 0)
+ return buf.Bytes(), nil
+}
+func (m *AppAddCertKeyPair) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.CertLen = buf.DecodeUint16()
+ m.CertkeyLen = buf.DecodeUint16()
+ m.Certkey = make([]byte, m.CertkeyLen)
+ copy(m.Certkey, buf.DecodeBytes(len(m.Certkey)))
+ return nil
+}
+
+// AppAddCertKeyPairReply defines message 'app_add_cert_key_pair_reply'.
+type AppAddCertKeyPairReply struct {
+ Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"`
+ Index uint32 `binapi:"u32,name=index" json:"index,omitempty"`
+}
+
+func (m *AppAddCertKeyPairReply) Reset() { *m = AppAddCertKeyPairReply{} }
+func (*AppAddCertKeyPairReply) GetMessageName() string { return "app_add_cert_key_pair_reply" }
+func (*AppAddCertKeyPairReply) GetCrcString() string { return "b42958d0" }
+func (*AppAddCertKeyPairReply) GetMessageType() api.MessageType {
+ return api.ReplyMessage
+}
+
+func (m *AppAddCertKeyPairReply) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.Retval
+ size += 4 // m.Index
+ return size
+}
+func (m *AppAddCertKeyPairReply) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeInt32(m.Retval)
+ buf.EncodeUint32(m.Index)
+ return buf.Bytes(), nil
+}
+func (m *AppAddCertKeyPairReply) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.Retval = buf.DecodeInt32()
+ m.Index = buf.DecodeUint32()
+ return nil
+}
+
+// AppAttach defines message 'app_attach'.
+type AppAttach struct {
+ Options []uint64 `binapi:"u64[16],name=options" json:"options,omitempty"`
+ NamespaceIDLen uint8 `binapi:"u8,name=namespace_id_len" json:"namespace_id_len,omitempty"`
+ NamespaceID []byte `binapi:"u8[64],name=namespace_id" json:"namespace_id,omitempty"`
+}
+
+func (m *AppAttach) Reset() { *m = AppAttach{} }
+func (*AppAttach) GetMessageName() string { return "app_attach" }
+func (*AppAttach) GetCrcString() string { return "ed08f4bd" }
+func (*AppAttach) GetMessageType() api.MessageType {
+ return api.RequestMessage
+}
+
+func (m *AppAttach) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 8 * 16 // m.Options
+ size += 1 // m.NamespaceIDLen
+ size += 1 * 64 // m.NamespaceID
+ return size
+}
+func (m *AppAttach) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ for i := 0; i < 16; i++ {
+ var x uint64
+ if i < len(m.Options) {
+ x = uint64(m.Options[i])
+ }
+ buf.EncodeUint64(x)
+ }
+ buf.EncodeUint8(m.NamespaceIDLen)
+ buf.EncodeBytes(m.NamespaceID, 64)
+ return buf.Bytes(), nil
+}
+func (m *AppAttach) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.Options = make([]uint64, 16)
+ for i := 0; i < len(m.Options); i++ {
+ m.Options[i] = buf.DecodeUint64()
+ }
+ m.NamespaceIDLen = buf.DecodeUint8()
+ m.NamespaceID = make([]byte, 64)
+ copy(m.NamespaceID, buf.DecodeBytes(len(m.NamespaceID)))
+ return nil
+}
+
+// AppAttachReply defines message 'app_attach_reply'.
+type AppAttachReply struct {
+ Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"`
+ AppMq uint64 `binapi:"u64,name=app_mq" json:"app_mq,omitempty"`
+ VppCtrlMq uint64 `binapi:"u64,name=vpp_ctrl_mq" json:"vpp_ctrl_mq,omitempty"`
+ VppCtrlMqThread uint8 `binapi:"u8,name=vpp_ctrl_mq_thread" json:"vpp_ctrl_mq_thread,omitempty"`
+ AppIndex uint32 `binapi:"u32,name=app_index" json:"app_index,omitempty"`
+ NFds uint8 `binapi:"u8,name=n_fds" json:"n_fds,omitempty"`
+ FdFlags uint8 `binapi:"u8,name=fd_flags" json:"fd_flags,omitempty"`
+ SegmentSize uint32 `binapi:"u32,name=segment_size" json:"segment_size,omitempty"`
+ SegmentNameLength uint8 `binapi:"u8,name=segment_name_length" json:"segment_name_length,omitempty"`
+ SegmentName []byte `binapi:"u8[128],name=segment_name" json:"segment_name,omitempty"`
+ SegmentHandle uint64 `binapi:"u64,name=segment_handle" json:"segment_handle,omitempty"`
+}
+
+func (m *AppAttachReply) Reset() { *m = AppAttachReply{} }
+func (*AppAttachReply) GetMessageName() string { return "app_attach_reply" }
+func (*AppAttachReply) GetCrcString() string { return "0112f647" }
+func (*AppAttachReply) GetMessageType() api.MessageType {
+ return api.ReplyMessage
+}
+
+func (m *AppAttachReply) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.Retval
+ size += 8 // m.AppMq
+ size += 8 // m.VppCtrlMq
+ size += 1 // m.VppCtrlMqThread
+ size += 4 // m.AppIndex
+ size += 1 // m.NFds
+ size += 1 // m.FdFlags
+ size += 4 // m.SegmentSize
+ size += 1 // m.SegmentNameLength
+ size += 1 * 128 // m.SegmentName
+ size += 8 // m.SegmentHandle
+ return size
+}
+func (m *AppAttachReply) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeInt32(m.Retval)
+ buf.EncodeUint64(m.AppMq)
+ buf.EncodeUint64(m.VppCtrlMq)
+ buf.EncodeUint8(m.VppCtrlMqThread)
+ buf.EncodeUint32(m.AppIndex)
+ buf.EncodeUint8(m.NFds)
+ buf.EncodeUint8(m.FdFlags)
+ buf.EncodeUint32(m.SegmentSize)
+ buf.EncodeUint8(m.SegmentNameLength)
+ buf.EncodeBytes(m.SegmentName, 128)
+ buf.EncodeUint64(m.SegmentHandle)
+ return buf.Bytes(), nil
+}
+func (m *AppAttachReply) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.Retval = buf.DecodeInt32()
+ m.AppMq = buf.DecodeUint64()
+ m.VppCtrlMq = buf.DecodeUint64()
+ m.VppCtrlMqThread = buf.DecodeUint8()
+ m.AppIndex = buf.DecodeUint32()
+ m.NFds = buf.DecodeUint8()
+ m.FdFlags = buf.DecodeUint8()
+ m.SegmentSize = buf.DecodeUint32()
+ m.SegmentNameLength = buf.DecodeUint8()
+ m.SegmentName = make([]byte, 128)
+ copy(m.SegmentName, buf.DecodeBytes(len(m.SegmentName)))
+ m.SegmentHandle = buf.DecodeUint64()
+ return nil
+}
+
+// AppCutThroughRegistrationAdd defines message 'app_cut_through_registration_add'.
+type AppCutThroughRegistrationAdd struct {
+ EvtQAddress uint64 `binapi:"u64,name=evt_q_address" json:"evt_q_address,omitempty"`
+ PeerEvtQAddress uint64 `binapi:"u64,name=peer_evt_q_address" json:"peer_evt_q_address,omitempty"`
+ WrkIndex uint32 `binapi:"u32,name=wrk_index" json:"wrk_index,omitempty"`
+ NFds uint8 `binapi:"u8,name=n_fds" json:"n_fds,omitempty"`
+ FdFlags uint8 `binapi:"u8,name=fd_flags" json:"fd_flags,omitempty"`
+}
+
+func (m *AppCutThroughRegistrationAdd) Reset() { *m = AppCutThroughRegistrationAdd{} }
+func (*AppCutThroughRegistrationAdd) GetMessageName() string {
+ return "app_cut_through_registration_add"
+}
+func (*AppCutThroughRegistrationAdd) GetCrcString() string { return "6d73b1b9" }
+func (*AppCutThroughRegistrationAdd) GetMessageType() api.MessageType {
+ return api.RequestMessage
+}
+
+func (m *AppCutThroughRegistrationAdd) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 8 // m.EvtQAddress
+ size += 8 // m.PeerEvtQAddress
+ size += 4 // m.WrkIndex
+ size += 1 // m.NFds
+ size += 1 // m.FdFlags
+ return size
+}
+func (m *AppCutThroughRegistrationAdd) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeUint64(m.EvtQAddress)
+ buf.EncodeUint64(m.PeerEvtQAddress)
+ buf.EncodeUint32(m.WrkIndex)
+ buf.EncodeUint8(m.NFds)
+ buf.EncodeUint8(m.FdFlags)
+ return buf.Bytes(), nil
+}
+func (m *AppCutThroughRegistrationAdd) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.EvtQAddress = buf.DecodeUint64()
+ m.PeerEvtQAddress = buf.DecodeUint64()
+ m.WrkIndex = buf.DecodeUint32()
+ m.NFds = buf.DecodeUint8()
+ m.FdFlags = buf.DecodeUint8()
+ return nil
+}
+
+// AppCutThroughRegistrationAddReply defines message 'app_cut_through_registration_add_reply'.
+type AppCutThroughRegistrationAddReply struct {
+ Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"`
+}
+
+func (m *AppCutThroughRegistrationAddReply) Reset() { *m = AppCutThroughRegistrationAddReply{} }
+func (*AppCutThroughRegistrationAddReply) GetMessageName() string {
+ return "app_cut_through_registration_add_reply"
+}
+func (*AppCutThroughRegistrationAddReply) GetCrcString() string { return "e8d4e804" }
+func (*AppCutThroughRegistrationAddReply) GetMessageType() api.MessageType {
+ return api.ReplyMessage
+}
+
+func (m *AppCutThroughRegistrationAddReply) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.Retval
+ return size
+}
+func (m *AppCutThroughRegistrationAddReply) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeInt32(m.Retval)
+ return buf.Bytes(), nil
+}
+func (m *AppCutThroughRegistrationAddReply) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.Retval = buf.DecodeInt32()
+ return nil
+}
+
+// AppDelCertKeyPair defines message 'app_del_cert_key_pair'.
+type AppDelCertKeyPair struct {
+ Index uint32 `binapi:"u32,name=index" json:"index,omitempty"`
+}
+
+func (m *AppDelCertKeyPair) Reset() { *m = AppDelCertKeyPair{} }
+func (*AppDelCertKeyPair) GetMessageName() string { return "app_del_cert_key_pair" }
+func (*AppDelCertKeyPair) GetCrcString() string { return "8ac76db6" }
+func (*AppDelCertKeyPair) GetMessageType() api.MessageType {
+ return api.RequestMessage
+}
+
+func (m *AppDelCertKeyPair) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.Index
+ return size
+}
+func (m *AppDelCertKeyPair) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeUint32(m.Index)
+ return buf.Bytes(), nil
+}
+func (m *AppDelCertKeyPair) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.Index = buf.DecodeUint32()
+ return nil
+}
+
+// AppDelCertKeyPairReply defines message 'app_del_cert_key_pair_reply'.
+type AppDelCertKeyPairReply struct {
+ Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"`
+}
+
+func (m *AppDelCertKeyPairReply) Reset() { *m = AppDelCertKeyPairReply{} }
+func (*AppDelCertKeyPairReply) GetMessageName() string { return "app_del_cert_key_pair_reply" }
+func (*AppDelCertKeyPairReply) GetCrcString() string { return "e8d4e804" }
+func (*AppDelCertKeyPairReply) GetMessageType() api.MessageType {
+ return api.ReplyMessage
+}
+
+func (m *AppDelCertKeyPairReply) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.Retval
+ return size
+}
+func (m *AppDelCertKeyPairReply) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeInt32(m.Retval)
+ return buf.Bytes(), nil
+}
+func (m *AppDelCertKeyPairReply) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.Retval = buf.DecodeInt32()
+ return nil
+}
+
+// AppNamespaceAddDel defines message 'app_namespace_add_del'.
+type AppNamespaceAddDel struct {
+ Secret uint64 `binapi:"u64,name=secret" json:"secret,omitempty"`
+ SwIfIndex uint32 `binapi:"u32,name=sw_if_index" json:"sw_if_index,omitempty"`
+ IP4FibID uint32 `binapi:"u32,name=ip4_fib_id" json:"ip4_fib_id,omitempty"`
+ IP6FibID uint32 `binapi:"u32,name=ip6_fib_id" json:"ip6_fib_id,omitempty"`
+ NamespaceIDLen uint8 `binapi:"u8,name=namespace_id_len" json:"namespace_id_len,omitempty"`
+ NamespaceID []byte `binapi:"u8[64],name=namespace_id" json:"namespace_id,omitempty"`
+}
+
+func (m *AppNamespaceAddDel) Reset() { *m = AppNamespaceAddDel{} }
+func (*AppNamespaceAddDel) GetMessageName() string { return "app_namespace_add_del" }
+func (*AppNamespaceAddDel) GetCrcString() string { return "dd074c65" }
+func (*AppNamespaceAddDel) GetMessageType() api.MessageType {
+ return api.RequestMessage
+}
+
+func (m *AppNamespaceAddDel) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 8 // m.Secret
+ size += 4 // m.SwIfIndex
+ size += 4 // m.IP4FibID
+ size += 4 // m.IP6FibID
+ size += 1 // m.NamespaceIDLen
+ size += 1 * 64 // m.NamespaceID
+ return size
+}
+func (m *AppNamespaceAddDel) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeUint64(m.Secret)
+ buf.EncodeUint32(m.SwIfIndex)
+ buf.EncodeUint32(m.IP4FibID)
+ buf.EncodeUint32(m.IP6FibID)
+ buf.EncodeUint8(m.NamespaceIDLen)
+ buf.EncodeBytes(m.NamespaceID, 64)
+ return buf.Bytes(), nil
+}
+func (m *AppNamespaceAddDel) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.Secret = buf.DecodeUint64()
+ m.SwIfIndex = buf.DecodeUint32()
+ m.IP4FibID = buf.DecodeUint32()
+ m.IP6FibID = buf.DecodeUint32()
+ m.NamespaceIDLen = buf.DecodeUint8()
+ m.NamespaceID = make([]byte, 64)
+ copy(m.NamespaceID, buf.DecodeBytes(len(m.NamespaceID)))
+ return nil
+}
+
+// AppNamespaceAddDelReply defines message 'app_namespace_add_del_reply'.
+type AppNamespaceAddDelReply struct {
+ Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"`
+ AppnsIndex uint32 `binapi:"u32,name=appns_index" json:"appns_index,omitempty"`
+}
+
+func (m *AppNamespaceAddDelReply) Reset() { *m = AppNamespaceAddDelReply{} }
+func (*AppNamespaceAddDelReply) GetMessageName() string { return "app_namespace_add_del_reply" }
+func (*AppNamespaceAddDelReply) GetCrcString() string { return "85137120" }
+func (*AppNamespaceAddDelReply) GetMessageType() api.MessageType {
+ return api.ReplyMessage
+}
+
+func (m *AppNamespaceAddDelReply) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.Retval
+ size += 4 // m.AppnsIndex
+ return size
+}
+func (m *AppNamespaceAddDelReply) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeInt32(m.Retval)
+ buf.EncodeUint32(m.AppnsIndex)
+ return buf.Bytes(), nil
+}
+func (m *AppNamespaceAddDelReply) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.Retval = buf.DecodeInt32()
+ m.AppnsIndex = buf.DecodeUint32()
+ return nil
+}
+
+// AppWorkerAddDel defines message 'app_worker_add_del'.
+type AppWorkerAddDel struct {
+ AppIndex uint32 `binapi:"u32,name=app_index" json:"app_index,omitempty"`
+ WrkIndex uint32 `binapi:"u32,name=wrk_index" json:"wrk_index,omitempty"`
+ IsAdd uint8 `binapi:"u8,name=is_add" json:"is_add,omitempty"`
+}
+
+func (m *AppWorkerAddDel) Reset() { *m = AppWorkerAddDel{} }
+func (*AppWorkerAddDel) GetMessageName() string { return "app_worker_add_del" }
+func (*AppWorkerAddDel) GetCrcString() string { return "6d2b2279" }
+func (*AppWorkerAddDel) GetMessageType() api.MessageType {
+ return api.RequestMessage
+}
+
+func (m *AppWorkerAddDel) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.AppIndex
+ size += 4 // m.WrkIndex
+ size += 1 // m.IsAdd
+ return size
+}
+func (m *AppWorkerAddDel) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeUint32(m.AppIndex)
+ buf.EncodeUint32(m.WrkIndex)
+ buf.EncodeUint8(m.IsAdd)
+ return buf.Bytes(), nil
+}
+func (m *AppWorkerAddDel) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.AppIndex = buf.DecodeUint32()
+ m.WrkIndex = buf.DecodeUint32()
+ m.IsAdd = buf.DecodeUint8()
+ return nil
+}
+
+// AppWorkerAddDelReply defines message 'app_worker_add_del_reply'.
+type AppWorkerAddDelReply struct {
+ Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"`
+ WrkIndex uint32 `binapi:"u32,name=wrk_index" json:"wrk_index,omitempty"`
+ AppEventQueueAddress uint64 `binapi:"u64,name=app_event_queue_address" json:"app_event_queue_address,omitempty"`
+ NFds uint8 `binapi:"u8,name=n_fds" json:"n_fds,omitempty"`
+ FdFlags uint8 `binapi:"u8,name=fd_flags" json:"fd_flags,omitempty"`
+ SegmentNameLength uint8 `binapi:"u8,name=segment_name_length" json:"segment_name_length,omitempty"`
+ SegmentName []byte `binapi:"u8[128],name=segment_name" json:"segment_name,omitempty"`
+ SegmentHandle uint64 `binapi:"u64,name=segment_handle" json:"segment_handle,omitempty"`
+ IsAdd uint8 `binapi:"u8,name=is_add" json:"is_add,omitempty"`
+}
+
+func (m *AppWorkerAddDelReply) Reset() { *m = AppWorkerAddDelReply{} }
+func (*AppWorkerAddDelReply) GetMessageName() string { return "app_worker_add_del_reply" }
+func (*AppWorkerAddDelReply) GetCrcString() string { return "56b21abc" }
+func (*AppWorkerAddDelReply) GetMessageType() api.MessageType {
+ return api.ReplyMessage
+}
+
+func (m *AppWorkerAddDelReply) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.Retval
+ size += 4 // m.WrkIndex
+ size += 8 // m.AppEventQueueAddress
+ size += 1 // m.NFds
+ size += 1 // m.FdFlags
+ size += 1 // m.SegmentNameLength
+ size += 1 * 128 // m.SegmentName
+ size += 8 // m.SegmentHandle
+ size += 1 // m.IsAdd
+ return size
+}
+func (m *AppWorkerAddDelReply) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeInt32(m.Retval)
+ buf.EncodeUint32(m.WrkIndex)
+ buf.EncodeUint64(m.AppEventQueueAddress)
+ buf.EncodeUint8(m.NFds)
+ buf.EncodeUint8(m.FdFlags)
+ buf.EncodeUint8(m.SegmentNameLength)
+ buf.EncodeBytes(m.SegmentName, 128)
+ buf.EncodeUint64(m.SegmentHandle)
+ buf.EncodeUint8(m.IsAdd)
+ return buf.Bytes(), nil
+}
+func (m *AppWorkerAddDelReply) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.Retval = buf.DecodeInt32()
+ m.WrkIndex = buf.DecodeUint32()
+ m.AppEventQueueAddress = buf.DecodeUint64()
+ m.NFds = buf.DecodeUint8()
+ m.FdFlags = buf.DecodeUint8()
+ m.SegmentNameLength = buf.DecodeUint8()
+ m.SegmentName = make([]byte, 128)
+ copy(m.SegmentName, buf.DecodeBytes(len(m.SegmentName)))
+ m.SegmentHandle = buf.DecodeUint64()
+ m.IsAdd = buf.DecodeUint8()
+ return nil
+}
+
+// ApplicationAttach defines message 'application_attach'.
+type ApplicationAttach struct {
+ InitialSegmentSize uint32 `binapi:"u32,name=initial_segment_size" json:"initial_segment_size,omitempty"`
+ Options []uint64 `binapi:"u64[16],name=options" json:"options,omitempty"`
+ NamespaceIDLen uint8 `binapi:"u8,name=namespace_id_len" json:"namespace_id_len,omitempty"`
+ NamespaceID []byte `binapi:"u8[64],name=namespace_id" json:"namespace_id,omitempty"`
+}
+
+func (m *ApplicationAttach) Reset() { *m = ApplicationAttach{} }
+func (*ApplicationAttach) GetMessageName() string { return "application_attach" }
+func (*ApplicationAttach) GetCrcString() string { return "81d4f974" }
+func (*ApplicationAttach) GetMessageType() api.MessageType {
+ return api.RequestMessage
+}
+
+func (m *ApplicationAttach) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.InitialSegmentSize
+ size += 8 * 16 // m.Options
+ size += 1 // m.NamespaceIDLen
+ size += 1 * 64 // m.NamespaceID
+ return size
+}
+func (m *ApplicationAttach) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeUint32(m.InitialSegmentSize)
+ for i := 0; i < 16; i++ {
+ var x uint64
+ if i < len(m.Options) {
+ x = uint64(m.Options[i])
+ }
+ buf.EncodeUint64(x)
+ }
+ buf.EncodeUint8(m.NamespaceIDLen)
+ buf.EncodeBytes(m.NamespaceID, 64)
+ return buf.Bytes(), nil
+}
+func (m *ApplicationAttach) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.InitialSegmentSize = buf.DecodeUint32()
+ m.Options = make([]uint64, 16)
+ for i := 0; i < len(m.Options); i++ {
+ m.Options[i] = buf.DecodeUint64()
+ }
+ m.NamespaceIDLen = buf.DecodeUint8()
+ m.NamespaceID = make([]byte, 64)
+ copy(m.NamespaceID, buf.DecodeBytes(len(m.NamespaceID)))
+ return nil
+}
+
+// ApplicationAttachReply defines message 'application_attach_reply'.
+type ApplicationAttachReply struct {
+ Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"`
+ AppEventQueueAddress uint64 `binapi:"u64,name=app_event_queue_address" json:"app_event_queue_address,omitempty"`
+ NFds uint8 `binapi:"u8,name=n_fds" json:"n_fds,omitempty"`
+ FdFlags uint8 `binapi:"u8,name=fd_flags" json:"fd_flags,omitempty"`
+ SegmentSize uint32 `binapi:"u32,name=segment_size" json:"segment_size,omitempty"`
+ SegmentNameLength uint8 `binapi:"u8,name=segment_name_length" json:"segment_name_length,omitempty"`
+ SegmentName []byte `binapi:"u8[128],name=segment_name" json:"segment_name,omitempty"`
+ AppIndex uint32 `binapi:"u32,name=app_index" json:"app_index,omitempty"`
+ SegmentHandle uint64 `binapi:"u64,name=segment_handle" json:"segment_handle,omitempty"`
+}
+
+func (m *ApplicationAttachReply) Reset() { *m = ApplicationAttachReply{} }
+func (*ApplicationAttachReply) GetMessageName() string { return "application_attach_reply" }
+func (*ApplicationAttachReply) GetCrcString() string { return "581866e8" }
+func (*ApplicationAttachReply) GetMessageType() api.MessageType {
+ return api.ReplyMessage
+}
+
+func (m *ApplicationAttachReply) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.Retval
+ size += 8 // m.AppEventQueueAddress
+ size += 1 // m.NFds
+ size += 1 // m.FdFlags
+ size += 4 // m.SegmentSize
+ size += 1 // m.SegmentNameLength
+ size += 1 * 128 // m.SegmentName
+ size += 4 // m.AppIndex
+ size += 8 // m.SegmentHandle
+ return size
+}
+func (m *ApplicationAttachReply) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeInt32(m.Retval)
+ buf.EncodeUint64(m.AppEventQueueAddress)
+ buf.EncodeUint8(m.NFds)
+ buf.EncodeUint8(m.FdFlags)
+ buf.EncodeUint32(m.SegmentSize)
+ buf.EncodeUint8(m.SegmentNameLength)
+ buf.EncodeBytes(m.SegmentName, 128)
+ buf.EncodeUint32(m.AppIndex)
+ buf.EncodeUint64(m.SegmentHandle)
+ return buf.Bytes(), nil
+}
+func (m *ApplicationAttachReply) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.Retval = buf.DecodeInt32()
+ m.AppEventQueueAddress = buf.DecodeUint64()
+ m.NFds = buf.DecodeUint8()
+ m.FdFlags = buf.DecodeUint8()
+ m.SegmentSize = buf.DecodeUint32()
+ m.SegmentNameLength = buf.DecodeUint8()
+ m.SegmentName = make([]byte, 128)
+ copy(m.SegmentName, buf.DecodeBytes(len(m.SegmentName)))
+ m.AppIndex = buf.DecodeUint32()
+ m.SegmentHandle = buf.DecodeUint64()
+ return nil
+}
+
+// ApplicationDetach defines message 'application_detach'.
+type ApplicationDetach struct{}
+
+func (m *ApplicationDetach) Reset() { *m = ApplicationDetach{} }
+func (*ApplicationDetach) GetMessageName() string { return "application_detach" }
+func (*ApplicationDetach) GetCrcString() string { return "51077d14" }
+func (*ApplicationDetach) GetMessageType() api.MessageType {
+ return api.RequestMessage
+}
+
+func (m *ApplicationDetach) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ return size
+}
+func (m *ApplicationDetach) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ return buf.Bytes(), nil
+}
+func (m *ApplicationDetach) Unmarshal(b []byte) error {
+ return nil
+}
+
+// ApplicationDetachReply defines message 'application_detach_reply'.
+type ApplicationDetachReply struct {
+ Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"`
+}
+
+func (m *ApplicationDetachReply) Reset() { *m = ApplicationDetachReply{} }
+func (*ApplicationDetachReply) GetMessageName() string { return "application_detach_reply" }
+func (*ApplicationDetachReply) GetCrcString() string { return "e8d4e804" }
+func (*ApplicationDetachReply) GetMessageType() api.MessageType {
+ return api.ReplyMessage
+}
+
+func (m *ApplicationDetachReply) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.Retval
+ return size
+}
+func (m *ApplicationDetachReply) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeInt32(m.Retval)
+ return buf.Bytes(), nil
+}
+func (m *ApplicationDetachReply) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.Retval = buf.DecodeInt32()
+ return nil
+}
+
+// ApplicationTLSCertAdd defines message 'application_tls_cert_add'.
+type ApplicationTLSCertAdd struct {
+ AppIndex uint32 `binapi:"u32,name=app_index" json:"app_index,omitempty"`
+ CertLen uint16 `binapi:"u16,name=cert_len" json:"-"`
+ Cert []byte `binapi:"u8[cert_len],name=cert" json:"cert,omitempty"`
+}
+
+func (m *ApplicationTLSCertAdd) Reset() { *m = ApplicationTLSCertAdd{} }
+func (*ApplicationTLSCertAdd) GetMessageName() string { return "application_tls_cert_add" }
+func (*ApplicationTLSCertAdd) GetCrcString() string { return "3f5cfe45" }
+func (*ApplicationTLSCertAdd) GetMessageType() api.MessageType {
+ return api.RequestMessage
+}
+
+func (m *ApplicationTLSCertAdd) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.AppIndex
+ size += 2 // m.CertLen
+ size += 1 * len(m.Cert) // m.Cert
+ return size
+}
+func (m *ApplicationTLSCertAdd) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeUint32(m.AppIndex)
+ buf.EncodeUint16(uint16(len(m.Cert)))
+ buf.EncodeBytes(m.Cert, 0)
+ return buf.Bytes(), nil
+}
+func (m *ApplicationTLSCertAdd) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.AppIndex = buf.DecodeUint32()
+ m.CertLen = buf.DecodeUint16()
+ m.Cert = make([]byte, m.CertLen)
+ copy(m.Cert, buf.DecodeBytes(len(m.Cert)))
+ return nil
+}
+
+// ApplicationTLSCertAddReply defines message 'application_tls_cert_add_reply'.
+type ApplicationTLSCertAddReply struct {
+ Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"`
+}
+
+func (m *ApplicationTLSCertAddReply) Reset() { *m = ApplicationTLSCertAddReply{} }
+func (*ApplicationTLSCertAddReply) GetMessageName() string { return "application_tls_cert_add_reply" }
+func (*ApplicationTLSCertAddReply) GetCrcString() string { return "e8d4e804" }
+func (*ApplicationTLSCertAddReply) GetMessageType() api.MessageType {
+ return api.ReplyMessage
+}
+
+func (m *ApplicationTLSCertAddReply) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.Retval
+ return size
+}
+func (m *ApplicationTLSCertAddReply) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeInt32(m.Retval)
+ return buf.Bytes(), nil
+}
+func (m *ApplicationTLSCertAddReply) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.Retval = buf.DecodeInt32()
+ return nil
+}
+
+// ApplicationTLSKeyAdd defines message 'application_tls_key_add'.
+type ApplicationTLSKeyAdd struct {
+ AppIndex uint32 `binapi:"u32,name=app_index" json:"app_index,omitempty"`
+ KeyLen uint16 `binapi:"u16,name=key_len" json:"-"`
+ Key []byte `binapi:"u8[key_len],name=key" json:"key,omitempty"`
+}
+
+func (m *ApplicationTLSKeyAdd) Reset() { *m = ApplicationTLSKeyAdd{} }
+func (*ApplicationTLSKeyAdd) GetMessageName() string { return "application_tls_key_add" }
+func (*ApplicationTLSKeyAdd) GetCrcString() string { return "5eaf70cd" }
+func (*ApplicationTLSKeyAdd) GetMessageType() api.MessageType {
+ return api.RequestMessage
+}
+
+func (m *ApplicationTLSKeyAdd) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.AppIndex
+ size += 2 // m.KeyLen
+ size += 1 * len(m.Key) // m.Key
+ return size
+}
+func (m *ApplicationTLSKeyAdd) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeUint32(m.AppIndex)
+ buf.EncodeUint16(uint16(len(m.Key)))
+ buf.EncodeBytes(m.Key, 0)
+ return buf.Bytes(), nil
+}
+func (m *ApplicationTLSKeyAdd) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.AppIndex = buf.DecodeUint32()
+ m.KeyLen = buf.DecodeUint16()
+ m.Key = make([]byte, m.KeyLen)
+ copy(m.Key, buf.DecodeBytes(len(m.Key)))
+ return nil
+}
+
+// ApplicationTLSKeyAddReply defines message 'application_tls_key_add_reply'.
+type ApplicationTLSKeyAddReply struct {
+ Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"`
+}
+
+func (m *ApplicationTLSKeyAddReply) Reset() { *m = ApplicationTLSKeyAddReply{} }
+func (*ApplicationTLSKeyAddReply) GetMessageName() string { return "application_tls_key_add_reply" }
+func (*ApplicationTLSKeyAddReply) GetCrcString() string { return "e8d4e804" }
+func (*ApplicationTLSKeyAddReply) GetMessageType() api.MessageType {
+ return api.ReplyMessage
+}
+
+func (m *ApplicationTLSKeyAddReply) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.Retval
+ return size
+}
+func (m *ApplicationTLSKeyAddReply) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeInt32(m.Retval)
+ return buf.Bytes(), nil
+}
+func (m *ApplicationTLSKeyAddReply) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.Retval = buf.DecodeInt32()
+ return nil
+}
+
+// BindSock defines message 'bind_sock'.
+type BindSock struct {
+ WrkIndex uint32 `binapi:"u32,name=wrk_index" json:"wrk_index,omitempty"`
+ Vrf uint32 `binapi:"u32,name=vrf" json:"vrf,omitempty"`
+ IsIP4 uint8 `binapi:"u8,name=is_ip4" json:"is_ip4,omitempty"`
+ IP []byte `binapi:"u8[16],name=ip" json:"ip,omitempty"`
+ Port uint16 `binapi:"u16,name=port" json:"port,omitempty"`
+ Proto uint8 `binapi:"u8,name=proto" json:"proto,omitempty"`
+ Options []uint64 `binapi:"u64[16],name=options" json:"options,omitempty"`
+}
+
+func (m *BindSock) Reset() { *m = BindSock{} }
+func (*BindSock) GetMessageName() string { return "bind_sock" }
+func (*BindSock) GetCrcString() string { return "0394633f" }
+func (*BindSock) GetMessageType() api.MessageType {
+ return api.RequestMessage
+}
+
+func (m *BindSock) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.WrkIndex
+ size += 4 // m.Vrf
+ size += 1 // m.IsIP4
+ size += 1 * 16 // m.IP
+ size += 2 // m.Port
+ size += 1 // m.Proto
+ size += 8 * 16 // m.Options
+ return size
+}
+func (m *BindSock) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeUint32(m.WrkIndex)
+ buf.EncodeUint32(m.Vrf)
+ buf.EncodeUint8(m.IsIP4)
+ buf.EncodeBytes(m.IP, 16)
+ buf.EncodeUint16(m.Port)
+ buf.EncodeUint8(m.Proto)
+ for i := 0; i < 16; i++ {
+ var x uint64
+ if i < len(m.Options) {
+ x = uint64(m.Options[i])
+ }
+ buf.EncodeUint64(x)
+ }
+ return buf.Bytes(), nil
+}
+func (m *BindSock) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.WrkIndex = buf.DecodeUint32()
+ m.Vrf = buf.DecodeUint32()
+ m.IsIP4 = buf.DecodeUint8()
+ m.IP = make([]byte, 16)
+ copy(m.IP, buf.DecodeBytes(len(m.IP)))
+ m.Port = buf.DecodeUint16()
+ m.Proto = buf.DecodeUint8()
+ m.Options = make([]uint64, 16)
+ for i := 0; i < len(m.Options); i++ {
+ m.Options[i] = buf.DecodeUint64()
+ }
+ return nil
+}
+
+// BindSockReply defines message 'bind_sock_reply'.
+type BindSockReply struct {
+ Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"`
+}
+
+func (m *BindSockReply) Reset() { *m = BindSockReply{} }
+func (*BindSockReply) GetMessageName() string { return "bind_sock_reply" }
+func (*BindSockReply) GetCrcString() string { return "e8d4e804" }
+func (*BindSockReply) GetMessageType() api.MessageType {
+ return api.ReplyMessage
+}
+
+func (m *BindSockReply) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.Retval
+ return size
+}
+func (m *BindSockReply) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeInt32(m.Retval)
+ return buf.Bytes(), nil
+}
+func (m *BindSockReply) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.Retval = buf.DecodeInt32()
+ return nil
+}
+
+// BindURI defines message 'bind_uri'.
+type BindURI struct {
+ AcceptCookie uint32 `binapi:"u32,name=accept_cookie" json:"accept_cookie,omitempty"`
+ URI []byte `binapi:"u8[128],name=uri" json:"uri,omitempty"`
+}
+
+func (m *BindURI) Reset() { *m = BindURI{} }
+func (*BindURI) GetMessageName() string { return "bind_uri" }
+func (*BindURI) GetCrcString() string { return "fae140cb" }
+func (*BindURI) GetMessageType() api.MessageType {
+ return api.RequestMessage
+}
+
+func (m *BindURI) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.AcceptCookie
+ size += 1 * 128 // m.URI
+ return size
+}
+func (m *BindURI) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeUint32(m.AcceptCookie)
+ buf.EncodeBytes(m.URI, 128)
+ return buf.Bytes(), nil
+}
+func (m *BindURI) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.AcceptCookie = buf.DecodeUint32()
+ m.URI = make([]byte, 128)
+ copy(m.URI, buf.DecodeBytes(len(m.URI)))
+ return nil
+}
+
+// BindURIReply defines message 'bind_uri_reply'.
+type BindURIReply struct {
+ Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"`
+}
+
+func (m *BindURIReply) Reset() { *m = BindURIReply{} }
+func (*BindURIReply) GetMessageName() string { return "bind_uri_reply" }
+func (*BindURIReply) GetCrcString() string { return "e8d4e804" }
+func (*BindURIReply) GetMessageType() api.MessageType {
+ return api.ReplyMessage
+}
+
+func (m *BindURIReply) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.Retval
+ return size
+}
+func (m *BindURIReply) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeInt32(m.Retval)
+ return buf.Bytes(), nil
+}
+func (m *BindURIReply) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.Retval = buf.DecodeInt32()
+ return nil
+}
+
+// ConnectSock defines message 'connect_sock'.
+type ConnectSock struct {
+ WrkIndex uint32 `binapi:"u32,name=wrk_index" json:"wrk_index,omitempty"`
+ ClientQueueAddress uint64 `binapi:"u64,name=client_queue_address" json:"client_queue_address,omitempty"`
+ Options []uint64 `binapi:"u64[16],name=options" json:"options,omitempty"`
+ Vrf uint32 `binapi:"u32,name=vrf" json:"vrf,omitempty"`
+ IsIP4 uint8 `binapi:"u8,name=is_ip4" json:"is_ip4,omitempty"`
+ IP []byte `binapi:"u8[16],name=ip" json:"ip,omitempty"`
+ Port uint16 `binapi:"u16,name=port" json:"port,omitempty"`
+ Proto uint8 `binapi:"u8,name=proto" json:"proto,omitempty"`
+ ParentHandle uint64 `binapi:"u64,name=parent_handle" json:"parent_handle,omitempty"`
+ HostnameLen uint8 `binapi:"u8,name=hostname_len" json:"-"`
+ Hostname []byte `binapi:"u8[hostname_len],name=hostname" json:"hostname,omitempty"`
+}
+
+func (m *ConnectSock) Reset() { *m = ConnectSock{} }
+func (*ConnectSock) GetMessageName() string { return "connect_sock" }
+func (*ConnectSock) GetCrcString() string { return "d2b460ca" }
+func (*ConnectSock) GetMessageType() api.MessageType {
+ return api.RequestMessage
+}
+
+func (m *ConnectSock) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.WrkIndex
+ size += 8 // m.ClientQueueAddress
+ size += 8 * 16 // m.Options
+ size += 4 // m.Vrf
+ size += 1 // m.IsIP4
+ size += 1 * 16 // m.IP
+ size += 2 // m.Port
+ size += 1 // m.Proto
+ size += 8 // m.ParentHandle
+ size += 1 // m.HostnameLen
+ size += 1 * len(m.Hostname) // m.Hostname
+ return size
+}
+func (m *ConnectSock) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeUint32(m.WrkIndex)
+ buf.EncodeUint64(m.ClientQueueAddress)
+ for i := 0; i < 16; i++ {
+ var x uint64
+ if i < len(m.Options) {
+ x = uint64(m.Options[i])
+ }
+ buf.EncodeUint64(x)
+ }
+ buf.EncodeUint32(m.Vrf)
+ buf.EncodeUint8(m.IsIP4)
+ buf.EncodeBytes(m.IP, 16)
+ buf.EncodeUint16(m.Port)
+ buf.EncodeUint8(m.Proto)
+ buf.EncodeUint64(m.ParentHandle)
+ buf.EncodeUint8(uint8(len(m.Hostname)))
+ buf.EncodeBytes(m.Hostname, 0)
+ return buf.Bytes(), nil
+}
+func (m *ConnectSock) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.WrkIndex = buf.DecodeUint32()
+ m.ClientQueueAddress = buf.DecodeUint64()
+ m.Options = make([]uint64, 16)
+ for i := 0; i < len(m.Options); i++ {
+ m.Options[i] = buf.DecodeUint64()
+ }
+ m.Vrf = buf.DecodeUint32()
+ m.IsIP4 = buf.DecodeUint8()
+ m.IP = make([]byte, 16)
+ copy(m.IP, buf.DecodeBytes(len(m.IP)))
+ m.Port = buf.DecodeUint16()
+ m.Proto = buf.DecodeUint8()
+ m.ParentHandle = buf.DecodeUint64()
+ m.HostnameLen = buf.DecodeUint8()
+ m.Hostname = make([]byte, m.HostnameLen)
+ copy(m.Hostname, buf.DecodeBytes(len(m.Hostname)))
+ return nil
+}
+
+// ConnectSockReply defines message 'connect_sock_reply'.
+type ConnectSockReply struct {
+ Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"`
+}
+
+func (m *ConnectSockReply) Reset() { *m = ConnectSockReply{} }
+func (*ConnectSockReply) GetMessageName() string { return "connect_sock_reply" }
+func (*ConnectSockReply) GetCrcString() string { return "e8d4e804" }
+func (*ConnectSockReply) GetMessageType() api.MessageType {
+ return api.ReplyMessage
+}
+
+func (m *ConnectSockReply) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.Retval
+ return size
+}
+func (m *ConnectSockReply) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeInt32(m.Retval)
+ return buf.Bytes(), nil
+}
+func (m *ConnectSockReply) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.Retval = buf.DecodeInt32()
+ return nil
+}
+
+// ConnectURI defines message 'connect_uri'.
+type ConnectURI struct {
+ ClientQueueAddress uint64 `binapi:"u64,name=client_queue_address" json:"client_queue_address,omitempty"`
+ Options []uint64 `binapi:"u64[16],name=options" json:"options,omitempty"`
+ URI []byte `binapi:"u8[128],name=uri" json:"uri,omitempty"`
+}
+
+func (m *ConnectURI) Reset() { *m = ConnectURI{} }
+func (*ConnectURI) GetMessageName() string { return "connect_uri" }
+func (*ConnectURI) GetCrcString() string { return "a36143d6" }
+func (*ConnectURI) GetMessageType() api.MessageType {
+ return api.RequestMessage
+}
+
+func (m *ConnectURI) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 8 // m.ClientQueueAddress
+ size += 8 * 16 // m.Options
+ size += 1 * 128 // m.URI
+ return size
+}
+func (m *ConnectURI) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeUint64(m.ClientQueueAddress)
+ for i := 0; i < 16; i++ {
+ var x uint64
+ if i < len(m.Options) {
+ x = uint64(m.Options[i])
+ }
+ buf.EncodeUint64(x)
+ }
+ buf.EncodeBytes(m.URI, 128)
+ return buf.Bytes(), nil
+}
+func (m *ConnectURI) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.ClientQueueAddress = buf.DecodeUint64()
+ m.Options = make([]uint64, 16)
+ for i := 0; i < len(m.Options); i++ {
+ m.Options[i] = buf.DecodeUint64()
+ }
+ m.URI = make([]byte, 128)
+ copy(m.URI, buf.DecodeBytes(len(m.URI)))
+ return nil
+}
+
+// ConnectURIReply defines message 'connect_uri_reply'.
+type ConnectURIReply struct {
+ Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"`
+}
+
+func (m *ConnectURIReply) Reset() { *m = ConnectURIReply{} }
+func (*ConnectURIReply) GetMessageName() string { return "connect_uri_reply" }
+func (*ConnectURIReply) GetCrcString() string { return "e8d4e804" }
+func (*ConnectURIReply) GetMessageType() api.MessageType {
+ return api.ReplyMessage
+}
+
+func (m *ConnectURIReply) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.Retval
+ return size
+}
+func (m *ConnectURIReply) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeInt32(m.Retval)
+ return buf.Bytes(), nil
+}
+func (m *ConnectURIReply) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.Retval = buf.DecodeInt32()
+ return nil
+}
+
+// DisconnectSession defines message 'disconnect_session'.
+type DisconnectSession struct {
+ Handle uint64 `binapi:"u64,name=handle" json:"handle,omitempty"`
+}
+
+func (m *DisconnectSession) Reset() { *m = DisconnectSession{} }
+func (*DisconnectSession) GetMessageName() string { return "disconnect_session" }
+func (*DisconnectSession) GetCrcString() string { return "7279205b" }
+func (*DisconnectSession) GetMessageType() api.MessageType {
+ return api.RequestMessage
+}
+
+func (m *DisconnectSession) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 8 // m.Handle
+ return size
+}
+func (m *DisconnectSession) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeUint64(m.Handle)
+ return buf.Bytes(), nil
+}
+func (m *DisconnectSession) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.Handle = buf.DecodeUint64()
+ return nil
+}
+
+// DisconnectSessionReply defines message 'disconnect_session_reply'.
+type DisconnectSessionReply struct {
+ Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"`
+ Handle uint64 `binapi:"u64,name=handle" json:"handle,omitempty"`
+}
+
+func (m *DisconnectSessionReply) Reset() { *m = DisconnectSessionReply{} }
+func (*DisconnectSessionReply) GetMessageName() string { return "disconnect_session_reply" }
+func (*DisconnectSessionReply) GetCrcString() string { return "d6960a03" }
+func (*DisconnectSessionReply) GetMessageType() api.MessageType {
+ return api.ReplyMessage
+}
+
+func (m *DisconnectSessionReply) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.Retval
+ size += 8 // m.Handle
+ return size
+}
+func (m *DisconnectSessionReply) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeInt32(m.Retval)
+ buf.EncodeUint64(m.Handle)
+ return buf.Bytes(), nil
+}
+func (m *DisconnectSessionReply) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.Retval = buf.DecodeInt32()
+ m.Handle = buf.DecodeUint64()
+ return nil
+}
+
+// MapAnotherSegment defines message 'map_another_segment'.
+type MapAnotherSegment struct {
+ FdFlags uint8 `binapi:"u8,name=fd_flags" json:"fd_flags,omitempty"`
+ SegmentSize uint32 `binapi:"u32,name=segment_size" json:"segment_size,omitempty"`
+ SegmentName []byte `binapi:"u8[128],name=segment_name" json:"segment_name,omitempty"`
+ SegmentHandle uint64 `binapi:"u64,name=segment_handle" json:"segment_handle,omitempty"`
+}
+
+func (m *MapAnotherSegment) Reset() { *m = MapAnotherSegment{} }
+func (*MapAnotherSegment) GetMessageName() string { return "map_another_segment" }
+func (*MapAnotherSegment) GetCrcString() string { return "dc2d630b" }
+func (*MapAnotherSegment) GetMessageType() api.MessageType {
+ return api.RequestMessage
+}
+
+func (m *MapAnotherSegment) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 1 // m.FdFlags
+ size += 4 // m.SegmentSize
+ size += 1 * 128 // m.SegmentName
+ size += 8 // m.SegmentHandle
+ return size
+}
+func (m *MapAnotherSegment) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeUint8(m.FdFlags)
+ buf.EncodeUint32(m.SegmentSize)
+ buf.EncodeBytes(m.SegmentName, 128)
+ buf.EncodeUint64(m.SegmentHandle)
+ return buf.Bytes(), nil
+}
+func (m *MapAnotherSegment) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.FdFlags = buf.DecodeUint8()
+ m.SegmentSize = buf.DecodeUint32()
+ m.SegmentName = make([]byte, 128)
+ copy(m.SegmentName, buf.DecodeBytes(len(m.SegmentName)))
+ m.SegmentHandle = buf.DecodeUint64()
+ return nil
+}
+
+// MapAnotherSegmentReply defines message 'map_another_segment_reply'.
+type MapAnotherSegmentReply struct {
+ Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"`
+}
+
+func (m *MapAnotherSegmentReply) Reset() { *m = MapAnotherSegmentReply{} }
+func (*MapAnotherSegmentReply) GetMessageName() string { return "map_another_segment_reply" }
+func (*MapAnotherSegmentReply) GetCrcString() string { return "e8d4e804" }
+func (*MapAnotherSegmentReply) GetMessageType() api.MessageType {
+ return api.ReplyMessage
+}
+
+func (m *MapAnotherSegmentReply) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.Retval
+ return size
+}
+func (m *MapAnotherSegmentReply) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeInt32(m.Retval)
+ return buf.Bytes(), nil
+}
+func (m *MapAnotherSegmentReply) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.Retval = buf.DecodeInt32()
+ return nil
+}
+
+// SessionEnableDisable defines message 'session_enable_disable'.
+type SessionEnableDisable struct {
+ IsEnable uint8 `binapi:"u8,name=is_enable" json:"is_enable,omitempty"`
+}
+
+func (m *SessionEnableDisable) Reset() { *m = SessionEnableDisable{} }
+func (*SessionEnableDisable) GetMessageName() string { return "session_enable_disable" }
+func (*SessionEnableDisable) GetCrcString() string { return "30ac9be7" }
+func (*SessionEnableDisable) GetMessageType() api.MessageType {
+ return api.RequestMessage
+}
+
+func (m *SessionEnableDisable) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 1 // m.IsEnable
+ return size
+}
+func (m *SessionEnableDisable) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeUint8(m.IsEnable)
+ return buf.Bytes(), nil
+}
+func (m *SessionEnableDisable) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.IsEnable = buf.DecodeUint8()
+ return nil
+}
+
+// SessionEnableDisableReply defines message 'session_enable_disable_reply'.
+type SessionEnableDisableReply struct {
+ Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"`
+}
+
+func (m *SessionEnableDisableReply) Reset() { *m = SessionEnableDisableReply{} }
+func (*SessionEnableDisableReply) GetMessageName() string { return "session_enable_disable_reply" }
+func (*SessionEnableDisableReply) GetCrcString() string { return "e8d4e804" }
+func (*SessionEnableDisableReply) GetMessageType() api.MessageType {
+ return api.ReplyMessage
+}
+
+func (m *SessionEnableDisableReply) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.Retval
+ return size
+}
+func (m *SessionEnableDisableReply) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeInt32(m.Retval)
+ return buf.Bytes(), nil
+}
+func (m *SessionEnableDisableReply) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.Retval = buf.DecodeInt32()
+ return nil
+}
+
+// SessionRuleAddDel defines message 'session_rule_add_del'.
+type SessionRuleAddDel struct {
+ TransportProto uint8 `binapi:"u8,name=transport_proto" json:"transport_proto,omitempty"`
+ IsIP4 uint8 `binapi:"u8,name=is_ip4" json:"is_ip4,omitempty"`
+ LclIP []byte `binapi:"u8[16],name=lcl_ip" json:"lcl_ip,omitempty"`
+ LclPlen uint8 `binapi:"u8,name=lcl_plen" json:"lcl_plen,omitempty"`
+ RmtIP []byte `binapi:"u8[16],name=rmt_ip" json:"rmt_ip,omitempty"`
+ RmtPlen uint8 `binapi:"u8,name=rmt_plen" json:"rmt_plen,omitempty"`
+ LclPort uint16 `binapi:"u16,name=lcl_port" json:"lcl_port,omitempty"`
+ RmtPort uint16 `binapi:"u16,name=rmt_port" json:"rmt_port,omitempty"`
+ ActionIndex uint32 `binapi:"u32,name=action_index" json:"action_index,omitempty"`
+ IsAdd uint8 `binapi:"u8,name=is_add" json:"is_add,omitempty"`
+ AppnsIndex uint32 `binapi:"u32,name=appns_index" json:"appns_index,omitempty"`
+ Scope uint8 `binapi:"u8,name=scope" json:"scope,omitempty"`
+ Tag []byte `binapi:"u8[64],name=tag" json:"tag,omitempty"`
+}
+
+func (m *SessionRuleAddDel) Reset() { *m = SessionRuleAddDel{} }
+func (*SessionRuleAddDel) GetMessageName() string { return "session_rule_add_del" }
+func (*SessionRuleAddDel) GetCrcString() string { return "4ab2eb06" }
+func (*SessionRuleAddDel) GetMessageType() api.MessageType {
+ return api.RequestMessage
+}
+
+func (m *SessionRuleAddDel) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 1 // m.TransportProto
+ size += 1 // m.IsIP4
+ size += 1 * 16 // m.LclIP
+ size += 1 // m.LclPlen
+ size += 1 * 16 // m.RmtIP
+ size += 1 // m.RmtPlen
+ size += 2 // m.LclPort
+ size += 2 // m.RmtPort
+ size += 4 // m.ActionIndex
+ size += 1 // m.IsAdd
+ size += 4 // m.AppnsIndex
+ size += 1 // m.Scope
+ size += 1 * 64 // m.Tag
+ return size
+}
+func (m *SessionRuleAddDel) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeUint8(m.TransportProto)
+ buf.EncodeUint8(m.IsIP4)
+ buf.EncodeBytes(m.LclIP, 16)
+ buf.EncodeUint8(m.LclPlen)
+ buf.EncodeBytes(m.RmtIP, 16)
+ buf.EncodeUint8(m.RmtPlen)
+ buf.EncodeUint16(m.LclPort)
+ buf.EncodeUint16(m.RmtPort)
+ buf.EncodeUint32(m.ActionIndex)
+ buf.EncodeUint8(m.IsAdd)
+ buf.EncodeUint32(m.AppnsIndex)
+ buf.EncodeUint8(m.Scope)
+ buf.EncodeBytes(m.Tag, 64)
+ return buf.Bytes(), nil
+}
+func (m *SessionRuleAddDel) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.TransportProto = buf.DecodeUint8()
+ m.IsIP4 = buf.DecodeUint8()
+ m.LclIP = make([]byte, 16)
+ copy(m.LclIP, buf.DecodeBytes(len(m.LclIP)))
+ m.LclPlen = buf.DecodeUint8()
+ m.RmtIP = make([]byte, 16)
+ copy(m.RmtIP, buf.DecodeBytes(len(m.RmtIP)))
+ m.RmtPlen = buf.DecodeUint8()
+ m.LclPort = buf.DecodeUint16()
+ m.RmtPort = buf.DecodeUint16()
+ m.ActionIndex = buf.DecodeUint32()
+ m.IsAdd = buf.DecodeUint8()
+ m.AppnsIndex = buf.DecodeUint32()
+ m.Scope = buf.DecodeUint8()
+ m.Tag = make([]byte, 64)
+ copy(m.Tag, buf.DecodeBytes(len(m.Tag)))
+ return nil
+}
+
+// SessionRuleAddDelReply defines message 'session_rule_add_del_reply'.
+type SessionRuleAddDelReply struct {
+ Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"`
+}
+
+func (m *SessionRuleAddDelReply) Reset() { *m = SessionRuleAddDelReply{} }
+func (*SessionRuleAddDelReply) GetMessageName() string { return "session_rule_add_del_reply" }
+func (*SessionRuleAddDelReply) GetCrcString() string { return "e8d4e804" }
+func (*SessionRuleAddDelReply) GetMessageType() api.MessageType {
+ return api.ReplyMessage
+}
+
+func (m *SessionRuleAddDelReply) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.Retval
+ return size
+}
+func (m *SessionRuleAddDelReply) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeInt32(m.Retval)
+ return buf.Bytes(), nil
+}
+func (m *SessionRuleAddDelReply) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.Retval = buf.DecodeInt32()
+ return nil
+}
+
+// SessionRulesDetails defines message 'session_rules_details'.
+type SessionRulesDetails struct {
+ TransportProto uint8 `binapi:"u8,name=transport_proto" json:"transport_proto,omitempty"`
+ IsIP4 uint8 `binapi:"u8,name=is_ip4" json:"is_ip4,omitempty"`
+ LclIP []byte `binapi:"u8[16],name=lcl_ip" json:"lcl_ip,omitempty"`
+ LclPlen uint8 `binapi:"u8,name=lcl_plen" json:"lcl_plen,omitempty"`
+ RmtIP []byte `binapi:"u8[16],name=rmt_ip" json:"rmt_ip,omitempty"`
+ RmtPlen uint8 `binapi:"u8,name=rmt_plen" json:"rmt_plen,omitempty"`
+ LclPort uint16 `binapi:"u16,name=lcl_port" json:"lcl_port,omitempty"`
+ RmtPort uint16 `binapi:"u16,name=rmt_port" json:"rmt_port,omitempty"`
+ ActionIndex uint32 `binapi:"u32,name=action_index" json:"action_index,omitempty"`
+ AppnsIndex uint32 `binapi:"u32,name=appns_index" json:"appns_index,omitempty"`
+ Scope uint8 `binapi:"u8,name=scope" json:"scope,omitempty"`
+ Tag []byte `binapi:"u8[64],name=tag" json:"tag,omitempty"`
+}
+
+func (m *SessionRulesDetails) Reset() { *m = SessionRulesDetails{} }
+func (*SessionRulesDetails) GetMessageName() string { return "session_rules_details" }
+func (*SessionRulesDetails) GetCrcString() string { return "a52b0e96" }
+func (*SessionRulesDetails) GetMessageType() api.MessageType {
+ return api.ReplyMessage
+}
+
+func (m *SessionRulesDetails) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 1 // m.TransportProto
+ size += 1 // m.IsIP4
+ size += 1 * 16 // m.LclIP
+ size += 1 // m.LclPlen
+ size += 1 * 16 // m.RmtIP
+ size += 1 // m.RmtPlen
+ size += 2 // m.LclPort
+ size += 2 // m.RmtPort
+ size += 4 // m.ActionIndex
+ size += 4 // m.AppnsIndex
+ size += 1 // m.Scope
+ size += 1 * 64 // m.Tag
+ return size
+}
+func (m *SessionRulesDetails) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeUint8(m.TransportProto)
+ buf.EncodeUint8(m.IsIP4)
+ buf.EncodeBytes(m.LclIP, 16)
+ buf.EncodeUint8(m.LclPlen)
+ buf.EncodeBytes(m.RmtIP, 16)
+ buf.EncodeUint8(m.RmtPlen)
+ buf.EncodeUint16(m.LclPort)
+ buf.EncodeUint16(m.RmtPort)
+ buf.EncodeUint32(m.ActionIndex)
+ buf.EncodeUint32(m.AppnsIndex)
+ buf.EncodeUint8(m.Scope)
+ buf.EncodeBytes(m.Tag, 64)
+ return buf.Bytes(), nil
+}
+func (m *SessionRulesDetails) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.TransportProto = buf.DecodeUint8()
+ m.IsIP4 = buf.DecodeUint8()
+ m.LclIP = make([]byte, 16)
+ copy(m.LclIP, buf.DecodeBytes(len(m.LclIP)))
+ m.LclPlen = buf.DecodeUint8()
+ m.RmtIP = make([]byte, 16)
+ copy(m.RmtIP, buf.DecodeBytes(len(m.RmtIP)))
+ m.RmtPlen = buf.DecodeUint8()
+ m.LclPort = buf.DecodeUint16()
+ m.RmtPort = buf.DecodeUint16()
+ m.ActionIndex = buf.DecodeUint32()
+ m.AppnsIndex = buf.DecodeUint32()
+ m.Scope = buf.DecodeUint8()
+ m.Tag = make([]byte, 64)
+ copy(m.Tag, buf.DecodeBytes(len(m.Tag)))
+ return nil
+}
+
+// SessionRulesDump defines message 'session_rules_dump'.
+type SessionRulesDump struct{}
+
+func (m *SessionRulesDump) Reset() { *m = SessionRulesDump{} }
+func (*SessionRulesDump) GetMessageName() string { return "session_rules_dump" }
+func (*SessionRulesDump) GetCrcString() string { return "51077d14" }
+func (*SessionRulesDump) GetMessageType() api.MessageType {
+ return api.RequestMessage
+}
+
+func (m *SessionRulesDump) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ return size
+}
+func (m *SessionRulesDump) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ return buf.Bytes(), nil
+}
+func (m *SessionRulesDump) Unmarshal(b []byte) error {
+ return nil
+}
+
+// UnbindSock defines message 'unbind_sock'.
+type UnbindSock struct {
+ WrkIndex uint32 `binapi:"u32,name=wrk_index" json:"wrk_index,omitempty"`
+ Handle uint64 `binapi:"u64,name=handle" json:"handle,omitempty"`
+}
+
+func (m *UnbindSock) Reset() { *m = UnbindSock{} }
+func (*UnbindSock) GetMessageName() string { return "unbind_sock" }
+func (*UnbindSock) GetCrcString() string { return "08880908" }
+func (*UnbindSock) GetMessageType() api.MessageType {
+ return api.RequestMessage
+}
+
+func (m *UnbindSock) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.WrkIndex
+ size += 8 // m.Handle
+ return size
+}
+func (m *UnbindSock) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeUint32(m.WrkIndex)
+ buf.EncodeUint64(m.Handle)
+ return buf.Bytes(), nil
+}
+func (m *UnbindSock) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.WrkIndex = buf.DecodeUint32()
+ m.Handle = buf.DecodeUint64()
+ return nil
+}
+
+// UnbindSockReply defines message 'unbind_sock_reply'.
+type UnbindSockReply struct {
+ Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"`
+}
+
+func (m *UnbindSockReply) Reset() { *m = UnbindSockReply{} }
+func (*UnbindSockReply) GetMessageName() string { return "unbind_sock_reply" }
+func (*UnbindSockReply) GetCrcString() string { return "e8d4e804" }
+func (*UnbindSockReply) GetMessageType() api.MessageType {
+ return api.ReplyMessage
+}
+
+func (m *UnbindSockReply) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.Retval
+ return size
+}
+func (m *UnbindSockReply) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeInt32(m.Retval)
+ return buf.Bytes(), nil
+}
+func (m *UnbindSockReply) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.Retval = buf.DecodeInt32()
+ return nil
+}
+
+// UnbindURI defines message 'unbind_uri'.
+type UnbindURI struct {
+ URI []byte `binapi:"u8[128],name=uri" json:"uri,omitempty"`
+}
+
+func (m *UnbindURI) Reset() { *m = UnbindURI{} }
+func (*UnbindURI) GetMessageName() string { return "unbind_uri" }
+func (*UnbindURI) GetCrcString() string { return "294cf07d" }
+func (*UnbindURI) GetMessageType() api.MessageType {
+ return api.RequestMessage
+}
+
+func (m *UnbindURI) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 1 * 128 // m.URI
+ return size
+}
+func (m *UnbindURI) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeBytes(m.URI, 128)
+ return buf.Bytes(), nil
+}
+func (m *UnbindURI) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.URI = make([]byte, 128)
+ copy(m.URI, buf.DecodeBytes(len(m.URI)))
+ return nil
+}
+
+// UnbindURIReply defines message 'unbind_uri_reply'.
+type UnbindURIReply struct {
+ Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"`
+}
+
+func (m *UnbindURIReply) Reset() { *m = UnbindURIReply{} }
+func (*UnbindURIReply) GetMessageName() string { return "unbind_uri_reply" }
+func (*UnbindURIReply) GetCrcString() string { return "e8d4e804" }
+func (*UnbindURIReply) GetMessageType() api.MessageType {
+ return api.ReplyMessage
+}
+
+func (m *UnbindURIReply) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.Retval
+ return size
+}
+func (m *UnbindURIReply) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeInt32(m.Retval)
+ return buf.Bytes(), nil
+}
+func (m *UnbindURIReply) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.Retval = buf.DecodeInt32()
+ return nil
+}
+
+// UnmapSegment defines message 'unmap_segment'.
+type UnmapSegment struct {
+ SegmentHandle uint64 `binapi:"u64,name=segment_handle" json:"segment_handle,omitempty"`
+}
+
+func (m *UnmapSegment) Reset() { *m = UnmapSegment{} }
+func (*UnmapSegment) GetMessageName() string { return "unmap_segment" }
+func (*UnmapSegment) GetCrcString() string { return "f77096f6" }
+func (*UnmapSegment) GetMessageType() api.MessageType {
+ return api.RequestMessage
+}
+
+func (m *UnmapSegment) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 8 // m.SegmentHandle
+ return size
+}
+func (m *UnmapSegment) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeUint64(m.SegmentHandle)
+ return buf.Bytes(), nil
+}
+func (m *UnmapSegment) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.SegmentHandle = buf.DecodeUint64()
+ return nil
+}
+
+// UnmapSegmentReply defines message 'unmap_segment_reply'.
+type UnmapSegmentReply struct {
+ Retval int32 `binapi:"i32,name=retval" json:"retval,omitempty"`
+}
+
+func (m *UnmapSegmentReply) Reset() { *m = UnmapSegmentReply{} }
+func (*UnmapSegmentReply) GetMessageName() string { return "unmap_segment_reply" }
+func (*UnmapSegmentReply) GetCrcString() string { return "e8d4e804" }
+func (*UnmapSegmentReply) GetMessageType() api.MessageType {
+ return api.ReplyMessage
+}
+
+func (m *UnmapSegmentReply) Size() (size int) {
+ if m == nil {
+ return 0
+ }
+ size += 4 // m.Retval
+ return size
+}
+func (m *UnmapSegmentReply) Marshal(b []byte) ([]byte, error) {
+ if b == nil {
+ b = make([]byte, m.Size())
+ }
+ buf := codec.NewBuffer(b)
+ buf.EncodeInt32(m.Retval)
+ return buf.Bytes(), nil
+}
+func (m *UnmapSegmentReply) Unmarshal(b []byte) error {
+ buf := codec.NewBuffer(b)
+ m.Retval = buf.DecodeInt32()
+ return nil
+}
+
+func init() { file_session_binapi_init() }
+func file_session_binapi_init() {
+ api.RegisterMessage((*AppAddCertKeyPair)(nil), "app_add_cert_key_pair_02eb8016")
+ api.RegisterMessage((*AppAddCertKeyPairReply)(nil), "app_add_cert_key_pair_reply_b42958d0")
+ api.RegisterMessage((*AppAttach)(nil), "app_attach_ed08f4bd")
+ api.RegisterMessage((*AppAttachReply)(nil), "app_attach_reply_0112f647")
+ api.RegisterMessage((*AppCutThroughRegistrationAdd)(nil), "app_cut_through_registration_add_6d73b1b9")
+ api.RegisterMessage((*AppCutThroughRegistrationAddReply)(nil), "app_cut_through_registration_add_reply_e8d4e804")
+ api.RegisterMessage((*AppDelCertKeyPair)(nil), "app_del_cert_key_pair_8ac76db6")
+ api.RegisterMessage((*AppDelCertKeyPairReply)(nil), "app_del_cert_key_pair_reply_e8d4e804")
+ api.RegisterMessage((*AppNamespaceAddDel)(nil), "app_namespace_add_del_dd074c65")
+ api.RegisterMessage((*AppNamespaceAddDelReply)(nil), "app_namespace_add_del_reply_85137120")
+ api.RegisterMessage((*AppWorkerAddDel)(nil), "app_worker_add_del_6d2b2279")
+ api.RegisterMessage((*AppWorkerAddDelReply)(nil), "app_worker_add_del_reply_56b21abc")
+ api.RegisterMessage((*ApplicationAttach)(nil), "application_attach_81d4f974")
+ api.RegisterMessage((*ApplicationAttachReply)(nil), "application_attach_reply_581866e8")
+ api.RegisterMessage((*ApplicationDetach)(nil), "application_detach_51077d14")
+ api.RegisterMessage((*ApplicationDetachReply)(nil), "application_detach_reply_e8d4e804")
+ api.RegisterMessage((*ApplicationTLSCertAdd)(nil), "application_tls_cert_add_3f5cfe45")
+ api.RegisterMessage((*ApplicationTLSCertAddReply)(nil), "application_tls_cert_add_reply_e8d4e804")
+ api.RegisterMessage((*ApplicationTLSKeyAdd)(nil), "application_tls_key_add_5eaf70cd")
+ api.RegisterMessage((*ApplicationTLSKeyAddReply)(nil), "application_tls_key_add_reply_e8d4e804")
+ api.RegisterMessage((*BindSock)(nil), "bind_sock_0394633f")
+ api.RegisterMessage((*BindSockReply)(nil), "bind_sock_reply_e8d4e804")
+ api.RegisterMessage((*BindURI)(nil), "bind_uri_fae140cb")
+ api.RegisterMessage((*BindURIReply)(nil), "bind_uri_reply_e8d4e804")
+ api.RegisterMessage((*ConnectSock)(nil), "connect_sock_d2b460ca")
+ api.RegisterMessage((*ConnectSockReply)(nil), "connect_sock_reply_e8d4e804")
+ api.RegisterMessage((*ConnectURI)(nil), "connect_uri_a36143d6")
+ api.RegisterMessage((*ConnectURIReply)(nil), "connect_uri_reply_e8d4e804")
+ api.RegisterMessage((*DisconnectSession)(nil), "disconnect_session_7279205b")
+ api.RegisterMessage((*DisconnectSessionReply)(nil), "disconnect_session_reply_d6960a03")
+ api.RegisterMessage((*MapAnotherSegment)(nil), "map_another_segment_dc2d630b")
+ api.RegisterMessage((*MapAnotherSegmentReply)(nil), "map_another_segment_reply_e8d4e804")
+ api.RegisterMessage((*SessionEnableDisable)(nil), "session_enable_disable_30ac9be7")
+ api.RegisterMessage((*SessionEnableDisableReply)(nil), "session_enable_disable_reply_e8d4e804")
+ api.RegisterMessage((*SessionRuleAddDel)(nil), "session_rule_add_del_4ab2eb06")
+ api.RegisterMessage((*SessionRuleAddDelReply)(nil), "session_rule_add_del_reply_e8d4e804")
+ api.RegisterMessage((*SessionRulesDetails)(nil), "session_rules_details_a52b0e96")
+ api.RegisterMessage((*SessionRulesDump)(nil), "session_rules_dump_51077d14")
+ api.RegisterMessage((*UnbindSock)(nil), "unbind_sock_08880908")
+ api.RegisterMessage((*UnbindSockReply)(nil), "unbind_sock_reply_e8d4e804")
+ api.RegisterMessage((*UnbindURI)(nil), "unbind_uri_294cf07d")
+ api.RegisterMessage((*UnbindURIReply)(nil), "unbind_uri_reply_e8d4e804")
+ api.RegisterMessage((*UnmapSegment)(nil), "unmap_segment_f77096f6")
+ api.RegisterMessage((*UnmapSegmentReply)(nil), "unmap_segment_reply_e8d4e804")
+}
+
+// Messages returns list of all messages in this module.
+func AllMessages() []api.Message {
+ return []api.Message{
+ (*AppAddCertKeyPair)(nil),
+ (*AppAddCertKeyPairReply)(nil),
+ (*AppAttach)(nil),
+ (*AppAttachReply)(nil),
+ (*AppCutThroughRegistrationAdd)(nil),
+ (*AppCutThroughRegistrationAddReply)(nil),
+ (*AppDelCertKeyPair)(nil),
+ (*AppDelCertKeyPairReply)(nil),
+ (*AppNamespaceAddDel)(nil),
+ (*AppNamespaceAddDelReply)(nil),
+ (*AppWorkerAddDel)(nil),
+ (*AppWorkerAddDelReply)(nil),
+ (*ApplicationAttach)(nil),
+ (*ApplicationAttachReply)(nil),
+ (*ApplicationDetach)(nil),
+ (*ApplicationDetachReply)(nil),
+ (*ApplicationTLSCertAdd)(nil),
+ (*ApplicationTLSCertAddReply)(nil),
+ (*ApplicationTLSKeyAdd)(nil),
+ (*ApplicationTLSKeyAddReply)(nil),
+ (*BindSock)(nil),
+ (*BindSockReply)(nil),
+ (*BindURI)(nil),
+ (*BindURIReply)(nil),
+ (*ConnectSock)(nil),
+ (*ConnectSockReply)(nil),
+ (*ConnectURI)(nil),
+ (*ConnectURIReply)(nil),
+ (*DisconnectSession)(nil),
+ (*DisconnectSessionReply)(nil),
+ (*MapAnotherSegment)(nil),
+ (*MapAnotherSegmentReply)(nil),
+ (*SessionEnableDisable)(nil),
+ (*SessionEnableDisableReply)(nil),
+ (*SessionRuleAddDel)(nil),
+ (*SessionRuleAddDelReply)(nil),
+ (*SessionRulesDetails)(nil),
+ (*SessionRulesDump)(nil),
+ (*UnbindSock)(nil),
+ (*UnbindSockReply)(nil),
+ (*UnbindURI)(nil),
+ (*UnbindURIReply)(nil),
+ (*UnmapSegment)(nil),
+ (*UnmapSegmentReply)(nil),
+ }
+}
diff --git a/internal/testbinapi/binapi2001/session/session_rpc.ba.go b/internal/testbinapi/binapi2001/session/session_rpc.ba.go
new file mode 100644
index 0000000..519aa06
--- /dev/null
+++ b/internal/testbinapi/binapi2001/session/session_rpc.ba.go
@@ -0,0 +1,273 @@
+// Code generated by GoVPP's binapi-generator. DO NOT EDIT.
+
+package session
+
+import (
+ "context"
+ "fmt"
+ api "git.fd.io/govpp.git/api"
+ vpe "git.fd.io/govpp.git/internal/testbinapi/binapi2001/vpe"
+ "io"
+)
+
+// RPCService defines RPC service session.
+type RPCService interface {
+ AppAddCertKeyPair(ctx context.Context, in *AppAddCertKeyPair) (*AppAddCertKeyPairReply, error)
+ AppAttach(ctx context.Context, in *AppAttach) (*AppAttachReply, error)
+ AppCutThroughRegistrationAdd(ctx context.Context, in *AppCutThroughRegistrationAdd) (*AppCutThroughRegistrationAddReply, error)
+ AppDelCertKeyPair(ctx context.Context, in *AppDelCertKeyPair) (*AppDelCertKeyPairReply, error)
+ AppNamespaceAddDel(ctx context.Context, in *AppNamespaceAddDel) (*AppNamespaceAddDelReply, error)
+ AppWorkerAddDel(ctx context.Context, in *AppWorkerAddDel) (*AppWorkerAddDelReply, error)
+ ApplicationAttach(ctx context.Context, in *ApplicationAttach) (*ApplicationAttachReply, error)
+ ApplicationDetach(ctx context.Context, in *ApplicationDetach) (*ApplicationDetachReply, error)
+ ApplicationTLSCertAdd(ctx context.Context, in *ApplicationTLSCertAdd) (*ApplicationTLSCertAddReply, error)
+ ApplicationTLSKeyAdd(ctx context.Context, in *ApplicationTLSKeyAdd) (*ApplicationTLSKeyAddReply, error)
+ BindSock(ctx context.Context, in *BindSock) (*BindSockReply, error)
+ BindURI(ctx context.Context, in *BindURI) (*BindURIReply, error)
+ ConnectSock(ctx context.Context, in *ConnectSock) (*ConnectSockReply, error)
+ ConnectURI(ctx context.Context, in *ConnectURI) (*ConnectURIReply, error)
+ DisconnectSession(ctx context.Context, in *DisconnectSession) (*DisconnectSessionReply, error)
+ MapAnotherSegment(ctx context.Context, in *MapAnotherSegment) (*MapAnotherSegmentReply, error)
+ SessionEnableDisable(ctx context.Context, in *SessionEnableDisable) (*SessionEnableDisableReply, error)
+ SessionRuleAddDel(ctx context.Context, in *SessionRuleAddDel) (*SessionRuleAddDelReply, error)
+ SessionRulesDump(ctx context.Context, in *SessionRulesDump) (RPCService_SessionRulesDumpClient, error)
+ UnbindSock(ctx context.Context, in *UnbindSock) (*UnbindSockReply, error)
+ UnbindURI(ctx context.Context, in *UnbindURI) (*UnbindURIReply, error)
+ UnmapSegment(ctx context.Context, in *UnmapSegment) (*UnmapSegmentReply, error)
+}
+
+type serviceClient struct {
+ conn api.Connection
+}
+
+func NewServiceClient(conn api.Connection) RPCService {
+ return &serviceClient{conn}
+}
+
+func (c *serviceClient) AppAddCertKeyPair(ctx context.Context, in *AppAddCertKeyPair) (*AppAddCertKeyPairReply, error) {
+ out := new(AppAddCertKeyPairReply)
+ err := c.conn.Invoke(ctx, in, out)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+func (c *serviceClient) AppAttach(ctx context.Context, in *AppAttach) (*AppAttachReply, error) {
+ out := new(AppAttachReply)
+ err := c.conn.Invoke(ctx, in, out)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+func (c *serviceClient) AppCutThroughRegistrationAdd(ctx context.Context, in *AppCutThroughRegistrationAdd) (*AppCutThroughRegistrationAddReply, error) {
+ out := new(AppCutThroughRegistrationAddReply)
+ err := c.conn.Invoke(ctx, in, out)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+func (c *serviceClient) AppDelCertKeyPair(ctx context.Context, in *AppDelCertKeyPair) (*AppDelCertKeyPairReply, error) {
+ out := new(AppDelCertKeyPairReply)
+ err := c.conn.Invoke(ctx, in, out)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+func (c *serviceClient) AppNamespaceAddDel(ctx context.Context, in *AppNamespaceAddDel) (*AppNamespaceAddDelReply, error) {
+ out := new(AppNamespaceAddDelReply)
+ err := c.conn.Invoke(ctx, in, out)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+func (c *serviceClient) AppWorkerAddDel(ctx context.Context, in *AppWorkerAddDel) (*AppWorkerAddDelReply, error) {
+ out := new(AppWorkerAddDelReply)
+ err := c.conn.Invoke(ctx, in, out)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+func (c *serviceClient) ApplicationAttach(ctx context.Context, in *ApplicationAttach) (*ApplicationAttachReply, error) {
+ out := new(ApplicationAttachReply)
+ err := c.conn.Invoke(ctx, in, out)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+func (c *serviceClient) ApplicationDetach(ctx context.Context, in *ApplicationDetach) (*ApplicationDetachReply, error) {
+ out := new(ApplicationDetachReply)
+ err := c.conn.Invoke(ctx, in, out)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+func (c *serviceClient) ApplicationTLSCertAdd(ctx context.Context, in *ApplicationTLSCertAdd) (*ApplicationTLSCertAddReply, error) {
+ out := new(ApplicationTLSCertAddReply)
+ err := c.conn.Invoke(ctx, in, out)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+func (c *serviceClient) ApplicationTLSKeyAdd(ctx context.Context, in *ApplicationTLSKeyAdd) (*ApplicationTLSKeyAddReply, error) {
+ out := new(ApplicationTLSKeyAddReply)
+ err := c.conn.Invoke(ctx, in, out)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+func (c *serviceClient) BindSock(ctx context.Context, in *BindSock) (*BindSockReply, error) {
+ out := new(BindSockReply)
+ err := c.conn.Invoke(ctx, in, out)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+func (c *serviceClient) BindURI(ctx context.Context, in *BindURI) (*BindURIReply, error) {
+ out := new(BindURIReply)
+ err := c.conn.Invoke(ctx, in, out)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+func (c *serviceClient) ConnectSock(ctx context.Context, in *ConnectSock) (*ConnectSockReply, error) {
+ out := new(ConnectSockReply)
+ err := c.conn.Invoke(ctx, in, out)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+func (c *serviceClient) ConnectURI(ctx context.Context, in *ConnectURI) (*ConnectURIReply, error) {
+ out := new(ConnectURIReply)
+ err := c.conn.Invoke(ctx, in, out)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+func (c *serviceClient) DisconnectSession(ctx context.Context, in *DisconnectSession) (*DisconnectSessionReply, error) {
+ out := new(DisconnectSessionReply)
+ err := c.conn.Invoke(ctx, in, out)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+func (c *serviceClient) MapAnotherSegment(ctx context.Context, in *MapAnotherSegment) (*MapAnotherSegmentReply, error) {
+ out := new(MapAnotherSegmentReply)
+ err := c.conn.Invoke(ctx, in, out)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+func (c *serviceClient) SessionEnableDisable(ctx context.Context, in *SessionEnableDisable) (*SessionEnableDisableReply, error) {
+ out := new(SessionEnableDisableReply)
+ err := c.conn.Invoke(ctx, in, out)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+func (c *serviceClient) SessionRuleAddDel(ctx context.Context, in *SessionRuleAddDel) (*SessionRuleAddDelReply, error) {
+ out := new(SessionRuleAddDelReply)
+ err := c.conn.Invoke(ctx, in, out)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+func (c *serviceClient) SessionRulesDump(ctx context.Context, in *SessionRulesDump) (RPCService_SessionRulesDumpClient, error) {
+ stream, err := c.conn.NewStream(ctx)
+ if err != nil {
+ return nil, err
+ }
+ x := &serviceClient_SessionRulesDumpClient{stream}
+ if err := x.Stream.SendMsg(in); err != nil {
+ return nil, err
+ }
+ if err = x.Stream.SendMsg(&vpe.ControlPing{}); err != nil {
+ return nil, err
+ }
+ return x, nil
+}
+
+type RPCService_SessionRulesDumpClient interface {
+ Recv() (*SessionRulesDetails, error)
+ api.Stream
+}
+
+type serviceClient_SessionRulesDumpClient struct {
+ api.Stream
+}
+
+func (c *serviceClient_SessionRulesDumpClient) Recv() (*SessionRulesDetails, error) {
+ msg, err := c.Stream.RecvMsg()
+ if err != nil {
+ return nil, err
+ }
+ switch m := msg.(type) {
+ case *SessionRulesDetails:
+ return m, nil
+ case *vpe.ControlPingReply:
+ return nil, io.EOF
+ default:
+ return nil, fmt.Errorf("unexpected message: %T %v", m, m)
+ }
+}
+
+func (c *serviceClient) UnbindSock(ctx context.Context, in *UnbindSock) (*UnbindSockReply, error) {
+ out := new(UnbindSockReply)
+ err := c.conn.Invoke(ctx, in, out)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+func (c *serviceClient) UnbindURI(ctx context.Context, in *UnbindURI) (*UnbindURIReply, error) {
+ out := new(UnbindURIReply)
+ err := c.conn.Invoke(ctx, in, out)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
+func (c *serviceClient) UnmapSegment(ctx context.Context, in *UnmapSegment) (*UnmapSegmentReply, error) {
+ out := new(UnmapSegmentReply)
+ err := c.conn.Invoke(ctx, in, out)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}