binlogdata

package
v1.0.10 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var BinlogTransaction_Statement_Category_name = map[int32]string{
	0: "BL_UNRECOGNIZED",
	1: "BL_BEGIN",
	2: "BL_COMMIT",
	3: "BL_ROLLBACK",
	4: "BL_DML_DEPRECATED",
	5: "BL_DDL",
	6: "BL_SET",
	7: "BL_INSERT",
	8: "BL_UPDATE",
	9: "BL_DELETE",
}
View Source 
var BinlogTransaction_Statement_Category_value = map[string]int32{
	"BL_UNRECOGNIZED":   0,
	"BL_BEGIN":          1,
	"BL_COMMIT":         2,
	"BL_ROLLBACK":       3,
	"BL_DML_DEPRECATED": 4,
	"BL_DDL":            5,
	"BL_SET":            6,
	"BL_INSERT":         7,
	"BL_UPDATE":         8,
	"BL_DELETE":         9,
}

Functions

This section is empty.

Types

type BinlogSource 

type BinlogSource struct {
	// the source keyspace
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// the source shard
	Shard string `protobuf:"bytes,2,opt,name=shard,proto3" json:"shard,omitempty"`
	// the source tablet type
	TabletType topodata.TabletType `protobuf:"varint,3,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
	// key_range is set if the request is for a keyrange
	KeyRange *topodata.KeyRange `protobuf:"bytes,4,opt,name=key_range,json=keyRange,proto3" json:"key_range,omitempty"`
	// tables is set if the request is for a list of tables
	Tables               []string `protobuf:"bytes,5,rep,name=tables,proto3" json:"tables,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

BinlogSource specifies the source and filter parameters for Filtered Replication. It currently supports a keyrange or a list of tables.

func (*BinlogSource) Descriptor 

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

func (*BinlogSource) GetKeyRange 

func (m *BinlogSource) GetKeyRange() *topodata.KeyRange

func (*BinlogSource) GetKeyspace 

func (m *BinlogSource) GetKeyspace() string

func (*BinlogSource) GetShard 

func (m *BinlogSource) GetShard() string

func (*BinlogSource) GetTables 

func (m *BinlogSource) GetTables() []string

func (*BinlogSource) GetTabletType 

func (m *BinlogSource) GetTabletType() topodata.TabletType

func (*BinlogSource) ProtoMessage 

func (*BinlogSource) ProtoMessage()

func (*BinlogSource) Reset 

func (m *BinlogSource) Reset()

func (*BinlogSource) String 

func (m *BinlogSource) String() string

func (*BinlogSource) XXX_DiscardUnknown 

func (m *BinlogSource) XXX_DiscardUnknown()

func (*BinlogSource) XXX_Marshal 

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

func (*BinlogSource) XXX_Merge 

func (dst *BinlogSource) XXX_Merge(src proto.Message)

func (*BinlogSource) XXX_Size 

func (m *BinlogSource) XXX_Size() int

func (*BinlogSource) XXX_Unmarshal 

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

type BinlogTransaction 

type BinlogTransaction struct {
	// the statements in this transaction
	Statements []*BinlogTransaction_Statement `protobuf:"bytes,1,rep,name=statements,proto3" json:"statements,omitempty"`
	// The Event Token for this event.
	EventToken           *query.EventToken `protobuf:"bytes,4,opt,name=event_token,json=eventToken,proto3" json:"event_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

BinlogTransaction describes a transaction inside the binlogs. It is streamed by vttablet for filtered replication, used during resharding.

func (*BinlogTransaction) Descriptor 

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

func (*BinlogTransaction) GetEventToken 

func (m *BinlogTransaction) GetEventToken() *query.EventToken

func (*BinlogTransaction) GetStatements 

func (m *BinlogTransaction) GetStatements() []*BinlogTransaction_Statement

func (*BinlogTransaction) ProtoMessage 

func (*BinlogTransaction) ProtoMessage()

func (*BinlogTransaction) Reset 

func (m *BinlogTransaction) Reset()

func (*BinlogTransaction) String 

func (m *BinlogTransaction) String() string

func (*BinlogTransaction) XXX_DiscardUnknown 

func (m *BinlogTransaction) XXX_DiscardUnknown()

func (*BinlogTransaction) XXX_Marshal 

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

func (*BinlogTransaction) XXX_Merge 

func (dst *BinlogTransaction) XXX_Merge(src proto.Message)

func (*BinlogTransaction) XXX_Size 

func (m *BinlogTransaction) XXX_Size() int

func (*BinlogTransaction) XXX_Unmarshal 

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

type BinlogTransaction_Statement 

type BinlogTransaction_Statement struct {
	// what type of statement is this?
	Category BinlogTransaction_Statement_Category `protobuf:"varint,1,opt,name=category,proto3,enum=binlogdata.BinlogTransaction_Statement_Category" json:"category,omitempty"`
	// charset of this statement, if different from pre-negotiated default.
	Charset *Charset `protobuf:"bytes,2,opt,name=charset,proto3" json:"charset,omitempty"`
	// the sql
	Sql                  []byte   `protobuf:"bytes,3,opt,name=sql,proto3" json:"sql,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BinlogTransaction_Statement) Descriptor 

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

func (*BinlogTransaction_Statement) GetCategory 

func (m *BinlogTransaction_Statement) GetCategory() BinlogTransaction_Statement_Category

func (*BinlogTransaction_Statement) GetCharset 

func (m *BinlogTransaction_Statement) GetCharset() *Charset

func (*BinlogTransaction_Statement) GetSql 

func (m *BinlogTransaction_Statement) GetSql() []byte

func (*BinlogTransaction_Statement) ProtoMessage 

func (*BinlogTransaction_Statement) ProtoMessage()

func (*BinlogTransaction_Statement) Reset 

func (m *BinlogTransaction_Statement) Reset()

func (*BinlogTransaction_Statement) String 

func (m *BinlogTransaction_Statement) String() string

func (*BinlogTransaction_Statement) XXX_DiscardUnknown 

func (m *BinlogTransaction_Statement) XXX_DiscardUnknown()

func (*BinlogTransaction_Statement) XXX_Marshal 

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

func (*BinlogTransaction_Statement) XXX_Merge 

func (dst *BinlogTransaction_Statement) XXX_Merge(src proto.Message)

func (*BinlogTransaction_Statement) XXX_Size 

func (m *BinlogTransaction_Statement) XXX_Size() int

func (*BinlogTransaction_Statement) XXX_Unmarshal 

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

type BinlogTransaction_Statement_Category 

type BinlogTransaction_Statement_Category int32
const (
	BinlogTransaction_Statement_BL_UNRECOGNIZED BinlogTransaction_Statement_Category = 0
	BinlogTransaction_Statement_BL_BEGIN        BinlogTransaction_Statement_Category = 1
	BinlogTransaction_Statement_BL_COMMIT       BinlogTransaction_Statement_Category = 2
	BinlogTransaction_Statement_BL_ROLLBACK     BinlogTransaction_Statement_Category = 3
	// BL_DML is deprecated.
	BinlogTransaction_Statement_BL_DML_DEPRECATED BinlogTransaction_Statement_Category = 4
	BinlogTransaction_Statement_BL_DDL            BinlogTransaction_Statement_Category = 5
	BinlogTransaction_Statement_BL_SET            BinlogTransaction_Statement_Category = 6
	BinlogTransaction_Statement_BL_INSERT         BinlogTransaction_Statement_Category = 7
	BinlogTransaction_Statement_BL_UPDATE         BinlogTransaction_Statement_Category = 8
	BinlogTransaction_Statement_BL_DELETE         BinlogTransaction_Statement_Category = 9
)

func (BinlogTransaction_Statement_Category) EnumDescriptor 

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

func (BinlogTransaction_Statement_Category) String 

func (x BinlogTransaction_Statement_Category) String() string

type Charset 

type Charset struct {
	// @@session.character_set_client
	Client int32 `protobuf:"varint,1,opt,name=client,proto3" json:"client,omitempty"`
	// @@session.collation_connection
	Conn int32 `protobuf:"varint,2,opt,name=conn,proto3" json:"conn,omitempty"`
	// @@session.collation_server
	Server               int32    `protobuf:"varint,3,opt,name=server,proto3" json:"server,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Charset is the per-statement charset info from a QUERY_EVENT binlog entry.

func (*Charset) Descriptor 

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

func (*Charset) GetClient 

func (m *Charset) GetClient() int32

func (*Charset) GetConn 

func (m *Charset) GetConn() int32

func (*Charset) GetServer 

func (m *Charset) GetServer() int32

func (*Charset) ProtoMessage 

func (*Charset) ProtoMessage()

func (*Charset) Reset 

func (m *Charset) Reset()

func (*Charset) String 

func (m *Charset) String() string

func (*Charset) XXX_DiscardUnknown 

func (m *Charset) XXX_DiscardUnknown()

func (*Charset) XXX_Marshal 

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

func (*Charset) XXX_Merge 

func (dst *Charset) XXX_Merge(src proto.Message)

func (*Charset) XXX_Size 

func (m *Charset) XXX_Size() int

func (*Charset) XXX_Unmarshal 

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

type StreamKeyRangeRequest 

type StreamKeyRangeRequest struct {
	// where to start
	Position string `protobuf:"bytes,1,opt,name=position,proto3" json:"position,omitempty"`
	// what to get
	KeyRange *topodata.KeyRange `protobuf:"bytes,2,opt,name=key_range,json=keyRange,proto3" json:"key_range,omitempty"`
	// default charset on the player side
	Charset              *Charset `protobuf:"bytes,3,opt,name=charset,proto3" json:"charset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

StreamKeyRangeRequest is the payload to StreamKeyRange

func (*StreamKeyRangeRequest) Descriptor 

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

func (*StreamKeyRangeRequest) GetCharset 

func (m *StreamKeyRangeRequest) GetCharset() *Charset

func (*StreamKeyRangeRequest) GetKeyRange 

func (m *StreamKeyRangeRequest) GetKeyRange() *topodata.KeyRange

func (*StreamKeyRangeRequest) GetPosition 

func (m *StreamKeyRangeRequest) GetPosition() string

func (*StreamKeyRangeRequest) ProtoMessage 

func (*StreamKeyRangeRequest) ProtoMessage()

func (*StreamKeyRangeRequest) Reset 

func (m *StreamKeyRangeRequest) Reset()

func (*StreamKeyRangeRequest) String 

func (m *StreamKeyRangeRequest) String() string

func (*StreamKeyRangeRequest) XXX_DiscardUnknown 

func (m *StreamKeyRangeRequest) XXX_DiscardUnknown()

func (*StreamKeyRangeRequest) XXX_Marshal 

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

func (*StreamKeyRangeRequest) XXX_Merge 

func (dst *StreamKeyRangeRequest) XXX_Merge(src proto.Message)

func (*StreamKeyRangeRequest) XXX_Size 

func (m *StreamKeyRangeRequest) XXX_Size() int

func (*StreamKeyRangeRequest) XXX_Unmarshal 

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

type StreamKeyRangeResponse 

type StreamKeyRangeResponse struct {
	BinlogTransaction    *BinlogTransaction `protobuf:"bytes,1,opt,name=binlog_transaction,json=binlogTransaction,proto3" json:"binlog_transaction,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

StreamKeyRangeResponse is the response from StreamKeyRange

func (*StreamKeyRangeResponse) Descriptor 

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

func (*StreamKeyRangeResponse) GetBinlogTransaction 

func (m *StreamKeyRangeResponse) GetBinlogTransaction() *BinlogTransaction

func (*StreamKeyRangeResponse) ProtoMessage 

func (*StreamKeyRangeResponse) ProtoMessage()

func (*StreamKeyRangeResponse) Reset 

func (m *StreamKeyRangeResponse) Reset()

func (*StreamKeyRangeResponse) String 

func (m *StreamKeyRangeResponse) String() string

func (*StreamKeyRangeResponse) XXX_DiscardUnknown 

func (m *StreamKeyRangeResponse) XXX_DiscardUnknown()

func (*StreamKeyRangeResponse) XXX_Marshal 

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

func (*StreamKeyRangeResponse) XXX_Merge 

func (dst *StreamKeyRangeResponse) XXX_Merge(src proto.Message)

func (*StreamKeyRangeResponse) XXX_Size 

func (m *StreamKeyRangeResponse) XXX_Size() int

func (*StreamKeyRangeResponse) XXX_Unmarshal 

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

type StreamTablesRequest 

type StreamTablesRequest struct {
	// where to start
	Position string `protobuf:"bytes,1,opt,name=position,proto3" json:"position,omitempty"`
	// what to get
	Tables []string `protobuf:"bytes,2,rep,name=tables,proto3" json:"tables,omitempty"`
	// default charset on the player side
	Charset              *Charset `protobuf:"bytes,3,opt,name=charset,proto3" json:"charset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

StreamTablesRequest is the payload to StreamTables

func (*StreamTablesRequest) Descriptor 

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

func (*StreamTablesRequest) GetCharset 

func (m *StreamTablesRequest) GetCharset() *Charset

func (*StreamTablesRequest) GetPosition 

func (m *StreamTablesRequest) GetPosition() string

func (*StreamTablesRequest) GetTables 

func (m *StreamTablesRequest) GetTables() []string

func (*StreamTablesRequest) ProtoMessage 

func (*StreamTablesRequest) ProtoMessage()

func (*StreamTablesRequest) Reset 

func (m *StreamTablesRequest) Reset()

func (*StreamTablesRequest) String 

func (m *StreamTablesRequest) String() string

func (*StreamTablesRequest) XXX_DiscardUnknown 

func (m *StreamTablesRequest) XXX_DiscardUnknown()

func (*StreamTablesRequest) XXX_Marshal 

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

func (*StreamTablesRequest) XXX_Merge 

func (dst *StreamTablesRequest) XXX_Merge(src proto.Message)

func (*StreamTablesRequest) XXX_Size 

func (m *StreamTablesRequest) XXX_Size() int

func (*StreamTablesRequest) XXX_Unmarshal 

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

type StreamTablesResponse 

type StreamTablesResponse struct {
	BinlogTransaction    *BinlogTransaction `protobuf:"bytes,1,opt,name=binlog_transaction,json=binlogTransaction,proto3" json:"binlog_transaction,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

StreamTablesResponse is the response from StreamTables

func (*StreamTablesResponse) Descriptor 

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

func (*StreamTablesResponse) GetBinlogTransaction 

func (m *StreamTablesResponse) GetBinlogTransaction() *BinlogTransaction

func (*StreamTablesResponse) ProtoMessage 

func (*StreamTablesResponse) ProtoMessage()

func (*StreamTablesResponse) Reset 

func (m *StreamTablesResponse) Reset()

func (*StreamTablesResponse) String 

func (m *StreamTablesResponse) String() string

func (*StreamTablesResponse) XXX_DiscardUnknown 

func (m *StreamTablesResponse) XXX_DiscardUnknown()

func (*StreamTablesResponse) XXX_Marshal 

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

func (*StreamTablesResponse) XXX_Merge 

func (dst *StreamTablesResponse) XXX_Merge(src proto.Message)

func (*StreamTablesResponse) XXX_Size 

func (m *StreamTablesResponse) XXX_Size() int

func (*StreamTablesResponse) XXX_Unmarshal 

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