com_alibaba_otter_canal_protocol

package
v0.0.0-...-4624acb Latest Latest
Warning

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

 Go to latest Published: Dec 24, 2024 License: Apache-2.0 Imports: 5 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCanalProtocol        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCanalProtocol          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCanalProtocol = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthEntryProtocol        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEntryProtocol          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEntryProtocol = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Compression_name = map[int32]string{
	0: "COMPRESSIONCOMPATIBLEPROTO2",
	1: "NONE",
	2: "ZLIB",
	3: "GZIP",
	4: "LZF",
}
View Source 
var Compression_value = map[string]int32{
	"COMPRESSIONCOMPATIBLEPROTO2": 0,
	"NONE":                        1,
	"ZLIB":                        2,
	"GZIP":                        3,
	"LZF":                         4,
}
View Source 
var EntryType_name = map[int32]string{
	0: "ENTRYTYPECOMPATIBLEPROTO2",
	1: "TRANSACTIONBEGIN",
	2: "ROWDATA",
	3: "TRANSACTIONEND",
	4: "ENTRYHEARTBEAT",
	5: "GTIDLOG",
}
View Source 
var EntryType_value = map[string]int32{
	"ENTRYTYPECOMPATIBLEPROTO2": 0,
	"TRANSACTIONBEGIN":          1,
	"ROWDATA":                   2,
	"TRANSACTIONEND":            3,
	"ENTRYHEARTBEAT":            4,
	"GTIDLOG":                   5,
}
View Source 
var EventType_name = map[int32]string{
	0:  "EVENTTYPECOMPATIBLEPROTO2",
	1:  "INSERT",
	2:  "UPDATE",
	3:  "DELETE",
	4:  "CREATE",
	5:  "ALTER",
	6:  "ERASE",
	7:  "QUERY",
	8:  "TRUNCATE",
	9:  "RENAME",
	10: "CINDEX",
	11: "DINDEX",
	12: "GTID",
	13: "XACOMMIT",
	14: "XAROLLBACK",
	15: "MHEARTBEAT",
}
View Source 
var EventType_value = map[string]int32{
	"EVENTTYPECOMPATIBLEPROTO2": 0,
	"INSERT":                    1,
	"UPDATE":                    2,
	"DELETE":                    3,
	"CREATE":                    4,
	"ALTER":                     5,
	"ERASE":                     6,
	"QUERY":                     7,
	"TRUNCATE":                  8,
	"RENAME":                    9,
	"CINDEX":                    10,
	"DINDEX":                    11,
	"GTID":                      12,
	"XACOMMIT":                  13,
	"XAROLLBACK":                14,
	"MHEARTBEAT":                15,
}
View Source 
var PacketType_name = map[int32]string{
	0:  "PACKAGETYPECOMPATIBLEPROTO2",
	1:  "HANDSHAKE",
	2:  "CLIENTAUTHENTICATION",
	3:  "ACK",
	4:  "SUBSCRIPTION",
	5:  "UNSUBSCRIPTION",
	6:  "GET",
	7:  "MESSAGES",
	8:  "CLIENTACK",
	9:  "SHUTDOWN",
	10: "DUMP",
	11: "HEARTBEAT",
	12: "CLIENTROLLBACK",
}
View Source 
var PacketType_value = map[string]int32{
	"PACKAGETYPECOMPATIBLEPROTO2": 0,
	"HANDSHAKE":                   1,
	"CLIENTAUTHENTICATION":        2,
	"ACK":                         3,
	"SUBSCRIPTION":                4,
	"UNSUBSCRIPTION":              5,
	"GET":                         6,
	"MESSAGES":                    7,
	"CLIENTACK":                   8,
	"SHUTDOWN":                    9,
	"DUMP":                        10,
	"HEARTBEAT":                   11,
	"CLIENTROLLBACK":              12,
}
View Source 
var Type_name = map[int32]string{
	0: "TYPECOMPATIBLEPROTO2",
	1: "ORACLE",
	2: "MYSQL",
	3: "PGSQL",
}
View Source 
var Type_value = map[string]int32{
	"TYPECOMPATIBLEPROTO2": 0,
	"ORACLE":               1,
	"MYSQL":                2,
	"PGSQL":                3,
}

Functions

This section is empty.

Types

type Ack 

type Ack struct {
	// [default = 0]
	//
	// Types that are valid to be assigned to ErrorCodePresent:
	//
	//	*Ack_ErrorCode
	ErrorCodePresent isAck_ErrorCodePresent `protobuf_oneof:"error_code_present"`
	ErrorMessage     string                 `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
}

func (*Ack) Descriptor 

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

func (*Ack) GetErrorCode 

func (m *Ack) GetErrorCode() int32

func (*Ack) GetErrorCodePresent 

func (m *Ack) GetErrorCodePresent() isAck_ErrorCodePresent

func (*Ack) GetErrorMessage 

func (m *Ack) GetErrorMessage() string

func (*Ack) Marshal 

func (m *Ack) Marshal() (dAtA []byte, err error)

func (*Ack) MarshalTo 

func (m *Ack) MarshalTo(dAtA []byte) (int, error)

func (*Ack) MarshalToSizedBuffer 

func (m *Ack) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Ack) ProtoMessage 

func (*Ack) ProtoMessage()

func (*Ack) Reset 

func (m *Ack) Reset()

func (*Ack) Size 

func (m *Ack) Size() (n int)

func (*Ack) String 

func (m *Ack) String() string

func (*Ack) Unmarshal 

func (m *Ack) Unmarshal(dAtA []byte) error

func (*Ack) XXX_DiscardUnknown 

func (m *Ack) XXX_DiscardUnknown()

func (*Ack) XXX_Marshal 

func (m *Ack) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Ack) XXX_Merge 

func (m *Ack) XXX_Merge(src proto.Message)

func (*Ack) XXX_OneofWrappers 

func (*Ack) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Ack) XXX_Size 

func (m *Ack) XXX_Size() int

func (*Ack) XXX_Unmarshal 

func (m *Ack) XXX_Unmarshal(b []byte) error

type Ack_ErrorCode 

type Ack_ErrorCode struct {
	ErrorCode int32 `protobuf:"varint,1,opt,name=error_code,json=errorCode,proto3,oneof" json:"error_code,omitempty"`
}

func (*Ack_ErrorCode) MarshalTo 

func (m *Ack_ErrorCode) MarshalTo(dAtA []byte) (int, error)

func (*Ack_ErrorCode) MarshalToSizedBuffer 

func (m *Ack_ErrorCode) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Ack_ErrorCode) Size 

func (m *Ack_ErrorCode) Size() (n int)

type ClientAck 

type ClientAck struct {
	Destination string `protobuf:"bytes,1,opt,name=destination,proto3" json:"destination,omitempty"`
	ClientId    string `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	BatchId     int64  `protobuf:"varint,3,opt,name=batch_id,json=batchId,proto3" json:"batch_id,omitempty"`
}

func (*ClientAck) Descriptor 

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

func (*ClientAck) GetBatchId 

func (m *ClientAck) GetBatchId() int64

func (*ClientAck) GetClientId 

func (m *ClientAck) GetClientId() string

func (*ClientAck) GetDestination 

func (m *ClientAck) GetDestination() string

func (*ClientAck) Marshal 

func (m *ClientAck) Marshal() (dAtA []byte, err error)

func (*ClientAck) MarshalTo 

func (m *ClientAck) MarshalTo(dAtA []byte) (int, error)

func (*ClientAck) MarshalToSizedBuffer 

func (m *ClientAck) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientAck) ProtoMessage 

func (*ClientAck) ProtoMessage()

func (*ClientAck) Reset 

func (m *ClientAck) Reset()

func (*ClientAck) Size 

func (m *ClientAck) Size() (n int)

func (*ClientAck) String 

func (m *ClientAck) String() string

func (*ClientAck) Unmarshal 

func (m *ClientAck) Unmarshal(dAtA []byte) error

func (*ClientAck) XXX_DiscardUnknown 

func (m *ClientAck) XXX_DiscardUnknown()

func (*ClientAck) XXX_Marshal 

func (m *ClientAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientAck) XXX_Merge 

func (m *ClientAck) XXX_Merge(src proto.Message)

func (*ClientAck) XXX_Size 

func (m *ClientAck) XXX_Size() int

func (*ClientAck) XXX_Unmarshal 

func (m *ClientAck) XXX_Unmarshal(b []byte) error

type ClientAuth 

type ClientAuth struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password []byte `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// [default = 0]
	//
	// Types that are valid to be assigned to NetReadTimeoutPresent:
	//
	//	*ClientAuth_NetReadTimeout
	NetReadTimeoutPresent isClientAuth_NetReadTimeoutPresent `protobuf_oneof:"net_read_timeout_present"`
	// [default = 0];
	//
	// Types that are valid to be assigned to NetWriteTimeoutPresent:
	//
	//	*ClientAuth_NetWriteTimeout
	NetWriteTimeoutPresent isClientAuth_NetWriteTimeoutPresent `protobuf_oneof:"net_write_timeout_present"`
	Destination            string                              `protobuf:"bytes,5,opt,name=destination,proto3" json:"destination,omitempty"`
	ClientId               string                              `protobuf:"bytes,6,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Filter                 string                              `protobuf:"bytes,7,opt,name=filter,proto3" json:"filter,omitempty"`
	StartTimestamp         int64                               `protobuf:"varint,8,opt,name=start_timestamp,json=startTimestamp,proto3" json:"start_timestamp,omitempty"`
}

client authentication

func (*ClientAuth) Descriptor 

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

func (*ClientAuth) GetClientId 

func (m *ClientAuth) GetClientId() string

func (*ClientAuth) GetDestination 

func (m *ClientAuth) GetDestination() string

func (*ClientAuth) GetFilter 

func (m *ClientAuth) GetFilter() string

func (*ClientAuth) GetNetReadTimeout 

func (m *ClientAuth) GetNetReadTimeout() int32

func (*ClientAuth) GetNetReadTimeoutPresent 

func (m *ClientAuth) GetNetReadTimeoutPresent() isClientAuth_NetReadTimeoutPresent

func (*ClientAuth) GetNetWriteTimeout 

func (m *ClientAuth) GetNetWriteTimeout() int32

func (*ClientAuth) GetNetWriteTimeoutPresent 

func (m *ClientAuth) GetNetWriteTimeoutPresent() isClientAuth_NetWriteTimeoutPresent

func (*ClientAuth) GetPassword 

func (m *ClientAuth) GetPassword() []byte

func (*ClientAuth) GetStartTimestamp 

func (m *ClientAuth) GetStartTimestamp() int64

func (*ClientAuth) GetUsername 

func (m *ClientAuth) GetUsername() string

func (*ClientAuth) Marshal 

func (m *ClientAuth) Marshal() (dAtA []byte, err error)

func (*ClientAuth) MarshalTo 

func (m *ClientAuth) MarshalTo(dAtA []byte) (int, error)

func (*ClientAuth) MarshalToSizedBuffer 

func (m *ClientAuth) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientAuth) ProtoMessage 

func (*ClientAuth) ProtoMessage()

func (*ClientAuth) Reset 

func (m *ClientAuth) Reset()

func (*ClientAuth) Size 

func (m *ClientAuth) Size() (n int)

func (*ClientAuth) String 

func (m *ClientAuth) String() string

func (*ClientAuth) Unmarshal 

func (m *ClientAuth) Unmarshal(dAtA []byte) error

func (*ClientAuth) XXX_DiscardUnknown 

func (m *ClientAuth) XXX_DiscardUnknown()

func (*ClientAuth) XXX_Marshal 

func (m *ClientAuth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientAuth) XXX_Merge 

func (m *ClientAuth) XXX_Merge(src proto.Message)

func (*ClientAuth) XXX_OneofWrappers 

func (*ClientAuth) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ClientAuth) XXX_Size 

func (m *ClientAuth) XXX_Size() int

func (*ClientAuth) XXX_Unmarshal 

func (m *ClientAuth) XXX_Unmarshal(b []byte) error

type ClientAuth_NetReadTimeout 

type ClientAuth_NetReadTimeout struct {
	NetReadTimeout int32 `protobuf:"varint,3,opt,name=net_read_timeout,json=netReadTimeout,proto3,oneof" json:"net_read_timeout,omitempty"`
}

func (*ClientAuth_NetReadTimeout) MarshalTo 

func (m *ClientAuth_NetReadTimeout) MarshalTo(dAtA []byte) (int, error)

func (*ClientAuth_NetReadTimeout) MarshalToSizedBuffer 

func (m *ClientAuth_NetReadTimeout) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientAuth_NetReadTimeout) Size 

func (m *ClientAuth_NetReadTimeout) Size() (n int)

type ClientAuth_NetWriteTimeout 

type ClientAuth_NetWriteTimeout struct {
	NetWriteTimeout int32 `protobuf:"varint,4,opt,name=net_write_timeout,json=netWriteTimeout,proto3,oneof" json:"net_write_timeout,omitempty"`
}

func (*ClientAuth_NetWriteTimeout) MarshalTo 

func (m *ClientAuth_NetWriteTimeout) MarshalTo(dAtA []byte) (int, error)

func (*ClientAuth_NetWriteTimeout) MarshalToSizedBuffer 

func (m *ClientAuth_NetWriteTimeout) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientAuth_NetWriteTimeout) Size 

func (m *ClientAuth_NetWriteTimeout) Size() (n int)

type ClientRollback 

type ClientRollback struct {
	Destination string `protobuf:"bytes,1,opt,name=destination,proto3" json:"destination,omitempty"`
	ClientId    string `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	BatchId     int64  `protobuf:"varint,3,opt,name=batch_id,json=batchId,proto3" json:"batch_id,omitempty"`
}

func (*ClientRollback) Descriptor 

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

func (*ClientRollback) GetBatchId 

func (m *ClientRollback) GetBatchId() int64

func (*ClientRollback) GetClientId 

func (m *ClientRollback) GetClientId() string

func (*ClientRollback) GetDestination 

func (m *ClientRollback) GetDestination() string

func (*ClientRollback) Marshal 

func (m *ClientRollback) Marshal() (dAtA []byte, err error)

func (*ClientRollback) MarshalTo 

func (m *ClientRollback) MarshalTo(dAtA []byte) (int, error)

func (*ClientRollback) MarshalToSizedBuffer 

func (m *ClientRollback) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientRollback) ProtoMessage 

func (*ClientRollback) ProtoMessage()

func (*ClientRollback) Reset 

func (m *ClientRollback) Reset()

func (*ClientRollback) Size 

func (m *ClientRollback) Size() (n int)

func (*ClientRollback) String 

func (m *ClientRollback) String() string

func (*ClientRollback) Unmarshal 

func (m *ClientRollback) Unmarshal(dAtA []byte) error

func (*ClientRollback) XXX_DiscardUnknown 

func (m *ClientRollback) XXX_DiscardUnknown()

func (*ClientRollback) XXX_Marshal 

func (m *ClientRollback) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientRollback) XXX_Merge 

func (m *ClientRollback) XXX_Merge(src proto.Message)

func (*ClientRollback) XXX_Size 

func (m *ClientRollback) XXX_Size() int

func (*ClientRollback) XXX_Unmarshal 

func (m *ClientRollback) XXX_Unmarshal(b []byte) error

type Column 

type Column struct {
	// *字段下标*
	Index int32 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	// *字段java中类型*
	SqlType int32 `protobuf:"varint,2,opt,name=sqlType,proto3" json:"sqlType,omitempty"`
	// *字段名称(忽略大小写)，在mysql中是没有的*
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// *是否是主键*
	IsKey bool `protobuf:"varint,4,opt,name=isKey,proto3" json:"isKey,omitempty"`
	// *如果EventType=UPDATE,用于标识这个字段值是否有修改*
	Updated bool `protobuf:"varint,5,opt,name=updated,proto3" json:"updated,omitempty"`
	// [default = false]
	//
	// Types that are valid to be assigned to IsNullPresent:
	//
	//	*Column_IsNull
	IsNullPresent isColumn_IsNullPresent `protobuf_oneof:"isNull_present"`
	// *预留扩展*
	Props []*Pair `protobuf:"bytes,7,rep,name=props,proto3" json:"props,omitempty"`
	// * 字段值,timestamp,Datetime是一个时间格式的文本 *
	Value string `protobuf:"bytes,8,opt,name=value,proto3" json:"value,omitempty"`
	// * 对应数据对象原始长度 *
	Length int32 `protobuf:"varint,9,opt,name=length,proto3" json:"length,omitempty"`
	// *字段mysql类型*
	MysqlType string `protobuf:"bytes,10,opt,name=mysqlType,proto3" json:"mysqlType,omitempty"`
}

*每个字段的数据结构*

func (*Column) Descriptor 

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

func (*Column) GetIndex 

func (m *Column) GetIndex() int32

func (*Column) GetIsKey 

func (m *Column) GetIsKey() bool

func (*Column) GetIsNull 

func (m *Column) GetIsNull() bool

func (*Column) GetIsNullPresent 

func (m *Column) GetIsNullPresent() isColumn_IsNullPresent

func (*Column) GetLength 

func (m *Column) GetLength() int32

func (*Column) GetMysqlType 

func (m *Column) GetMysqlType() string

func (*Column) GetName 

func (m *Column) GetName() string

func (*Column) GetProps 

func (m *Column) GetProps() []*Pair

func (*Column) GetSqlType 

func (m *Column) GetSqlType() int32

func (*Column) GetUpdated 

func (m *Column) GetUpdated() bool

func (*Column) GetValue 

func (m *Column) GetValue() string

func (*Column) Marshal 

func (m *Column) Marshal() (dAtA []byte, err error)

func (*Column) MarshalTo 

func (m *Column) MarshalTo(dAtA []byte) (int, error)

func (*Column) MarshalToSizedBuffer 

func (m *Column) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Column) ProtoMessage 

func (*Column) ProtoMessage()

func (*Column) Reset 

func (m *Column) Reset()

func (*Column) Size 

func (m *Column) Size() (n int)

func (*Column) String 

func (m *Column) String() string

func (*Column) Unmarshal 

func (m *Column) Unmarshal(dAtA []byte) error

func (*Column) XXX_DiscardUnknown 

func (m *Column) XXX_DiscardUnknown()

func (*Column) XXX_Marshal 

func (m *Column) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Column) XXX_Merge 

func (m *Column) XXX_Merge(src proto.Message)

func (*Column) XXX_OneofWrappers 

func (*Column) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Column) XXX_Size 

func (m *Column) XXX_Size() int

func (*Column) XXX_Unmarshal 

func (m *Column) XXX_Unmarshal(b []byte) error

type Column_IsNull 

type Column_IsNull struct {
	IsNull bool `protobuf:"varint,6,opt,name=isNull,proto3,oneof" json:"isNull,omitempty"`
}

func (*Column_IsNull) MarshalTo 

func (m *Column_IsNull) MarshalTo(dAtA []byte) (int, error)

func (*Column_IsNull) MarshalToSizedBuffer 

func (m *Column_IsNull) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Column_IsNull) Size 

func (m *Column_IsNull) Size() (n int)

type Compression 

type Compression int32
const (
	Compression_COMPRESSIONCOMPATIBLEPROTO2 Compression = 0
	Compression_NONE                        Compression = 1
	Compression_ZLIB                        Compression = 2
	Compression_GZIP                        Compression = 3
	Compression_LZF                         Compression = 4
)

func (Compression) EnumDescriptor 

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

func (Compression) String 

func (x Compression) String() string

type Dump 

type Dump struct {
	Journal  string `protobuf:"bytes,1,opt,name=journal,proto3" json:"journal,omitempty"`
	Position int64  `protobuf:"varint,2,opt,name=position,proto3" json:"position,omitempty"`
	// [default = 0]
	//
	// Types that are valid to be assigned to TimestampPresent:
	//
	//	*Dump_Timestamp
	TimestampPresent isDump_TimestampPresent `protobuf_oneof:"timestamp_present"`
}

TBD when new packets are required

func (*Dump) Descriptor 

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

func (*Dump) GetJournal 

func (m *Dump) GetJournal() string

func (*Dump) GetPosition 

func (m *Dump) GetPosition() int64

func (*Dump) GetTimestamp 

func (m *Dump) GetTimestamp() int64

func (*Dump) GetTimestampPresent 

func (m *Dump) GetTimestampPresent() isDump_TimestampPresent

func (*Dump) Marshal 

func (m *Dump) Marshal() (dAtA []byte, err error)

func (*Dump) MarshalTo 

func (m *Dump) MarshalTo(dAtA []byte) (int, error)

func (*Dump) MarshalToSizedBuffer 

func (m *Dump) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Dump) ProtoMessage 

func (*Dump) ProtoMessage()

func (*Dump) Reset 

func (m *Dump) Reset()

func (*Dump) Size 

func (m *Dump) Size() (n int)

func (*Dump) String 

func (m *Dump) String() string

func (*Dump) Unmarshal 

func (m *Dump) Unmarshal(dAtA []byte) error

func (*Dump) XXX_DiscardUnknown 

func (m *Dump) XXX_DiscardUnknown()

func (*Dump) XXX_Marshal 

func (m *Dump) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Dump) XXX_Merge 

func (m *Dump) XXX_Merge(src proto.Message)

func (*Dump) XXX_OneofWrappers 

func (*Dump) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Dump) XXX_Size 

func (m *Dump) XXX_Size() int

func (*Dump) XXX_Unmarshal 

func (m *Dump) XXX_Unmarshal(b []byte) error

type Dump_Timestamp 

type Dump_Timestamp struct {
	Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3,oneof" json:"timestamp,omitempty"`
}

func (*Dump_Timestamp) MarshalTo 

func (m *Dump_Timestamp) MarshalTo(dAtA []byte) (int, error)

func (*Dump_Timestamp) MarshalToSizedBuffer 

func (m *Dump_Timestamp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Dump_Timestamp) Size 

func (m *Dump_Timestamp) Size() (n int)

type Entry 

type Entry struct {
	// *协议头部信息*
	Header *Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// /**打散后的事件类型**/ [default = ROWDATA]
	//
	// Types that are valid to be assigned to EntryTypePresent:
	//
	//	*Entry_EntryType
	EntryTypePresent isEntry_EntryTypePresent `protobuf_oneof:"entryType_present"`
	// *传输的二进制数组*
	StoreValue []byte `protobuf:"bytes,3,opt,name=storeValue,proto3" json:"storeValue,omitempty"`
}

*************************************************************** message model 如果要在Enum中新增类型，确保以前的类型的下标值不变. **************************************************************

func (*Entry) Descriptor 

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

func (*Entry) GetEntryType 

func (m *Entry) GetEntryType() EntryType

func (*Entry) GetEntryTypePresent 

func (m *Entry) GetEntryTypePresent() isEntry_EntryTypePresent

func (*Entry) GetHeader 

func (m *Entry) GetHeader() *Header

func (*Entry) GetStoreValue 

func (m *Entry) GetStoreValue() []byte

func (*Entry) Marshal 

func (m *Entry) Marshal() (dAtA []byte, err error)

func (*Entry) MarshalTo 

func (m *Entry) MarshalTo(dAtA []byte) (int, error)

func (*Entry) MarshalToSizedBuffer 

func (m *Entry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Entry) ProtoMessage 

func (*Entry) ProtoMessage()

func (*Entry) Reset 

func (m *Entry) Reset()

func (*Entry) Size 

func (m *Entry) Size() (n int)

func (*Entry) String 

func (m *Entry) String() string

func (*Entry) Unmarshal 

func (m *Entry) Unmarshal(dAtA []byte) error

func (*Entry) XXX_DiscardUnknown 

func (m *Entry) XXX_DiscardUnknown()

func (*Entry) XXX_Marshal 

func (m *Entry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Entry) XXX_Merge 

func (m *Entry) XXX_Merge(src proto.Message)

func (*Entry) XXX_OneofWrappers 

func (*Entry) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Entry) XXX_Size 

func (m *Entry) XXX_Size() int

func (*Entry) XXX_Unmarshal 

func (m *Entry) XXX_Unmarshal(b []byte) error

type EntryType 

type EntryType int32

*打散后的事件类型，主要用于标识事务的开始，变更数据，结束* 

const (
	EntryType_ENTRYTYPECOMPATIBLEPROTO2 EntryType = 0
	EntryType_TRANSACTIONBEGIN          EntryType = 1
	EntryType_ROWDATA                   EntryType = 2
	EntryType_TRANSACTIONEND            EntryType = 3
	//* 心跳类型，内部使用，外部暂不可见，可忽略 *
	EntryType_ENTRYHEARTBEAT EntryType = 4
	EntryType_GTIDLOG        EntryType = 5
)

func (EntryType) EnumDescriptor 

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

func (EntryType) String 

func (x EntryType) String() string

type Entry_EntryType 

type Entry_EntryType struct {
	EntryType EntryType `` /* 126-byte string literal not displayed */
}

func (*Entry_EntryType) MarshalTo 

func (m *Entry_EntryType) MarshalTo(dAtA []byte) (int, error)

func (*Entry_EntryType) MarshalToSizedBuffer 

func (m *Entry_EntryType) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Entry_EntryType) Size 

func (m *Entry_EntryType) Size() (n int)

type EventType 

type EventType int32

* 事件类型 * 

const (
	EventType_EVENTTYPECOMPATIBLEPROTO2 EventType = 0
	EventType_INSERT                    EventType = 1
	EventType_UPDATE                    EventType = 2
	EventType_DELETE                    EventType = 3
	EventType_CREATE                    EventType = 4
	EventType_ALTER                     EventType = 5
	EventType_ERASE                     EventType = 6
	EventType_QUERY                     EventType = 7
	EventType_TRUNCATE                  EventType = 8
	EventType_RENAME                    EventType = 9
	//*CREATE INDEX*
	EventType_CINDEX EventType = 10
	EventType_DINDEX EventType = 11
	EventType_GTID   EventType = 12
	//* XA *
	EventType_XACOMMIT   EventType = 13
	EventType_XAROLLBACK EventType = 14
	//* MASTER HEARTBEAT *
	EventType_MHEARTBEAT EventType = 15
)

func (EventType) EnumDescriptor 

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

func (EventType) String 

func (x EventType) String() string

type Get 

type Get struct {
	Destination string `protobuf:"bytes,1,opt,name=destination,proto3" json:"destination,omitempty"`
	ClientId    string `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	FetchSize   int32  `protobuf:"varint,3,opt,name=fetch_size,json=fetchSize,proto3" json:"fetch_size,omitempty"`
	// [default = -1]
	//
	// Types that are valid to be assigned to TimeoutPresent:
	//
	//	*Get_Timeout
	TimeoutPresent isGet_TimeoutPresent `protobuf_oneof:"timeout_present"`
	// [default = 2]
	//
	// Types that are valid to be assigned to UnitPresent:
	//
	//	*Get_Unit
	UnitPresent isGet_UnitPresent `protobuf_oneof:"unit_present"`
	// [default = false]
	//
	// Types that are valid to be assigned to AutoAckPresent:
	//
	//	*Get_AutoAck
	AutoAckPresent isGet_AutoAckPresent `protobuf_oneof:"auto_ack_present"`
}

PullRequest

func (*Get) Descriptor 

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

func (*Get) GetAutoAck 

func (m *Get) GetAutoAck() bool

func (*Get) GetAutoAckPresent 

func (m *Get) GetAutoAckPresent() isGet_AutoAckPresent

func (*Get) GetClientId 

func (m *Get) GetClientId() string

func (*Get) GetDestination 

func (m *Get) GetDestination() string

func (*Get) GetFetchSize 

func (m *Get) GetFetchSize() int32

func (*Get) GetTimeout 

func (m *Get) GetTimeout() int64

func (*Get) GetTimeoutPresent 

func (m *Get) GetTimeoutPresent() isGet_TimeoutPresent

func (*Get) GetUnit 

func (m *Get) GetUnit() int32

func (*Get) GetUnitPresent 

func (m *Get) GetUnitPresent() isGet_UnitPresent

func (*Get) Marshal 

func (m *Get) Marshal() (dAtA []byte, err error)

func (*Get) MarshalTo 

func (m *Get) MarshalTo(dAtA []byte) (int, error)

func (*Get) MarshalToSizedBuffer 

func (m *Get) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Get) ProtoMessage 

func (*Get) ProtoMessage()

func (*Get) Reset 

func (m *Get) Reset()

func (*Get) Size 

func (m *Get) Size() (n int)

func (*Get) String 

func (m *Get) String() string

func (*Get) Unmarshal 

func (m *Get) Unmarshal(dAtA []byte) error

func (*Get) XXX_DiscardUnknown 

func (m *Get) XXX_DiscardUnknown()

func (*Get) XXX_Marshal 

func (m *Get) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Get) XXX_Merge 

func (m *Get) XXX_Merge(src proto.Message)

func (*Get) XXX_OneofWrappers 

func (*Get) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Get) XXX_Size 

func (m *Get) XXX_Size() int

func (*Get) XXX_Unmarshal 

func (m *Get) XXX_Unmarshal(b []byte) error

type Get_AutoAck 

type Get_AutoAck struct {
	AutoAck bool `protobuf:"varint,6,opt,name=auto_ack,json=autoAck,proto3,oneof" json:"auto_ack,omitempty"`
}

func (*Get_AutoAck) MarshalTo 

func (m *Get_AutoAck) MarshalTo(dAtA []byte) (int, error)

func (*Get_AutoAck) MarshalToSizedBuffer 

func (m *Get_AutoAck) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Get_AutoAck) Size 

func (m *Get_AutoAck) Size() (n int)

type Get_Timeout 

type Get_Timeout struct {
	Timeout int64 `protobuf:"varint,4,opt,name=timeout,proto3,oneof" json:"timeout,omitempty"`
}

func (*Get_Timeout) MarshalTo 

func (m *Get_Timeout) MarshalTo(dAtA []byte) (int, error)

func (*Get_Timeout) MarshalToSizedBuffer 

func (m *Get_Timeout) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Get_Timeout) Size 

func (m *Get_Timeout) Size() (n int)

type Get_Unit 

type Get_Unit struct {
	Unit int32 `protobuf:"varint,5,opt,name=unit,proto3,oneof" json:"unit,omitempty"`
}

func (*Get_Unit) MarshalTo 

func (m *Get_Unit) MarshalTo(dAtA []byte) (int, error)

func (*Get_Unit) MarshalToSizedBuffer 

func (m *Get_Unit) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Get_Unit) Size 

func (m *Get_Unit) Size() (n int)

type Handshake 

type Handshake struct {
	//	[default = "utf8"];
	//
	// Types that are valid to be assigned to CommunicationEncodingPresent:
	//
	//	*Handshake_CommunicationEncoding
	CommunicationEncodingPresent isHandshake_CommunicationEncodingPresent `protobuf_oneof:"communication_encoding_present"`
	Seeds                        []byte                                   `protobuf:"bytes,2,opt,name=seeds,proto3" json:"seeds,omitempty"`
	SupportedCompressions        Compression                              `` /* 175-byte string literal not displayed */
}

func (*Handshake) Descriptor 

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

func (*Handshake) GetCommunicationEncoding 

func (m *Handshake) GetCommunicationEncoding() string

func (*Handshake) GetCommunicationEncodingPresent 

func (m *Handshake) GetCommunicationEncodingPresent() isHandshake_CommunicationEncodingPresent

func (*Handshake) GetSeeds 

func (m *Handshake) GetSeeds() []byte

func (*Handshake) GetSupportedCompressions 

func (m *Handshake) GetSupportedCompressions() Compression

func (*Handshake) Marshal 

func (m *Handshake) Marshal() (dAtA []byte, err error)

func (*Handshake) MarshalTo 

func (m *Handshake) MarshalTo(dAtA []byte) (int, error)

func (*Handshake) MarshalToSizedBuffer 

func (m *Handshake) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Handshake) ProtoMessage 

func (*Handshake) ProtoMessage()

func (*Handshake) Reset 

func (m *Handshake) Reset()

func (*Handshake) Size 

func (m *Handshake) Size() (n int)

func (*Handshake) String 

func (m *Handshake) String() string

func (*Handshake) Unmarshal 

func (m *Handshake) Unmarshal(dAtA []byte) error

func (*Handshake) XXX_DiscardUnknown 

func (m *Handshake) XXX_DiscardUnknown()

func (*Handshake) XXX_Marshal 

func (m *Handshake) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Handshake) XXX_Merge 

func (m *Handshake) XXX_Merge(src proto.Message)

func (*Handshake) XXX_OneofWrappers 

func (*Handshake) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Handshake) XXX_Size 

func (m *Handshake) XXX_Size() int

func (*Handshake) XXX_Unmarshal 

func (m *Handshake) XXX_Unmarshal(b []byte) error

type Handshake_CommunicationEncoding 

type Handshake_CommunicationEncoding struct {
	CommunicationEncoding string `` /* 130-byte string literal not displayed */
}

func (*Handshake_CommunicationEncoding) MarshalTo 

func (m *Handshake_CommunicationEncoding) MarshalTo(dAtA []byte) (int, error)

func (*Handshake_CommunicationEncoding) MarshalToSizedBuffer 

func (m *Handshake_CommunicationEncoding) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Handshake_CommunicationEncoding) Size 

func (m *Handshake_CommunicationEncoding) Size() (n int)
type Header struct {
	// [default = 1]
	//
	// Types that are valid to be assigned to VersionPresent:
	//
	//	*Header_Version
	VersionPresent isHeader_VersionPresent `protobuf_oneof:"version_present"`
	// *binlog/redolog 文件名*
	LogfileName string `protobuf:"bytes,2,opt,name=logfileName,proto3" json:"logfileName,omitempty"`
	// *binlog/redolog 文件的偏移位置*
	LogfileOffset int64 `protobuf:"varint,3,opt,name=logfileOffset,proto3" json:"logfileOffset,omitempty"`
	// *服务端serverId*
	ServerId int64 `protobuf:"varint,4,opt,name=serverId,proto3" json:"serverId,omitempty"`
	// * 变更数据的编码 *
	ServerenCode string `protobuf:"bytes,5,opt,name=serverenCode,proto3" json:"serverenCode,omitempty"`
	// *变更数据的执行时间 *
	ExecuteTime int64 `protobuf:"varint,6,opt,name=executeTime,proto3" json:"executeTime,omitempty"`
	// [default = MYSQL]
	//
	// Types that are valid to be assigned to SourceTypePresent:
	//
	//	*Header_SourceType
	SourceTypePresent isHeader_SourceTypePresent `protobuf_oneof:"sourceType_present"`
	// * 变更数据的schemaname*
	SchemaName string `protobuf:"bytes,8,opt,name=schemaName,proto3" json:"schemaName,omitempty"`
	// *变更数据的tablename*
	TableName string `protobuf:"bytes,9,opt,name=tableName,proto3" json:"tableName,omitempty"`
	// *每个event的长度*
	EventLength int64 `protobuf:"varint,10,opt,name=eventLength,proto3" json:"eventLength,omitempty"`
	// [default = UPDATE]
	//
	// Types that are valid to be assigned to EventTypePresent:
	//
	//	*Header_EventType
	EventTypePresent isHeader_EventTypePresent `protobuf_oneof:"eventType_present"`
	// *预留扩展*
	Props []*Pair `protobuf:"bytes,12,rep,name=props,proto3" json:"props,omitempty"`
	// *当前事务的gitd*
	Gtid string `protobuf:"bytes,13,opt,name=gtid,proto3" json:"gtid,omitempty"`
}

*message Header*

func (*Header) Descriptor 

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

func (*Header) GetEventLength 

func (m *Header) GetEventLength() int64

func (*Header) GetEventType 

func (m *Header) GetEventType() EventType

func (*Header) GetEventTypePresent 

func (m *Header) GetEventTypePresent() isHeader_EventTypePresent

func (*Header) GetExecuteTime 

func (m *Header) GetExecuteTime() int64

func (*Header) GetGtid 

func (m *Header) GetGtid() string

func (*Header) GetLogfileName 

func (m *Header) GetLogfileName() string

func (*Header) GetLogfileOffset 

func (m *Header) GetLogfileOffset() int64

func (*Header) GetProps 

func (m *Header) GetProps() []*Pair

func (*Header) GetSchemaName 

func (m *Header) GetSchemaName() string

func (*Header) GetServerId 

func (m *Header) GetServerId() int64

func (*Header) GetServerenCode 

func (m *Header) GetServerenCode() string

func (*Header) GetSourceType 

func (m *Header) GetSourceType() Type

func (*Header) GetSourceTypePresent 

func (m *Header) GetSourceTypePresent() isHeader_SourceTypePresent

func (*Header) GetTableName 

func (m *Header) GetTableName() string

func (*Header) GetVersion 

func (m *Header) GetVersion() int32

func (*Header) GetVersionPresent 

func (m *Header) GetVersionPresent() isHeader_VersionPresent

func (*Header) Marshal 

func (m *Header) Marshal() (dAtA []byte, err error)

func (*Header) MarshalTo 

func (m *Header) MarshalTo(dAtA []byte) (int, error)

func (*Header) MarshalToSizedBuffer 

func (m *Header) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) Reset 

func (m *Header) Reset()

func (*Header) Size 

func (m *Header) Size() (n int)

func (*Header) String 

func (m *Header) String() string

func (*Header) Unmarshal 

func (m *Header) Unmarshal(dAtA []byte) error

func (*Header) XXX_DiscardUnknown 

func (m *Header) XXX_DiscardUnknown()

func (*Header) XXX_Marshal 

func (m *Header) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Header) XXX_Merge 

func (m *Header) XXX_Merge(src proto.Message)

func (*Header) XXX_OneofWrappers 

func (*Header) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Header) XXX_Size 

func (m *Header) XXX_Size() int

func (*Header) XXX_Unmarshal 

func (m *Header) XXX_Unmarshal(b []byte) error

type Header_EventType 

type Header_EventType struct {
	EventType EventType `` /* 127-byte string literal not displayed */
}

func (*Header_EventType) MarshalTo 

func (m *Header_EventType) MarshalTo(dAtA []byte) (int, error)

func (*Header_EventType) MarshalToSizedBuffer 

func (m *Header_EventType) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Header_EventType) Size 

func (m *Header_EventType) Size() (n int)

type Header_SourceType 

type Header_SourceType struct {
	SourceType Type `protobuf:"varint,7,opt,name=sourceType,proto3,enum=com.alibaba.otter.canal.protocol.Type,oneof" json:"sourceType,omitempty"`
}

func (*Header_SourceType) MarshalTo 

func (m *Header_SourceType) MarshalTo(dAtA []byte) (int, error)

func (*Header_SourceType) MarshalToSizedBuffer 

func (m *Header_SourceType) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Header_SourceType) Size 

func (m *Header_SourceType) Size() (n int)

type Header_Version 

type Header_Version struct {
	Version int32 `protobuf:"varint,1,opt,name=version,proto3,oneof" json:"version,omitempty"`
}

func (*Header_Version) MarshalTo 

func (m *Header_Version) MarshalTo(dAtA []byte) (int, error)

func (*Header_Version) MarshalToSizedBuffer 

func (m *Header_Version) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Header_Version) Size 

func (m *Header_Version) Size() (n int)

type HeartBeat 

type HeartBeat struct {
	SendTimestamp  int64 `protobuf:"varint,1,opt,name=send_timestamp,json=sendTimestamp,proto3" json:"send_timestamp,omitempty"`
	StartTimestamp int64 `protobuf:"varint,2,opt,name=start_timestamp,json=startTimestamp,proto3" json:"start_timestamp,omitempty"`
}

func (*HeartBeat) Descriptor 

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

func (*HeartBeat) GetSendTimestamp 

func (m *HeartBeat) GetSendTimestamp() int64

func (*HeartBeat) GetStartTimestamp 

func (m *HeartBeat) GetStartTimestamp() int64

func (*HeartBeat) Marshal 

func (m *HeartBeat) Marshal() (dAtA []byte, err error)

func (*HeartBeat) MarshalTo 

func (m *HeartBeat) MarshalTo(dAtA []byte) (int, error)

func (*HeartBeat) MarshalToSizedBuffer 

func (m *HeartBeat) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HeartBeat) ProtoMessage 

func (*HeartBeat) ProtoMessage()

func (*HeartBeat) Reset 

func (m *HeartBeat) Reset()

func (*HeartBeat) Size 

func (m *HeartBeat) Size() (n int)

func (*HeartBeat) String 

func (m *HeartBeat) String() string

func (*HeartBeat) Unmarshal 

func (m *HeartBeat) Unmarshal(dAtA []byte) error

func (*HeartBeat) XXX_DiscardUnknown 

func (m *HeartBeat) XXX_DiscardUnknown()

func (*HeartBeat) XXX_Marshal 

func (m *HeartBeat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HeartBeat) XXX_Merge 

func (m *HeartBeat) XXX_Merge(src proto.Message)

func (*HeartBeat) XXX_Size 

func (m *HeartBeat) XXX_Size() int

func (*HeartBeat) XXX_Unmarshal 

func (m *HeartBeat) XXX_Unmarshal(b []byte) error

type Messages 

type Messages struct {
	BatchId  int64    `protobuf:"varint,1,opt,name=batch_id,json=batchId,proto3" json:"batch_id,omitempty"`
	Messages [][]byte `protobuf:"bytes,2,rep,name=messages,proto3" json:"messages,omitempty"`
}

func (*Messages) Descriptor 

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

func (*Messages) GetBatchId 

func (m *Messages) GetBatchId() int64

func (*Messages) GetMessages 

func (m *Messages) GetMessages() [][]byte

func (*Messages) Marshal 

func (m *Messages) Marshal() (dAtA []byte, err error)

func (*Messages) MarshalTo 

func (m *Messages) MarshalTo(dAtA []byte) (int, error)

func (*Messages) MarshalToSizedBuffer 

func (m *Messages) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Messages) ProtoMessage 

func (*Messages) ProtoMessage()

func (*Messages) Reset 

func (m *Messages) Reset()

func (*Messages) Size 

func (m *Messages) Size() (n int)

func (*Messages) String 

func (m *Messages) String() string

func (*Messages) Unmarshal 

func (m *Messages) Unmarshal(dAtA []byte) error

func (*Messages) XXX_DiscardUnknown 

func (m *Messages) XXX_DiscardUnknown()

func (*Messages) XXX_Marshal 

func (m *Messages) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Messages) XXX_Merge 

func (m *Messages) XXX_Merge(src proto.Message)

func (*Messages) XXX_Size 

func (m *Messages) XXX_Size() int

func (*Messages) XXX_Unmarshal 

func (m *Messages) XXX_Unmarshal(b []byte) error

type Packet 

type Packet struct {
	// [default = 17];
	//
	// Types that are valid to be assigned to MagicNumberPresent:
	//
	//	*Packet_MagicNumber
	MagicNumberPresent isPacket_MagicNumberPresent `protobuf_oneof:"magic_number_present"`
	// [default = 1];
	//
	// Types that are valid to be assigned to VersionPresent:
	//
	//	*Packet_Version
	VersionPresent isPacket_VersionPresent `protobuf_oneof:"version_present"`
	Type           PacketType              `protobuf:"varint,3,opt,name=type,proto3,enum=com.alibaba.otter.canal.protocol.PacketType" json:"type,omitempty"`
	// [default = NONE];
	//
	// Types that are valid to be assigned to CompressionPresent:
	//
	//	*Packet_Compression
	CompressionPresent isPacket_CompressionPresent `protobuf_oneof:"compression_present"`
	Body               []byte                      `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"`
}

func (*Packet) Descriptor 

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

func (*Packet) GetBody 

func (m *Packet) GetBody() []byte

func (*Packet) GetCompression 

func (m *Packet) GetCompression() Compression

func (*Packet) GetCompressionPresent 

func (m *Packet) GetCompressionPresent() isPacket_CompressionPresent

func (*Packet) GetMagicNumber 

func (m *Packet) GetMagicNumber() int32

func (*Packet) GetMagicNumberPresent 

func (m *Packet) GetMagicNumberPresent() isPacket_MagicNumberPresent

func (*Packet) GetType 

func (m *Packet) GetType() PacketType

func (*Packet) GetVersion 

func (m *Packet) GetVersion() int32

func (*Packet) GetVersionPresent 

func (m *Packet) GetVersionPresent() isPacket_VersionPresent

func (*Packet) Marshal 

func (m *Packet) Marshal() (dAtA []byte, err error)

func (*Packet) MarshalTo 

func (m *Packet) MarshalTo(dAtA []byte) (int, error)

func (*Packet) MarshalToSizedBuffer 

func (m *Packet) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Packet) ProtoMessage 

func (*Packet) ProtoMessage()

func (*Packet) Reset 

func (m *Packet) Reset()

func (*Packet) Size 

func (m *Packet) Size() (n int)

func (*Packet) String 

func (m *Packet) String() string

func (*Packet) Unmarshal 

func (m *Packet) Unmarshal(dAtA []byte) error

func (*Packet) XXX_DiscardUnknown 

func (m *Packet) XXX_DiscardUnknown()

func (*Packet) XXX_Marshal 

func (m *Packet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Packet) XXX_Merge 

func (m *Packet) XXX_Merge(src proto.Message)

func (*Packet) XXX_OneofWrappers 

func (*Packet) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Packet) XXX_Size 

func (m *Packet) XXX_Size() int

func (*Packet) XXX_Unmarshal 

func (m *Packet) XXX_Unmarshal(b []byte) error

type PacketType 

type PacketType int32
const (
	//compatible
	PacketType_PACKAGETYPECOMPATIBLEPROTO2 PacketType = 0
	PacketType_HANDSHAKE                   PacketType = 1
	PacketType_CLIENTAUTHENTICATION        PacketType = 2
	PacketType_ACK                         PacketType = 3
	PacketType_SUBSCRIPTION                PacketType = 4
	PacketType_UNSUBSCRIPTION              PacketType = 5
	PacketType_GET                         PacketType = 6
	PacketType_MESSAGES                    PacketType = 7
	PacketType_CLIENTACK                   PacketType = 8
	// management part
	PacketType_SHUTDOWN PacketType = 9
	// integration
	PacketType_DUMP           PacketType = 10
	PacketType_HEARTBEAT      PacketType = 11
	PacketType_CLIENTROLLBACK PacketType = 12
)

func (PacketType) EnumDescriptor 

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

func (PacketType) String 

func (x PacketType) String() string

type Packet_Compression 

type Packet_Compression struct {
	Compression Compression `` /* 132-byte string literal not displayed */
}

func (*Packet_Compression) MarshalTo 

func (m *Packet_Compression) MarshalTo(dAtA []byte) (int, error)

func (*Packet_Compression) MarshalToSizedBuffer 

func (m *Packet_Compression) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Packet_Compression) Size 

func (m *Packet_Compression) Size() (n int)

type Packet_MagicNumber 

type Packet_MagicNumber struct {
	MagicNumber int32 `protobuf:"varint,1,opt,name=magic_number,json=magicNumber,proto3,oneof" json:"magic_number,omitempty"`
}

func (*Packet_MagicNumber) MarshalTo 

func (m *Packet_MagicNumber) MarshalTo(dAtA []byte) (int, error)

func (*Packet_MagicNumber) MarshalToSizedBuffer 

func (m *Packet_MagicNumber) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Packet_MagicNumber) Size 

func (m *Packet_MagicNumber) Size() (n int)

type Packet_Version 

type Packet_Version struct {
	Version int32 `protobuf:"varint,2,opt,name=version,proto3,oneof" json:"version,omitempty"`
}

func (*Packet_Version) MarshalTo 

func (m *Packet_Version) MarshalTo(dAtA []byte) (int, error)

func (*Packet_Version) MarshalToSizedBuffer 

func (m *Packet_Version) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Packet_Version) Size 

func (m *Packet_Version) Size() (n int)

type Pair 

type Pair struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

*预留扩展*

func (*Pair) Descriptor 

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

func (*Pair) GetKey 

func (m *Pair) GetKey() string

func (*Pair) GetValue 

func (m *Pair) GetValue() string

func (*Pair) Marshal 

func (m *Pair) Marshal() (dAtA []byte, err error)

func (*Pair) MarshalTo 

func (m *Pair) MarshalTo(dAtA []byte) (int, error)

func (*Pair) MarshalToSizedBuffer 

func (m *Pair) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Pair) ProtoMessage 

func (*Pair) ProtoMessage()

func (*Pair) Reset 

func (m *Pair) Reset()

func (*Pair) Size 

func (m *Pair) Size() (n int)

func (*Pair) String 

func (m *Pair) String() string

func (*Pair) Unmarshal 

func (m *Pair) Unmarshal(dAtA []byte) error

func (*Pair) XXX_DiscardUnknown 

func (m *Pair) XXX_DiscardUnknown()

func (*Pair) XXX_Marshal 

func (m *Pair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Pair) XXX_Merge 

func (m *Pair) XXX_Merge(src proto.Message)

func (*Pair) XXX_Size 

func (m *Pair) XXX_Size() int

func (*Pair) XXX_Unmarshal 

func (m *Pair) XXX_Unmarshal(b []byte) error

type RowChange 

type RowChange struct {
	// *tableId,由数据库产生*
	TableId int64 `protobuf:"varint,1,opt,name=tableId,proto3" json:"tableId,omitempty"`
	// [default = UPDATE]
	//
	// Types that are valid to be assigned to EventTypePresent:
	//
	//	*RowChange_EventType
	EventTypePresent isRowChange_EventTypePresent `protobuf_oneof:"eventType_present"`
	// [default = false]
	//
	// Types that are valid to be assigned to IsDdlPresent:
	//
	//	*RowChange_IsDdl
	IsDdlPresent isRowChange_IsDdlPresent `protobuf_oneof:"isDdl_present"`
	// * ddl/query的sql语句  *
	Sql string `protobuf:"bytes,11,opt,name=sql,proto3" json:"sql,omitempty"`
	// * 一次数据库变更可能存在多行  *
	RowDatas []*RowData `protobuf:"bytes,12,rep,name=rowDatas,proto3" json:"rowDatas,omitempty"`
	// *预留扩展*
	Props []*Pair `protobuf:"bytes,13,rep,name=props,proto3" json:"props,omitempty"`
	// * ddl/query的schemaName，会存在跨库ddl，需要保留执行ddl的当前schemaName  *
	DdlSchemaName string `protobuf:"bytes,14,opt,name=ddlSchemaName,proto3" json:"ddlSchemaName,omitempty"`
}

*message row 每行变更数据的数据结构*

func (*RowChange) Descriptor 

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

func (*RowChange) GetDdlSchemaName 

func (m *RowChange) GetDdlSchemaName() string

func (*RowChange) GetEventType 

func (m *RowChange) GetEventType() EventType

func (*RowChange) GetEventTypePresent 

func (m *RowChange) GetEventTypePresent() isRowChange_EventTypePresent

func (*RowChange) GetIsDdl 

func (m *RowChange) GetIsDdl() bool

func (*RowChange) GetIsDdlPresent 

func (m *RowChange) GetIsDdlPresent() isRowChange_IsDdlPresent

func (*RowChange) GetProps 

func (m *RowChange) GetProps() []*Pair

func (*RowChange) GetRowDatas 

func (m *RowChange) GetRowDatas() []*RowData

func (*RowChange) GetSql 

func (m *RowChange) GetSql() string

func (*RowChange) GetTableId 

func (m *RowChange) GetTableId() int64

func (*RowChange) Marshal 

func (m *RowChange) Marshal() (dAtA []byte, err error)

func (*RowChange) MarshalTo 

func (m *RowChange) MarshalTo(dAtA []byte) (int, error)

func (*RowChange) MarshalToSizedBuffer 

func (m *RowChange) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RowChange) ProtoMessage 

func (*RowChange) ProtoMessage()

func (*RowChange) Reset 

func (m *RowChange) Reset()

func (*RowChange) Size 

func (m *RowChange) Size() (n int)

func (*RowChange) String 

func (m *RowChange) String() string

func (*RowChange) Unmarshal 

func (m *RowChange) Unmarshal(dAtA []byte) error

func (*RowChange) XXX_DiscardUnknown 

func (m *RowChange) XXX_DiscardUnknown()

func (*RowChange) XXX_Marshal 

func (m *RowChange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RowChange) XXX_Merge 

func (m *RowChange) XXX_Merge(src proto.Message)

func (*RowChange) XXX_OneofWrappers 

func (*RowChange) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*RowChange) XXX_Size 

func (m *RowChange) XXX_Size() int

func (*RowChange) XXX_Unmarshal 

func (m *RowChange) XXX_Unmarshal(b []byte) error

type RowChange_EventType 

type RowChange_EventType struct {
	EventType EventType `` /* 126-byte string literal not displayed */
}

func (*RowChange_EventType) MarshalTo 

func (m *RowChange_EventType) MarshalTo(dAtA []byte) (int, error)

func (*RowChange_EventType) MarshalToSizedBuffer 

func (m *RowChange_EventType) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RowChange_EventType) Size 

func (m *RowChange_EventType) Size() (n int)

type RowChange_IsDdl 

type RowChange_IsDdl struct {
	IsDdl bool `protobuf:"varint,10,opt,name=isDdl,proto3,oneof" json:"isDdl,omitempty"`
}

func (*RowChange_IsDdl) MarshalTo 

func (m *RowChange_IsDdl) MarshalTo(dAtA []byte) (int, error)

func (*RowChange_IsDdl) MarshalToSizedBuffer 

func (m *RowChange_IsDdl) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RowChange_IsDdl) Size 

func (m *RowChange_IsDdl) Size() (n int)

type RowData 

type RowData struct {
	// * 字段信息，增量数据(修改前,删除前) *
	BeforeColumns []*Column `protobuf:"bytes,1,rep,name=beforeColumns,proto3" json:"beforeColumns,omitempty"`
	// * 字段信息，增量数据(修改后,新增后)  *
	AfterColumns []*Column `protobuf:"bytes,2,rep,name=afterColumns,proto3" json:"afterColumns,omitempty"`
	// *预留扩展*
	Props []*Pair `protobuf:"bytes,3,rep,name=props,proto3" json:"props,omitempty"`
}

func (*RowData) Descriptor 

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

func (*RowData) GetAfterColumns 

func (m *RowData) GetAfterColumns() []*Column

func (*RowData) GetBeforeColumns 

func (m *RowData) GetBeforeColumns() []*Column

func (*RowData) GetProps 

func (m *RowData) GetProps() []*Pair

func (*RowData) Marshal 

func (m *RowData) Marshal() (dAtA []byte, err error)

func (*RowData) MarshalTo 

func (m *RowData) MarshalTo(dAtA []byte) (int, error)

func (*RowData) MarshalToSizedBuffer 

func (m *RowData) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RowData) ProtoMessage 

func (*RowData) ProtoMessage()

func (*RowData) Reset 

func (m *RowData) Reset()

func (*RowData) Size 

func (m *RowData) Size() (n int)

func (*RowData) String 

func (m *RowData) String() string

func (*RowData) Unmarshal 

func (m *RowData) Unmarshal(dAtA []byte) error

func (*RowData) XXX_DiscardUnknown 

func (m *RowData) XXX_DiscardUnknown()

func (*RowData) XXX_Marshal 

func (m *RowData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RowData) XXX_Merge 

func (m *RowData) XXX_Merge(src proto.Message)

func (*RowData) XXX_Size 

func (m *RowData) XXX_Size() int

func (*RowData) XXX_Unmarshal 

func (m *RowData) XXX_Unmarshal(b []byte) error

type Sub 

type Sub struct {
	Destination string `protobuf:"bytes,1,opt,name=destination,proto3" json:"destination,omitempty"`
	ClientId    string `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Filter      string `protobuf:"bytes,7,opt,name=filter,proto3" json:"filter,omitempty"`
}

subscription

func (*Sub) Descriptor 

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

func (*Sub) GetClientId 

func (m *Sub) GetClientId() string

func (*Sub) GetDestination 

func (m *Sub) GetDestination() string

func (*Sub) GetFilter 

func (m *Sub) GetFilter() string

func (*Sub) Marshal 

func (m *Sub) Marshal() (dAtA []byte, err error)

func (*Sub) MarshalTo 

func (m *Sub) MarshalTo(dAtA []byte) (int, error)

func (*Sub) MarshalToSizedBuffer 

func (m *Sub) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Sub) ProtoMessage 

func (*Sub) ProtoMessage()

func (*Sub) Reset 

func (m *Sub) Reset()

func (*Sub) Size 

func (m *Sub) Size() (n int)

func (*Sub) String 

func (m *Sub) String() string

func (*Sub) Unmarshal 

func (m *Sub) Unmarshal(dAtA []byte) error

func (*Sub) XXX_DiscardUnknown 

func (m *Sub) XXX_DiscardUnknown()

func (*Sub) XXX_Marshal 

func (m *Sub) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Sub) XXX_Merge 

func (m *Sub) XXX_Merge(src proto.Message)

func (*Sub) XXX_Size 

func (m *Sub) XXX_Size() int

func (*Sub) XXX_Unmarshal 

func (m *Sub) XXX_Unmarshal(b []byte) error

type TransactionBegin 

type TransactionBegin struct {
	// *已废弃，请使用header里的executeTime*
	ExecuteTime int64 `protobuf:"varint,1,opt,name=executeTime,proto3" json:"executeTime,omitempty"`
	// *已废弃，Begin里不提供事务id*
	TransactionId string `protobuf:"bytes,2,opt,name=transactionId,proto3" json:"transactionId,omitempty"`
	// *预留扩展*
	Props []*Pair `protobuf:"bytes,3,rep,name=props,proto3" json:"props,omitempty"`
	// *执行的thread Id*
	ThreadId int64 `protobuf:"varint,4,opt,name=threadId,proto3" json:"threadId,omitempty"`
}

*开始事务的一些信息*

func (*TransactionBegin) Descriptor 

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

func (*TransactionBegin) GetExecuteTime 

func (m *TransactionBegin) GetExecuteTime() int64

func (*TransactionBegin) GetProps 

func (m *TransactionBegin) GetProps() []*Pair

func (*TransactionBegin) GetThreadId 

func (m *TransactionBegin) GetThreadId() int64

func (*TransactionBegin) GetTransactionId 

func (m *TransactionBegin) GetTransactionId() string

func (*TransactionBegin) Marshal 

func (m *TransactionBegin) Marshal() (dAtA []byte, err error)

func (*TransactionBegin) MarshalTo 

func (m *TransactionBegin) MarshalTo(dAtA []byte) (int, error)

func (*TransactionBegin) MarshalToSizedBuffer 

func (m *TransactionBegin) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TransactionBegin) ProtoMessage 

func (*TransactionBegin) ProtoMessage()

func (*TransactionBegin) Reset 

func (m *TransactionBegin) Reset()

func (*TransactionBegin) Size 

func (m *TransactionBegin) Size() (n int)

func (*TransactionBegin) String 

func (m *TransactionBegin) String() string

func (*TransactionBegin) Unmarshal 

func (m *TransactionBegin) Unmarshal(dAtA []byte) error

func (*TransactionBegin) XXX_DiscardUnknown 

func (m *TransactionBegin) XXX_DiscardUnknown()

func (*TransactionBegin) XXX_Marshal 

func (m *TransactionBegin) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TransactionBegin) XXX_Merge 

func (m *TransactionBegin) XXX_Merge(src proto.Message)

func (*TransactionBegin) XXX_Size 

func (m *TransactionBegin) XXX_Size() int

func (*TransactionBegin) XXX_Unmarshal 

func (m *TransactionBegin) XXX_Unmarshal(b []byte) error

type TransactionEnd 

type TransactionEnd struct {
	// *已废弃，请使用header里的executeTime*
	ExecuteTime int64 `protobuf:"varint,1,opt,name=executeTime,proto3" json:"executeTime,omitempty"`
	// *事务号*
	TransactionId string `protobuf:"bytes,2,opt,name=transactionId,proto3" json:"transactionId,omitempty"`
	// *预留扩展*
	Props []*Pair `protobuf:"bytes,3,rep,name=props,proto3" json:"props,omitempty"`
}

*结束事务的一些信息*

func (*TransactionEnd) Descriptor 

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

func (*TransactionEnd) GetExecuteTime 

func (m *TransactionEnd) GetExecuteTime() int64

func (*TransactionEnd) GetProps 

func (m *TransactionEnd) GetProps() []*Pair

func (*TransactionEnd) GetTransactionId 

func (m *TransactionEnd) GetTransactionId() string

func (*TransactionEnd) Marshal 

func (m *TransactionEnd) Marshal() (dAtA []byte, err error)

func (*TransactionEnd) MarshalTo 

func (m *TransactionEnd) MarshalTo(dAtA []byte) (int, error)

func (*TransactionEnd) MarshalToSizedBuffer 

func (m *TransactionEnd) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TransactionEnd) ProtoMessage 

func (*TransactionEnd) ProtoMessage()

func (*TransactionEnd) Reset 

func (m *TransactionEnd) Reset()

func (*TransactionEnd) Size 

func (m *TransactionEnd) Size() (n int)

func (*TransactionEnd) String 

func (m *TransactionEnd) String() string

func (*TransactionEnd) Unmarshal 

func (m *TransactionEnd) Unmarshal(dAtA []byte) error

func (*TransactionEnd) XXX_DiscardUnknown 

func (m *TransactionEnd) XXX_DiscardUnknown()

func (*TransactionEnd) XXX_Marshal 

func (m *TransactionEnd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TransactionEnd) XXX_Merge 

func (m *TransactionEnd) XXX_Merge(src proto.Message)

func (*TransactionEnd) XXX_Size 

func (m *TransactionEnd) XXX_Size() int

func (*TransactionEnd) XXX_Unmarshal 

func (m *TransactionEnd) XXX_Unmarshal(b []byte) error

type Type 

type Type int32

*数据库类型* 

const (
	Type_TYPECOMPATIBLEPROTO2 Type = 0
	Type_ORACLE               Type = 1
	Type_MYSQL                Type = 2
	Type_PGSQL                Type = 3
)

func (Type) EnumDescriptor 

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

func (Type) String 

func (x Type) String() string

type Unsub 

type Unsub struct {
	Destination string `protobuf:"bytes,1,opt,name=destination,proto3" json:"destination,omitempty"`
	ClientId    string `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Filter      string `protobuf:"bytes,7,opt,name=filter,proto3" json:"filter,omitempty"`
}

Unsubscription

func (*Unsub) Descriptor 

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

func (*Unsub) GetClientId 

func (m *Unsub) GetClientId() string

func (*Unsub) GetDestination 

func (m *Unsub) GetDestination() string

func (*Unsub) GetFilter 

func (m *Unsub) GetFilter() string

func (*Unsub) Marshal 

func (m *Unsub) Marshal() (dAtA []byte, err error)

func (*Unsub) MarshalTo 

func (m *Unsub) MarshalTo(dAtA []byte) (int, error)

func (*Unsub) MarshalToSizedBuffer 

func (m *Unsub) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Unsub) ProtoMessage 

func (*Unsub) ProtoMessage()

func (*Unsub) Reset 

func (m *Unsub) Reset()

func (*Unsub) Size 

func (m *Unsub) Size() (n int)

func (*Unsub) String 

func (m *Unsub) String() string

func (*Unsub) Unmarshal 

func (m *Unsub) Unmarshal(dAtA []byte) error

func (*Unsub) XXX_DiscardUnknown 

func (m *Unsub) XXX_DiscardUnknown()

func (*Unsub) XXX_Marshal 

func (m *Unsub) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Unsub) XXX_Merge 

func (m *Unsub) XXX_Merge(src proto.Message)

func (*Unsub) XXX_Size 

func (m *Unsub) XXX_Size() int

func (*Unsub) XXX_Unmarshal 

func (m *Unsub) XXX_Unmarshal(b []byte) error

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.