import "gopkg.in/src-d/go-vitess.v1/vt/proto/binlogdata"
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", }
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, }
var VEventType_name = map[int32]string{ 0: "UNKNOWN", 1: "GTID", 2: "BEGIN", 3: "COMMIT", 4: "ROLLBACK", 5: "DDL", 6: "INSERT", 7: "REPLACE", 8: "UPDATE", 9: "DELETE", 10: "SET", 11: "OTHER", 12: "ROW", 13: "FIELD", 14: "HEARTBEAT", }
var VEventType_value = map[string]int32{ "UNKNOWN": 0, "GTID": 1, "BEGIN": 2, "COMMIT": 3, "ROLLBACK": 4, "DDL": 5, "INSERT": 6, "REPLACE": 7, "UPDATE": 8, "DELETE": 9, "SET": 10, "OTHER": 11, "ROW": 12, "FIELD": 13, "HEARTBEAT": 14, }
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"` // filter is set if we're using the generalized representation // for the filter. Filter *Filter `protobuf:"bytes,6,opt,name=filter,proto3" json:"filter,omitempty"` // on_ddl specifies the action to be taken when a DDL is encountered. OnDdl OnDDLAction `protobuf:"varint,7,opt,name=on_ddl,json=onDdl,proto3,enum=binlogdata.OnDDLAction" json:"on_ddl,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() ([]byte, []int)
func (m *BinlogSource) GetFilter() *Filter
func (m *BinlogSource) GetKeyRange() *topodata.KeyRange
func (m *BinlogSource) GetKeyspace() string
func (m *BinlogSource) GetOnDdl() OnDDLAction
func (m *BinlogSource) GetShard() string
func (m *BinlogSource) GetTables() []string
func (m *BinlogSource) GetTabletType() topodata.TabletType
func (*BinlogSource) ProtoMessage()
func (m *BinlogSource) Reset()
func (m *BinlogSource) String() string
func (m *BinlogSource) XXX_DiscardUnknown()
func (dst *BinlogSource) XXX_Merge(src proto.Message)
func (m *BinlogSource) XXX_Size() int
func (m *BinlogSource) XXX_Unmarshal(b []byte) error
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() ([]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
func (m *BinlogTransaction) XXX_DiscardUnknown()
func (dst *BinlogTransaction) XXX_Merge(src proto.Message)
func (m *BinlogTransaction) XXX_Size() int
func (m *BinlogTransaction) XXX_Unmarshal(b []byte) error
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() ([]byte, []int)
func (m *BinlogTransaction_Statement) GetCategory() BinlogTransaction_Statement_Category
func (m *BinlogTransaction_Statement) GetCharset() *Charset
func (m *BinlogTransaction_Statement) GetSql() []byte
func (*BinlogTransaction_Statement) ProtoMessage()
func (m *BinlogTransaction_Statement) Reset()
func (m *BinlogTransaction_Statement) String() string
func (m *BinlogTransaction_Statement) XXX_DiscardUnknown()
func (dst *BinlogTransaction_Statement) XXX_Merge(src proto.Message)
func (m *BinlogTransaction_Statement) XXX_Size() int
func (m *BinlogTransaction_Statement) XXX_Unmarshal(b []byte) error
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() ([]byte, []int)
func (x BinlogTransaction_Statement_Category) String() string
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.
type FieldEvent struct { TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` Fields []*query.Field `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FieldEvent) Descriptor() ([]byte, []int)
func (m *FieldEvent) GetFields() []*query.Field
func (m *FieldEvent) GetTableName() string
func (*FieldEvent) ProtoMessage()
func (m *FieldEvent) Reset()
func (m *FieldEvent) String() string
func (m *FieldEvent) XXX_DiscardUnknown()
func (dst *FieldEvent) XXX_Merge(src proto.Message)
func (m *FieldEvent) XXX_Size() int
func (m *FieldEvent) XXX_Unmarshal(b []byte) error
type Filter struct { Rules []*Rule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Filter represents a list of ordered rules. First match wins.
OnDDLAction lists the possible actions for DDLs.
const ( OnDDLAction_IGNORE OnDDLAction = 0 OnDDLAction_STOP OnDDLAction = 1 OnDDLAction_EXEC OnDDLAction = 2 OnDDLAction_EXEC_IGNORE OnDDLAction = 3 )
func (OnDDLAction) EnumDescriptor() ([]byte, []int)
func (x OnDDLAction) String() string
type RowChange struct { Before *query.Row `protobuf:"bytes,1,opt,name=before,proto3" json:"before,omitempty"` After *query.Row `protobuf:"bytes,2,opt,name=after,proto3" json:"after,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
RowChange represents one row change
type RowEvent struct { TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` RowChanges []*RowChange `protobuf:"bytes,2,rep,name=row_changes,json=rowChanges,proto3" json:"row_changes,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
RowEvent represent row events for one table
type Rule struct { // match can be a table name or a regular expression // delineated by '/' and '/'. Match string `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"` // filter can be an empty string or keyrange if the match // is a regular expression. Otherwise, it must be a select // query. Filter string `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Rule represents one rule.
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() ([]byte, []int)
func (m *StreamKeyRangeRequest) GetCharset() *Charset
func (m *StreamKeyRangeRequest) GetKeyRange() *topodata.KeyRange
func (m *StreamKeyRangeRequest) GetPosition() string
func (*StreamKeyRangeRequest) ProtoMessage()
func (m *StreamKeyRangeRequest) Reset()
func (m *StreamKeyRangeRequest) String() string
func (m *StreamKeyRangeRequest) XXX_DiscardUnknown()
func (dst *StreamKeyRangeRequest) XXX_Merge(src proto.Message)
func (m *StreamKeyRangeRequest) XXX_Size() int
func (m *StreamKeyRangeRequest) XXX_Unmarshal(b []byte) error
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() ([]byte, []int)
func (m *StreamKeyRangeResponse) GetBinlogTransaction() *BinlogTransaction
func (*StreamKeyRangeResponse) ProtoMessage()
func (m *StreamKeyRangeResponse) Reset()
func (m *StreamKeyRangeResponse) String() string
func (m *StreamKeyRangeResponse) XXX_DiscardUnknown()
func (dst *StreamKeyRangeResponse) XXX_Merge(src proto.Message)
func (m *StreamKeyRangeResponse) XXX_Size() int
func (m *StreamKeyRangeResponse) XXX_Unmarshal(b []byte) error
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() ([]byte, []int)
func (m *StreamTablesRequest) GetCharset() *Charset
func (m *StreamTablesRequest) GetPosition() string
func (m *StreamTablesRequest) GetTables() []string
func (*StreamTablesRequest) ProtoMessage()
func (m *StreamTablesRequest) Reset()
func (m *StreamTablesRequest) String() string
func (m *StreamTablesRequest) XXX_DiscardUnknown()
func (dst *StreamTablesRequest) XXX_Merge(src proto.Message)
func (m *StreamTablesRequest) XXX_Size() int
func (m *StreamTablesRequest) XXX_Unmarshal(b []byte) error
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() ([]byte, []int)
func (m *StreamTablesResponse) GetBinlogTransaction() *BinlogTransaction
func (*StreamTablesResponse) ProtoMessage()
func (m *StreamTablesResponse) Reset()
func (m *StreamTablesResponse) String() string
func (m *StreamTablesResponse) XXX_DiscardUnknown()
func (dst *StreamTablesResponse) XXX_Merge(src proto.Message)
func (m *StreamTablesResponse) XXX_Size() int
func (m *StreamTablesResponse) XXX_Unmarshal(b []byte) error
type VEvent struct { Type VEventType `protobuf:"varint,1,opt,name=type,proto3,enum=binlogdata.VEventType" json:"type,omitempty"` Timestamp int64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Gtid string `protobuf:"bytes,3,opt,name=gtid,proto3" json:"gtid,omitempty"` Ddl string `protobuf:"bytes,4,opt,name=ddl,proto3" json:"ddl,omitempty"` RowEvent *RowEvent `protobuf:"bytes,5,opt,name=row_event,json=rowEvent,proto3" json:"row_event,omitempty"` FieldEvent *FieldEvent `protobuf:"bytes,6,opt,name=field_event,json=fieldEvent,proto3" json:"field_event,omitempty"` // current_time specifies the current time to handle clock skew. CurrentTime int64 `protobuf:"varint,20,opt,name=current_time,json=currentTime,proto3" json:"current_time,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
VEvent represents a vstream event
func (m *VEvent) GetFieldEvent() *FieldEvent
func (m *VEvent) GetType() VEventType
VEventType enumerates the event types. This list is comprehensive. Many of these types will not be encountered in RBR mode.
const ( VEventType_UNKNOWN VEventType = 0 VEventType_GTID VEventType = 1 VEventType_BEGIN VEventType = 2 VEventType_COMMIT VEventType = 3 VEventType_ROLLBACK VEventType = 4 VEventType_DDL VEventType = 5 VEventType_INSERT VEventType = 6 VEventType_REPLACE VEventType = 7 VEventType_UPDATE VEventType = 8 VEventType_DELETE VEventType = 9 VEventType_SET VEventType = 10 VEventType_OTHER VEventType = 11 VEventType_ROW VEventType = 12 VEventType_FIELD VEventType = 13 VEventType_HEARTBEAT VEventType = 14 )
func (VEventType) EnumDescriptor() ([]byte, []int)
func (x VEventType) String() string
type VStreamRequest struct { EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"` ImmediateCallerId *query.VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"` Target *query.Target `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` Position string `protobuf:"bytes,4,opt,name=position,proto3" json:"position,omitempty"` Filter *Filter `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
VStreamRequest is the payload for VStream
func (*VStreamRequest) Descriptor() ([]byte, []int)
func (m *VStreamRequest) GetEffectiveCallerId() *vtrpc.CallerID
func (m *VStreamRequest) GetFilter() *Filter
func (m *VStreamRequest) GetImmediateCallerId() *query.VTGateCallerID
func (m *VStreamRequest) GetPosition() string
func (m *VStreamRequest) GetTarget() *query.Target
func (*VStreamRequest) ProtoMessage()
func (m *VStreamRequest) Reset()
func (m *VStreamRequest) String() string
func (m *VStreamRequest) XXX_DiscardUnknown()
func (dst *VStreamRequest) XXX_Merge(src proto.Message)
func (m *VStreamRequest) XXX_Size() int
func (m *VStreamRequest) XXX_Unmarshal(b []byte) error
type VStreamResponse struct { Events []*VEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
VStreamResponse is the response from VStream
func (*VStreamResponse) Descriptor() ([]byte, []int)
func (m *VStreamResponse) GetEvents() []*VEvent
func (*VStreamResponse) ProtoMessage()
func (m *VStreamResponse) Reset()
func (m *VStreamResponse) String() string
func (m *VStreamResponse) XXX_DiscardUnknown()
func (dst *VStreamResponse) XXX_Merge(src proto.Message)
func (m *VStreamResponse) XXX_Size() int
func (m *VStreamResponse) XXX_Unmarshal(b []byte) error
type VStreamRowsRequest struct { EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"` ImmediateCallerId *query.VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"` Target *query.Target `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` Query string `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"` Lastpk *query.QueryResult `protobuf:"bytes,5,opt,name=lastpk,proto3" json:"lastpk,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
VStreamRowsRequest is the payload for VStreamRows
func (*VStreamRowsRequest) Descriptor() ([]byte, []int)
func (m *VStreamRowsRequest) GetEffectiveCallerId() *vtrpc.CallerID
func (m *VStreamRowsRequest) GetImmediateCallerId() *query.VTGateCallerID
func (m *VStreamRowsRequest) GetLastpk() *query.QueryResult
func (m *VStreamRowsRequest) GetQuery() string
func (m *VStreamRowsRequest) GetTarget() *query.Target
func (*VStreamRowsRequest) ProtoMessage()
func (m *VStreamRowsRequest) Reset()
func (m *VStreamRowsRequest) String() string
func (m *VStreamRowsRequest) XXX_DiscardUnknown()
func (dst *VStreamRowsRequest) XXX_Merge(src proto.Message)
func (m *VStreamRowsRequest) XXX_Size() int
func (m *VStreamRowsRequest) XXX_Unmarshal(b []byte) error
type VStreamRowsResponse struct { Fields []*query.Field `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"` Pkfields []*query.Field `protobuf:"bytes,2,rep,name=pkfields,proto3" json:"pkfields,omitempty"` Gtid string `protobuf:"bytes,3,opt,name=gtid,proto3" json:"gtid,omitempty"` Rows []*query.Row `protobuf:"bytes,4,rep,name=rows,proto3" json:"rows,omitempty"` Lastpk *query.Row `protobuf:"bytes,5,opt,name=lastpk,proto3" json:"lastpk,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
VStreamRowsResponse is the response from VStreamRows
func (*VStreamRowsResponse) Descriptor() ([]byte, []int)
func (m *VStreamRowsResponse) GetFields() []*query.Field
func (m *VStreamRowsResponse) GetGtid() string
func (m *VStreamRowsResponse) GetLastpk() *query.Row
func (m *VStreamRowsResponse) GetPkfields() []*query.Field
func (m *VStreamRowsResponse) GetRows() []*query.Row
func (*VStreamRowsResponse) ProtoMessage()
func (m *VStreamRowsResponse) Reset()
func (m *VStreamRowsResponse) String() string
func (m *VStreamRowsResponse) XXX_DiscardUnknown()
func (dst *VStreamRowsResponse) XXX_Merge(src proto.Message)
func (m *VStreamRowsResponse) XXX_Size() int
func (m *VStreamRowsResponse) XXX_Unmarshal(b []byte) error
Package binlogdata imports 6 packages (graph) and is imported by 28 packages. Updated 2019-06-13. Refresh now. Tools for package owners.