Versions in this module Expand all Collapse all v1 v1.0.1 Mar 12, 2026 Changes in this version + var ATBUS_ACCESS_DATA_ALGORITHM_TYPE_name = map[int32]string + var ATBUS_ACCESS_DATA_ALGORITHM_TYPE_value = map[string]int32 + var ATBUS_COMPRESSION_ALGORITHM_TYPE_name = map[int32]string + var ATBUS_COMPRESSION_ALGORITHM_TYPE_value = map[string]int32 + var ATBUS_COMPRESSION_LEVEL_name = map[int32]string + var ATBUS_COMPRESSION_LEVEL_value = map[string]int32 + var ATBUS_CRYPTO_ALGORITHM_TYPE_name = map[int32]string + var ATBUS_CRYPTO_ALGORITHM_TYPE_value = map[string]int32 + var ATBUS_CRYPTO_KDF_TYPE_name = map[int32]string + var ATBUS_CRYPTO_KDF_TYPE_value = map[string]int32 + var ATBUS_CRYPTO_KEY_EXCHANGE_TYPE_name = map[int32]string + var ATBUS_CRYPTO_KEY_EXCHANGE_TYPE_value = map[string]int32 + var ATBUS_FORWARD_DATA_FLAG_TYPE_name = map[int32]string + var ATBUS_FORWARD_DATA_FLAG_TYPE_value = map[string]int32 + var ATBUS_PROTOCOL_CONST_name = map[int32]string + var ATBUS_PROTOCOL_CONST_value = map[string]int32 + var File_libatbus_protocol_proto protoreflect.FileDescriptor + func GetTypeIDMessageBody_CustomCommandReq() lu.TypeID + func GetTypeIDMessageBody_CustomCommandRsp() lu.TypeID + func GetTypeIDMessageBody_DataTransformReq() lu.TypeID + func GetTypeIDMessageBody_DataTransformRsp() lu.TypeID + func GetTypeIDMessageBody_NodePingReq() lu.TypeID + func GetTypeIDMessageBody_NodePongRsp() lu.TypeID + func GetTypeIDMessageBody_NodeRegisterReq() lu.TypeID + func GetTypeIDMessageBody_NodeRegisterRsp() lu.TypeID + type ATBUS_ACCESS_DATA_ALGORITHM_TYPE int32 + const ATBUS_ACCESS_DATA_ALGORITHM_TYPE_ATBUS_ACCESS_DATA_ALGORITHM_HMAC_SHA256 + func (ATBUS_ACCESS_DATA_ALGORITHM_TYPE) Descriptor() protoreflect.EnumDescriptor + func (ATBUS_ACCESS_DATA_ALGORITHM_TYPE) EnumDescriptor() ([]byte, []int) + func (ATBUS_ACCESS_DATA_ALGORITHM_TYPE) Type() protoreflect.EnumType + func (x ATBUS_ACCESS_DATA_ALGORITHM_TYPE) Enum() *ATBUS_ACCESS_DATA_ALGORITHM_TYPE + func (x ATBUS_ACCESS_DATA_ALGORITHM_TYPE) Number() protoreflect.EnumNumber + func (x ATBUS_ACCESS_DATA_ALGORITHM_TYPE) String() string + type ATBUS_COMPRESSION_ALGORITHM_TYPE int32 + const ATBUS_COMPRESSION_ALGORITHM_TYPE_ATBUS_COMPRESSION_ALGORITHM_LZ4 + const ATBUS_COMPRESSION_ALGORITHM_TYPE_ATBUS_COMPRESSION_ALGORITHM_NONE + const ATBUS_COMPRESSION_ALGORITHM_TYPE_ATBUS_COMPRESSION_ALGORITHM_SNAPPY + const ATBUS_COMPRESSION_ALGORITHM_TYPE_ATBUS_COMPRESSION_ALGORITHM_ZLIB + const ATBUS_COMPRESSION_ALGORITHM_TYPE_ATBUS_COMPRESSION_ALGORITHM_ZSTD + func (ATBUS_COMPRESSION_ALGORITHM_TYPE) Descriptor() protoreflect.EnumDescriptor + func (ATBUS_COMPRESSION_ALGORITHM_TYPE) EnumDescriptor() ([]byte, []int) + func (ATBUS_COMPRESSION_ALGORITHM_TYPE) Type() protoreflect.EnumType + func (x ATBUS_COMPRESSION_ALGORITHM_TYPE) Enum() *ATBUS_COMPRESSION_ALGORITHM_TYPE + func (x ATBUS_COMPRESSION_ALGORITHM_TYPE) Number() protoreflect.EnumNumber + func (x ATBUS_COMPRESSION_ALGORITHM_TYPE) String() string + type ATBUS_COMPRESSION_LEVEL int32 + const ATBUS_COMPRESSION_LEVEL_ATBUS_COMPRESSION_LEVEL_BALANCED + const ATBUS_COMPRESSION_LEVEL_ATBUS_COMPRESSION_LEVEL_DEFAULT + const ATBUS_COMPRESSION_LEVEL_ATBUS_COMPRESSION_LEVEL_FAST + const ATBUS_COMPRESSION_LEVEL_ATBUS_COMPRESSION_LEVEL_HIGH_RATIO + const ATBUS_COMPRESSION_LEVEL_ATBUS_COMPRESSION_LEVEL_LOW_CPU + const ATBUS_COMPRESSION_LEVEL_ATBUS_COMPRESSION_LEVEL_MAX_RATIO + const ATBUS_COMPRESSION_LEVEL_ATBUS_COMPRESSION_LEVEL_STORAGE + func (ATBUS_COMPRESSION_LEVEL) Descriptor() protoreflect.EnumDescriptor + func (ATBUS_COMPRESSION_LEVEL) EnumDescriptor() ([]byte, []int) + func (ATBUS_COMPRESSION_LEVEL) Type() protoreflect.EnumType + func (x ATBUS_COMPRESSION_LEVEL) Enum() *ATBUS_COMPRESSION_LEVEL + func (x ATBUS_COMPRESSION_LEVEL) Number() protoreflect.EnumNumber + func (x ATBUS_COMPRESSION_LEVEL) String() string + type ATBUS_CRYPTO_ALGORITHM_TYPE int32 + const ATBUS_CRYPTO_ALGORITHM_TYPE_ATBUS_CRYPTO_ALGORITHM_AES_128_CBC + const ATBUS_CRYPTO_ALGORITHM_TYPE_ATBUS_CRYPTO_ALGORITHM_AES_128_GCM + const ATBUS_CRYPTO_ALGORITHM_TYPE_ATBUS_CRYPTO_ALGORITHM_AES_192_CBC + const ATBUS_CRYPTO_ALGORITHM_TYPE_ATBUS_CRYPTO_ALGORITHM_AES_192_GCM + const ATBUS_CRYPTO_ALGORITHM_TYPE_ATBUS_CRYPTO_ALGORITHM_AES_256_CBC + const ATBUS_CRYPTO_ALGORITHM_TYPE_ATBUS_CRYPTO_ALGORITHM_AES_256_GCM + const ATBUS_CRYPTO_ALGORITHM_TYPE_ATBUS_CRYPTO_ALGORITHM_CHACHA20 + const ATBUS_CRYPTO_ALGORITHM_TYPE_ATBUS_CRYPTO_ALGORITHM_CHACHA20_POLY1305_IETF + const ATBUS_CRYPTO_ALGORITHM_TYPE_ATBUS_CRYPTO_ALGORITHM_NONE + const ATBUS_CRYPTO_ALGORITHM_TYPE_ATBUS_CRYPTO_ALGORITHM_XCHACHA20_POLY1305_IETF + const ATBUS_CRYPTO_ALGORITHM_TYPE_ATBUS_CRYPTO_ALGORITHM_XXTEA + func (ATBUS_CRYPTO_ALGORITHM_TYPE) Descriptor() protoreflect.EnumDescriptor + func (ATBUS_CRYPTO_ALGORITHM_TYPE) EnumDescriptor() ([]byte, []int) + func (ATBUS_CRYPTO_ALGORITHM_TYPE) Type() protoreflect.EnumType + func (x ATBUS_CRYPTO_ALGORITHM_TYPE) Enum() *ATBUS_CRYPTO_ALGORITHM_TYPE + func (x ATBUS_CRYPTO_ALGORITHM_TYPE) Number() protoreflect.EnumNumber + func (x ATBUS_CRYPTO_ALGORITHM_TYPE) String() string + type ATBUS_CRYPTO_KDF_TYPE int32 + const ATBUS_CRYPTO_KDF_TYPE_ATBUS_CRYPTO_KDF_HKDF_SHA256 + func (ATBUS_CRYPTO_KDF_TYPE) Descriptor() protoreflect.EnumDescriptor + func (ATBUS_CRYPTO_KDF_TYPE) EnumDescriptor() ([]byte, []int) + func (ATBUS_CRYPTO_KDF_TYPE) Type() protoreflect.EnumType + func (x ATBUS_CRYPTO_KDF_TYPE) Enum() *ATBUS_CRYPTO_KDF_TYPE + func (x ATBUS_CRYPTO_KDF_TYPE) Number() protoreflect.EnumNumber + func (x ATBUS_CRYPTO_KDF_TYPE) String() string + type ATBUS_CRYPTO_KEY_EXCHANGE_TYPE int32 + const ATBUS_CRYPTO_KEY_EXCHANGE_TYPE_ATBUS_CRYPTO_KEY_EXCHANGE_NONE + const ATBUS_CRYPTO_KEY_EXCHANGE_TYPE_ATBUS_CRYPTO_KEY_EXCHANGE_SECP256R1 + const ATBUS_CRYPTO_KEY_EXCHANGE_TYPE_ATBUS_CRYPTO_KEY_EXCHANGE_SECP384R1 + const ATBUS_CRYPTO_KEY_EXCHANGE_TYPE_ATBUS_CRYPTO_KEY_EXCHANGE_SECP521R1 + const ATBUS_CRYPTO_KEY_EXCHANGE_TYPE_ATBUS_CRYPTO_KEY_EXCHANGE_X25519 + func (ATBUS_CRYPTO_KEY_EXCHANGE_TYPE) Descriptor() protoreflect.EnumDescriptor + func (ATBUS_CRYPTO_KEY_EXCHANGE_TYPE) EnumDescriptor() ([]byte, []int) + func (ATBUS_CRYPTO_KEY_EXCHANGE_TYPE) Type() protoreflect.EnumType + func (x ATBUS_CRYPTO_KEY_EXCHANGE_TYPE) Enum() *ATBUS_CRYPTO_KEY_EXCHANGE_TYPE + func (x ATBUS_CRYPTO_KEY_EXCHANGE_TYPE) Number() protoreflect.EnumNumber + func (x ATBUS_CRYPTO_KEY_EXCHANGE_TYPE) String() string + type ATBUS_FORWARD_DATA_FLAG_TYPE int32 + const ATBUS_FORWARD_DATA_FLAG_TYPE_FORWARD_DATA_FLAG_NONE + const ATBUS_FORWARD_DATA_FLAG_TYPE_FORWARD_DATA_FLAG_REQUIRE_RSP + func (ATBUS_FORWARD_DATA_FLAG_TYPE) Descriptor() protoreflect.EnumDescriptor + func (ATBUS_FORWARD_DATA_FLAG_TYPE) EnumDescriptor() ([]byte, []int) + func (ATBUS_FORWARD_DATA_FLAG_TYPE) Type() protoreflect.EnumType + func (x ATBUS_FORWARD_DATA_FLAG_TYPE) Enum() *ATBUS_FORWARD_DATA_FLAG_TYPE + func (x ATBUS_FORWARD_DATA_FLAG_TYPE) Number() protoreflect.EnumNumber + func (x ATBUS_FORWARD_DATA_FLAG_TYPE) String() string + type ATBUS_PROTOCOL_CONST int32 + const ATBUS_PROTOCOL_CONST_ATBUS_PROTOCOL_CONST_UNKNOWN + const ATBUS_PROTOCOL_CONST_ATBUS_PROTOCOL_MINIMAL_VERSION + const ATBUS_PROTOCOL_CONST_ATBUS_PROTOCOL_VERSION + func (ATBUS_PROTOCOL_CONST) Descriptor() protoreflect.EnumDescriptor + func (ATBUS_PROTOCOL_CONST) EnumDescriptor() ([]byte, []int) + func (ATBUS_PROTOCOL_CONST) Type() protoreflect.EnumType + func (x ATBUS_PROTOCOL_CONST) Enum() *ATBUS_PROTOCOL_CONST + func (x ATBUS_PROTOCOL_CONST) Number() protoreflect.EnumNumber + func (x ATBUS_PROTOCOL_CONST) String() string + type AccessData struct + Algorithm ATBUS_ACCESS_DATA_ALGORITHM_TYPE + Nonce1 uint64 + Nonce2 uint64 + Signature [][]byte + Timestamp int64 + func (*AccessData) Descriptor() ([]byte, []int) + func (*AccessData) ProtoMessage() + func (_ *AccessData) GetTypeID() lu.TypeID + func (m *AccessData) AppendSignature(d []byte) + func (m *AccessData) Clone() *AccessData + func (m *AccessData) LogValue() slog.Value + func (m *AccessData) Merge(src *AccessData) + func (m *AccessData) MergeSignature(d [][]byte) [][]byte + func (m *AccessData) MutableSignature() [][]byte + func (m *AccessData) RemoveLastSignature() + func (m *AccessData) ReverseIfNilSignature(l int32) [][]byte + func (m *AccessData) ToReadonly() *Readonly_AccessData + func (x *AccessData) GetAlgorithm() ATBUS_ACCESS_DATA_ALGORITHM_TYPE + func (x *AccessData) GetNonce1() uint64 + func (x *AccessData) GetNonce2() uint64 + func (x *AccessData) GetSignature() [][]byte + func (x *AccessData) GetTimestamp() int64 + func (x *AccessData) ProtoReflect() protoreflect.Message + func (x *AccessData) Reset() + func (x *AccessData) String() string + type ChannelData struct + Address string + func (*ChannelData) Descriptor() ([]byte, []int) + func (*ChannelData) ProtoMessage() + func (_ *ChannelData) GetTypeID() lu.TypeID + func (m *ChannelData) Clone() *ChannelData + func (m *ChannelData) LogValue() slog.Value + func (m *ChannelData) Merge(src *ChannelData) + func (m *ChannelData) ToReadonly() *Readonly_ChannelData + func (x *ChannelData) GetAddress() string + func (x *ChannelData) ProtoReflect() protoreflect.Message + func (x *ChannelData) Reset() + func (x *ChannelData) String() string + type CryptoHandshakeData struct + Algorithms []ATBUS_CRYPTO_ALGORITHM_TYPE + IvSize uint32 + KdfType []ATBUS_CRYPTO_KDF_TYPE + PublicKey []byte + Sequence uint64 + TagSize uint32 + Type ATBUS_CRYPTO_KEY_EXCHANGE_TYPE + func (*CryptoHandshakeData) Descriptor() ([]byte, []int) + func (*CryptoHandshakeData) ProtoMessage() + func (_ *CryptoHandshakeData) GetTypeID() lu.TypeID + func (m *CryptoHandshakeData) AppendAlgorithms(d ATBUS_CRYPTO_ALGORITHM_TYPE) + func (m *CryptoHandshakeData) AppendKdfType(d ATBUS_CRYPTO_KDF_TYPE) + func (m *CryptoHandshakeData) Clone() *CryptoHandshakeData + func (m *CryptoHandshakeData) LogValue() slog.Value + func (m *CryptoHandshakeData) Merge(src *CryptoHandshakeData) + func (m *CryptoHandshakeData) MergeAlgorithms(d []ATBUS_CRYPTO_ALGORITHM_TYPE) []ATBUS_CRYPTO_ALGORITHM_TYPE + func (m *CryptoHandshakeData) MergeKdfType(d []ATBUS_CRYPTO_KDF_TYPE) []ATBUS_CRYPTO_KDF_TYPE + func (m *CryptoHandshakeData) MutableAlgorithms() []ATBUS_CRYPTO_ALGORITHM_TYPE + func (m *CryptoHandshakeData) MutableKdfType() []ATBUS_CRYPTO_KDF_TYPE + func (m *CryptoHandshakeData) RemoveLastAlgorithms() + func (m *CryptoHandshakeData) RemoveLastKdfType() + func (m *CryptoHandshakeData) ReverseIfNilAlgorithms(l int32) []ATBUS_CRYPTO_ALGORITHM_TYPE + func (m *CryptoHandshakeData) ReverseIfNilKdfType(l int32) []ATBUS_CRYPTO_KDF_TYPE + func (m *CryptoHandshakeData) ToReadonly() *Readonly_CryptoHandshakeData + func (x *CryptoHandshakeData) GetAlgorithms() []ATBUS_CRYPTO_ALGORITHM_TYPE + func (x *CryptoHandshakeData) GetIvSize() uint32 + func (x *CryptoHandshakeData) GetKdfType() []ATBUS_CRYPTO_KDF_TYPE + func (x *CryptoHandshakeData) GetPublicKey() []byte + func (x *CryptoHandshakeData) GetSequence() uint64 + func (x *CryptoHandshakeData) GetTagSize() uint32 + func (x *CryptoHandshakeData) GetType() ATBUS_CRYPTO_KEY_EXCHANGE_TYPE + func (x *CryptoHandshakeData) ProtoReflect() protoreflect.Message + func (x *CryptoHandshakeData) Reset() + func (x *CryptoHandshakeData) String() string + type CustomCommandArgv struct + Arg []byte + func (*CustomCommandArgv) Descriptor() ([]byte, []int) + func (*CustomCommandArgv) ProtoMessage() + func (_ *CustomCommandArgv) GetTypeID() lu.TypeID + func (m *CustomCommandArgv) Clone() *CustomCommandArgv + func (m *CustomCommandArgv) LogValue() slog.Value + func (m *CustomCommandArgv) Merge(src *CustomCommandArgv) + func (m *CustomCommandArgv) ToReadonly() *Readonly_CustomCommandArgv + func (x *CustomCommandArgv) GetArg() []byte + func (x *CustomCommandArgv) ProtoReflect() protoreflect.Message + func (x *CustomCommandArgv) Reset() + func (x *CustomCommandArgv) String() string + type CustomCommandData struct + AccessKey *AccessData + Commands []*CustomCommandArgv + From uint64 + func (*CustomCommandData) Descriptor() ([]byte, []int) + func (*CustomCommandData) ProtoMessage() + func (_ *CustomCommandData) GetTypeID() lu.TypeID + func (m *CustomCommandData) AddCommands() *CustomCommandArgv + func (m *CustomCommandData) AppendCommands(d *CustomCommandArgv) + func (m *CustomCommandData) Clone() *CustomCommandData + func (m *CustomCommandData) LogValue() slog.Value + func (m *CustomCommandData) Merge(src *CustomCommandData) + func (m *CustomCommandData) MergeCommands(d []*CustomCommandArgv) []*CustomCommandArgv + func (m *CustomCommandData) MutableAccessKey() *AccessData + func (m *CustomCommandData) MutableCommands() []*CustomCommandArgv + func (m *CustomCommandData) RemoveLastCommands() + func (m *CustomCommandData) ReverseIfNilCommands(l int32) []*CustomCommandArgv + func (m *CustomCommandData) ToReadonly() *Readonly_CustomCommandData + func (x *CustomCommandData) GetAccessKey() *AccessData + func (x *CustomCommandData) GetCommands() []*CustomCommandArgv + func (x *CustomCommandData) GetFrom() uint64 + func (x *CustomCommandData) ProtoReflect() protoreflect.Message + func (x *CustomCommandData) Reset() + func (x *CustomCommandData) String() string + type ForwardData struct + Content []byte + Flags uint32 + From uint64 + Router []uint64 + To uint64 + func (*ForwardData) Descriptor() ([]byte, []int) + func (*ForwardData) ProtoMessage() + func (_ *ForwardData) GetTypeID() lu.TypeID + func (m *ForwardData) AppendRouter(d uint64) + func (m *ForwardData) Clone() *ForwardData + func (m *ForwardData) LogValue() slog.Value + func (m *ForwardData) Merge(src *ForwardData) + func (m *ForwardData) MergeRouter(d []uint64) []uint64 + func (m *ForwardData) MutableRouter() []uint64 + func (m *ForwardData) RemoveLastRouter() + func (m *ForwardData) ReverseIfNilRouter(l int32) []uint64 + func (m *ForwardData) ToReadonly() *Readonly_ForwardData + func (x *ForwardData) GetContent() []byte + func (x *ForwardData) GetFlags() uint32 + func (x *ForwardData) GetFrom() uint64 + func (x *ForwardData) GetRouter() []uint64 + func (x *ForwardData) GetTo() uint64 + func (x *ForwardData) ProtoReflect() protoreflect.Message + func (x *ForwardData) Reset() + func (x *ForwardData) String() string + type MessageBody struct + MessageType isMessageBody_MessageType + func (*MessageBody) Descriptor() ([]byte, []int) + func (*MessageBody) ProtoMessage() + func (_ *MessageBody) GetTypeID() lu.TypeID + func (m *MessageBody) Clone() *MessageBody + func (m *MessageBody) GetMessageTypeOneofCase() MessageBody_EnMessageTypeID + func (m *MessageBody) GetMessageTypeOneofName() string + func (m *MessageBody) GetMessageTypeTypeID() lu.TypeID + func (m *MessageBody) LogValue() slog.Value + func (m *MessageBody) Merge(src *MessageBody) + func (m *MessageBody) MutableCustomCommandReq() *CustomCommandData + func (m *MessageBody) MutableCustomCommandRsp() *CustomCommandData + func (m *MessageBody) MutableDataTransformReq() *ForwardData + func (m *MessageBody) MutableDataTransformRsp() *ForwardData + func (m *MessageBody) MutableNodePingReq() *PingData + func (m *MessageBody) MutableNodePongRsp() *PingData + func (m *MessageBody) MutableNodeRegisterReq() *RegisterData + func (m *MessageBody) MutableNodeRegisterRsp() *RegisterData + func (m *MessageBody) ToReadonly() *Readonly_MessageBody + func (x *MessageBody) GetCustomCommandReq() *CustomCommandData + func (x *MessageBody) GetCustomCommandRsp() *CustomCommandData + func (x *MessageBody) GetDataTransformReq() *ForwardData + func (x *MessageBody) GetDataTransformRsp() *ForwardData + func (x *MessageBody) GetMessageType() isMessageBody_MessageType + func (x *MessageBody) GetNodePingReq() *PingData + func (x *MessageBody) GetNodePongRsp() *PingData + func (x *MessageBody) GetNodeRegisterReq() *RegisterData + func (x *MessageBody) GetNodeRegisterRsp() *RegisterData + func (x *MessageBody) ProtoReflect() protoreflect.Message + func (x *MessageBody) Reset() + func (x *MessageBody) String() string + type MessageBody_CustomCommandReq struct + CustomCommandReq *CustomCommandData + func (_ *MessageBody_CustomCommandReq) GetTypeID() lu.TypeID + func (m *MessageBody_CustomCommandReq) GetFieldNameMessageBody_MessageType() string + func (m *MessageBody_CustomCommandReq) GetMessageBody_MessageType() MessageBody_EnMessageTypeID + func (m *MessageBody_CustomCommandReq) GetTypeIDMessageBody_MessageType() lu.TypeID + func (m *MessageBody_CustomCommandReq) MutableCustomCommandReq() *CustomCommandData + type MessageBody_CustomCommandRsp struct + CustomCommandRsp *CustomCommandData + func (_ *MessageBody_CustomCommandRsp) GetTypeID() lu.TypeID + func (m *MessageBody_CustomCommandRsp) GetFieldNameMessageBody_MessageType() string + func (m *MessageBody_CustomCommandRsp) GetMessageBody_MessageType() MessageBody_EnMessageTypeID + func (m *MessageBody_CustomCommandRsp) GetTypeIDMessageBody_MessageType() lu.TypeID + func (m *MessageBody_CustomCommandRsp) MutableCustomCommandRsp() *CustomCommandData + type MessageBody_DataTransformReq struct + DataTransformReq *ForwardData + func (_ *MessageBody_DataTransformReq) GetTypeID() lu.TypeID + func (m *MessageBody_DataTransformReq) GetFieldNameMessageBody_MessageType() string + func (m *MessageBody_DataTransformReq) GetMessageBody_MessageType() MessageBody_EnMessageTypeID + func (m *MessageBody_DataTransformReq) GetTypeIDMessageBody_MessageType() lu.TypeID + func (m *MessageBody_DataTransformReq) MutableDataTransformReq() *ForwardData + type MessageBody_DataTransformRsp struct + DataTransformRsp *ForwardData + func (_ *MessageBody_DataTransformRsp) GetTypeID() lu.TypeID + func (m *MessageBody_DataTransformRsp) GetFieldNameMessageBody_MessageType() string + func (m *MessageBody_DataTransformRsp) GetMessageBody_MessageType() MessageBody_EnMessageTypeID + func (m *MessageBody_DataTransformRsp) GetTypeIDMessageBody_MessageType() lu.TypeID + func (m *MessageBody_DataTransformRsp) MutableDataTransformRsp() *ForwardData + type MessageBody_EnMessageTypeID int32 + const MessageBody_EnMessageTypeID_CustomCommandReq + const MessageBody_EnMessageTypeID_CustomCommandRsp + const MessageBody_EnMessageTypeID_DataTransformReq + const MessageBody_EnMessageTypeID_DataTransformRsp + const MessageBody_EnMessageTypeID_NONE + const MessageBody_EnMessageTypeID_NodePingReq + const MessageBody_EnMessageTypeID_NodePongRsp + const MessageBody_EnMessageTypeID_NodeRegisterReq + const MessageBody_EnMessageTypeID_NodeRegisterRsp + type MessageBody_NodePingReq struct + NodePingReq *PingData + func (_ *MessageBody_NodePingReq) GetTypeID() lu.TypeID + func (m *MessageBody_NodePingReq) GetFieldNameMessageBody_MessageType() string + func (m *MessageBody_NodePingReq) GetMessageBody_MessageType() MessageBody_EnMessageTypeID + func (m *MessageBody_NodePingReq) GetTypeIDMessageBody_MessageType() lu.TypeID + func (m *MessageBody_NodePingReq) MutableNodePingReq() *PingData + type MessageBody_NodePongRsp struct + NodePongRsp *PingData + func (_ *MessageBody_NodePongRsp) GetTypeID() lu.TypeID + func (m *MessageBody_NodePongRsp) GetFieldNameMessageBody_MessageType() string + func (m *MessageBody_NodePongRsp) GetMessageBody_MessageType() MessageBody_EnMessageTypeID + func (m *MessageBody_NodePongRsp) GetTypeIDMessageBody_MessageType() lu.TypeID + func (m *MessageBody_NodePongRsp) MutableNodePongRsp() *PingData + type MessageBody_NodeRegisterReq struct + NodeRegisterReq *RegisterData + func (_ *MessageBody_NodeRegisterReq) GetTypeID() lu.TypeID + func (m *MessageBody_NodeRegisterReq) GetFieldNameMessageBody_MessageType() string + func (m *MessageBody_NodeRegisterReq) GetMessageBody_MessageType() MessageBody_EnMessageTypeID + func (m *MessageBody_NodeRegisterReq) GetTypeIDMessageBody_MessageType() lu.TypeID + func (m *MessageBody_NodeRegisterReq) MutableNodeRegisterReq() *RegisterData + type MessageBody_NodeRegisterRsp struct + NodeRegisterRsp *RegisterData + func (_ *MessageBody_NodeRegisterRsp) GetTypeID() lu.TypeID + func (m *MessageBody_NodeRegisterRsp) GetFieldNameMessageBody_MessageType() string + func (m *MessageBody_NodeRegisterRsp) GetMessageBody_MessageType() MessageBody_EnMessageTypeID + func (m *MessageBody_NodeRegisterRsp) GetTypeIDMessageBody_MessageType() lu.TypeID + func (m *MessageBody_NodeRegisterRsp) MutableNodeRegisterRsp() *RegisterData + type MessageHead struct + BodySize uint64 + Compression *MessageHeadCompression + Crypto *MessageHeadCrypto + ResultCode int32 + Sequence uint64 + SourceBusId uint64 + Type int32 + Version int32 + func (*MessageHead) Descriptor() ([]byte, []int) + func (*MessageHead) ProtoMessage() + func (_ *MessageHead) GetTypeID() lu.TypeID + func (m *MessageHead) Clone() *MessageHead + func (m *MessageHead) LogValue() slog.Value + func (m *MessageHead) Merge(src *MessageHead) + func (m *MessageHead) MutableCompression() *MessageHeadCompression + func (m *MessageHead) MutableCrypto() *MessageHeadCrypto + func (m *MessageHead) ToReadonly() *Readonly_MessageHead + func (x *MessageHead) GetBodySize() uint64 + func (x *MessageHead) GetCompression() *MessageHeadCompression + func (x *MessageHead) GetCrypto() *MessageHeadCrypto + func (x *MessageHead) GetResultCode() int32 + func (x *MessageHead) GetSequence() uint64 + func (x *MessageHead) GetSourceBusId() uint64 + func (x *MessageHead) GetType() int32 + func (x *MessageHead) GetVersion() int32 + func (x *MessageHead) ProtoReflect() protoreflect.Message + func (x *MessageHead) Reset() + func (x *MessageHead) String() string + type MessageHeadCompression struct + OriginalSize uint64 + Type ATBUS_COMPRESSION_ALGORITHM_TYPE + func (*MessageHeadCompression) Descriptor() ([]byte, []int) + func (*MessageHeadCompression) ProtoMessage() + func (_ *MessageHeadCompression) GetTypeID() lu.TypeID + func (m *MessageHeadCompression) Clone() *MessageHeadCompression + func (m *MessageHeadCompression) LogValue() slog.Value + func (m *MessageHeadCompression) Merge(src *MessageHeadCompression) + func (m *MessageHeadCompression) ToReadonly() *Readonly_MessageHeadCompression + func (x *MessageHeadCompression) GetOriginalSize() uint64 + func (x *MessageHeadCompression) GetType() ATBUS_COMPRESSION_ALGORITHM_TYPE + func (x *MessageHeadCompression) ProtoReflect() protoreflect.Message + func (x *MessageHeadCompression) Reset() + func (x *MessageHeadCompression) String() string + type MessageHeadCrypto struct + Aad []byte + Algorithm ATBUS_CRYPTO_ALGORITHM_TYPE + Iv []byte + func (*MessageHeadCrypto) Descriptor() ([]byte, []int) + func (*MessageHeadCrypto) ProtoMessage() + func (_ *MessageHeadCrypto) GetTypeID() lu.TypeID + func (m *MessageHeadCrypto) Clone() *MessageHeadCrypto + func (m *MessageHeadCrypto) LogValue() slog.Value + func (m *MessageHeadCrypto) Merge(src *MessageHeadCrypto) + func (m *MessageHeadCrypto) ToReadonly() *Readonly_MessageHeadCrypto + func (x *MessageHeadCrypto) GetAad() []byte + func (x *MessageHeadCrypto) GetAlgorithm() ATBUS_CRYPTO_ALGORITHM_TYPE + func (x *MessageHeadCrypto) GetIv() []byte + func (x *MessageHeadCrypto) ProtoReflect() protoreflect.Message + func (x *MessageHeadCrypto) Reset() + func (x *MessageHeadCrypto) String() string + type PingData struct + CryptoHandshake *CryptoHandshakeData + TimePoint int64 + func (*PingData) Descriptor() ([]byte, []int) + func (*PingData) ProtoMessage() + func (_ *PingData) GetTypeID() lu.TypeID + func (m *PingData) Clone() *PingData + func (m *PingData) LogValue() slog.Value + func (m *PingData) Merge(src *PingData) + func (m *PingData) MutableCryptoHandshake() *CryptoHandshakeData + func (m *PingData) ToReadonly() *Readonly_PingData + func (x *PingData) GetCryptoHandshake() *CryptoHandshakeData + func (x *PingData) GetTimePoint() int64 + func (x *PingData) ProtoReflect() protoreflect.Message + func (x *PingData) Reset() + func (x *PingData) String() string + type Readonly_AccessData struct + func (r *Readonly_AccessData) CloneMessage() *AccessData + func (r *Readonly_AccessData) GetAlgorithm() ATBUS_ACCESS_DATA_ALGORITHM_TYPE + func (r *Readonly_AccessData) GetNonce1() uint64 + func (r *Readonly_AccessData) GetNonce2() uint64 + func (r *Readonly_AccessData) GetSignature() [][]byte + func (r *Readonly_AccessData) GetTimestamp() int64 + func (r *Readonly_AccessData) ReadonlyProtoReflect() innerFile_libatbus_protocol_protoReadonlyMessage + func (r *Readonly_AccessData) ToMessage() *AccessData + func (r Readonly_AccessData) LogValue() slog.Value + type Readonly_ChannelData struct + func (r *Readonly_ChannelData) CloneMessage() *ChannelData + func (r *Readonly_ChannelData) GetAddress() string + func (r *Readonly_ChannelData) ReadonlyProtoReflect() innerFile_libatbus_protocol_protoReadonlyMessage + func (r *Readonly_ChannelData) ToMessage() *ChannelData + func (r Readonly_ChannelData) LogValue() slog.Value + type Readonly_CryptoHandshakeData struct + func (r *Readonly_CryptoHandshakeData) CloneMessage() *CryptoHandshakeData + func (r *Readonly_CryptoHandshakeData) GetAlgorithms() []ATBUS_CRYPTO_ALGORITHM_TYPE + func (r *Readonly_CryptoHandshakeData) GetIvSize() uint32 + func (r *Readonly_CryptoHandshakeData) GetKdfType() []ATBUS_CRYPTO_KDF_TYPE + func (r *Readonly_CryptoHandshakeData) GetPublicKey() []byte + func (r *Readonly_CryptoHandshakeData) GetSequence() uint64 + func (r *Readonly_CryptoHandshakeData) GetTagSize() uint32 + func (r *Readonly_CryptoHandshakeData) GetType() ATBUS_CRYPTO_KEY_EXCHANGE_TYPE + func (r *Readonly_CryptoHandshakeData) ReadonlyProtoReflect() innerFile_libatbus_protocol_protoReadonlyMessage + func (r *Readonly_CryptoHandshakeData) ToMessage() *CryptoHandshakeData + func (r Readonly_CryptoHandshakeData) LogValue() slog.Value + type Readonly_CustomCommandArgv struct + func (r *Readonly_CustomCommandArgv) CloneMessage() *CustomCommandArgv + func (r *Readonly_CustomCommandArgv) GetArg() []byte + func (r *Readonly_CustomCommandArgv) ReadonlyProtoReflect() innerFile_libatbus_protocol_protoReadonlyMessage + func (r *Readonly_CustomCommandArgv) ToMessage() *CustomCommandArgv + func (r Readonly_CustomCommandArgv) LogValue() slog.Value + type Readonly_CustomCommandData struct + func (r *Readonly_CustomCommandData) CloneMessage() *CustomCommandData + func (r *Readonly_CustomCommandData) GetAccessKey() *Readonly_AccessData + func (r *Readonly_CustomCommandData) GetCommands() []*Readonly_CustomCommandArgv + func (r *Readonly_CustomCommandData) GetFrom() uint64 + func (r *Readonly_CustomCommandData) ReadonlyProtoReflect() innerFile_libatbus_protocol_protoReadonlyMessage + func (r *Readonly_CustomCommandData) ToMessage() *CustomCommandData + func (r Readonly_CustomCommandData) LogValue() slog.Value + type Readonly_ForwardData struct + func (r *Readonly_ForwardData) CloneMessage() *ForwardData + func (r *Readonly_ForwardData) GetContent() []byte + func (r *Readonly_ForwardData) GetFlags() uint32 + func (r *Readonly_ForwardData) GetFrom() uint64 + func (r *Readonly_ForwardData) GetRouter() []uint64 + func (r *Readonly_ForwardData) GetTo() uint64 + func (r *Readonly_ForwardData) ReadonlyProtoReflect() innerFile_libatbus_protocol_protoReadonlyMessage + func (r *Readonly_ForwardData) ToMessage() *ForwardData + func (r Readonly_ForwardData) LogValue() slog.Value + type Readonly_MessageBody struct + func (r *Readonly_MessageBody) CloneMessage() *MessageBody + func (r *Readonly_MessageBody) GetCustomCommandReq() *Readonly_CustomCommandData + func (r *Readonly_MessageBody) GetCustomCommandRsp() *Readonly_CustomCommandData + func (r *Readonly_MessageBody) GetDataTransformReq() *Readonly_ForwardData + func (r *Readonly_MessageBody) GetDataTransformRsp() *Readonly_ForwardData + func (r *Readonly_MessageBody) GetMessageTypeOneofCase() MessageBody_EnMessageTypeID + func (r *Readonly_MessageBody) GetMessageTypeTypeID() lu.TypeID + func (r *Readonly_MessageBody) GetNodePingReq() *Readonly_PingData + func (r *Readonly_MessageBody) GetNodePongRsp() *Readonly_PingData + func (r *Readonly_MessageBody) GetNodeRegisterReq() *Readonly_RegisterData + func (r *Readonly_MessageBody) GetNodeRegisterRsp() *Readonly_RegisterData + func (r *Readonly_MessageBody) ReadonlyProtoReflect() innerFile_libatbus_protocol_protoReadonlyMessage + func (r *Readonly_MessageBody) ToMessage() *MessageBody + func (r Readonly_MessageBody) LogValue() slog.Value + type Readonly_MessageBody_CustomCommandReq struct + func (r *Readonly_MessageBody_CustomCommandReq) GetCustomCommandReq() *Readonly_CustomCommandData + func (r *Readonly_MessageBody_CustomCommandReq) GetMessageBody_MessageType() MessageBody_EnMessageTypeID + func (r *Readonly_MessageBody_CustomCommandReq) GetTypeIDMessageBody_MessageType() lu.TypeID + type Readonly_MessageBody_CustomCommandRsp struct + func (r *Readonly_MessageBody_CustomCommandRsp) GetCustomCommandRsp() *Readonly_CustomCommandData + func (r *Readonly_MessageBody_CustomCommandRsp) GetMessageBody_MessageType() MessageBody_EnMessageTypeID + func (r *Readonly_MessageBody_CustomCommandRsp) GetTypeIDMessageBody_MessageType() lu.TypeID + type Readonly_MessageBody_DataTransformReq struct + func (r *Readonly_MessageBody_DataTransformReq) GetDataTransformReq() *Readonly_ForwardData + func (r *Readonly_MessageBody_DataTransformReq) GetMessageBody_MessageType() MessageBody_EnMessageTypeID + func (r *Readonly_MessageBody_DataTransformReq) GetTypeIDMessageBody_MessageType() lu.TypeID + type Readonly_MessageBody_DataTransformRsp struct + func (r *Readonly_MessageBody_DataTransformRsp) GetDataTransformRsp() *Readonly_ForwardData + func (r *Readonly_MessageBody_DataTransformRsp) GetMessageBody_MessageType() MessageBody_EnMessageTypeID + func (r *Readonly_MessageBody_DataTransformRsp) GetTypeIDMessageBody_MessageType() lu.TypeID + type Readonly_MessageBody_NodePingReq struct + func (r *Readonly_MessageBody_NodePingReq) GetMessageBody_MessageType() MessageBody_EnMessageTypeID + func (r *Readonly_MessageBody_NodePingReq) GetNodePingReq() *Readonly_PingData + func (r *Readonly_MessageBody_NodePingReq) GetTypeIDMessageBody_MessageType() lu.TypeID + type Readonly_MessageBody_NodePongRsp struct + func (r *Readonly_MessageBody_NodePongRsp) GetMessageBody_MessageType() MessageBody_EnMessageTypeID + func (r *Readonly_MessageBody_NodePongRsp) GetNodePongRsp() *Readonly_PingData + func (r *Readonly_MessageBody_NodePongRsp) GetTypeIDMessageBody_MessageType() lu.TypeID + type Readonly_MessageBody_NodeRegisterReq struct + func (r *Readonly_MessageBody_NodeRegisterReq) GetMessageBody_MessageType() MessageBody_EnMessageTypeID + func (r *Readonly_MessageBody_NodeRegisterReq) GetNodeRegisterReq() *Readonly_RegisterData + func (r *Readonly_MessageBody_NodeRegisterReq) GetTypeIDMessageBody_MessageType() lu.TypeID + type Readonly_MessageBody_NodeRegisterRsp struct + func (r *Readonly_MessageBody_NodeRegisterRsp) GetMessageBody_MessageType() MessageBody_EnMessageTypeID + func (r *Readonly_MessageBody_NodeRegisterRsp) GetNodeRegisterRsp() *Readonly_RegisterData + func (r *Readonly_MessageBody_NodeRegisterRsp) GetTypeIDMessageBody_MessageType() lu.TypeID + type Readonly_MessageHead struct + func (r *Readonly_MessageHead) CloneMessage() *MessageHead + func (r *Readonly_MessageHead) GetBodySize() uint64 + func (r *Readonly_MessageHead) GetCompression() *Readonly_MessageHeadCompression + func (r *Readonly_MessageHead) GetCrypto() *Readonly_MessageHeadCrypto + func (r *Readonly_MessageHead) GetResultCode() int32 + func (r *Readonly_MessageHead) GetSequence() uint64 + func (r *Readonly_MessageHead) GetSourceBusId() uint64 + func (r *Readonly_MessageHead) GetType() int32 + func (r *Readonly_MessageHead) GetVersion() int32 + func (r *Readonly_MessageHead) ReadonlyProtoReflect() innerFile_libatbus_protocol_protoReadonlyMessage + func (r *Readonly_MessageHead) ToMessage() *MessageHead + func (r Readonly_MessageHead) LogValue() slog.Value + type Readonly_MessageHeadCompression struct + func (r *Readonly_MessageHeadCompression) CloneMessage() *MessageHeadCompression + func (r *Readonly_MessageHeadCompression) GetOriginalSize() uint64 + func (r *Readonly_MessageHeadCompression) GetType() ATBUS_COMPRESSION_ALGORITHM_TYPE + func (r *Readonly_MessageHeadCompression) ReadonlyProtoReflect() innerFile_libatbus_protocol_protoReadonlyMessage + func (r *Readonly_MessageHeadCompression) ToMessage() *MessageHeadCompression + func (r Readonly_MessageHeadCompression) LogValue() slog.Value + type Readonly_MessageHeadCrypto struct + func (r *Readonly_MessageHeadCrypto) CloneMessage() *MessageHeadCrypto + func (r *Readonly_MessageHeadCrypto) GetAad() []byte + func (r *Readonly_MessageHeadCrypto) GetAlgorithm() ATBUS_CRYPTO_ALGORITHM_TYPE + func (r *Readonly_MessageHeadCrypto) GetIv() []byte + func (r *Readonly_MessageHeadCrypto) ReadonlyProtoReflect() innerFile_libatbus_protocol_protoReadonlyMessage + func (r *Readonly_MessageHeadCrypto) ToMessage() *MessageHeadCrypto + func (r Readonly_MessageHeadCrypto) LogValue() slog.Value + type Readonly_PingData struct + func (r *Readonly_PingData) CloneMessage() *PingData + func (r *Readonly_PingData) GetCryptoHandshake() *Readonly_CryptoHandshakeData + func (r *Readonly_PingData) GetTimePoint() int64 + func (r *Readonly_PingData) ReadonlyProtoReflect() innerFile_libatbus_protocol_protoReadonlyMessage + func (r *Readonly_PingData) ToMessage() *PingData + func (r Readonly_PingData) LogValue() slog.Value + type Readonly_RegisterData struct + func (r *Readonly_RegisterData) CloneMessage() *RegisterData + func (r *Readonly_RegisterData) GetAccessKey() *Readonly_AccessData + func (r *Readonly_RegisterData) GetBusId() uint64 + func (r *Readonly_RegisterData) GetChannels() []*Readonly_ChannelData + func (r *Readonly_RegisterData) GetCryptoHandshake() *Readonly_CryptoHandshakeData + func (r *Readonly_RegisterData) GetFlags() uint32 + func (r *Readonly_RegisterData) GetHashCode() string + func (r *Readonly_RegisterData) GetHostname() string + func (r *Readonly_RegisterData) GetPid() int32 + func (r *Readonly_RegisterData) GetSupportedChannelSchema() []string + func (r *Readonly_RegisterData) GetSupportedCompressionAlgorithm() []ATBUS_COMPRESSION_ALGORITHM_TYPE + func (r *Readonly_RegisterData) ReadonlyProtoReflect() innerFile_libatbus_protocol_protoReadonlyMessage + func (r *Readonly_RegisterData) ToMessage() *RegisterData + func (r Readonly_RegisterData) LogValue() slog.Value + type RegisterData struct + AccessKey *AccessData + BusId uint64 + Channels []*ChannelData + CryptoHandshake *CryptoHandshakeData + Flags uint32 + HashCode string + Hostname string + Pid int32 + SupportedChannelSchema []string + SupportedCompressionAlgorithm []ATBUS_COMPRESSION_ALGORITHM_TYPE + func (*RegisterData) Descriptor() ([]byte, []int) + func (*RegisterData) ProtoMessage() + func (_ *RegisterData) GetTypeID() lu.TypeID + func (m *RegisterData) AddChannels() *ChannelData + func (m *RegisterData) AppendChannels(d *ChannelData) + func (m *RegisterData) AppendSupportedChannelSchema(d string) + func (m *RegisterData) AppendSupportedCompressionAlgorithm(d ATBUS_COMPRESSION_ALGORITHM_TYPE) + func (m *RegisterData) Clone() *RegisterData + func (m *RegisterData) LogValue() slog.Value + func (m *RegisterData) Merge(src *RegisterData) + func (m *RegisterData) MergeChannels(d []*ChannelData) []*ChannelData + func (m *RegisterData) MergeSupportedChannelSchema(d []string) []string + func (m *RegisterData) MergeSupportedCompressionAlgorithm(d []ATBUS_COMPRESSION_ALGORITHM_TYPE) []ATBUS_COMPRESSION_ALGORITHM_TYPE + func (m *RegisterData) MutableAccessKey() *AccessData + func (m *RegisterData) MutableChannels() []*ChannelData + func (m *RegisterData) MutableCryptoHandshake() *CryptoHandshakeData + func (m *RegisterData) MutableSupportedChannelSchema() []string + func (m *RegisterData) MutableSupportedCompressionAlgorithm() []ATBUS_COMPRESSION_ALGORITHM_TYPE + func (m *RegisterData) RemoveLastChannels() + func (m *RegisterData) RemoveLastSupportedChannelSchema() + func (m *RegisterData) RemoveLastSupportedCompressionAlgorithm() + func (m *RegisterData) ReverseIfNilChannels(l int32) []*ChannelData + func (m *RegisterData) ReverseIfNilSupportedChannelSchema(l int32) []string + func (m *RegisterData) ReverseIfNilSupportedCompressionAlgorithm(l int32) []ATBUS_COMPRESSION_ALGORITHM_TYPE + func (m *RegisterData) ToReadonly() *Readonly_RegisterData + func (x *RegisterData) GetAccessKey() *AccessData + func (x *RegisterData) GetBusId() uint64 + func (x *RegisterData) GetChannels() []*ChannelData + func (x *RegisterData) GetCryptoHandshake() *CryptoHandshakeData + func (x *RegisterData) GetFlags() uint32 + func (x *RegisterData) GetHashCode() string + func (x *RegisterData) GetHostname() string + func (x *RegisterData) GetPid() int32 + func (x *RegisterData) GetSupportedChannelSchema() []string + func (x *RegisterData) GetSupportedCompressionAlgorithm() []ATBUS_COMPRESSION_ALGORITHM_TYPE + func (x *RegisterData) ProtoReflect() protoreflect.Message + func (x *RegisterData) Reset() + func (x *RegisterData) String() string
Go to main page