binlogdata

package
v2.0.0-alpha3+incompat... Latest Latest
Warning

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

 Go to latest Published: Oct 3, 2015 License: BSD-3-Clause Imports: 5 Imported by: 0

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
StreamEvent
StreamUpdateRequest
StreamUpdateResponse
StreamKeyRangeRequest
StreamKeyRangeResponse
StreamTablesRequest
StreamTablesResponse

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",
	5: "BL_DDL",
	6: "BL_SET",
}
View Source 
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,
}
View Source 
var StreamEvent_Category_name = map[int32]string{
	0: "SE_ERR",
	1: "SE_DML",
	2: "SE_DDL",
	3: "SE_POS",
}
View Source 
var StreamEvent_Category_value = map[string]int32{
	"SE_ERR": 0,
	"SE_DML": 1,
	"SE_DDL": 2,
	"SE_POS": 3,
}

Functions

This section is empty.

Types

type BinlogTransaction 

type BinlogTransaction struct {
	// the statements in this transaction
	Statements []*BinlogTransaction_Statement `protobuf:"bytes,1,rep,name=statements" json:"statements,omitempty"`
	// the timestamp of the statements
	Timestamp int64 `protobuf:"varint,2,opt,name=timestamp" json:"timestamp,omitempty"`
	// the Transaction ID after this statement was applied
	TransactionId string `protobuf:"bytes,3,opt,name=transaction_id" json:"transaction_id,omitempty"`
}

BinlogTransaction describes a transaction inside the binlogs.

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 string `protobuf:"bytes,3,opt,name=sql" json:"sql,omitempty"`
}

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

func (*Charset) ProtoMessage()

func (*Charset) Reset 

func (m *Charset) Reset()

func (*Charset) String 

func (m *Charset) String() string

type StreamEvent 

type StreamEvent struct {
	Category StreamEvent_Category `protobuf:"varint,1,opt,name=category,enum=binlogdata.StreamEvent_Category" json:"category,omitempty"`
	// table_name, primary_key_fields and primary_key_values are set for SE_DML
	TableName        string         `protobuf:"bytes,2,opt,name=table_name" json:"table_name,omitempty"`
	PrimaryKeyFields []*query.Field `protobuf:"bytes,3,rep,name=primary_key_fields" json:"primary_key_fields,omitempty"`
	PrimaryKeyValues []*query.Row   `protobuf:"bytes,4,rep,name=primary_key_values" json:"primary_key_values,omitempty"`
	// sql is set for SE_DDL or SE_ERR
	Sql string `protobuf:"bytes,5,opt,name=sql" json:"sql,omitempty"`
	// timestamp is set for SE_DML, SE_DDL or SE_ERR
	Timestamp int64 `protobuf:"varint,6,opt,name=timestamp" json:"timestamp,omitempty"`
	// the Transaction ID after this statement was applied
	TransactionId string `protobuf:"bytes,7,opt,name=transaction_id" json:"transaction_id,omitempty"`
}

StreamEvent describes an update stream event inside the binlogs.

func (*StreamEvent) GetPrimaryKeyFields 

func (m *StreamEvent) GetPrimaryKeyFields() []*query.Field

func (*StreamEvent) GetPrimaryKeyValues 

func (m *StreamEvent) GetPrimaryKeyValues() []*query.Row

func (*StreamEvent) ProtoMessage 

func (*StreamEvent) ProtoMessage()

func (*StreamEvent) Reset 

func (m *StreamEvent) Reset()

func (*StreamEvent) String 

func (m *StreamEvent) String() string

type StreamEvent_Category 

type StreamEvent_Category int32

the category of this event 

const (
	StreamEvent_SE_ERR StreamEvent_Category = 0
	StreamEvent_SE_DML StreamEvent_Category = 1
	StreamEvent_SE_DDL StreamEvent_Category = 2
	StreamEvent_SE_POS StreamEvent_Category = 3
)

func (StreamEvent_Category) String 

func (x StreamEvent_Category) String() string

type StreamKeyRangeRequest 

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

StreamKeyRangeRequest is the payload to StreamKeyRange

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:"binlog_transaction,omitempty"`
}

StreamKeyRangeResponse is the response from StreamKeyRange

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) 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:"binlog_transaction,omitempty"`
}

StreamTablesResponse is the response from StreamTables

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

type StreamUpdateRequest 

type StreamUpdateRequest struct {
	// where to start
	Position string `protobuf:"bytes,1,opt,name=position" json:"position,omitempty"`
}

StreamUpdateRequest is the payload to StreamUpdate

func (*StreamUpdateRequest) ProtoMessage 

func (*StreamUpdateRequest) ProtoMessage()

func (*StreamUpdateRequest) Reset 

func (m *StreamUpdateRequest) Reset()

func (*StreamUpdateRequest) String 

func (m *StreamUpdateRequest) String() string

type StreamUpdateResponse 

type StreamUpdateResponse struct {
	StreamEvent *StreamEvent `protobuf:"bytes,1,opt,name=stream_event" json:"stream_event,omitempty"`
}

StreamUpdateResponse is the response from StreamUpdate

func (*StreamUpdateResponse) GetStreamEvent 

func (m *StreamUpdateResponse) GetStreamEvent() *StreamEvent

func (*StreamUpdateResponse) ProtoMessage 

func (*StreamUpdateResponse) ProtoMessage()

func (*StreamUpdateResponse) Reset 

func (m *StreamUpdateResponse) Reset()

func (*StreamUpdateResponse) String 

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