Versions in this module Expand all Collapse all v0 v0.1.0 Nov 25, 2023 Changes in this version + var Compression_name = map[int32]string + var Compression_value = map[string]int32 + var File_CanalProtocol_proto protoreflect.FileDescriptor + var PacketType_name = map[int32]string + var PacketType_value = map[string]int32 + type Ack struct + ErrorCodePresent isAck_ErrorCodePresent + ErrorMessage string + func (*Ack) Descriptor() ([]byte, []int) + func (*Ack) ProtoMessage() + func (m *Ack) GetErrorCodePresent() isAck_ErrorCodePresent + func (x *Ack) GetErrorCode() int32 + func (x *Ack) GetErrorMessage() string + func (x *Ack) ProtoReflect() protoreflect.Message + func (x *Ack) Reset() + func (x *Ack) String() string + type Ack_ErrorCode struct + ErrorCode int32 + type ClientAck struct + BatchId int64 + ClientId string + Destination string + func (*ClientAck) Descriptor() ([]byte, []int) + func (*ClientAck) ProtoMessage() + func (x *ClientAck) GetBatchId() int64 + func (x *ClientAck) GetClientId() string + func (x *ClientAck) GetDestination() string + func (x *ClientAck) ProtoReflect() protoreflect.Message + func (x *ClientAck) Reset() + func (x *ClientAck) String() string + type ClientAuth struct + ClientId string + Destination string + Filter string + NetReadTimeoutPresent isClientAuth_NetReadTimeoutPresent + NetWriteTimeoutPresent isClientAuth_NetWriteTimeoutPresent + Password []byte + StartTimestamp int64 + Username string + func (*ClientAuth) Descriptor() ([]byte, []int) + func (*ClientAuth) ProtoMessage() + func (m *ClientAuth) GetNetReadTimeoutPresent() isClientAuth_NetReadTimeoutPresent + func (m *ClientAuth) GetNetWriteTimeoutPresent() isClientAuth_NetWriteTimeoutPresent + func (x *ClientAuth) GetClientId() string + func (x *ClientAuth) GetDestination() string + func (x *ClientAuth) GetFilter() string + func (x *ClientAuth) GetNetReadTimeout() int32 + func (x *ClientAuth) GetNetWriteTimeout() int32 + func (x *ClientAuth) GetPassword() []byte + func (x *ClientAuth) GetStartTimestamp() int64 + func (x *ClientAuth) GetUsername() string + func (x *ClientAuth) ProtoReflect() protoreflect.Message + func (x *ClientAuth) Reset() + func (x *ClientAuth) String() string + type ClientAuth_NetReadTimeout struct + NetReadTimeout int32 + type ClientAuth_NetWriteTimeout struct + NetWriteTimeout int32 + type ClientRollback struct + BatchId int64 + ClientId string + Destination string + func (*ClientRollback) Descriptor() ([]byte, []int) + func (*ClientRollback) ProtoMessage() + func (x *ClientRollback) GetBatchId() int64 + func (x *ClientRollback) GetClientId() string + func (x *ClientRollback) GetDestination() string + func (x *ClientRollback) ProtoReflect() protoreflect.Message + func (x *ClientRollback) Reset() + func (x *ClientRollback) String() string + type Compression int32 + const Compression_COMPRESSIONCOMPATIBLEPROTO2 + const Compression_GZIP + const Compression_LZF + const Compression_NONE + const Compression_ZLIB + func (Compression) Descriptor() protoreflect.EnumDescriptor + func (Compression) EnumDescriptor() ([]byte, []int) + func (Compression) Type() protoreflect.EnumType + func (x Compression) Enum() *Compression + func (x Compression) Number() protoreflect.EnumNumber + func (x Compression) String() string + type Dump struct + Journal string + Position int64 + TimestampPresent isDump_TimestampPresent + func (*Dump) Descriptor() ([]byte, []int) + func (*Dump) ProtoMessage() + func (m *Dump) GetTimestampPresent() isDump_TimestampPresent + func (x *Dump) GetJournal() string + func (x *Dump) GetPosition() int64 + func (x *Dump) GetTimestamp() int64 + func (x *Dump) ProtoReflect() protoreflect.Message + func (x *Dump) Reset() + func (x *Dump) String() string + type Dump_Timestamp struct + Timestamp int64 + type Get struct + AutoAckPresent isGet_AutoAckPresent + ClientId string + Destination string + FetchSize int32 + TimeoutPresent isGet_TimeoutPresent + UnitPresent isGet_UnitPresent + func (*Get) Descriptor() ([]byte, []int) + func (*Get) ProtoMessage() + func (m *Get) GetAutoAckPresent() isGet_AutoAckPresent + func (m *Get) GetTimeoutPresent() isGet_TimeoutPresent + func (m *Get) GetUnitPresent() isGet_UnitPresent + func (x *Get) GetAutoAck() bool + func (x *Get) GetClientId() string + func (x *Get) GetDestination() string + func (x *Get) GetFetchSize() int32 + func (x *Get) GetTimeout() int64 + func (x *Get) GetUnit() int32 + func (x *Get) ProtoReflect() protoreflect.Message + func (x *Get) Reset() + func (x *Get) String() string + type Get_AutoAck struct + AutoAck bool + type Get_Timeout struct + Timeout int64 + type Get_Unit struct + Unit int32 + type Handshake struct + CommunicationEncodingPresent isHandshake_CommunicationEncodingPresent + Seeds []byte + SupportedCompressions Compression + func (*Handshake) Descriptor() ([]byte, []int) + func (*Handshake) ProtoMessage() + func (m *Handshake) GetCommunicationEncodingPresent() isHandshake_CommunicationEncodingPresent + func (x *Handshake) GetCommunicationEncoding() string + func (x *Handshake) GetSeeds() []byte + func (x *Handshake) GetSupportedCompressions() Compression + func (x *Handshake) ProtoReflect() protoreflect.Message + func (x *Handshake) Reset() + func (x *Handshake) String() string + type Handshake_CommunicationEncoding struct + CommunicationEncoding string + type HeartBeat struct + SendTimestamp int64 + StartTimestamp int64 + func (*HeartBeat) Descriptor() ([]byte, []int) + func (*HeartBeat) ProtoMessage() + func (x *HeartBeat) GetSendTimestamp() int64 + func (x *HeartBeat) GetStartTimestamp() int64 + func (x *HeartBeat) ProtoReflect() protoreflect.Message + func (x *HeartBeat) Reset() + func (x *HeartBeat) String() string + type Messages struct + BatchId int64 + Messages [][]byte + func (*Messages) Descriptor() ([]byte, []int) + func (*Messages) ProtoMessage() + func (x *Messages) GetBatchId() int64 + func (x *Messages) GetMessages() [][]byte + func (x *Messages) ProtoReflect() protoreflect.Message + func (x *Messages) Reset() + func (x *Messages) String() string + type Packet struct + Body []byte + CompressionPresent isPacket_CompressionPresent + MagicNumberPresent isPacket_MagicNumberPresent + Type PacketType + VersionPresent isPacket_VersionPresent + func (*Packet) Descriptor() ([]byte, []int) + func (*Packet) ProtoMessage() + func (m *Packet) GetCompressionPresent() isPacket_CompressionPresent + func (m *Packet) GetMagicNumberPresent() isPacket_MagicNumberPresent + func (m *Packet) GetVersionPresent() isPacket_VersionPresent + func (x *Packet) GetBody() []byte + func (x *Packet) GetCompression() Compression + func (x *Packet) GetMagicNumber() int32 + func (x *Packet) GetType() PacketType + func (x *Packet) GetVersion() int32 + func (x *Packet) ProtoReflect() protoreflect.Message + func (x *Packet) Reset() + func (x *Packet) String() string + type PacketType int32 + const PacketType_ACK + const PacketType_CLIENTACK + const PacketType_CLIENTAUTHENTICATION + const PacketType_CLIENTROLLBACK + const PacketType_DUMP + const PacketType_GET + const PacketType_HANDSHAKE + const PacketType_HEARTBEAT + const PacketType_MESSAGES + const PacketType_PACKAGETYPECOMPATIBLEPROTO2 + const PacketType_SHUTDOWN + const PacketType_SUBSCRIPTION + const PacketType_UNSUBSCRIPTION + func (PacketType) Descriptor() protoreflect.EnumDescriptor + func (PacketType) EnumDescriptor() ([]byte, []int) + func (PacketType) Type() protoreflect.EnumType + func (x PacketType) Enum() *PacketType + func (x PacketType) Number() protoreflect.EnumNumber + func (x PacketType) String() string + type Packet_Compression struct + Compression Compression + type Packet_MagicNumber struct + MagicNumber int32 + type Packet_Version struct + Version int32 + type Sub struct + ClientId string + Destination string + Filter string + func (*Sub) Descriptor() ([]byte, []int) + func (*Sub) ProtoMessage() + func (x *Sub) GetClientId() string + func (x *Sub) GetDestination() string + func (x *Sub) GetFilter() string + func (x *Sub) ProtoReflect() protoreflect.Message + func (x *Sub) Reset() + func (x *Sub) String() string + type Unsub struct + ClientId string + Destination string + Filter string + func (*Unsub) Descriptor() ([]byte, []int) + func (*Unsub) ProtoMessage() + func (x *Unsub) GetClientId() string + func (x *Unsub) GetDestination() string + func (x *Unsub) GetFilter() string + func (x *Unsub) ProtoReflect() protoreflect.Message + func (x *Unsub) Reset() + func (x *Unsub) String() string
Go to main page