diff options
Diffstat (limited to 'internal/testbinapi/binapi2001/session')
| -rw-r--r-- | internal/testbinapi/binapi2001/session/session.ba.go | 2026 | ||||
| -rw-r--r-- | internal/testbinapi/binapi2001/session/session_rpc.ba.go | 273 |
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 +} |