protocol

package
v1.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 12, 2026 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ATBUS_PROTOCOL_CONST_name = map[int32]string{
		0: "ATBUS_PROTOCOL_CONST_UNKNOWN",
		3: "ATBUS_PROTOCOL_VERSION",
	}
	ATBUS_PROTOCOL_CONST_value = map[string]int32{
		"ATBUS_PROTOCOL_CONST_UNKNOWN":   0,
		"ATBUS_PROTOCOL_VERSION":         3,
		"ATBUS_PROTOCOL_MINIMAL_VERSION": 3,
	}
)

Enum value maps for ATBUS_PROTOCOL_CONST.

View Source 
var (
	ATBUS_FORWARD_DATA_FLAG_TYPE_name = map[int32]string{
		0: "FORWARD_DATA_FLAG_NONE",
		1: "FORWARD_DATA_FLAG_REQUIRE_RSP",
	}
	ATBUS_FORWARD_DATA_FLAG_TYPE_value = map[string]int32{
		"FORWARD_DATA_FLAG_NONE":        0,
		"FORWARD_DATA_FLAG_REQUIRE_RSP": 1,
	}
)

Enum value maps for ATBUS_FORWARD_DATA_FLAG_TYPE.

View Source 
var (
	ATBUS_ACCESS_DATA_ALGORITHM_TYPE_name = map[int32]string{
		0: "ATBUS_ACCESS_DATA_ALGORITHM_HMAC_SHA256",
	}
	ATBUS_ACCESS_DATA_ALGORITHM_TYPE_value = map[string]int32{
		"ATBUS_ACCESS_DATA_ALGORITHM_HMAC_SHA256": 0,
	}
)

Enum value maps for ATBUS_ACCESS_DATA_ALGORITHM_TYPE.

View Source 
var (
	ATBUS_CRYPTO_KDF_TYPE_name = map[int32]string{
		0: "ATBUS_CRYPTO_KDF_HKDF_SHA256",
	}
	ATBUS_CRYPTO_KDF_TYPE_value = map[string]int32{
		"ATBUS_CRYPTO_KDF_HKDF_SHA256": 0,
	}
)

Enum value maps for ATBUS_CRYPTO_KDF_TYPE.

View Source 
var (
	ATBUS_CRYPTO_ALGORITHM_TYPE_name = map[int32]string{
		0:  "ATBUS_CRYPTO_ALGORITHM_NONE",
		1:  "ATBUS_CRYPTO_ALGORITHM_XXTEA",
		11: "ATBUS_CRYPTO_ALGORITHM_AES_128_CBC",
		12: "ATBUS_CRYPTO_ALGORITHM_AES_192_CBC",
		13: "ATBUS_CRYPTO_ALGORITHM_AES_256_CBC",
		14: "ATBUS_CRYPTO_ALGORITHM_AES_128_GCM",
		15: "ATBUS_CRYPTO_ALGORITHM_AES_192_GCM",
		16: "ATBUS_CRYPTO_ALGORITHM_AES_256_GCM",
		31: "ATBUS_CRYPTO_ALGORITHM_CHACHA20",
		32: "ATBUS_CRYPTO_ALGORITHM_CHACHA20_POLY1305_IETF",
		33: "ATBUS_CRYPTO_ALGORITHM_XCHACHA20_POLY1305_IETF",
	}
	ATBUS_CRYPTO_ALGORITHM_TYPE_value = map[string]int32{
		"ATBUS_CRYPTO_ALGORITHM_NONE":                    0,
		"ATBUS_CRYPTO_ALGORITHM_XXTEA":                   1,
		"ATBUS_CRYPTO_ALGORITHM_AES_128_CBC":             11,
		"ATBUS_CRYPTO_ALGORITHM_AES_192_CBC":             12,
		"ATBUS_CRYPTO_ALGORITHM_AES_256_CBC":             13,
		"ATBUS_CRYPTO_ALGORITHM_AES_128_GCM":             14,
		"ATBUS_CRYPTO_ALGORITHM_AES_192_GCM":             15,
		"ATBUS_CRYPTO_ALGORITHM_AES_256_GCM":             16,
		"ATBUS_CRYPTO_ALGORITHM_CHACHA20":                31,
		"ATBUS_CRYPTO_ALGORITHM_CHACHA20_POLY1305_IETF":  32,
		"ATBUS_CRYPTO_ALGORITHM_XCHACHA20_POLY1305_IETF": 33,
	}
)

Enum value maps for ATBUS_CRYPTO_ALGORITHM_TYPE.

View Source 
var (
	ATBUS_CRYPTO_KEY_EXCHANGE_TYPE_name = map[int32]string{
		0: "ATBUS_CRYPTO_KEY_EXCHANGE_NONE",
		1: "ATBUS_CRYPTO_KEY_EXCHANGE_X25519",
		2: "ATBUS_CRYPTO_KEY_EXCHANGE_SECP256R1",
		3: "ATBUS_CRYPTO_KEY_EXCHANGE_SECP384R1",
		4: "ATBUS_CRYPTO_KEY_EXCHANGE_SECP521R1",
	}
	ATBUS_CRYPTO_KEY_EXCHANGE_TYPE_value = map[string]int32{
		"ATBUS_CRYPTO_KEY_EXCHANGE_NONE":      0,
		"ATBUS_CRYPTO_KEY_EXCHANGE_X25519":    1,
		"ATBUS_CRYPTO_KEY_EXCHANGE_SECP256R1": 2,
		"ATBUS_CRYPTO_KEY_EXCHANGE_SECP384R1": 3,
		"ATBUS_CRYPTO_KEY_EXCHANGE_SECP521R1": 4,
	}
)

Enum value maps for ATBUS_CRYPTO_KEY_EXCHANGE_TYPE.

View Source 
var (
	ATBUS_COMPRESSION_ALGORITHM_TYPE_name = map[int32]string{
		0:   "ATBUS_COMPRESSION_ALGORITHM_NONE",
		100: "ATBUS_COMPRESSION_ALGORITHM_ZSTD",
		200: "ATBUS_COMPRESSION_ALGORITHM_LZ4",
		300: "ATBUS_COMPRESSION_ALGORITHM_SNAPPY",
		400: "ATBUS_COMPRESSION_ALGORITHM_ZLIB",
	}
	ATBUS_COMPRESSION_ALGORITHM_TYPE_value = map[string]int32{
		"ATBUS_COMPRESSION_ALGORITHM_NONE":   0,
		"ATBUS_COMPRESSION_ALGORITHM_ZSTD":   100,
		"ATBUS_COMPRESSION_ALGORITHM_LZ4":    200,
		"ATBUS_COMPRESSION_ALGORITHM_SNAPPY": 300,
		"ATBUS_COMPRESSION_ALGORITHM_ZLIB":   400,
	}
)

Enum value maps for ATBUS_COMPRESSION_ALGORITHM_TYPE.

View Source 
var (
	ATBUS_COMPRESSION_LEVEL_name = map[int32]string{
		0:   "ATBUS_COMPRESSION_LEVEL_DEFAULT",
		100: "ATBUS_COMPRESSION_LEVEL_STORAGE",
		200: "ATBUS_COMPRESSION_LEVEL_FAST",
		300: "ATBUS_COMPRESSION_LEVEL_LOW_CPU",
		400: "ATBUS_COMPRESSION_LEVEL_BALANCED",
		500: "ATBUS_COMPRESSION_LEVEL_HIGH_RATIO",
		600: "ATBUS_COMPRESSION_LEVEL_MAX_RATIO",
	}
	ATBUS_COMPRESSION_LEVEL_value = map[string]int32{
		"ATBUS_COMPRESSION_LEVEL_DEFAULT":    0,
		"ATBUS_COMPRESSION_LEVEL_STORAGE":    100,
		"ATBUS_COMPRESSION_LEVEL_FAST":       200,
		"ATBUS_COMPRESSION_LEVEL_LOW_CPU":    300,
		"ATBUS_COMPRESSION_LEVEL_BALANCED":   400,
		"ATBUS_COMPRESSION_LEVEL_HIGH_RATIO": 500,
		"ATBUS_COMPRESSION_LEVEL_MAX_RATIO":  600,
	}
)

Enum value maps for ATBUS_COMPRESSION_LEVEL.

View Source 
var File_libatbus_protocol_proto protoreflect.FileDescriptor

Functions

func GetTypeIDMessageBody_CustomCommandReq 

func GetTypeIDMessageBody_CustomCommandReq() lu.TypeID

===== Get reflect Type for MessageBody Oneof MessageType ===== Oneof =====

func GetTypeIDMessageBody_CustomCommandRsp 

func GetTypeIDMessageBody_CustomCommandRsp() lu.TypeID

===== Get reflect Type for MessageBody Oneof MessageType ===== Oneof =====

func GetTypeIDMessageBody_DataTransformReq 

func GetTypeIDMessageBody_DataTransformReq() lu.TypeID

===== Get reflect Type for MessageBody Oneof MessageType ===== Oneof =====

func GetTypeIDMessageBody_DataTransformRsp 

func GetTypeIDMessageBody_DataTransformRsp() lu.TypeID

===== Get reflect Type for MessageBody Oneof MessageType ===== Oneof =====

func GetTypeIDMessageBody_NodePingReq 

func GetTypeIDMessageBody_NodePingReq() lu.TypeID

===== Get reflect Type for MessageBody Oneof MessageType ===== Oneof =====

func GetTypeIDMessageBody_NodePongRsp 

func GetTypeIDMessageBody_NodePongRsp() lu.TypeID

===== Get reflect Type for MessageBody Oneof MessageType ===== Oneof =====

func GetTypeIDMessageBody_NodeRegisterReq 

func GetTypeIDMessageBody_NodeRegisterReq() lu.TypeID

===== Get reflect Type for MessageBody Oneof MessageType ===== Oneof =====

func GetTypeIDMessageBody_NodeRegisterRsp 

func GetTypeIDMessageBody_NodeRegisterRsp() lu.TypeID

===== Get reflect Type for MessageBody Oneof MessageType ===== Oneof =====

Types

type ATBUS_ACCESS_DATA_ALGORITHM_TYPE 

type ATBUS_ACCESS_DATA_ALGORITHM_TYPE int32
const (
	ATBUS_ACCESS_DATA_ALGORITHM_TYPE_ATBUS_ACCESS_DATA_ALGORITHM_HMAC_SHA256 ATBUS_ACCESS_DATA_ALGORITHM_TYPE = 0
)

func (ATBUS_ACCESS_DATA_ALGORITHM_TYPE) Descriptor 

func (ATBUS_ACCESS_DATA_ALGORITHM_TYPE) Descriptor() protoreflect.EnumDescriptor

func (ATBUS_ACCESS_DATA_ALGORITHM_TYPE) Enum 

func (x ATBUS_ACCESS_DATA_ALGORITHM_TYPE) Enum() *ATBUS_ACCESS_DATA_ALGORITHM_TYPE

func (ATBUS_ACCESS_DATA_ALGORITHM_TYPE) EnumDescriptor deprecated 

func (ATBUS_ACCESS_DATA_ALGORITHM_TYPE) EnumDescriptor() ([]byte, []int)

Deprecated: Use ATBUS_ACCESS_DATA_ALGORITHM_TYPE.Descriptor instead.

func (ATBUS_ACCESS_DATA_ALGORITHM_TYPE) Number 

func (x ATBUS_ACCESS_DATA_ALGORITHM_TYPE) Number() protoreflect.EnumNumber

func (ATBUS_ACCESS_DATA_ALGORITHM_TYPE) String 

func (x ATBUS_ACCESS_DATA_ALGORITHM_TYPE) String() string

func (ATBUS_ACCESS_DATA_ALGORITHM_TYPE) Type 

func (ATBUS_ACCESS_DATA_ALGORITHM_TYPE) Type() protoreflect.EnumType

type ATBUS_COMPRESSION_ALGORITHM_TYPE 

type ATBUS_COMPRESSION_ALGORITHM_TYPE int32
const (
	ATBUS_COMPRESSION_ALGORITHM_TYPE_ATBUS_COMPRESSION_ALGORITHM_NONE   ATBUS_COMPRESSION_ALGORITHM_TYPE = 0
	ATBUS_COMPRESSION_ALGORITHM_TYPE_ATBUS_COMPRESSION_ALGORITHM_ZSTD   ATBUS_COMPRESSION_ALGORITHM_TYPE = 100
	ATBUS_COMPRESSION_ALGORITHM_TYPE_ATBUS_COMPRESSION_ALGORITHM_LZ4    ATBUS_COMPRESSION_ALGORITHM_TYPE = 200
	ATBUS_COMPRESSION_ALGORITHM_TYPE_ATBUS_COMPRESSION_ALGORITHM_SNAPPY ATBUS_COMPRESSION_ALGORITHM_TYPE = 300
	ATBUS_COMPRESSION_ALGORITHM_TYPE_ATBUS_COMPRESSION_ALGORITHM_ZLIB   ATBUS_COMPRESSION_ALGORITHM_TYPE = 400
)

func (ATBUS_COMPRESSION_ALGORITHM_TYPE) Descriptor 

func (ATBUS_COMPRESSION_ALGORITHM_TYPE) Descriptor() protoreflect.EnumDescriptor

func (ATBUS_COMPRESSION_ALGORITHM_TYPE) Enum 

func (x ATBUS_COMPRESSION_ALGORITHM_TYPE) Enum() *ATBUS_COMPRESSION_ALGORITHM_TYPE

func (ATBUS_COMPRESSION_ALGORITHM_TYPE) EnumDescriptor deprecated 

func (ATBUS_COMPRESSION_ALGORITHM_TYPE) EnumDescriptor() ([]byte, []int)

Deprecated: Use ATBUS_COMPRESSION_ALGORITHM_TYPE.Descriptor instead.

func (ATBUS_COMPRESSION_ALGORITHM_TYPE) Number 

func (x ATBUS_COMPRESSION_ALGORITHM_TYPE) Number() protoreflect.EnumNumber

func (ATBUS_COMPRESSION_ALGORITHM_TYPE) String 

func (x ATBUS_COMPRESSION_ALGORITHM_TYPE) String() string

func (ATBUS_COMPRESSION_ALGORITHM_TYPE) Type 

func (ATBUS_COMPRESSION_ALGORITHM_TYPE) Type() protoreflect.EnumType

type ATBUS_COMPRESSION_LEVEL 

type ATBUS_COMPRESSION_LEVEL int32

统一压缩等级定义，用于抽象不同压缩算法的压缩强度。 枚举值表达语义等级，具体算法参数由实现层映射。 

const (
	// 默认值：使用各压缩算法的默认推荐配置
	//
	// 典型映射：
	//
	//	zstd   : level 3
	//	lz4    : fast 默认
	//	snappy : 默认配置
	//	zlib   : level 6
	ATBUS_COMPRESSION_LEVEL_ATBUS_COMPRESSION_LEVEL_DEFAULT ATBUS_COMPRESSION_LEVEL = 0
	// 存储优先：最低 CPU 开销，允许不压缩直接存储
	//
	// 典型映射：
	//
	//	zstd   : level -1
	//	lz4    : fast(1)
	//	snappy : 默认配置
	//	zlib   : level 1
	//	none   : 不压缩
	ATBUS_COMPRESSION_LEVEL_ATBUS_COMPRESSION_LEVEL_STORAGE ATBUS_COMPRESSION_LEVEL = 100
	// 极速压缩，强调最低 CPU 与延迟
	//
	// 典型映射：
	//
	//	zstd   : level -1
	//	lz4    : fast(1)
	//	snappy : 默认配置
	//	zlib   : level 1
	ATBUS_COMPRESSION_LEVEL_ATBUS_COMPRESSION_LEVEL_FAST ATBUS_COMPRESSION_LEVEL = 200
	// 低 CPU 开销压缩，在性能与压缩率之间轻度折中
	//
	// 典型映射：
	//
	//	zstd   : level 1
	//	lz4    : fast(3)
	//	zlib   : level 3
	ATBUS_COMPRESSION_LEVEL_ATBUS_COMPRESSION_LEVEL_LOW_CPU ATBUS_COMPRESSION_LEVEL = 300
	// 均衡压缩，作为系统推荐的通用等级
	//
	// 典型映射：
	//
	//	zstd   : level 3
	//	lz4    : fast(6)
	//	zlib   : level 6
	ATBUS_COMPRESSION_LEVEL_ATBUS_COMPRESSION_LEVEL_BALANCED ATBUS_COMPRESSION_LEVEL = 400
	// 高压缩率，存储优先，允许较高 CPU 成本
	//
	// 典型映射：
	//
	//	zstd   : level 6
	//	lz4    : hc(9)
	//	zlib   : level 9
	ATBUS_COMPRESSION_LEVEL_ATBUS_COMPRESSION_LEVEL_HIGH_RATIO ATBUS_COMPRESSION_LEVEL = 500
	// 极限压缩，仅适用于冷数据或离线场景
	//
	// 典型映射：
	//
	//	zstd   : level 9 ~ 15
	ATBUS_COMPRESSION_LEVEL_ATBUS_COMPRESSION_LEVEL_MAX_RATIO ATBUS_COMPRESSION_LEVEL = 600
)

func (ATBUS_COMPRESSION_LEVEL) Descriptor 

func (ATBUS_COMPRESSION_LEVEL) Descriptor() protoreflect.EnumDescriptor

func (ATBUS_COMPRESSION_LEVEL) Enum 

func (x ATBUS_COMPRESSION_LEVEL) Enum() *ATBUS_COMPRESSION_LEVEL

func (ATBUS_COMPRESSION_LEVEL) EnumDescriptor deprecated 

func (ATBUS_COMPRESSION_LEVEL) EnumDescriptor() ([]byte, []int)

Deprecated: Use ATBUS_COMPRESSION_LEVEL.Descriptor instead.

func (ATBUS_COMPRESSION_LEVEL) Number 

func (x ATBUS_COMPRESSION_LEVEL) Number() protoreflect.EnumNumber

func (ATBUS_COMPRESSION_LEVEL) String 

func (x ATBUS_COMPRESSION_LEVEL) String() string

func (ATBUS_COMPRESSION_LEVEL) Type 

func (ATBUS_COMPRESSION_LEVEL) Type() protoreflect.EnumType

type ATBUS_CRYPTO_ALGORITHM_TYPE 

type ATBUS_CRYPTO_ALGORITHM_TYPE int32
const (
	ATBUS_CRYPTO_ALGORITHM_TYPE_ATBUS_CRYPTO_ALGORITHM_NONE                    ATBUS_CRYPTO_ALGORITHM_TYPE = 0
	ATBUS_CRYPTO_ALGORITHM_TYPE_ATBUS_CRYPTO_ALGORITHM_XXTEA                   ATBUS_CRYPTO_ALGORITHM_TYPE = 1
	ATBUS_CRYPTO_ALGORITHM_TYPE_ATBUS_CRYPTO_ALGORITHM_AES_128_CBC             ATBUS_CRYPTO_ALGORITHM_TYPE = 11 // PKCS#7
	ATBUS_CRYPTO_ALGORITHM_TYPE_ATBUS_CRYPTO_ALGORITHM_AES_192_CBC             ATBUS_CRYPTO_ALGORITHM_TYPE = 12 // PKCS#7
	ATBUS_CRYPTO_ALGORITHM_TYPE_ATBUS_CRYPTO_ALGORITHM_AES_256_CBC             ATBUS_CRYPTO_ALGORITHM_TYPE = 13 // PKCS#7
	ATBUS_CRYPTO_ALGORITHM_TYPE_ATBUS_CRYPTO_ALGORITHM_AES_128_GCM             ATBUS_CRYPTO_ALGORITHM_TYPE = 14 // AEAD
	ATBUS_CRYPTO_ALGORITHM_TYPE_ATBUS_CRYPTO_ALGORITHM_AES_192_GCM             ATBUS_CRYPTO_ALGORITHM_TYPE = 15 // AEAD
	ATBUS_CRYPTO_ALGORITHM_TYPE_ATBUS_CRYPTO_ALGORITHM_AES_256_GCM             ATBUS_CRYPTO_ALGORITHM_TYPE = 16 // AEAD
	ATBUS_CRYPTO_ALGORITHM_TYPE_ATBUS_CRYPTO_ALGORITHM_CHACHA20                ATBUS_CRYPTO_ALGORITHM_TYPE = 31
	ATBUS_CRYPTO_ALGORITHM_TYPE_ATBUS_CRYPTO_ALGORITHM_CHACHA20_POLY1305_IETF  ATBUS_CRYPTO_ALGORITHM_TYPE = 32 // AEAD
	ATBUS_CRYPTO_ALGORITHM_TYPE_ATBUS_CRYPTO_ALGORITHM_XCHACHA20_POLY1305_IETF ATBUS_CRYPTO_ALGORITHM_TYPE = 33 // AEAD
)

func (ATBUS_CRYPTO_ALGORITHM_TYPE) Descriptor 

func (ATBUS_CRYPTO_ALGORITHM_TYPE) Descriptor() protoreflect.EnumDescriptor

func (ATBUS_CRYPTO_ALGORITHM_TYPE) Enum 

func (x ATBUS_CRYPTO_ALGORITHM_TYPE) Enum() *ATBUS_CRYPTO_ALGORITHM_TYPE

func (ATBUS_CRYPTO_ALGORITHM_TYPE) EnumDescriptor deprecated 

func (ATBUS_CRYPTO_ALGORITHM_TYPE) EnumDescriptor() ([]byte, []int)

Deprecated: Use ATBUS_CRYPTO_ALGORITHM_TYPE.Descriptor instead.

func (ATBUS_CRYPTO_ALGORITHM_TYPE) Number 

func (x ATBUS_CRYPTO_ALGORITHM_TYPE) Number() protoreflect.EnumNumber

func (ATBUS_CRYPTO_ALGORITHM_TYPE) String 

func (x ATBUS_CRYPTO_ALGORITHM_TYPE) String() string

func (ATBUS_CRYPTO_ALGORITHM_TYPE) Type 

func (ATBUS_CRYPTO_ALGORITHM_TYPE) Type() protoreflect.EnumType

type ATBUS_CRYPTO_KDF_TYPE 

type ATBUS_CRYPTO_KDF_TYPE int32
const (
	ATBUS_CRYPTO_KDF_TYPE_ATBUS_CRYPTO_KDF_HKDF_SHA256 ATBUS_CRYPTO_KDF_TYPE = 0
)

func (ATBUS_CRYPTO_KDF_TYPE) Descriptor 

func (ATBUS_CRYPTO_KDF_TYPE) Descriptor() protoreflect.EnumDescriptor

func (ATBUS_CRYPTO_KDF_TYPE) Enum 

func (x ATBUS_CRYPTO_KDF_TYPE) Enum() *ATBUS_CRYPTO_KDF_TYPE

func (ATBUS_CRYPTO_KDF_TYPE) EnumDescriptor deprecated 

func (ATBUS_CRYPTO_KDF_TYPE) EnumDescriptor() ([]byte, []int)

Deprecated: Use ATBUS_CRYPTO_KDF_TYPE.Descriptor instead.

func (ATBUS_CRYPTO_KDF_TYPE) Number 

func (x ATBUS_CRYPTO_KDF_TYPE) Number() protoreflect.EnumNumber

func (ATBUS_CRYPTO_KDF_TYPE) String 

func (x ATBUS_CRYPTO_KDF_TYPE) String() string

func (ATBUS_CRYPTO_KDF_TYPE) Type 

func (ATBUS_CRYPTO_KDF_TYPE) Type() protoreflect.EnumType

type ATBUS_CRYPTO_KEY_EXCHANGE_TYPE 

type ATBUS_CRYPTO_KEY_EXCHANGE_TYPE int32
const (
	ATBUS_CRYPTO_KEY_EXCHANGE_TYPE_ATBUS_CRYPTO_KEY_EXCHANGE_NONE ATBUS_CRYPTO_KEY_EXCHANGE_TYPE = 0
	// golang 标准库只支持ECDH
	ATBUS_CRYPTO_KEY_EXCHANGE_TYPE_ATBUS_CRYPTO_KEY_EXCHANGE_X25519    ATBUS_CRYPTO_KEY_EXCHANGE_TYPE = 1 // x25519(TLS 1.3推荐)
	ATBUS_CRYPTO_KEY_EXCHANGE_TYPE_ATBUS_CRYPTO_KEY_EXCHANGE_SECP256R1 ATBUS_CRYPTO_KEY_EXCHANGE_TYPE = 2 // secp256r1, p-256
	ATBUS_CRYPTO_KEY_EXCHANGE_TYPE_ATBUS_CRYPTO_KEY_EXCHANGE_SECP384R1 ATBUS_CRYPTO_KEY_EXCHANGE_TYPE = 3 // secp384r1, p-384
	ATBUS_CRYPTO_KEY_EXCHANGE_TYPE_ATBUS_CRYPTO_KEY_EXCHANGE_SECP521R1 ATBUS_CRYPTO_KEY_EXCHANGE_TYPE = 4 // secp521r1, p-521
)

func (ATBUS_CRYPTO_KEY_EXCHANGE_TYPE) Descriptor 

func (ATBUS_CRYPTO_KEY_EXCHANGE_TYPE) Descriptor() protoreflect.EnumDescriptor

func (ATBUS_CRYPTO_KEY_EXCHANGE_TYPE) Enum 

func (x ATBUS_CRYPTO_KEY_EXCHANGE_TYPE) Enum() *ATBUS_CRYPTO_KEY_EXCHANGE_TYPE

func (ATBUS_CRYPTO_KEY_EXCHANGE_TYPE) EnumDescriptor deprecated 

func (ATBUS_CRYPTO_KEY_EXCHANGE_TYPE) EnumDescriptor() ([]byte, []int)

Deprecated: Use ATBUS_CRYPTO_KEY_EXCHANGE_TYPE.Descriptor instead.

func (ATBUS_CRYPTO_KEY_EXCHANGE_TYPE) Number 

func (x ATBUS_CRYPTO_KEY_EXCHANGE_TYPE) Number() protoreflect.EnumNumber

func (ATBUS_CRYPTO_KEY_EXCHANGE_TYPE) String 

func (x ATBUS_CRYPTO_KEY_EXCHANGE_TYPE) String() string

func (ATBUS_CRYPTO_KEY_EXCHANGE_TYPE) Type 

func (ATBUS_CRYPTO_KEY_EXCHANGE_TYPE) Type() protoreflect.EnumType

type ATBUS_FORWARD_DATA_FLAG_TYPE 

type ATBUS_FORWARD_DATA_FLAG_TYPE int32
const (
	ATBUS_FORWARD_DATA_FLAG_TYPE_FORWARD_DATA_FLAG_NONE ATBUS_FORWARD_DATA_FLAG_TYPE = 0
	// all flags must be power of 2
	ATBUS_FORWARD_DATA_FLAG_TYPE_FORWARD_DATA_FLAG_REQUIRE_RSP ATBUS_FORWARD_DATA_FLAG_TYPE = 1
)

func (ATBUS_FORWARD_DATA_FLAG_TYPE) Descriptor 

func (ATBUS_FORWARD_DATA_FLAG_TYPE) Descriptor() protoreflect.EnumDescriptor

func (ATBUS_FORWARD_DATA_FLAG_TYPE) Enum 

func (x ATBUS_FORWARD_DATA_FLAG_TYPE) Enum() *ATBUS_FORWARD_DATA_FLAG_TYPE

func (ATBUS_FORWARD_DATA_FLAG_TYPE) EnumDescriptor deprecated 

func (ATBUS_FORWARD_DATA_FLAG_TYPE) EnumDescriptor() ([]byte, []int)

Deprecated: Use ATBUS_FORWARD_DATA_FLAG_TYPE.Descriptor instead.

func (ATBUS_FORWARD_DATA_FLAG_TYPE) Number 

func (x ATBUS_FORWARD_DATA_FLAG_TYPE) Number() protoreflect.EnumNumber

func (ATBUS_FORWARD_DATA_FLAG_TYPE) String 

func (x ATBUS_FORWARD_DATA_FLAG_TYPE) String() string

func (ATBUS_FORWARD_DATA_FLAG_TYPE) Type 

func (ATBUS_FORWARD_DATA_FLAG_TYPE) Type() protoreflect.EnumType

type ATBUS_PROTOCOL_CONST 

type ATBUS_PROTOCOL_CONST int32
const (
	ATBUS_PROTOCOL_CONST_ATBUS_PROTOCOL_CONST_UNKNOWN   ATBUS_PROTOCOL_CONST = 0
	ATBUS_PROTOCOL_CONST_ATBUS_PROTOCOL_VERSION         ATBUS_PROTOCOL_CONST = 3
	ATBUS_PROTOCOL_CONST_ATBUS_PROTOCOL_MINIMAL_VERSION ATBUS_PROTOCOL_CONST = 3 // minimal protocol version supported
)

func (ATBUS_PROTOCOL_CONST) Descriptor 

func (ATBUS_PROTOCOL_CONST) Descriptor() protoreflect.EnumDescriptor

func (ATBUS_PROTOCOL_CONST) Enum 

func (x ATBUS_PROTOCOL_CONST) Enum() *ATBUS_PROTOCOL_CONST

func (ATBUS_PROTOCOL_CONST) EnumDescriptor deprecated 

func (ATBUS_PROTOCOL_CONST) EnumDescriptor() ([]byte, []int)

Deprecated: Use ATBUS_PROTOCOL_CONST.Descriptor instead.

func (ATBUS_PROTOCOL_CONST) Number 

func (x ATBUS_PROTOCOL_CONST) Number() protoreflect.EnumNumber

func (ATBUS_PROTOCOL_CONST) String 

func (x ATBUS_PROTOCOL_CONST) String() string

func (ATBUS_PROTOCOL_CONST) Type 

func (ATBUS_PROTOCOL_CONST) Type() protoreflect.EnumType

type AccessData 

type AccessData struct {
	Algorithm ATBUS_ACCESS_DATA_ALGORITHM_TYPE ``                                                                         /* 137-byte string literal not displayed */
	Timestamp int64                            `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // unix timestamp
	// 128bits nonce is enough
	// - TLS 1.3: 96 bits
	// - IPSec:   64 bits
	// - JWT:     128 bits
	// - UUID v4: 128 bits
	Nonce1 uint64 `protobuf:"varint,3,opt,name=nonce1,proto3" json:"nonce1,omitempty"` // random
	Nonce2 uint64 `protobuf:"varint,4,opt,name=nonce2,proto3" json:"nonce2,omitempty"` // random
	// access_token="<timestamp>:<nonce1>-<nonce2>:<register_data.bus_id>:{register_data.crypto_handshake.type}:{hex(sha256_lower_case(register_data.crypto_handshake.public_key))}"
	// access_token="<timestamp>:<nonce1>-<nonce2>:<register_data.bus_id>" (without encryption)
	// access_token="<timestamp>:<nonce1>-<nonce2>:<custom_command_data.from>:{hex(sha256_lower_case(custom_command_data.commands.arg))}"
	// abs(timestamp-current time)<=300
	// access_token must be lower than 32KB
	// signature=HMAC.sha256(access_token)
	// 通过配置 access_token 并在节点注册和自定义命令中验证 access_data 来防止中间人攻击和重放攻击
	Signature [][]byte `protobuf:"bytes,9,rep,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*AccessData) AppendSignature 

func (m *AccessData) AppendSignature(d []byte)

===== Append methods for AccessData ===== Repeated =====

func (*AccessData) Clone 

func (m *AccessData) Clone() *AccessData

===== Clone methods for AccessData ===== Message ====

func (*AccessData) Descriptor deprecated 

func (*AccessData) Descriptor() ([]byte, []int)

Deprecated: Use AccessData.ProtoReflect.Descriptor instead.

func (*AccessData) GetAlgorithm 

func (x *AccessData) GetAlgorithm() ATBUS_ACCESS_DATA_ALGORITHM_TYPE

func (*AccessData) GetNonce1 

func (x *AccessData) GetNonce1() uint64

func (*AccessData) GetNonce2 

func (x *AccessData) GetNonce2() uint64

func (*AccessData) GetSignature 

func (x *AccessData) GetSignature() [][]byte

func (*AccessData) GetTimestamp 

func (x *AccessData) GetTimestamp() int64

func (*AccessData) GetTypeID 

func (_ *AccessData) GetTypeID() lu.TypeID

===== GetMessageReflectType methods for AccessData ===== Message =====

func (*AccessData) LogValue 

func (m *AccessData) LogValue() slog.Value

===== SlogValue methods for AccessData ===== Message ====

func (*AccessData) Merge 

func (m *AccessData) Merge(src *AccessData)

===== Merge methods for AccessData ===== Message ====

func (*AccessData) MergeSignature 

func (m *AccessData) MergeSignature(d [][]byte) [][]byte

===== Merge methods for AccessData ===== Repeated =====

func (*AccessData) MutableSignature 

func (m *AccessData) MutableSignature() [][]byte

===== Mutable methods for AccessData ===== Repeated =====

func (*AccessData) ProtoMessage 

func (*AccessData) ProtoMessage()

func (*AccessData) ProtoReflect 

func (x *AccessData) ProtoReflect() protoreflect.Message

func (*AccessData) RemoveLastSignature 

func (m *AccessData) RemoveLastSignature()

===== RemoveLast methods for AccessData ===== Repeated =====

func (*AccessData) Reset 

func (x *AccessData) Reset()

func (*AccessData) ReverseIfNilSignature 

func (m *AccessData) ReverseIfNilSignature(l int32) [][]byte

===== ReverseIfNil methods for AccessData ===== Repeated =====

func (*AccessData) String 

func (x *AccessData) String() string

func (*AccessData) ToReadonly 

func (m *AccessData) ToReadonly() *Readonly_AccessData

type ChannelData 

type ChannelData struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*ChannelData) Clone 

func (m *ChannelData) Clone() *ChannelData

===== Clone methods for ChannelData ===== Message ====

func (*ChannelData) Descriptor deprecated 

func (*ChannelData) Descriptor() ([]byte, []int)

Deprecated: Use ChannelData.ProtoReflect.Descriptor instead.

func (*ChannelData) GetAddress 

func (x *ChannelData) GetAddress() string

func (*ChannelData) GetTypeID 

func (_ *ChannelData) GetTypeID() lu.TypeID

===== GetMessageReflectType methods for ChannelData ===== Message =====

func (*ChannelData) LogValue 

func (m *ChannelData) LogValue() slog.Value

===== SlogValue methods for ChannelData ===== Message ====

func (*ChannelData) Merge 

func (m *ChannelData) Merge(src *ChannelData)

===== Merge methods for ChannelData ===== Message ====

func (*ChannelData) ProtoMessage 

func (*ChannelData) ProtoMessage()

func (*ChannelData) ProtoReflect 

func (x *ChannelData) ProtoReflect() protoreflect.Message

func (*ChannelData) Reset 

func (x *ChannelData) Reset()

func (*ChannelData) String 

func (x *ChannelData) String() string

func (*ChannelData) ToReadonly 

func (m *ChannelData) ToReadonly() *Readonly_ChannelData

type CryptoHandshakeData 

type CryptoHandshakeData struct {
	Sequence   uint64                         `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"` // used to prevent duplication
	Type       ATBUS_CRYPTO_KEY_EXCHANGE_TYPE `protobuf:"varint,2,opt,name=type,proto3,enum=atframework.atbus.protocol.ATBUS_CRYPTO_KEY_EXCHANGE_TYPE" json:"type,omitempty"`
	KdfType    []ATBUS_CRYPTO_KDF_TYPE        `` /* 144-byte string literal not displayed */
	Algorithms []ATBUS_CRYPTO_ALGORITHM_TYPE  `` // available cryptographic algorithms
	/* 141-byte string literal not displayed */
	// golang 标准库接口不支持生成 TLS 1.2 ECDHE ServerKeyExchange 结构
	// 为了兼容性我们采用 ATBUS_CRYPTO_KEY_EXCHANGE_TYPE 字段标识密钥交换类型，两边配置一致
	// 要求跨语言、跨加密库时需要保证算法都受到支持。
	// 密钥生成算法:
	//   - ATBUS_CRYPTO_KDF_HKDF_SHA256 -> HKDF(sha256(), shared_secret, nil, nil)
	//   - 内容: [KEY][IV]
	PublicKey []byte `protobuf:"bytes,5,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	// 初始iv size for crypto, must be same as the selected algorithm requirement
	IvSize uint32 `protobuf:"varint,11,opt,name=iv_size,json=ivSize,proto3" json:"iv_size,omitempty"`
	// tag length for AEAD
	TagSize uint32 `protobuf:"varint,21,opt,name=tag_size,json=tagSize,proto3" json:"tag_size,omitempty"`
	// contains filtered or unexported fields
}

func (*CryptoHandshakeData) AppendAlgorithms 

func (m *CryptoHandshakeData) AppendAlgorithms(d ATBUS_CRYPTO_ALGORITHM_TYPE)

===== Append methods for CryptoHandshakeData ===== Repeated =====

func (*CryptoHandshakeData) AppendKdfType 

func (m *CryptoHandshakeData) AppendKdfType(d ATBUS_CRYPTO_KDF_TYPE)

===== Append methods for CryptoHandshakeData ===== Repeated =====

func (*CryptoHandshakeData) Clone 

func (m *CryptoHandshakeData) Clone() *CryptoHandshakeData

===== Clone methods for CryptoHandshakeData ===== Message ====

func (*CryptoHandshakeData) Descriptor deprecated 

func (*CryptoHandshakeData) Descriptor() ([]byte, []int)

Deprecated: Use CryptoHandshakeData.ProtoReflect.Descriptor instead.

func (*CryptoHandshakeData) GetAlgorithms 

func (x *CryptoHandshakeData) GetAlgorithms() []ATBUS_CRYPTO_ALGORITHM_TYPE

func (*CryptoHandshakeData) GetIvSize 

func (x *CryptoHandshakeData) GetIvSize() uint32

func (*CryptoHandshakeData) GetKdfType 

func (x *CryptoHandshakeData) GetKdfType() []ATBUS_CRYPTO_KDF_TYPE

func (*CryptoHandshakeData) GetPublicKey 

func (x *CryptoHandshakeData) GetPublicKey() []byte

func (*CryptoHandshakeData) GetSequence 

func (x *CryptoHandshakeData) GetSequence() uint64

func (*CryptoHandshakeData) GetTagSize 

func (x *CryptoHandshakeData) GetTagSize() uint32

func (*CryptoHandshakeData) GetType 

func (x *CryptoHandshakeData) GetType() ATBUS_CRYPTO_KEY_EXCHANGE_TYPE

func (*CryptoHandshakeData) GetTypeID 

func (_ *CryptoHandshakeData) GetTypeID() lu.TypeID

===== GetMessageReflectType methods for CryptoHandshakeData ===== Message =====

func (*CryptoHandshakeData) LogValue 

func (m *CryptoHandshakeData) LogValue() slog.Value

===== SlogValue methods for CryptoHandshakeData ===== Message ====

func (*CryptoHandshakeData) Merge 

func (m *CryptoHandshakeData) Merge(src *CryptoHandshakeData)

===== Merge methods for CryptoHandshakeData ===== Message ====

func (*CryptoHandshakeData) MergeAlgorithms 

func (m *CryptoHandshakeData) MergeAlgorithms(d []ATBUS_CRYPTO_ALGORITHM_TYPE) []ATBUS_CRYPTO_ALGORITHM_TYPE

===== Merge methods for CryptoHandshakeData ===== Repeated =====

func (*CryptoHandshakeData) MergeKdfType 

func (m *CryptoHandshakeData) MergeKdfType(d []ATBUS_CRYPTO_KDF_TYPE) []ATBUS_CRYPTO_KDF_TYPE

===== Merge methods for CryptoHandshakeData ===== Repeated =====

func (*CryptoHandshakeData) MutableAlgorithms 

func (m *CryptoHandshakeData) MutableAlgorithms() []ATBUS_CRYPTO_ALGORITHM_TYPE

===== Mutable methods for CryptoHandshakeData ===== Repeated =====

func (*CryptoHandshakeData) MutableKdfType 

func (m *CryptoHandshakeData) MutableKdfType() []ATBUS_CRYPTO_KDF_TYPE

===== Mutable methods for CryptoHandshakeData ===== Repeated =====

func (*CryptoHandshakeData) ProtoMessage 

func (*CryptoHandshakeData) ProtoMessage()

func (*CryptoHandshakeData) ProtoReflect 

func (x *CryptoHandshakeData) ProtoReflect() protoreflect.Message

func (*CryptoHandshakeData) RemoveLastAlgorithms 

func (m *CryptoHandshakeData) RemoveLastAlgorithms()

===== RemoveLast methods for CryptoHandshakeData ===== Repeated =====

func (*CryptoHandshakeData) RemoveLastKdfType 

func (m *CryptoHandshakeData) RemoveLastKdfType()

===== RemoveLast methods for CryptoHandshakeData ===== Repeated =====

func (*CryptoHandshakeData) Reset 

func (x *CryptoHandshakeData) Reset()

func (*CryptoHandshakeData) ReverseIfNilAlgorithms 

func (m *CryptoHandshakeData) ReverseIfNilAlgorithms(l int32) []ATBUS_CRYPTO_ALGORITHM_TYPE

===== ReverseIfNil methods for CryptoHandshakeData ===== Repeated =====

func (*CryptoHandshakeData) ReverseIfNilKdfType 

func (m *CryptoHandshakeData) ReverseIfNilKdfType(l int32) []ATBUS_CRYPTO_KDF_TYPE

===== ReverseIfNil methods for CryptoHandshakeData ===== Repeated =====

func (*CryptoHandshakeData) String 

func (x *CryptoHandshakeData) String() string

func (*CryptoHandshakeData) ToReadonly 

func (m *CryptoHandshakeData) ToReadonly() *Readonly_CryptoHandshakeData

type CustomCommandArgv 

type CustomCommandArgv struct {
	Arg []byte `protobuf:"bytes,1,opt,name=arg,proto3" json:"arg,omitempty"`
	// contains filtered or unexported fields
}

func (*CustomCommandArgv) Clone 

func (m *CustomCommandArgv) Clone() *CustomCommandArgv

===== Clone methods for CustomCommandArgv ===== Message ====

func (*CustomCommandArgv) Descriptor deprecated 

func (*CustomCommandArgv) Descriptor() ([]byte, []int)

Deprecated: Use CustomCommandArgv.ProtoReflect.Descriptor instead.

func (*CustomCommandArgv) GetArg 

func (x *CustomCommandArgv) GetArg() []byte

func (*CustomCommandArgv) GetTypeID 

func (_ *CustomCommandArgv) GetTypeID() lu.TypeID

===== GetMessageReflectType methods for CustomCommandArgv ===== Message =====

func (*CustomCommandArgv) LogValue 

func (m *CustomCommandArgv) LogValue() slog.Value

===== SlogValue methods for CustomCommandArgv ===== Message ====

func (*CustomCommandArgv) Merge 

func (m *CustomCommandArgv) Merge(src *CustomCommandArgv)

===== Merge methods for CustomCommandArgv ===== Message ====

func (*CustomCommandArgv) ProtoMessage 

func (*CustomCommandArgv) ProtoMessage()

func (*CustomCommandArgv) ProtoReflect 

func (x *CustomCommandArgv) ProtoReflect() protoreflect.Message

func (*CustomCommandArgv) Reset 

func (x *CustomCommandArgv) Reset()

func (*CustomCommandArgv) String 

func (x *CustomCommandArgv) String() string

func (*CustomCommandArgv) ToReadonly 

func (m *CustomCommandArgv) ToReadonly() *Readonly_CustomCommandArgv

type CustomCommandData 

type CustomCommandData struct {
	From      uint64               `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"`
	Commands  []*CustomCommandArgv `protobuf:"bytes,2,rep,name=commands,proto3" json:"commands,omitempty"`
	AccessKey *AccessData          `protobuf:"bytes,3,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
	// contains filtered or unexported fields
}

func (*CustomCommandData) AddCommands 

func (m *CustomCommandData) AddCommands() *CustomCommandArgv

===== Add methods for CustomCommandData ===== Repeated =====

func (*CustomCommandData) AppendCommands 

func (m *CustomCommandData) AppendCommands(d *CustomCommandArgv)

===== Append methods for CustomCommandData ===== Repeated =====

func (*CustomCommandData) Clone 

func (m *CustomCommandData) Clone() *CustomCommandData

===== Clone methods for CustomCommandData ===== Message ====

func (*CustomCommandData) Descriptor deprecated 

func (*CustomCommandData) Descriptor() ([]byte, []int)

Deprecated: Use CustomCommandData.ProtoReflect.Descriptor instead.

func (*CustomCommandData) GetAccessKey 

func (x *CustomCommandData) GetAccessKey() *AccessData

func (*CustomCommandData) GetCommands 

func (x *CustomCommandData) GetCommands() []*CustomCommandArgv

func (*CustomCommandData) GetFrom 

func (x *CustomCommandData) GetFrom() uint64

func (*CustomCommandData) GetTypeID 

func (_ *CustomCommandData) GetTypeID() lu.TypeID

===== GetMessageReflectType methods for CustomCommandData ===== Message =====

func (*CustomCommandData) LogValue 

func (m *CustomCommandData) LogValue() slog.Value

===== SlogValue methods for CustomCommandData ===== Message ====

func (*CustomCommandData) Merge 

func (m *CustomCommandData) Merge(src *CustomCommandData)

===== Merge methods for CustomCommandData ===== Message ====

func (*CustomCommandData) MergeCommands 

func (m *CustomCommandData) MergeCommands(d []*CustomCommandArgv) []*CustomCommandArgv

===== Merge methods for CustomCommandData ===== Repeated =====

func (*CustomCommandData) MutableAccessKey 

func (m *CustomCommandData) MutableAccessKey() *AccessData

===== Mutable methods for CustomCommandData ===== Message =====

func (*CustomCommandData) MutableCommands 

func (m *CustomCommandData) MutableCommands() []*CustomCommandArgv

===== Mutable methods for CustomCommandData ===== Repeated =====

func (*CustomCommandData) ProtoMessage 

func (*CustomCommandData) ProtoMessage()

func (*CustomCommandData) ProtoReflect 

func (x *CustomCommandData) ProtoReflect() protoreflect.Message

func (*CustomCommandData) RemoveLastCommands 

func (m *CustomCommandData) RemoveLastCommands()

===== RemoveLast methods for CustomCommandData ===== Repeated =====

func (*CustomCommandData) Reset 

func (x *CustomCommandData) Reset()

func (*CustomCommandData) ReverseIfNilCommands 

func (m *CustomCommandData) ReverseIfNilCommands(l int32) []*CustomCommandArgv

===== ReverseIfNil methods for CustomCommandData ===== Repeated =====

func (*CustomCommandData) String 

func (x *CustomCommandData) String() string

func (*CustomCommandData) ToReadonly 

func (m *CustomCommandData) ToReadonly() *Readonly_CustomCommandData

type ForwardData 

type ForwardData struct {
	From    uint64   `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"`
	To      uint64   `protobuf:"varint,2,opt,name=to,proto3" json:"to,omitempty"`
	Router  []uint64 `protobuf:"varint,3,rep,packed,name=router,proto3" json:"router,omitempty"`
	Content []byte   `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"`
	Flags   uint32   `protobuf:"varint,5,opt,name=flags,proto3" json:"flags,omitempty"`
	// contains filtered or unexported fields
}

func (*ForwardData) AppendRouter 

func (m *ForwardData) AppendRouter(d uint64)

===== Append methods for ForwardData ===== Repeated =====

func (*ForwardData) Clone 

func (m *ForwardData) Clone() *ForwardData

===== Clone methods for ForwardData ===== Message ====

func (*ForwardData) Descriptor deprecated 

func (*ForwardData) Descriptor() ([]byte, []int)

Deprecated: Use ForwardData.ProtoReflect.Descriptor instead.

func (*ForwardData) GetContent 

func (x *ForwardData) GetContent() []byte

func (*ForwardData) GetFlags 

func (x *ForwardData) GetFlags() uint32

func (*ForwardData) GetFrom 

func (x *ForwardData) GetFrom() uint64

func (*ForwardData) GetRouter 

func (x *ForwardData) GetRouter() []uint64

func (*ForwardData) GetTo 

func (x *ForwardData) GetTo() uint64

func (*ForwardData) GetTypeID 

func (_ *ForwardData) GetTypeID() lu.TypeID

===== GetMessageReflectType methods for ForwardData ===== Message =====

func (*ForwardData) LogValue 

func (m *ForwardData) LogValue() slog.Value

===== SlogValue methods for ForwardData ===== Message ====

func (*ForwardData) Merge 

func (m *ForwardData) Merge(src *ForwardData)

===== Merge methods for ForwardData ===== Message ====

func (*ForwardData) MergeRouter 

func (m *ForwardData) MergeRouter(d []uint64) []uint64

===== Merge methods for ForwardData ===== Repeated =====

func (*ForwardData) MutableRouter 

func (m *ForwardData) MutableRouter() []uint64

===== Mutable methods for ForwardData ===== Repeated =====

func (*ForwardData) ProtoMessage 

func (*ForwardData) ProtoMessage()

func (*ForwardData) ProtoReflect 

func (x *ForwardData) ProtoReflect() protoreflect.Message

func (*ForwardData) RemoveLastRouter 

func (m *ForwardData) RemoveLastRouter()

===== RemoveLast methods for ForwardData ===== Repeated =====

func (*ForwardData) Reset 

func (x *ForwardData) Reset()

func (*ForwardData) ReverseIfNilRouter 

func (m *ForwardData) ReverseIfNilRouter(l int32) []uint64

===== ReverseIfNil methods for ForwardData ===== Repeated =====

func (*ForwardData) String 

func (x *ForwardData) String() string

func (*ForwardData) ToReadonly 

func (m *ForwardData) ToReadonly() *Readonly_ForwardData

type MessageBody 

type MessageBody struct {

	// Types that are valid to be assigned to MessageType:
	//
	//	*MessageBody_CustomCommandReq
	//	*MessageBody_CustomCommandRsp
	//	*MessageBody_DataTransformReq
	//	*MessageBody_DataTransformRsp
	//	*MessageBody_NodeRegisterReq
	//	*MessageBody_NodeRegisterRsp
	//	*MessageBody_NodePingReq
	//	*MessageBody_NodePongRsp
	MessageType isMessageBody_MessageType `protobuf_oneof:"message_type"`
	// contains filtered or unexported fields
}

func (*MessageBody) Clone 

func (m *MessageBody) Clone() *MessageBody

===== Clone methods for MessageBody ===== Message ====

func (*MessageBody) Descriptor deprecated 

func (*MessageBody) Descriptor() ([]byte, []int)

Deprecated: Use MessageBody.ProtoReflect.Descriptor instead.

func (*MessageBody) GetCustomCommandReq 

func (x *MessageBody) GetCustomCommandReq() *CustomCommandData

func (*MessageBody) GetCustomCommandRsp 

func (x *MessageBody) GetCustomCommandRsp() *CustomCommandData

func (*MessageBody) GetDataTransformReq 

func (x *MessageBody) GetDataTransformReq() *ForwardData

func (*MessageBody) GetDataTransformRsp 

func (x *MessageBody) GetDataTransformRsp() *ForwardData

func (*MessageBody) GetMessageType 

func (x *MessageBody) GetMessageType() isMessageBody_MessageType

func (*MessageBody) GetMessageTypeOneofCase 

func (m *MessageBody) GetMessageTypeOneofCase() MessageBody_EnMessageTypeID

===== GetCase methods for MessageBody Oneof MessageType ===== Oneof =====

func (*MessageBody) GetMessageTypeOneofName 

func (m *MessageBody) GetMessageTypeOneofName() string

func (*MessageBody) GetMessageTypeTypeID 

func (m *MessageBody) GetMessageTypeTypeID() lu.TypeID

===== GetOneofTypeID methods for MessageBody Oneof MessageType ===== Oneof =====

func (*MessageBody) GetNodePingReq 

func (x *MessageBody) GetNodePingReq() *PingData

func (*MessageBody) GetNodePongRsp 

func (x *MessageBody) GetNodePongRsp() *PingData

func (*MessageBody) GetNodeRegisterReq 

func (x *MessageBody) GetNodeRegisterReq() *RegisterData

func (*MessageBody) GetNodeRegisterRsp 

func (x *MessageBody) GetNodeRegisterRsp() *RegisterData

func (*MessageBody) GetTypeID 

func (_ *MessageBody) GetTypeID() lu.TypeID

===== GetMessageReflectType methods for MessageBody ===== Message =====

func (*MessageBody) LogValue 

func (m *MessageBody) LogValue() slog.Value

===== SlogValue methods for MessageBody ===== Message ====

func (*MessageBody) Merge 

func (m *MessageBody) Merge(src *MessageBody)

===== Merge methods for MessageBody ===== Message ====

func (*MessageBody) MutableCustomCommandReq 

func (m *MessageBody) MutableCustomCommandReq() *CustomCommandData

===== Mutable methods for MessageBody ===== Oneof =====

func (*MessageBody) MutableCustomCommandRsp 

func (m *MessageBody) MutableCustomCommandRsp() *CustomCommandData

===== Mutable methods for MessageBody ===== Oneof =====

func (*MessageBody) MutableDataTransformReq 

func (m *MessageBody) MutableDataTransformReq() *ForwardData

===== Mutable methods for MessageBody ===== Oneof =====

func (*MessageBody) MutableDataTransformRsp 

func (m *MessageBody) MutableDataTransformRsp() *ForwardData

===== Mutable methods for MessageBody ===== Oneof =====

func (*MessageBody) MutableNodePingReq 

func (m *MessageBody) MutableNodePingReq() *PingData

===== Mutable methods for MessageBody ===== Oneof =====

func (*MessageBody) MutableNodePongRsp 

func (m *MessageBody) MutableNodePongRsp() *PingData

===== Mutable methods for MessageBody ===== Oneof =====

func (*MessageBody) MutableNodeRegisterReq 

func (m *MessageBody) MutableNodeRegisterReq() *RegisterData

===== Mutable methods for MessageBody ===== Oneof =====

func (*MessageBody) MutableNodeRegisterRsp 

func (m *MessageBody) MutableNodeRegisterRsp() *RegisterData

===== Mutable methods for MessageBody ===== Oneof =====

func (*MessageBody) ProtoMessage 

func (*MessageBody) ProtoMessage()

func (*MessageBody) ProtoReflect 

func (x *MessageBody) ProtoReflect() protoreflect.Message

func (*MessageBody) Reset 

func (x *MessageBody) Reset()

func (*MessageBody) String 

func (x *MessageBody) String() string

func (*MessageBody) ToReadonly 

func (m *MessageBody) ToReadonly() *Readonly_MessageBody

type MessageBody_CustomCommandReq 

type MessageBody_CustomCommandReq struct {
	CustomCommandReq *CustomCommandData `protobuf:"bytes,11,opt,name=custom_command_req,json=customCommandReq,proto3,oneof"`
}

func (*MessageBody_CustomCommandReq) GetFieldNameMessageBody_MessageType 

func (m *MessageBody_CustomCommandReq) GetFieldNameMessageBody_MessageType() string

func (*MessageBody_CustomCommandReq) GetMessageBody_MessageType 

func (m *MessageBody_CustomCommandReq) GetMessageBody_MessageType() MessageBody_EnMessageTypeID

===== Oneof Interface for MessageBody Oneof MessageBody_CustomCommandReq ===== Oneof =====

func (*MessageBody_CustomCommandReq) GetTypeID 

func (_ *MessageBody_CustomCommandReq) GetTypeID() lu.TypeID

func (*MessageBody_CustomCommandReq) GetTypeIDMessageBody_MessageType 

func (m *MessageBody_CustomCommandReq) GetTypeIDMessageBody_MessageType() lu.TypeID

func (*MessageBody_CustomCommandReq) MutableCustomCommandReq 

func (m *MessageBody_CustomCommandReq) MutableCustomCommandReq() *CustomCommandData

===== Mutable Message method for MessageBody Oneof MessageBody_CustomCommandReq ===== Oneof =====

type MessageBody_CustomCommandRsp 

type MessageBody_CustomCommandRsp struct {
	CustomCommandRsp *CustomCommandData `protobuf:"bytes,12,opt,name=custom_command_rsp,json=customCommandRsp,proto3,oneof"`
}

func (*MessageBody_CustomCommandRsp) GetFieldNameMessageBody_MessageType 

func (m *MessageBody_CustomCommandRsp) GetFieldNameMessageBody_MessageType() string

func (*MessageBody_CustomCommandRsp) GetMessageBody_MessageType 

func (m *MessageBody_CustomCommandRsp) GetMessageBody_MessageType() MessageBody_EnMessageTypeID

===== Oneof Interface for MessageBody Oneof MessageBody_CustomCommandRsp ===== Oneof =====

func (*MessageBody_CustomCommandRsp) GetTypeID 

func (_ *MessageBody_CustomCommandRsp) GetTypeID() lu.TypeID

func (*MessageBody_CustomCommandRsp) GetTypeIDMessageBody_MessageType 

func (m *MessageBody_CustomCommandRsp) GetTypeIDMessageBody_MessageType() lu.TypeID

func (*MessageBody_CustomCommandRsp) MutableCustomCommandRsp 

func (m *MessageBody_CustomCommandRsp) MutableCustomCommandRsp() *CustomCommandData

===== Mutable Message method for MessageBody Oneof MessageBody_CustomCommandRsp ===== Oneof =====

type MessageBody_DataTransformReq 

type MessageBody_DataTransformReq struct {
	DataTransformReq *ForwardData `protobuf:"bytes,13,opt,name=data_transform_req,json=dataTransformReq,proto3,oneof"`
}

func (*MessageBody_DataTransformReq) GetFieldNameMessageBody_MessageType 

func (m *MessageBody_DataTransformReq) GetFieldNameMessageBody_MessageType() string

func (*MessageBody_DataTransformReq) GetMessageBody_MessageType 

func (m *MessageBody_DataTransformReq) GetMessageBody_MessageType() MessageBody_EnMessageTypeID

===== Oneof Interface for MessageBody Oneof MessageBody_DataTransformReq ===== Oneof =====

func (*MessageBody_DataTransformReq) GetTypeID 

func (_ *MessageBody_DataTransformReq) GetTypeID() lu.TypeID

func (*MessageBody_DataTransformReq) GetTypeIDMessageBody_MessageType 

func (m *MessageBody_DataTransformReq) GetTypeIDMessageBody_MessageType() lu.TypeID

func (*MessageBody_DataTransformReq) MutableDataTransformReq 

func (m *MessageBody_DataTransformReq) MutableDataTransformReq() *ForwardData

===== Mutable Message method for MessageBody Oneof MessageBody_DataTransformReq ===== Oneof =====

type MessageBody_DataTransformRsp 

type MessageBody_DataTransformRsp struct {
	DataTransformRsp *ForwardData `protobuf:"bytes,14,opt,name=data_transform_rsp,json=dataTransformRsp,proto3,oneof"`
}

func (*MessageBody_DataTransformRsp) GetFieldNameMessageBody_MessageType 

func (m *MessageBody_DataTransformRsp) GetFieldNameMessageBody_MessageType() string

func (*MessageBody_DataTransformRsp) GetMessageBody_MessageType 

func (m *MessageBody_DataTransformRsp) GetMessageBody_MessageType() MessageBody_EnMessageTypeID

===== Oneof Interface for MessageBody Oneof MessageBody_DataTransformRsp ===== Oneof =====

func (*MessageBody_DataTransformRsp) GetTypeID 

func (_ *MessageBody_DataTransformRsp) GetTypeID() lu.TypeID

func (*MessageBody_DataTransformRsp) GetTypeIDMessageBody_MessageType 

func (m *MessageBody_DataTransformRsp) GetTypeIDMessageBody_MessageType() lu.TypeID

func (*MessageBody_DataTransformRsp) MutableDataTransformRsp 

func (m *MessageBody_DataTransformRsp) MutableDataTransformRsp() *ForwardData

===== Mutable Message method for MessageBody Oneof MessageBody_DataTransformRsp ===== Oneof =====

type MessageBody_EnMessageTypeID 

type MessageBody_EnMessageTypeID int32

===== Case Enum for MessageBody Oneof MessageType ===== Oneof ===== 

const (
	MessageBody_EnMessageTypeID_NONE             MessageBody_EnMessageTypeID = 0  // none
	MessageBody_EnMessageTypeID_CustomCommandReq MessageBody_EnMessageTypeID = 11 // custom_command_req
	MessageBody_EnMessageTypeID_CustomCommandRsp MessageBody_EnMessageTypeID = 12 // custom_command_rsp
	MessageBody_EnMessageTypeID_DataTransformReq MessageBody_EnMessageTypeID = 13 // data_transform_req
	MessageBody_EnMessageTypeID_DataTransformRsp MessageBody_EnMessageTypeID = 14 // data_transform_rsp
	MessageBody_EnMessageTypeID_NodeRegisterReq  MessageBody_EnMessageTypeID = 17 // node_register_req
	MessageBody_EnMessageTypeID_NodeRegisterRsp  MessageBody_EnMessageTypeID = 18 // node_register_rsp
	MessageBody_EnMessageTypeID_NodePingReq      MessageBody_EnMessageTypeID = 21 // node_ping_req
	MessageBody_EnMessageTypeID_NodePongRsp      MessageBody_EnMessageTypeID = 22 // node_pong_rsp
)

type MessageBody_NodePingReq 

type MessageBody_NodePingReq struct {
	NodePingReq *PingData `protobuf:"bytes,21,opt,name=node_ping_req,json=nodePingReq,proto3,oneof"`
}

func (*MessageBody_NodePingReq) GetFieldNameMessageBody_MessageType 

func (m *MessageBody_NodePingReq) GetFieldNameMessageBody_MessageType() string

func (*MessageBody_NodePingReq) GetMessageBody_MessageType 

func (m *MessageBody_NodePingReq) GetMessageBody_MessageType() MessageBody_EnMessageTypeID

===== Oneof Interface for MessageBody Oneof MessageBody_NodePingReq ===== Oneof =====

func (*MessageBody_NodePingReq) GetTypeID 

func (_ *MessageBody_NodePingReq) GetTypeID() lu.TypeID

func (*MessageBody_NodePingReq) GetTypeIDMessageBody_MessageType 

func (m *MessageBody_NodePingReq) GetTypeIDMessageBody_MessageType() lu.TypeID

func (*MessageBody_NodePingReq) MutableNodePingReq 

func (m *MessageBody_NodePingReq) MutableNodePingReq() *PingData

===== Mutable Message method for MessageBody Oneof MessageBody_NodePingReq ===== Oneof =====

type MessageBody_NodePongRsp 

type MessageBody_NodePongRsp struct {
	NodePongRsp *PingData `protobuf:"bytes,22,opt,name=node_pong_rsp,json=nodePongRsp,proto3,oneof"`
}

func (*MessageBody_NodePongRsp) GetFieldNameMessageBody_MessageType 

func (m *MessageBody_NodePongRsp) GetFieldNameMessageBody_MessageType() string

func (*MessageBody_NodePongRsp) GetMessageBody_MessageType 

func (m *MessageBody_NodePongRsp) GetMessageBody_MessageType() MessageBody_EnMessageTypeID

===== Oneof Interface for MessageBody Oneof MessageBody_NodePongRsp ===== Oneof =====

func (*MessageBody_NodePongRsp) GetTypeID 

func (_ *MessageBody_NodePongRsp) GetTypeID() lu.TypeID

func (*MessageBody_NodePongRsp) GetTypeIDMessageBody_MessageType 

func (m *MessageBody_NodePongRsp) GetTypeIDMessageBody_MessageType() lu.TypeID

func (*MessageBody_NodePongRsp) MutableNodePongRsp 

func (m *MessageBody_NodePongRsp) MutableNodePongRsp() *PingData

===== Mutable Message method for MessageBody Oneof MessageBody_NodePongRsp ===== Oneof =====

type MessageBody_NodeRegisterReq 

type MessageBody_NodeRegisterReq struct {
	NodeRegisterReq *RegisterData `protobuf:"bytes,17,opt,name=node_register_req,json=nodeRegisterReq,proto3,oneof"`
}

func (*MessageBody_NodeRegisterReq) GetFieldNameMessageBody_MessageType 

func (m *MessageBody_NodeRegisterReq) GetFieldNameMessageBody_MessageType() string

func (*MessageBody_NodeRegisterReq) GetMessageBody_MessageType 

func (m *MessageBody_NodeRegisterReq) GetMessageBody_MessageType() MessageBody_EnMessageTypeID

===== Oneof Interface for MessageBody Oneof MessageBody_NodeRegisterReq ===== Oneof =====

func (*MessageBody_NodeRegisterReq) GetTypeID 

func (_ *MessageBody_NodeRegisterReq) GetTypeID() lu.TypeID

func (*MessageBody_NodeRegisterReq) GetTypeIDMessageBody_MessageType 

func (m *MessageBody_NodeRegisterReq) GetTypeIDMessageBody_MessageType() lu.TypeID

func (*MessageBody_NodeRegisterReq) MutableNodeRegisterReq 

func (m *MessageBody_NodeRegisterReq) MutableNodeRegisterReq() *RegisterData

===== Mutable Message method for MessageBody Oneof MessageBody_NodeRegisterReq ===== Oneof =====

type MessageBody_NodeRegisterRsp 

type MessageBody_NodeRegisterRsp struct {
	NodeRegisterRsp *RegisterData `protobuf:"bytes,18,opt,name=node_register_rsp,json=nodeRegisterRsp,proto3,oneof"`
}

func (*MessageBody_NodeRegisterRsp) GetFieldNameMessageBody_MessageType 

func (m *MessageBody_NodeRegisterRsp) GetFieldNameMessageBody_MessageType() string

func (*MessageBody_NodeRegisterRsp) GetMessageBody_MessageType 

func (m *MessageBody_NodeRegisterRsp) GetMessageBody_MessageType() MessageBody_EnMessageTypeID

===== Oneof Interface for MessageBody Oneof MessageBody_NodeRegisterRsp ===== Oneof =====

func (*MessageBody_NodeRegisterRsp) GetTypeID 

func (_ *MessageBody_NodeRegisterRsp) GetTypeID() lu.TypeID

func (*MessageBody_NodeRegisterRsp) GetTypeIDMessageBody_MessageType 

func (m *MessageBody_NodeRegisterRsp) GetTypeIDMessageBody_MessageType() lu.TypeID

func (*MessageBody_NodeRegisterRsp) MutableNodeRegisterRsp 

func (m *MessageBody_NodeRegisterRsp) MutableNodeRegisterRsp() *RegisterData

===== Mutable Message method for MessageBody Oneof MessageBody_NodeRegisterRsp ===== Oneof =====

type MessageHead 

type MessageHead struct {
	Version     int32              `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Type        int32              `protobuf:"varint,2,opt,name=type,proto3" json:"type,omitempty"`
	ResultCode  int32              `protobuf:"zigzag32,3,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
	Sequence    uint64             `protobuf:"varint,4,opt,name=sequence,proto3" json:"sequence,omitempty"`
	SourceBusId uint64             `protobuf:"varint,5,opt,name=source_bus_id,json=sourceBusId,proto3" json:"source_bus_id,omitempty"`
	Crypto      *MessageHeadCrypto `protobuf:"bytes,6,opt,name=crypto,proto3" json:"crypto,omitempty"`
	// 加密算法：加密会带字典头部，如果数据很小，加密后反而会扩大尺寸。此时不如不加密。
	// 所以我们每个包是动态决定是否加密的，通过此字段告诉对端如何解包。
	Compression *MessageHeadCompression `protobuf:"bytes,7,opt,name=compression,proto3" json:"compression,omitempty"`
	// body size without padding
	BodySize uint64 `protobuf:"varint,9,opt,name=body_size,json=bodySize,proto3" json:"body_size,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageHead) Clone 

func (m *MessageHead) Clone() *MessageHead

===== Clone methods for MessageHead ===== Message ====

func (*MessageHead) Descriptor deprecated 

func (*MessageHead) Descriptor() ([]byte, []int)

Deprecated: Use MessageHead.ProtoReflect.Descriptor instead.

func (*MessageHead) GetBodySize 

func (x *MessageHead) GetBodySize() uint64

func (*MessageHead) GetCompression 

func (x *MessageHead) GetCompression() *MessageHeadCompression

func (*MessageHead) GetCrypto 

func (x *MessageHead) GetCrypto() *MessageHeadCrypto

func (*MessageHead) GetResultCode 

func (x *MessageHead) GetResultCode() int32

func (*MessageHead) GetSequence 

func (x *MessageHead) GetSequence() uint64

func (*MessageHead) GetSourceBusId 

func (x *MessageHead) GetSourceBusId() uint64

func (*MessageHead) GetType 

func (x *MessageHead) GetType() int32

func (*MessageHead) GetTypeID 

func (_ *MessageHead) GetTypeID() lu.TypeID

===== GetMessageReflectType methods for MessageHead ===== Message =====

func (*MessageHead) GetVersion 

func (x *MessageHead) GetVersion() int32

func (*MessageHead) LogValue 

func (m *MessageHead) LogValue() slog.Value

===== SlogValue methods for MessageHead ===== Message ====

func (*MessageHead) Merge 

func (m *MessageHead) Merge(src *MessageHead)

===== Merge methods for MessageHead ===== Message ====

func (*MessageHead) MutableCompression 

func (m *MessageHead) MutableCompression() *MessageHeadCompression

===== Mutable methods for MessageHead ===== Message =====

func (*MessageHead) MutableCrypto 

func (m *MessageHead) MutableCrypto() *MessageHeadCrypto

===== Mutable methods for MessageHead ===== Message =====

func (*MessageHead) ProtoMessage 

func (*MessageHead) ProtoMessage()

func (*MessageHead) ProtoReflect 

func (x *MessageHead) ProtoReflect() protoreflect.Message

func (*MessageHead) Reset 

func (x *MessageHead) Reset()

func (*MessageHead) String 

func (x *MessageHead) String() string

func (*MessageHead) ToReadonly 

func (m *MessageHead) ToReadonly() *Readonly_MessageHead

type MessageHeadCompression 

type MessageHeadCompression struct {
	Type         ATBUS_COMPRESSION_ALGORITHM_TYPE `` /* 127-byte string literal not displayed */
	OriginalSize uint64                           `protobuf:"varint,2,opt,name=original_size,json=originalSize,proto3" json:"original_size,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageHeadCompression) Clone 

func (m *MessageHeadCompression) Clone() *MessageHeadCompression

===== Clone methods for MessageHeadCompression ===== Message ====

func (*MessageHeadCompression) Descriptor deprecated 

func (*MessageHeadCompression) Descriptor() ([]byte, []int)

Deprecated: Use MessageHeadCompression.ProtoReflect.Descriptor instead.

func (*MessageHeadCompression) GetOriginalSize 

func (x *MessageHeadCompression) GetOriginalSize() uint64

func (*MessageHeadCompression) GetType 

func (x *MessageHeadCompression) GetType() ATBUS_COMPRESSION_ALGORITHM_TYPE

func (*MessageHeadCompression) GetTypeID 

func (_ *MessageHeadCompression) GetTypeID() lu.TypeID

===== GetMessageReflectType methods for MessageHeadCompression ===== Message =====

func (*MessageHeadCompression) LogValue 

func (m *MessageHeadCompression) LogValue() slog.Value

===== SlogValue methods for MessageHeadCompression ===== Message ====

func (*MessageHeadCompression) Merge 

func (m *MessageHeadCompression) Merge(src *MessageHeadCompression)

===== Merge methods for MessageHeadCompression ===== Message ====

func (*MessageHeadCompression) ProtoMessage 

func (*MessageHeadCompression) ProtoMessage()

func (*MessageHeadCompression) ProtoReflect 

func (x *MessageHeadCompression) ProtoReflect() protoreflect.Message

func (*MessageHeadCompression) Reset 

func (x *MessageHeadCompression) Reset()

func (*MessageHeadCompression) String 

func (x *MessageHeadCompression) String() string

func (*MessageHeadCompression) ToReadonly 

func (m *MessageHeadCompression) ToReadonly() *Readonly_MessageHeadCompression

type MessageHeadCrypto 

type MessageHeadCrypto struct {
	Algorithm ATBUS_CRYPTO_ALGORITHM_TYPE `` /* 132-byte string literal not displayed */
	// IV/nonce for crypto, must be unique for each encryption
	// If not set, just used the default rotation/nonce rule of the algorithm
	Iv []byte `protobuf:"bytes,2,opt,name=iv,proto3" json:"iv,omitempty"`
	// AAD for AEAD
	Aad []byte `protobuf:"bytes,11,opt,name=aad,proto3" json:"aad,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageHeadCrypto) Clone 

func (m *MessageHeadCrypto) Clone() *MessageHeadCrypto

===== Clone methods for MessageHeadCrypto ===== Message ====

func (*MessageHeadCrypto) Descriptor deprecated 

func (*MessageHeadCrypto) Descriptor() ([]byte, []int)

Deprecated: Use MessageHeadCrypto.ProtoReflect.Descriptor instead.

func (*MessageHeadCrypto) GetAad 

func (x *MessageHeadCrypto) GetAad() []byte

func (*MessageHeadCrypto) GetAlgorithm 

func (x *MessageHeadCrypto) GetAlgorithm() ATBUS_CRYPTO_ALGORITHM_TYPE

func (*MessageHeadCrypto) GetIv 

func (x *MessageHeadCrypto) GetIv() []byte

func (*MessageHeadCrypto) GetTypeID 

func (_ *MessageHeadCrypto) GetTypeID() lu.TypeID

===== GetMessageReflectType methods for MessageHeadCrypto ===== Message =====

func (*MessageHeadCrypto) LogValue 

func (m *MessageHeadCrypto) LogValue() slog.Value

===== SlogValue methods for MessageHeadCrypto ===== Message ====

func (*MessageHeadCrypto) Merge 

func (m *MessageHeadCrypto) Merge(src *MessageHeadCrypto)

===== Merge methods for MessageHeadCrypto ===== Message ====

func (*MessageHeadCrypto) ProtoMessage 

func (*MessageHeadCrypto) ProtoMessage()

func (*MessageHeadCrypto) ProtoReflect 

func (x *MessageHeadCrypto) ProtoReflect() protoreflect.Message

func (*MessageHeadCrypto) Reset 

func (x *MessageHeadCrypto) Reset()

func (*MessageHeadCrypto) String 

func (x *MessageHeadCrypto) String() string

func (*MessageHeadCrypto) ToReadonly 

func (m *MessageHeadCrypto) ToReadonly() *Readonly_MessageHeadCrypto

type PingData 

type PingData struct {
	TimePoint       int64                `protobuf:"varint,1,opt,name=time_point,json=timePoint,proto3" json:"time_point,omitempty"`
	CryptoHandshake *CryptoHandshakeData `protobuf:"bytes,2,opt,name=crypto_handshake,json=cryptoHandshake,proto3" json:"crypto_handshake,omitempty"`
	// contains filtered or unexported fields
}

func (*PingData) Clone 

func (m *PingData) Clone() *PingData

===== Clone methods for PingData ===== Message ====

func (*PingData) Descriptor deprecated 

func (*PingData) Descriptor() ([]byte, []int)

Deprecated: Use PingData.ProtoReflect.Descriptor instead.

func (*PingData) GetCryptoHandshake 

func (x *PingData) GetCryptoHandshake() *CryptoHandshakeData

func (*PingData) GetTimePoint 

func (x *PingData) GetTimePoint() int64

func (*PingData) GetTypeID 

func (_ *PingData) GetTypeID() lu.TypeID

===== GetMessageReflectType methods for PingData ===== Message =====

func (*PingData) LogValue 

func (m *PingData) LogValue() slog.Value

===== SlogValue methods for PingData ===== Message ====

func (*PingData) Merge 

func (m *PingData) Merge(src *PingData)

===== Merge methods for PingData ===== Message ====

func (*PingData) MutableCryptoHandshake 

func (m *PingData) MutableCryptoHandshake() *CryptoHandshakeData

===== Mutable methods for PingData ===== Message =====

func (*PingData) ProtoMessage 

func (*PingData) ProtoMessage()

func (*PingData) ProtoReflect 

func (x *PingData) ProtoReflect() protoreflect.Message

func (*PingData) Reset 

func (x *PingData) Reset()

func (*PingData) String 

func (x *PingData) String() string

func (*PingData) ToReadonly 

func (m *PingData) ToReadonly() *Readonly_PingData

type Readonly_AccessData 

type Readonly_AccessData struct {
	// contains filtered or unexported fields
}

===== Readonly wrapper for AccessData ===== Message ====

func (*Readonly_AccessData) CloneMessage 

func (r *Readonly_AccessData) CloneMessage() *AccessData

func (*Readonly_AccessData) GetAlgorithm 

func (r *Readonly_AccessData) GetAlgorithm() ATBUS_ACCESS_DATA_ALGORITHM_TYPE

func (*Readonly_AccessData) GetNonce1 

func (r *Readonly_AccessData) GetNonce1() uint64

func (*Readonly_AccessData) GetNonce2 

func (r *Readonly_AccessData) GetNonce2() uint64

func (*Readonly_AccessData) GetSignature 

func (r *Readonly_AccessData) GetSignature() [][]byte

func (*Readonly_AccessData) GetTimestamp 

func (r *Readonly_AccessData) GetTimestamp() int64

func (Readonly_AccessData) LogValue 

func (r Readonly_AccessData) LogValue() slog.Value

func (*Readonly_AccessData) ReadonlyProtoReflect 

func (r *Readonly_AccessData) ReadonlyProtoReflect() innerFile_libatbus_protocol_protoReadonlyMessage

func (*Readonly_AccessData) ToMessage 

func (r *Readonly_AccessData) ToMessage() *AccessData

type Readonly_ChannelData 

type Readonly_ChannelData struct {
	// contains filtered or unexported fields
}

===== Readonly wrapper for ChannelData ===== Message ====

func (*Readonly_ChannelData) CloneMessage 

func (r *Readonly_ChannelData) CloneMessage() *ChannelData

func (*Readonly_ChannelData) GetAddress 

func (r *Readonly_ChannelData) GetAddress() string

func (Readonly_ChannelData) LogValue 

func (r Readonly_ChannelData) LogValue() slog.Value

func (*Readonly_ChannelData) ReadonlyProtoReflect 

func (r *Readonly_ChannelData) ReadonlyProtoReflect() innerFile_libatbus_protocol_protoReadonlyMessage

func (*Readonly_ChannelData) ToMessage 

func (r *Readonly_ChannelData) ToMessage() *ChannelData

type Readonly_CryptoHandshakeData 

type Readonly_CryptoHandshakeData struct {
	// contains filtered or unexported fields
}

===== Readonly wrapper for CryptoHandshakeData ===== Message ====

func (*Readonly_CryptoHandshakeData) CloneMessage 

func (r *Readonly_CryptoHandshakeData) CloneMessage() *CryptoHandshakeData

func (*Readonly_CryptoHandshakeData) GetAlgorithms 

func (r *Readonly_CryptoHandshakeData) GetAlgorithms() []ATBUS_CRYPTO_ALGORITHM_TYPE

func (*Readonly_CryptoHandshakeData) GetIvSize 

func (r *Readonly_CryptoHandshakeData) GetIvSize() uint32

func (*Readonly_CryptoHandshakeData) GetKdfType 

func (r *Readonly_CryptoHandshakeData) GetKdfType() []ATBUS_CRYPTO_KDF_TYPE

func (*Readonly_CryptoHandshakeData) GetPublicKey 

func (r *Readonly_CryptoHandshakeData) GetPublicKey() []byte

func (*Readonly_CryptoHandshakeData) GetSequence 

func (r *Readonly_CryptoHandshakeData) GetSequence() uint64

func (*Readonly_CryptoHandshakeData) GetTagSize 

func (r *Readonly_CryptoHandshakeData) GetTagSize() uint32

func (*Readonly_CryptoHandshakeData) GetType 

func (r *Readonly_CryptoHandshakeData) GetType() ATBUS_CRYPTO_KEY_EXCHANGE_TYPE

func (Readonly_CryptoHandshakeData) LogValue 

func (r Readonly_CryptoHandshakeData) LogValue() slog.Value

func (*Readonly_CryptoHandshakeData) ReadonlyProtoReflect 

func (r *Readonly_CryptoHandshakeData) ReadonlyProtoReflect() innerFile_libatbus_protocol_protoReadonlyMessage

func (*Readonly_CryptoHandshakeData) ToMessage 

func (r *Readonly_CryptoHandshakeData) ToMessage() *CryptoHandshakeData

type Readonly_CustomCommandArgv 

type Readonly_CustomCommandArgv struct {
	// contains filtered or unexported fields
}

===== Readonly wrapper for CustomCommandArgv ===== Message ====

func (*Readonly_CustomCommandArgv) CloneMessage 

func (r *Readonly_CustomCommandArgv) CloneMessage() *CustomCommandArgv

func (*Readonly_CustomCommandArgv) GetArg 

func (r *Readonly_CustomCommandArgv) GetArg() []byte

func (Readonly_CustomCommandArgv) LogValue 

func (r Readonly_CustomCommandArgv) LogValue() slog.Value

func (*Readonly_CustomCommandArgv) ReadonlyProtoReflect 

func (r *Readonly_CustomCommandArgv) ReadonlyProtoReflect() innerFile_libatbus_protocol_protoReadonlyMessage

func (*Readonly_CustomCommandArgv) ToMessage 

func (r *Readonly_CustomCommandArgv) ToMessage() *CustomCommandArgv

type Readonly_CustomCommandData 

type Readonly_CustomCommandData struct {
	// contains filtered or unexported fields
}

===== Readonly wrapper for CustomCommandData ===== Message ====

func (*Readonly_CustomCommandData) CloneMessage 

func (r *Readonly_CustomCommandData) CloneMessage() *CustomCommandData

func (*Readonly_CustomCommandData) GetAccessKey 

func (r *Readonly_CustomCommandData) GetAccessKey() *Readonly_AccessData

func (*Readonly_CustomCommandData) GetCommands 

func (r *Readonly_CustomCommandData) GetCommands() []*Readonly_CustomCommandArgv

func (*Readonly_CustomCommandData) GetFrom 

func (r *Readonly_CustomCommandData) GetFrom() uint64

func (Readonly_CustomCommandData) LogValue 

func (r Readonly_CustomCommandData) LogValue() slog.Value

func (*Readonly_CustomCommandData) ReadonlyProtoReflect 

func (r *Readonly_CustomCommandData) ReadonlyProtoReflect() innerFile_libatbus_protocol_protoReadonlyMessage

func (*Readonly_CustomCommandData) ToMessage 

func (r *Readonly_CustomCommandData) ToMessage() *CustomCommandData

type Readonly_ForwardData 

type Readonly_ForwardData struct {
	// contains filtered or unexported fields
}

===== Readonly wrapper for ForwardData ===== Message ====

func (*Readonly_ForwardData) CloneMessage 

func (r *Readonly_ForwardData) CloneMessage() *ForwardData

func (*Readonly_ForwardData) GetContent 

func (r *Readonly_ForwardData) GetContent() []byte

func (*Readonly_ForwardData) GetFlags 

func (r *Readonly_ForwardData) GetFlags() uint32

func (*Readonly_ForwardData) GetFrom 

func (r *Readonly_ForwardData) GetFrom() uint64

func (*Readonly_ForwardData) GetRouter 

func (r *Readonly_ForwardData) GetRouter() []uint64

func (*Readonly_ForwardData) GetTo 

func (r *Readonly_ForwardData) GetTo() uint64

func (Readonly_ForwardData) LogValue 

func (r Readonly_ForwardData) LogValue() slog.Value

func (*Readonly_ForwardData) ReadonlyProtoReflect 

func (r *Readonly_ForwardData) ReadonlyProtoReflect() innerFile_libatbus_protocol_protoReadonlyMessage

func (*Readonly_ForwardData) ToMessage 

func (r *Readonly_ForwardData) ToMessage() *ForwardData

type Readonly_MessageBody 

type Readonly_MessageBody struct {
	// contains filtered or unexported fields
}

===== Readonly wrapper for MessageBody ===== Message ====

func (*Readonly_MessageBody) CloneMessage 

func (r *Readonly_MessageBody) CloneMessage() *MessageBody

func (*Readonly_MessageBody) GetCustomCommandReq 

func (r *Readonly_MessageBody) GetCustomCommandReq() *Readonly_CustomCommandData

func (*Readonly_MessageBody) GetCustomCommandRsp 

func (r *Readonly_MessageBody) GetCustomCommandRsp() *Readonly_CustomCommandData

func (*Readonly_MessageBody) GetDataTransformReq 

func (r *Readonly_MessageBody) GetDataTransformReq() *Readonly_ForwardData

func (*Readonly_MessageBody) GetDataTransformRsp 

func (r *Readonly_MessageBody) GetDataTransformRsp() *Readonly_ForwardData

func (*Readonly_MessageBody) GetMessageTypeOneofCase 

func (r *Readonly_MessageBody) GetMessageTypeOneofCase() MessageBody_EnMessageTypeID

func (*Readonly_MessageBody) GetMessageTypeTypeID 

func (r *Readonly_MessageBody) GetMessageTypeTypeID() lu.TypeID

func (*Readonly_MessageBody) GetNodePingReq 

func (r *Readonly_MessageBody) GetNodePingReq() *Readonly_PingData

func (*Readonly_MessageBody) GetNodePongRsp 

func (r *Readonly_MessageBody) GetNodePongRsp() *Readonly_PingData

func (*Readonly_MessageBody) GetNodeRegisterReq 

func (r *Readonly_MessageBody) GetNodeRegisterReq() *Readonly_RegisterData

func (*Readonly_MessageBody) GetNodeRegisterRsp 

func (r *Readonly_MessageBody) GetNodeRegisterRsp() *Readonly_RegisterData

func (Readonly_MessageBody) LogValue 

func (r Readonly_MessageBody) LogValue() slog.Value

func (*Readonly_MessageBody) ReadonlyProtoReflect 

func (r *Readonly_MessageBody) ReadonlyProtoReflect() innerFile_libatbus_protocol_protoReadonlyMessage

func (*Readonly_MessageBody) ToMessage 

func (r *Readonly_MessageBody) ToMessage() *MessageBody

type Readonly_MessageBody_CustomCommandReq 

type Readonly_MessageBody_CustomCommandReq struct {
	// contains filtered or unexported fields
}

===== Readonly struct for MessageBody_CustomCommandReq ===== Oneof option ====

func (*Readonly_MessageBody_CustomCommandReq) GetCustomCommandReq 

func (r *Readonly_MessageBody_CustomCommandReq) GetCustomCommandReq() *Readonly_CustomCommandData

func (*Readonly_MessageBody_CustomCommandReq) GetMessageBody_MessageType 

func (r *Readonly_MessageBody_CustomCommandReq) GetMessageBody_MessageType() MessageBody_EnMessageTypeID

func (*Readonly_MessageBody_CustomCommandReq) GetTypeIDMessageBody_MessageType 

func (r *Readonly_MessageBody_CustomCommandReq) GetTypeIDMessageBody_MessageType() lu.TypeID

type Readonly_MessageBody_CustomCommandRsp 

type Readonly_MessageBody_CustomCommandRsp struct {
	// contains filtered or unexported fields
}

===== Readonly struct for MessageBody_CustomCommandRsp ===== Oneof option ====

func (*Readonly_MessageBody_CustomCommandRsp) GetCustomCommandRsp 

func (r *Readonly_MessageBody_CustomCommandRsp) GetCustomCommandRsp() *Readonly_CustomCommandData

func (*Readonly_MessageBody_CustomCommandRsp) GetMessageBody_MessageType 

func (r *Readonly_MessageBody_CustomCommandRsp) GetMessageBody_MessageType() MessageBody_EnMessageTypeID

func (*Readonly_MessageBody_CustomCommandRsp) GetTypeIDMessageBody_MessageType 

func (r *Readonly_MessageBody_CustomCommandRsp) GetTypeIDMessageBody_MessageType() lu.TypeID

type Readonly_MessageBody_DataTransformReq 

type Readonly_MessageBody_DataTransformReq struct {
	// contains filtered or unexported fields
}

===== Readonly struct for MessageBody_DataTransformReq ===== Oneof option ====

func (*Readonly_MessageBody_DataTransformReq) GetDataTransformReq 

func (r *Readonly_MessageBody_DataTransformReq) GetDataTransformReq() *Readonly_ForwardData

func (*Readonly_MessageBody_DataTransformReq) GetMessageBody_MessageType 

func (r *Readonly_MessageBody_DataTransformReq) GetMessageBody_MessageType() MessageBody_EnMessageTypeID

func (*Readonly_MessageBody_DataTransformReq) GetTypeIDMessageBody_MessageType 

func (r *Readonly_MessageBody_DataTransformReq) GetTypeIDMessageBody_MessageType() lu.TypeID

type Readonly_MessageBody_DataTransformRsp 

type Readonly_MessageBody_DataTransformRsp struct {
	// contains filtered or unexported fields
}

===== Readonly struct for MessageBody_DataTransformRsp ===== Oneof option ====

func (*Readonly_MessageBody_DataTransformRsp) GetDataTransformRsp 

func (r *Readonly_MessageBody_DataTransformRsp) GetDataTransformRsp() *Readonly_ForwardData

func (*Readonly_MessageBody_DataTransformRsp) GetMessageBody_MessageType 

func (r *Readonly_MessageBody_DataTransformRsp) GetMessageBody_MessageType() MessageBody_EnMessageTypeID

func (*Readonly_MessageBody_DataTransformRsp) GetTypeIDMessageBody_MessageType 

func (r *Readonly_MessageBody_DataTransformRsp) GetTypeIDMessageBody_MessageType() lu.TypeID

type Readonly_MessageBody_NodePingReq 

type Readonly_MessageBody_NodePingReq struct {
	// contains filtered or unexported fields
}

===== Readonly struct for MessageBody_NodePingReq ===== Oneof option ====

func (*Readonly_MessageBody_NodePingReq) GetMessageBody_MessageType 

func (r *Readonly_MessageBody_NodePingReq) GetMessageBody_MessageType() MessageBody_EnMessageTypeID

func (*Readonly_MessageBody_NodePingReq) GetNodePingReq 

func (r *Readonly_MessageBody_NodePingReq) GetNodePingReq() *Readonly_PingData

func (*Readonly_MessageBody_NodePingReq) GetTypeIDMessageBody_MessageType 

func (r *Readonly_MessageBody_NodePingReq) GetTypeIDMessageBody_MessageType() lu.TypeID

type Readonly_MessageBody_NodePongRsp 

type Readonly_MessageBody_NodePongRsp struct {
	// contains filtered or unexported fields
}

===== Readonly struct for MessageBody_NodePongRsp ===== Oneof option ====

func (*Readonly_MessageBody_NodePongRsp) GetMessageBody_MessageType 

func (r *Readonly_MessageBody_NodePongRsp) GetMessageBody_MessageType() MessageBody_EnMessageTypeID

func (*Readonly_MessageBody_NodePongRsp) GetNodePongRsp 

func (r *Readonly_MessageBody_NodePongRsp) GetNodePongRsp() *Readonly_PingData

func (*Readonly_MessageBody_NodePongRsp) GetTypeIDMessageBody_MessageType 

func (r *Readonly_MessageBody_NodePongRsp) GetTypeIDMessageBody_MessageType() lu.TypeID

type Readonly_MessageBody_NodeRegisterReq 

type Readonly_MessageBody_NodeRegisterReq struct {
	// contains filtered or unexported fields
}

===== Readonly struct for MessageBody_NodeRegisterReq ===== Oneof option ====

func (*Readonly_MessageBody_NodeRegisterReq) GetMessageBody_MessageType 

func (r *Readonly_MessageBody_NodeRegisterReq) GetMessageBody_MessageType() MessageBody_EnMessageTypeID

func (*Readonly_MessageBody_NodeRegisterReq) GetNodeRegisterReq 

func (r *Readonly_MessageBody_NodeRegisterReq) GetNodeRegisterReq() *Readonly_RegisterData

func (*Readonly_MessageBody_NodeRegisterReq) GetTypeIDMessageBody_MessageType 

func (r *Readonly_MessageBody_NodeRegisterReq) GetTypeIDMessageBody_MessageType() lu.TypeID

type Readonly_MessageBody_NodeRegisterRsp 

type Readonly_MessageBody_NodeRegisterRsp struct {
	// contains filtered or unexported fields
}

===== Readonly struct for MessageBody_NodeRegisterRsp ===== Oneof option ====

func (*Readonly_MessageBody_NodeRegisterRsp) GetMessageBody_MessageType 

func (r *Readonly_MessageBody_NodeRegisterRsp) GetMessageBody_MessageType() MessageBody_EnMessageTypeID

func (*Readonly_MessageBody_NodeRegisterRsp) GetNodeRegisterRsp 

func (r *Readonly_MessageBody_NodeRegisterRsp) GetNodeRegisterRsp() *Readonly_RegisterData

func (*Readonly_MessageBody_NodeRegisterRsp) GetTypeIDMessageBody_MessageType 

func (r *Readonly_MessageBody_NodeRegisterRsp) GetTypeIDMessageBody_MessageType() lu.TypeID

type Readonly_MessageHead 

type Readonly_MessageHead struct {
	// contains filtered or unexported fields
}

===== Readonly wrapper for MessageHead ===== Message ====

func (*Readonly_MessageHead) CloneMessage 

func (r *Readonly_MessageHead) CloneMessage() *MessageHead

func (*Readonly_MessageHead) GetBodySize 

func (r *Readonly_MessageHead) GetBodySize() uint64

func (*Readonly_MessageHead) GetCompression 

func (r *Readonly_MessageHead) GetCompression() *Readonly_MessageHeadCompression

func (*Readonly_MessageHead) GetCrypto 

func (r *Readonly_MessageHead) GetCrypto() *Readonly_MessageHeadCrypto

func (*Readonly_MessageHead) GetResultCode 

func (r *Readonly_MessageHead) GetResultCode() int32

func (*Readonly_MessageHead) GetSequence 

func (r *Readonly_MessageHead) GetSequence() uint64

func (*Readonly_MessageHead) GetSourceBusId 

func (r *Readonly_MessageHead) GetSourceBusId() uint64

func (*Readonly_MessageHead) GetType 

func (r *Readonly_MessageHead) GetType() int32

func (*Readonly_MessageHead) GetVersion 

func (r *Readonly_MessageHead) GetVersion() int32

func (Readonly_MessageHead) LogValue 

func (r Readonly_MessageHead) LogValue() slog.Value

func (*Readonly_MessageHead) ReadonlyProtoReflect 

func (r *Readonly_MessageHead) ReadonlyProtoReflect() innerFile_libatbus_protocol_protoReadonlyMessage

func (*Readonly_MessageHead) ToMessage 

func (r *Readonly_MessageHead) ToMessage() *MessageHead

type Readonly_MessageHeadCompression 

type Readonly_MessageHeadCompression struct {
	// contains filtered or unexported fields
}

===== Readonly wrapper for MessageHeadCompression ===== Message ====

func (*Readonly_MessageHeadCompression) CloneMessage 

func (r *Readonly_MessageHeadCompression) CloneMessage() *MessageHeadCompression

func (*Readonly_MessageHeadCompression) GetOriginalSize 

func (r *Readonly_MessageHeadCompression) GetOriginalSize() uint64

func (*Readonly_MessageHeadCompression) GetType 

func (r *Readonly_MessageHeadCompression) GetType() ATBUS_COMPRESSION_ALGORITHM_TYPE

func (Readonly_MessageHeadCompression) LogValue 

func (r Readonly_MessageHeadCompression) LogValue() slog.Value

func (*Readonly_MessageHeadCompression) ReadonlyProtoReflect 

func (r *Readonly_MessageHeadCompression) ReadonlyProtoReflect() innerFile_libatbus_protocol_protoReadonlyMessage

func (*Readonly_MessageHeadCompression) ToMessage 

func (r *Readonly_MessageHeadCompression) ToMessage() *MessageHeadCompression

type Readonly_MessageHeadCrypto 

type Readonly_MessageHeadCrypto struct {
	// contains filtered or unexported fields
}

===== Readonly wrapper for MessageHeadCrypto ===== Message ====

func (*Readonly_MessageHeadCrypto) CloneMessage 

func (r *Readonly_MessageHeadCrypto) CloneMessage() *MessageHeadCrypto

func (*Readonly_MessageHeadCrypto) GetAad 

func (r *Readonly_MessageHeadCrypto) GetAad() []byte

func (*Readonly_MessageHeadCrypto) GetAlgorithm 

func (r *Readonly_MessageHeadCrypto) GetAlgorithm() ATBUS_CRYPTO_ALGORITHM_TYPE

func (*Readonly_MessageHeadCrypto) GetIv 

func (r *Readonly_MessageHeadCrypto) GetIv() []byte

func (Readonly_MessageHeadCrypto) LogValue 

func (r Readonly_MessageHeadCrypto) LogValue() slog.Value

func (*Readonly_MessageHeadCrypto) ReadonlyProtoReflect 

func (r *Readonly_MessageHeadCrypto) ReadonlyProtoReflect() innerFile_libatbus_protocol_protoReadonlyMessage

func (*Readonly_MessageHeadCrypto) ToMessage 

func (r *Readonly_MessageHeadCrypto) ToMessage() *MessageHeadCrypto

type Readonly_PingData 

type Readonly_PingData struct {
	// contains filtered or unexported fields
}

===== Readonly wrapper for PingData ===== Message ====

func (*Readonly_PingData) CloneMessage 

func (r *Readonly_PingData) CloneMessage() *PingData

func (*Readonly_PingData) GetCryptoHandshake 

func (r *Readonly_PingData) GetCryptoHandshake() *Readonly_CryptoHandshakeData

func (*Readonly_PingData) GetTimePoint 

func (r *Readonly_PingData) GetTimePoint() int64

func (Readonly_PingData) LogValue 

func (r Readonly_PingData) LogValue() slog.Value

func (*Readonly_PingData) ReadonlyProtoReflect 

func (r *Readonly_PingData) ReadonlyProtoReflect() innerFile_libatbus_protocol_protoReadonlyMessage

func (*Readonly_PingData) ToMessage 

func (r *Readonly_PingData) ToMessage() *PingData

type Readonly_RegisterData 

type Readonly_RegisterData struct {
	// contains filtered or unexported fields
}

===== Readonly wrapper for RegisterData ===== Message ====

func (*Readonly_RegisterData) CloneMessage 

func (r *Readonly_RegisterData) CloneMessage() *RegisterData

func (*Readonly_RegisterData) GetAccessKey 

func (r *Readonly_RegisterData) GetAccessKey() *Readonly_AccessData

func (*Readonly_RegisterData) GetBusId 

func (r *Readonly_RegisterData) GetBusId() uint64

func (*Readonly_RegisterData) GetChannels 

func (r *Readonly_RegisterData) GetChannels() []*Readonly_ChannelData

func (*Readonly_RegisterData) GetCryptoHandshake 

func (r *Readonly_RegisterData) GetCryptoHandshake() *Readonly_CryptoHandshakeData

func (*Readonly_RegisterData) GetFlags 

func (r *Readonly_RegisterData) GetFlags() uint32

func (*Readonly_RegisterData) GetHashCode 

func (r *Readonly_RegisterData) GetHashCode() string

func (*Readonly_RegisterData) GetHostname 

func (r *Readonly_RegisterData) GetHostname() string

func (*Readonly_RegisterData) GetPid 

func (r *Readonly_RegisterData) GetPid() int32

func (*Readonly_RegisterData) GetSupportedChannelSchema 

func (r *Readonly_RegisterData) GetSupportedChannelSchema() []string

func (*Readonly_RegisterData) GetSupportedCompressionAlgorithm 

func (r *Readonly_RegisterData) GetSupportedCompressionAlgorithm() []ATBUS_COMPRESSION_ALGORITHM_TYPE

func (Readonly_RegisterData) LogValue 

func (r Readonly_RegisterData) LogValue() slog.Value

func (*Readonly_RegisterData) ReadonlyProtoReflect 

func (r *Readonly_RegisterData) ReadonlyProtoReflect() innerFile_libatbus_protocol_protoReadonlyMessage

func (*Readonly_RegisterData) ToMessage 

func (r *Readonly_RegisterData) ToMessage() *RegisterData

type RegisterData 

type RegisterData struct {
	BusId                         uint64                             `protobuf:"varint,1,opt,name=bus_id,json=busId,proto3" json:"bus_id,omitempty"`
	Pid                           int32                              `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
	Hostname                      string                             `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Channels                      []*ChannelData                     `protobuf:"bytes,4,rep,name=channels,proto3" json:"channels,omitempty"`
	SupportedChannelSchema        []string                           `` /* 129-byte string literal not displayed */
	SupportedCompressionAlgorithm []ATBUS_COMPRESSION_ALGORITHM_TYPE `` /* 223-byte string literal not displayed */
	Flags                         uint32                             `protobuf:"varint,7,opt,name=flags,proto3" json:"flags,omitempty"`
	AccessKey                     *AccessData                        `protobuf:"bytes,8,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
	HashCode                      string                             `protobuf:"bytes,10,opt,name=hash_code,json=hashCode,proto3" json:"hash_code,omitempty"`
	CryptoHandshake               *CryptoHandshakeData               `protobuf:"bytes,11,opt,name=crypto_handshake,json=cryptoHandshake,proto3" json:"crypto_handshake,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterData) AddChannels 

func (m *RegisterData) AddChannels() *ChannelData

===== Add methods for RegisterData ===== Repeated =====

func (*RegisterData) AppendChannels 

func (m *RegisterData) AppendChannels(d *ChannelData)

===== Append methods for RegisterData ===== Repeated =====

func (*RegisterData) AppendSupportedChannelSchema 

func (m *RegisterData) AppendSupportedChannelSchema(d string)

===== Append methods for RegisterData ===== Repeated =====

func (*RegisterData) AppendSupportedCompressionAlgorithm 

func (m *RegisterData) AppendSupportedCompressionAlgorithm(d ATBUS_COMPRESSION_ALGORITHM_TYPE)

===== Append methods for RegisterData ===== Repeated =====

func (*RegisterData) Clone 

func (m *RegisterData) Clone() *RegisterData

===== Clone methods for RegisterData ===== Message ====

func (*RegisterData) Descriptor deprecated 

func (*RegisterData) Descriptor() ([]byte, []int)

Deprecated: Use RegisterData.ProtoReflect.Descriptor instead.

func (*RegisterData) GetAccessKey 

func (x *RegisterData) GetAccessKey() *AccessData

func (*RegisterData) GetBusId 

func (x *RegisterData) GetBusId() uint64

func (*RegisterData) GetChannels 

func (x *RegisterData) GetChannels() []*ChannelData

func (*RegisterData) GetCryptoHandshake 

func (x *RegisterData) GetCryptoHandshake() *CryptoHandshakeData

func (*RegisterData) GetFlags 

func (x *RegisterData) GetFlags() uint32

func (*RegisterData) GetHashCode 

func (x *RegisterData) GetHashCode() string

func (*RegisterData) GetHostname 

func (x *RegisterData) GetHostname() string

func (*RegisterData) GetPid 

func (x *RegisterData) GetPid() int32

func (*RegisterData) GetSupportedChannelSchema 

func (x *RegisterData) GetSupportedChannelSchema() []string

func (*RegisterData) GetSupportedCompressionAlgorithm 

func (x *RegisterData) GetSupportedCompressionAlgorithm() []ATBUS_COMPRESSION_ALGORITHM_TYPE

func (*RegisterData) GetTypeID 

func (_ *RegisterData) GetTypeID() lu.TypeID

===== GetMessageReflectType methods for RegisterData ===== Message =====

func (*RegisterData) LogValue 

func (m *RegisterData) LogValue() slog.Value

===== SlogValue methods for RegisterData ===== Message ====

func (*RegisterData) Merge 

func (m *RegisterData) Merge(src *RegisterData)

===== Merge methods for RegisterData ===== Message ====

func (*RegisterData) MergeChannels 

func (m *RegisterData) MergeChannels(d []*ChannelData) []*ChannelData

===== Merge methods for RegisterData ===== Repeated =====

func (*RegisterData) MergeSupportedChannelSchema 

func (m *RegisterData) MergeSupportedChannelSchema(d []string) []string

===== Merge methods for RegisterData ===== Repeated =====

func (*RegisterData) MergeSupportedCompressionAlgorithm 

func (m *RegisterData) MergeSupportedCompressionAlgorithm(d []ATBUS_COMPRESSION_ALGORITHM_TYPE) []ATBUS_COMPRESSION_ALGORITHM_TYPE

===== Merge methods for RegisterData ===== Repeated =====

func (*RegisterData) MutableAccessKey 

func (m *RegisterData) MutableAccessKey() *AccessData

===== Mutable methods for RegisterData ===== Message =====

func (*RegisterData) MutableChannels 

func (m *RegisterData) MutableChannels() []*ChannelData

===== Mutable methods for RegisterData ===== Repeated =====

func (*RegisterData) MutableCryptoHandshake 

func (m *RegisterData) MutableCryptoHandshake() *CryptoHandshakeData

===== Mutable methods for RegisterData ===== Message =====

func (*RegisterData) MutableSupportedChannelSchema 

func (m *RegisterData) MutableSupportedChannelSchema() []string

===== Mutable methods for RegisterData ===== Repeated =====

func (*RegisterData) MutableSupportedCompressionAlgorithm 

func (m *RegisterData) MutableSupportedCompressionAlgorithm() []ATBUS_COMPRESSION_ALGORITHM_TYPE

===== Mutable methods for RegisterData ===== Repeated =====

func (*RegisterData) ProtoMessage 

func (*RegisterData) ProtoMessage()

func (*RegisterData) ProtoReflect 

func (x *RegisterData) ProtoReflect() protoreflect.Message

func (*RegisterData) RemoveLastChannels 

func (m *RegisterData) RemoveLastChannels()

===== RemoveLast methods for RegisterData ===== Repeated =====

func (*RegisterData) RemoveLastSupportedChannelSchema 

func (m *RegisterData) RemoveLastSupportedChannelSchema()

===== RemoveLast methods for RegisterData ===== Repeated =====

func (*RegisterData) RemoveLastSupportedCompressionAlgorithm 

func (m *RegisterData) RemoveLastSupportedCompressionAlgorithm()

===== RemoveLast methods for RegisterData ===== Repeated =====

func (*RegisterData) Reset 

func (x *RegisterData) Reset()

func (*RegisterData) ReverseIfNilChannels 

func (m *RegisterData) ReverseIfNilChannels(l int32) []*ChannelData

===== ReverseIfNil methods for RegisterData ===== Repeated =====

func (*RegisterData) ReverseIfNilSupportedChannelSchema 

func (m *RegisterData) ReverseIfNilSupportedChannelSchema(l int32) []string

===== ReverseIfNil methods for RegisterData ===== Repeated =====

func (*RegisterData) ReverseIfNilSupportedCompressionAlgorithm 

func (m *RegisterData) ReverseIfNilSupportedCompressionAlgorithm(l int32) []ATBUS_COMPRESSION_ALGORITHM_TYPE

===== ReverseIfNil methods for RegisterData ===== Repeated =====

func (*RegisterData) String 

func (x *RegisterData) String() string

func (*RegisterData) ToReadonly 

func (m *RegisterData) ToReadonly() *Readonly_RegisterData

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.