binlogdata

Documentation

Overview

Package binlogdata is a generated protocol buffer package.

It is generated from these files:

binlogdata.proto

It has these top-level messages:

Charset
BinlogTransaction
StreamKeyRangeRequest
StreamKeyRangeResponse
StreamTablesRequest
StreamTablesResponse

Index

• Variables
• type BinlogTransaction
  • func (*BinlogTransaction) Descriptor() ([]byte, []int)
  • func (m *BinlogTransaction) GetEventToken() *query.EventToken
  • func (m *BinlogTransaction) GetStatements() []*BinlogTransaction_Statement
  • func (*BinlogTransaction) ProtoMessage()
  • func (m *BinlogTransaction) Reset()
  • func (m *BinlogTransaction) String() string
• type BinlogTransaction_Statement
  • func (*BinlogTransaction_Statement) Descriptor() ([]byte, []int)
  • func (m *BinlogTransaction_Statement) GetCharset() *Charset
  • func (*BinlogTransaction_Statement) ProtoMessage()
  • func (m *BinlogTransaction_Statement) Reset()
  • func (m *BinlogTransaction_Statement) String() string
• type BinlogTransaction_Statement_Category
  • func (BinlogTransaction_Statement_Category) EnumDescriptor() ([]byte, []int)
  • func (x BinlogTransaction_Statement_Category) String() string
• type Charset
  • func (*Charset) Descriptor() ([]byte, []int)
  • func (*Charset) ProtoMessage()
  • func (m *Charset) Reset()
  • func (m *Charset) String() string
• type StreamKeyRangeRequest
  • func (*StreamKeyRangeRequest) Descriptor() ([]byte, []int)
  • func (m *StreamKeyRangeRequest) GetCharset() *Charset
  • func (m *StreamKeyRangeRequest) GetKeyRange() *topodata.KeyRange
  • func (*StreamKeyRangeRequest) ProtoMessage()
  • func (m *StreamKeyRangeRequest) Reset()
  • func (m *StreamKeyRangeRequest) String() string
• type StreamKeyRangeResponse
  • func (*StreamKeyRangeResponse) Descriptor() ([]byte, []int)
  • func (m *StreamKeyRangeResponse) GetBinlogTransaction() *BinlogTransaction
  • func (*StreamKeyRangeResponse) ProtoMessage()
  • func (m *StreamKeyRangeResponse) Reset()
  • func (m *StreamKeyRangeResponse) String() string
• type StreamTablesRequest
  • func (*StreamTablesRequest) Descriptor() ([]byte, []int)
  • func (m *StreamTablesRequest) GetCharset() *Charset
  • func (*StreamTablesRequest) ProtoMessage()
  • func (m *StreamTablesRequest) Reset()
  • func (m *StreamTablesRequest) String() string
• type StreamTablesResponse
  • func (*StreamTablesResponse) Descriptor() ([]byte, []int)
  • func (m *StreamTablesResponse) GetBinlogTransaction() *BinlogTransaction
  • func (*StreamTablesResponse) ProtoMessage()
  • func (m *StreamTablesResponse) Reset()
  • func (m *StreamTablesResponse) String() string

Variables

var BinlogTransaction_Statement_Category_name = map[int32]string{
	0: "BL_UNRECOGNIZED",
	1: "BL_BEGIN",
	2: "BL_COMMIT",
	3: "BL_ROLLBACK",
	4: "BL_DML",
	5: "BL_DDL",
	6: "BL_SET",
}

var BinlogTransaction_Statement_Category_value = map[string]int32{
	"BL_UNRECOGNIZED": 0,
	"BL_BEGIN":        1,
	"BL_COMMIT":       2,
	"BL_ROLLBACK":     3,
	"BL_DML":          4,
	"BL_DDL":          5,
	"BL_SET":          6,
}

Types

type BinlogTransaction

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

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

type BinlogTransaction_Statement

type BinlogTransaction_Statement struct {
	// what type of statement is this?
	Category BinlogTransaction_Statement_Category `protobuf:"varint,1,opt,name=category,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" json:"charset,omitempty"`
	// the sql
	Sql []byte `protobuf:"bytes,3,opt,name=sql,proto3" json:"sql,omitempty"`
}

func (*BinlogTransaction_Statement) Descriptor

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

func (*BinlogTransaction_Statement) GetCharset

func (m *BinlogTransaction_Statement) GetCharset() *Charset

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

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
	BinlogTransaction_Statement_BL_DML          BinlogTransaction_Statement_Category = 4
	BinlogTransaction_Statement_BL_DDL          BinlogTransaction_Statement_Category = 5
	BinlogTransaction_Statement_BL_SET          BinlogTransaction_Statement_Category = 6
)

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" json:"client,omitempty"`
	// @@session.collation_connection
	Conn int32 `protobuf:"varint,2,opt,name=conn" json:"conn,omitempty"`
	// @@session.collation_server
	Server int32 `protobuf:"varint,3,opt,name=server" json:"server,omitempty"`
}

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

func (*Charset) Descriptor

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

func (*Charset) ProtoMessage

func (*Charset) ProtoMessage()

func (*Charset) Reset

func (m *Charset) Reset()

func (*Charset) String

func (m *Charset) String() string

type StreamKeyRangeRequest

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

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) ProtoMessage

func (*StreamKeyRangeRequest) ProtoMessage()

func (*StreamKeyRangeRequest) Reset

func (m *StreamKeyRangeRequest) Reset()

func (*StreamKeyRangeRequest) String

func (m *StreamKeyRangeRequest) String() string

type StreamKeyRangeResponse

type StreamKeyRangeResponse struct {
	BinlogTransaction *BinlogTransaction `protobuf:"bytes,1,opt,name=binlog_transaction,json=binlogTransaction" json:"binlog_transaction,omitempty"`
}

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

type StreamTablesRequest

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

StreamTablesRequest is the payload to StreamTables

func (*StreamTablesRequest) Descriptor

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

func (*StreamTablesRequest) GetCharset

func (m *StreamTablesRequest) GetCharset() *Charset

func (*StreamTablesRequest) ProtoMessage

func (*StreamTablesRequest) ProtoMessage()

func (*StreamTablesRequest) Reset

func (m *StreamTablesRequest) Reset()

func (*StreamTablesRequest) String

func (m *StreamTablesRequest) String() string

type StreamTablesResponse

type StreamTablesResponse struct {
	BinlogTransaction *BinlogTransaction `protobuf:"bytes,1,opt,name=binlog_transaction,json=binlogTransaction" json:"binlog_transaction,omitempty"`
}

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