slave_binlog

package
v0.0.0-...-503c688 Latest Latest
Warning

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

 Go to latest Published: Nov 8, 2023 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package slave_binlog is a generated protocol buffer package.

It is generated from these files: 

secondary_binlog.proto

It has these top-level messages: 

Column
ColumnInfo
Row
Table
Key
TableMutation
DMLData
DDLData
Binlog

Index

Constants

View Source 
const Default_Column_IsNull bool = false

Variables

View Source 
var (
	ErrInvalidLengthSecondaryBinlog = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSecondaryBinlog   = fmt.Errorf("proto: integer overflow")
)
View Source 
var BinlogType_name = map[int32]string{
	0: "DML",
	1: "DDL",
}
View Source 
var BinlogType_value = map[string]int32{
	"DML": 0,
	"DDL": 1,
}
View Source 
var MutationType_name = map[int32]string{
	0: "Insert",
	1: "Update",
	2: "Delete",
}
View Source 
var MutationType_value = map[string]int32{
	"Insert": 0,
	"Update": 1,
	"Delete": 2,
}

Functions

This section is empty.

Types

type Binlog 

type Binlog struct {
	Type     BinlogType `protobuf:"varint,1,opt,name=type,enum=slave.binlog.BinlogType" json:"type"`
	CommitTs int64      `protobuf:"varint,2,opt,name=commit_ts,json=commitTs" json:"commit_ts"`
	// dml_data is marshalled from DML type
	DmlData *DMLData `protobuf:"bytes,3,opt,name=dml_data,json=dmlData" json:"dml_data,omitempty"`
	DdlData *DDLData `protobuf:"bytes,4,opt,name=ddl_data,json=ddlData" json:"ddl_data,omitempty"`
	// time_zone is the time zone of timestamp value
	TimeZone             *string  `protobuf:"bytes,5,opt,name=time_zone,json=timeZone" json:"time_zone,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Binlog contains all the changes in a transaction.

func (*Binlog) Descriptor 

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

func (*Binlog) GetCommitTs 

func (m *Binlog) GetCommitTs() int64

func (*Binlog) GetDdlData 

func (m *Binlog) GetDdlData() *DDLData

func (*Binlog) GetDmlData 

func (m *Binlog) GetDmlData() *DMLData

func (*Binlog) GetTimeZone 

func (m *Binlog) GetTimeZone() string

func (*Binlog) GetType 

func (m *Binlog) GetType() BinlogType

func (*Binlog) Marshal 

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

func (*Binlog) MarshalTo 

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

func (*Binlog) ProtoMessage 

func (*Binlog) ProtoMessage()

func (*Binlog) Reset 

func (m *Binlog) Reset()

func (*Binlog) Size 

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

func (*Binlog) String 

func (m *Binlog) String() string

func (*Binlog) Unmarshal 

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

func (*Binlog) XXX_DiscardUnknown 

func (m *Binlog) XXX_DiscardUnknown()

func (*Binlog) XXX_Marshal 

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

func (*Binlog) XXX_Merge 

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

func (*Binlog) XXX_Size 

func (m *Binlog) XXX_Size() int

func (*Binlog) XXX_Unmarshal 

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

type BinlogType 

type BinlogType int32
const (
	BinlogType_DML BinlogType = 0
	BinlogType_DDL BinlogType = 1
)

func (BinlogType) Enum 

func (x BinlogType) Enum() *BinlogType

func (BinlogType) EnumDescriptor 

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

func (BinlogType) String 

func (x BinlogType) String() string

func (*BinlogType) UnmarshalJSON 

func (x *BinlogType) UnmarshalJSON(data []byte) error

type Column 

type Column struct {
	IsNull               *bool    `protobuf:"varint,1,opt,name=is_null,json=isNull,def=0" json:"is_null,omitempty"`
	Int64Value           *int64   `protobuf:"varint,2,opt,name=int64_value,json=int64Value" json:"int64_value,omitempty"`
	Uint64Value          *uint64  `protobuf:"varint,3,opt,name=uint64_value,json=uint64Value" json:"uint64_value,omitempty"`
	DoubleValue          *float64 `protobuf:"fixed64,4,opt,name=double_value,json=doubleValue" json:"double_value,omitempty"`
	BytesValue           []byte   `protobuf:"bytes,5,opt,name=bytes_value,json=bytesValue" json:"bytes_value,omitempty"`
	StringValue          *string  `protobuf:"bytes,6,opt,name=string_value,json=stringValue" json:"string_value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

for text and char type, string_value is set for blob and binary type, bytes_value is set for enum, set, uint64_value is set for json, bytes_value is set

func (*Column) Descriptor 

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

func (*Column) GetBytesValue 

func (m *Column) GetBytesValue() []byte

func (*Column) GetDoubleValue 

func (m *Column) GetDoubleValue() float64

func (*Column) GetInt64Value 

func (m *Column) GetInt64Value() int64

func (*Column) GetIsNull 

func (m *Column) GetIsNull() bool

func (*Column) GetStringValue 

func (m *Column) GetStringValue() string

func (*Column) GetUint64Value 

func (m *Column) GetUint64Value() uint64

func (*Column) Marshal 

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

func (*Column) MarshalTo 

func (m *Column) MarshalTo(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_Size 

func (m *Column) XXX_Size() int

func (*Column) XXX_Unmarshal 

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

type ColumnInfo 

type ColumnInfo struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name"`
	// lower case column field type in mysql
	// https://dev.mysql.com/doc/refman/8.0/en/data-types.html
	// for numeric type: int bigint smallint tinyint float double decimal bit
	// for string type: text longtext mediumtext char tinytext varchar
	// blob longblob mediumblob binary tinyblob varbinary
	// enum set
	// for json type: json
	MysqlType            string   `protobuf:"bytes,2,opt,name=mysql_type,json=mysqlType" json:"mysql_type"`
	IsPrimaryKey         bool     `protobuf:"varint,3,opt,name=is_primary_key,json=isPrimaryKey" json:"is_primary_key"`
	Flen                 int32    `protobuf:"varint,4,opt,name=flen" json:"flen"`
	Decimal              int32    `protobuf:"varint,5,opt,name=decimal" json:"decimal"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ColumnInfo) Descriptor 

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

func (*ColumnInfo) GetDecimal 

func (m *ColumnInfo) GetDecimal() int32

func (*ColumnInfo) GetFlen 

func (m *ColumnInfo) GetFlen() int32

func (*ColumnInfo) GetIsPrimaryKey 

func (m *ColumnInfo) GetIsPrimaryKey() bool

func (*ColumnInfo) GetMysqlType 

func (m *ColumnInfo) GetMysqlType() string

func (*ColumnInfo) GetName 

func (m *ColumnInfo) GetName() string

func (*ColumnInfo) Marshal 

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

func (*ColumnInfo) MarshalTo 

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

func (*ColumnInfo) ProtoMessage 

func (*ColumnInfo) ProtoMessage()

func (*ColumnInfo) Reset 

func (m *ColumnInfo) Reset()

func (*ColumnInfo) Size 

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

func (*ColumnInfo) String 

func (m *ColumnInfo) String() string

func (*ColumnInfo) Unmarshal 

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

func (*ColumnInfo) XXX_DiscardUnknown 

func (m *ColumnInfo) XXX_DiscardUnknown()

func (*ColumnInfo) XXX_Marshal 

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

func (*ColumnInfo) XXX_Merge 

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

func (*ColumnInfo) XXX_Size 

func (m *ColumnInfo) XXX_Size() int

func (*ColumnInfo) XXX_Unmarshal 

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

type DDLData 

type DDLData struct {
	// the current database use
	SchemaName *string `protobuf:"bytes,1,opt,name=schema_name,json=schemaName" json:"schema_name,omitempty"`
	// the relate table
	TableName *string `protobuf:"bytes,2,opt,name=table_name,json=tableName" json:"table_name,omitempty"`
	// ddl_query is the original ddl statement query.
	DdlQuery             []byte   `protobuf:"bytes,3,opt,name=ddl_query,json=ddlQuery" json:"ddl_query,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DDLData) Descriptor 

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

func (*DDLData) GetDdlQuery 

func (m *DDLData) GetDdlQuery() []byte

func (*DDLData) GetSchemaName 

func (m *DDLData) GetSchemaName() string

func (*DDLData) GetTableName 

func (m *DDLData) GetTableName() string

func (*DDLData) Marshal 

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

func (*DDLData) MarshalTo 

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

func (*DDLData) ProtoMessage 

func (*DDLData) ProtoMessage()

func (*DDLData) Reset 

func (m *DDLData) Reset()

func (*DDLData) Size 

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

func (*DDLData) String 

func (m *DDLData) String() string

func (*DDLData) Unmarshal 

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

func (*DDLData) XXX_DiscardUnknown 

func (m *DDLData) XXX_DiscardUnknown()

func (*DDLData) XXX_Marshal 

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

func (*DDLData) XXX_Merge 

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

func (*DDLData) XXX_Size 

func (m *DDLData) XXX_Size() int

func (*DDLData) XXX_Unmarshal 

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

type DMLData 

type DMLData struct {
	// tables contains all the table changes.
	Tables               []*Table `protobuf:"bytes,1,rep,name=tables" json:"tables,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DMLData) Descriptor 

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

func (*DMLData) GetTables 

func (m *DMLData) GetTables() []*Table

func (*DMLData) Marshal 

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

func (*DMLData) MarshalTo 

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

func (*DMLData) ProtoMessage 

func (*DMLData) ProtoMessage()

func (*DMLData) Reset 

func (m *DMLData) Reset()

func (*DMLData) Size 

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

func (*DMLData) String 

func (m *DMLData) String() string

func (*DMLData) Unmarshal 

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

func (*DMLData) XXX_DiscardUnknown 

func (m *DMLData) XXX_DiscardUnknown()

func (*DMLData) XXX_Marshal 

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

func (*DMLData) XXX_Merge 

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

func (*DMLData) XXX_Size 

func (m *DMLData) XXX_Size() int

func (*DMLData) XXX_Unmarshal 

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

type Key 

type Key struct {
	// name will be PRIMARY if it's the primary key.
	Name                 *string  `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	ColumnNames          []string `protobuf:"bytes,2,rep,name=column_names,json=columnNames" json:"column_names,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Key contains Key info.

func (*Key) Descriptor 

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

func (*Key) GetColumnNames 

func (m *Key) GetColumnNames() []string

func (*Key) GetName 

func (m *Key) GetName() string

func (*Key) Marshal 

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

func (*Key) MarshalTo 

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

func (*Key) ProtoMessage 

func (*Key) ProtoMessage()

func (*Key) Reset 

func (m *Key) Reset()

func (*Key) Size 

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

func (*Key) String 

func (m *Key) String() string

func (*Key) Unmarshal 

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

func (*Key) XXX_DiscardUnknown 

func (m *Key) XXX_DiscardUnknown()

func (*Key) XXX_Marshal 

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

func (*Key) XXX_Merge 

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

func (*Key) XXX_Size 

func (m *Key) XXX_Size() int

func (*Key) XXX_Unmarshal 

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

type MutationType 

type MutationType int32
const (
	MutationType_Insert MutationType = 0
	MutationType_Update MutationType = 1
	MutationType_Delete MutationType = 2
)

func (MutationType) Enum 

func (x MutationType) Enum() *MutationType

func (MutationType) EnumDescriptor 

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

func (MutationType) String 

func (x MutationType) String() string

func (*MutationType) UnmarshalJSON 

func (x *MutationType) UnmarshalJSON(data []byte) error

type Row 

type Row struct {
	Columns              []*Column `protobuf:"bytes,1,rep,name=columns" json:"columns,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Row) Descriptor 

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

func (*Row) GetColumns 

func (m *Row) GetColumns() []*Column

func (*Row) Marshal 

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

func (*Row) MarshalTo 

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

func (*Row) ProtoMessage 

func (*Row) ProtoMessage()

func (*Row) Reset 

func (m *Row) Reset()

func (*Row) Size 

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

func (*Row) String 

func (m *Row) String() string

func (*Row) Unmarshal 

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

func (*Row) XXX_DiscardUnknown 

func (m *Row) XXX_DiscardUnknown()

func (*Row) XXX_Marshal 

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

func (*Row) XXX_Merge 

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

func (*Row) XXX_Size 

func (m *Row) XXX_Size() int

func (*Row) XXX_Unmarshal 

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

type Table 

type Table struct {
	SchemaName *string          `protobuf:"bytes,1,opt,name=schema_name,json=schemaName" json:"schema_name,omitempty"`
	TableName  *string          `protobuf:"bytes,2,opt,name=table_name,json=tableName" json:"table_name,omitempty"`
	ColumnInfo []*ColumnInfo    `protobuf:"bytes,3,rep,name=column_info,json=columnInfo" json:"column_info,omitempty"`
	Mutations  []*TableMutation `protobuf:"bytes,4,rep,name=mutations" json:"mutations,omitempty"`
	// will only be set with version >= 3.0.9
	UniqueKeys           []*Key   `protobuf:"bytes,5,rep,name=unique_keys,json=uniqueKeys" json:"unique_keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Table contains mutations in a table.

func (*Table) Descriptor 

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

func (*Table) GetColumnInfo 

func (m *Table) GetColumnInfo() []*ColumnInfo

func (*Table) GetMutations 

func (m *Table) GetMutations() []*TableMutation

func (*Table) GetSchemaName 

func (m *Table) GetSchemaName() string

func (*Table) GetTableName 

func (m *Table) GetTableName() string

func (*Table) GetUniqueKeys 

func (m *Table) GetUniqueKeys() []*Key

func (*Table) Marshal 

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

func (*Table) MarshalTo 

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

func (*Table) ProtoMessage 

func (*Table) ProtoMessage()

func (*Table) Reset 

func (m *Table) Reset()

func (*Table) Size 

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

func (*Table) String 

func (m *Table) String() string

func (*Table) Unmarshal 

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

func (*Table) XXX_DiscardUnknown 

func (m *Table) XXX_DiscardUnknown()

func (*Table) XXX_Marshal 

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

func (*Table) XXX_Merge 

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

func (*Table) XXX_Size 

func (m *Table) XXX_Size() int

func (*Table) XXX_Unmarshal 

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

type TableMutation 

type TableMutation struct {
	Type *MutationType `protobuf:"varint,1,req,name=type,enum=slave.binlog.MutationType" json:"type,omitempty"`
	Row  *Row          `protobuf:"bytes,2,req,name=row" json:"row,omitempty"`
	// for Update MutationType only
	ChangeRow            *Row     `protobuf:"bytes,3,opt,name=change_row,json=changeRow" json:"change_row,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TableMutation) Descriptor 

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

func (*TableMutation) GetChangeRow 

func (m *TableMutation) GetChangeRow() *Row

func (*TableMutation) GetRow 

func (m *TableMutation) GetRow() *Row

func (*TableMutation) GetType 

func (m *TableMutation) GetType() MutationType

func (*TableMutation) Marshal 

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

func (*TableMutation) MarshalTo 

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

func (*TableMutation) ProtoMessage 

func (*TableMutation) ProtoMessage()

func (*TableMutation) Reset 

func (m *TableMutation) Reset()

func (*TableMutation) Size 

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

func (*TableMutation) String 

func (m *TableMutation) String() string

func (*TableMutation) Unmarshal 

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

func (*TableMutation) XXX_DiscardUnknown 

func (m *TableMutation) XXX_DiscardUnknown()

func (*TableMutation) XXX_Marshal 

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

func (*TableMutation) XXX_Merge 

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

func (*TableMutation) XXX_Size 

func (m *TableMutation) XXX_Size() int

func (*TableMutation) XXX_Unmarshal 

func (m *TableMutation) 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.