entry

package
v0.0.0-...-f553f25 Latest Latest
Warning

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

 Go to latest Published: Apr 17, 2021 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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 EntryType_name = map[int32]string{
	0: "ENTRYTYPECOMPATIBLEPROTO2",
	1: "TRANSACTIONBEGIN",
	2: "ROWDATA",
	3: "TRANSACTIONEND",
	4: "HEARTBEAT",
	5: "GTIDLOG",
}
View Source 
var EntryType_value = map[string]int32{
	"ENTRYTYPECOMPATIBLEPROTO2": 0,
	"TRANSACTIONBEGIN":          1,
	"ROWDATA":                   2,
	"TRANSACTIONEND":            3,
	"HEARTBEAT":                 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 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 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

*每个字段的数据结构*

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 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

*************************************************************** 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_HEARTBEAT 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 `` /* 132-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 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

*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 `` /* 133-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 `` /* 129-byte string literal not displayed */
}

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 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

*预留扩展*

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

*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 `` /* 132-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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

*开始事务的一些信息*

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

*结束事务的一些信息*

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

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.