Documentation ¶
Index ¶
- Variables
- type BinlogSource
- func (*BinlogSource) Descriptor() ([]byte, []int)
- func (m *BinlogSource) GetExternalMysql() string
- 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) GetStopAfterCopy() bool
- 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 (m *BinlogSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BinlogSource) XXX_Merge(src proto.Message)
- func (m *BinlogSource) XXX_Size() int
- func (m *BinlogSource) XXX_Unmarshal(b []byte) error
- 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
- func (m *BinlogTransaction) XXX_DiscardUnknown()
- func (m *BinlogTransaction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BinlogTransaction) XXX_Merge(src proto.Message)
- func (m *BinlogTransaction) XXX_Size() int
- func (m *BinlogTransaction) XXX_Unmarshal(b []byte) error
- type BinlogTransaction_Statement
- 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 (m *BinlogTransaction_Statement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BinlogTransaction_Statement) XXX_Merge(src proto.Message)
- func (m *BinlogTransaction_Statement) XXX_Size() int
- func (m *BinlogTransaction_Statement) XXX_Unmarshal(b []byte) error
- type BinlogTransaction_Statement_Category
- type Charset
- func (*Charset) Descriptor() ([]byte, []int)
- func (m *Charset) GetClient() int32
- func (m *Charset) GetConn() int32
- func (m *Charset) GetServer() int32
- func (*Charset) ProtoMessage()
- func (m *Charset) Reset()
- func (m *Charset) String() string
- func (m *Charset) XXX_DiscardUnknown()
- func (m *Charset) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Charset) XXX_Merge(src proto.Message)
- func (m *Charset) XXX_Size() int
- func (m *Charset) XXX_Unmarshal(b []byte) error
- type FieldEvent
- 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 (m *FieldEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FieldEvent) XXX_Merge(src proto.Message)
- func (m *FieldEvent) XXX_Size() int
- func (m *FieldEvent) XXX_Unmarshal(b []byte) error
- type Filter
- func (*Filter) Descriptor() ([]byte, []int)
- func (m *Filter) GetFieldEventMode() Filter_FieldEventMode
- func (m *Filter) GetRules() []*Rule
- func (*Filter) ProtoMessage()
- func (m *Filter) Reset()
- func (m *Filter) String() string
- func (m *Filter) XXX_DiscardUnknown()
- func (m *Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Filter) XXX_Merge(src proto.Message)
- func (m *Filter) XXX_Size() int
- func (m *Filter) XXX_Unmarshal(b []byte) error
- type Filter_FieldEventMode
- type Journal
- func (*Journal) Descriptor() ([]byte, []int)
- func (m *Journal) GetId() int64
- func (m *Journal) GetLocalPosition() string
- func (m *Journal) GetMigrationType() MigrationType
- func (m *Journal) GetParticipants() []*KeyspaceShard
- func (m *Journal) GetShardGtids() []*ShardGtid
- func (m *Journal) GetSourceWorkflows() []string
- func (m *Journal) GetTables() []string
- func (*Journal) ProtoMessage()
- func (m *Journal) Reset()
- func (m *Journal) String() string
- func (m *Journal) XXX_DiscardUnknown()
- func (m *Journal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Journal) XXX_Merge(src proto.Message)
- func (m *Journal) XXX_Size() int
- func (m *Journal) XXX_Unmarshal(b []byte) error
- type KeyspaceShard
- func (*KeyspaceShard) Descriptor() ([]byte, []int)
- func (m *KeyspaceShard) GetKeyspace() string
- func (m *KeyspaceShard) GetShard() string
- func (*KeyspaceShard) ProtoMessage()
- func (m *KeyspaceShard) Reset()
- func (m *KeyspaceShard) String() string
- func (m *KeyspaceShard) XXX_DiscardUnknown()
- func (m *KeyspaceShard) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KeyspaceShard) XXX_Merge(src proto.Message)
- func (m *KeyspaceShard) XXX_Size() int
- func (m *KeyspaceShard) XXX_Unmarshal(b []byte) error
- type LastPKEvent
- func (*LastPKEvent) Descriptor() ([]byte, []int)
- func (m *LastPKEvent) GetCompleted() bool
- func (m *LastPKEvent) GetTableLastPK() *TableLastPK
- func (*LastPKEvent) ProtoMessage()
- func (m *LastPKEvent) Reset()
- func (m *LastPKEvent) String() string
- func (m *LastPKEvent) XXX_DiscardUnknown()
- func (m *LastPKEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LastPKEvent) XXX_Merge(src proto.Message)
- func (m *LastPKEvent) XXX_Size() int
- func (m *LastPKEvent) XXX_Unmarshal(b []byte) error
- type MigrationType
- type MinimalSchema
- func (*MinimalSchema) Descriptor() ([]byte, []int)
- func (m *MinimalSchema) GetTables() []*MinimalTable
- func (*MinimalSchema) ProtoMessage()
- func (m *MinimalSchema) Reset()
- func (m *MinimalSchema) String() string
- func (m *MinimalSchema) XXX_DiscardUnknown()
- func (m *MinimalSchema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MinimalSchema) XXX_Merge(src proto.Message)
- func (m *MinimalSchema) XXX_Size() int
- func (m *MinimalSchema) XXX_Unmarshal(b []byte) error
- type MinimalTable
- func (*MinimalTable) Descriptor() ([]byte, []int)
- func (m *MinimalTable) GetFields() []*query.Field
- func (m *MinimalTable) GetName() string
- func (m *MinimalTable) GetPKColumns() []int64
- func (*MinimalTable) ProtoMessage()
- func (m *MinimalTable) Reset()
- func (m *MinimalTable) String() string
- func (m *MinimalTable) XXX_DiscardUnknown()
- func (m *MinimalTable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MinimalTable) XXX_Merge(src proto.Message)
- func (m *MinimalTable) XXX_Size() int
- func (m *MinimalTable) XXX_Unmarshal(b []byte) error
- type OnDDLAction
- type RowChange
- func (*RowChange) Descriptor() ([]byte, []int)
- func (m *RowChange) GetAfter() *query.Row
- func (m *RowChange) GetBefore() *query.Row
- func (*RowChange) ProtoMessage()
- func (m *RowChange) Reset()
- func (m *RowChange) String() string
- func (m *RowChange) XXX_DiscardUnknown()
- func (m *RowChange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RowChange) XXX_Merge(src proto.Message)
- func (m *RowChange) XXX_Size() int
- func (m *RowChange) XXX_Unmarshal(b []byte) error
- type RowEvent
- func (*RowEvent) Descriptor() ([]byte, []int)
- func (m *RowEvent) GetRowChanges() []*RowChange
- func (m *RowEvent) GetTableName() string
- func (*RowEvent) ProtoMessage()
- func (m *RowEvent) Reset()
- func (m *RowEvent) String() string
- func (m *RowEvent) XXX_DiscardUnknown()
- func (m *RowEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RowEvent) XXX_Merge(src proto.Message)
- func (m *RowEvent) XXX_Size() int
- func (m *RowEvent) XXX_Unmarshal(b []byte) error
- type Rule
- func (*Rule) Descriptor() ([]byte, []int)
- func (m *Rule) GetFilter() string
- func (m *Rule) GetMatch() string
- func (*Rule) ProtoMessage()
- func (m *Rule) Reset()
- func (m *Rule) String() string
- func (m *Rule) XXX_DiscardUnknown()
- func (m *Rule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Rule) XXX_Merge(src proto.Message)
- func (m *Rule) XXX_Size() int
- func (m *Rule) XXX_Unmarshal(b []byte) error
- type ShardGtid
- func (*ShardGtid) Descriptor() ([]byte, []int)
- func (m *ShardGtid) GetGtid() string
- func (m *ShardGtid) GetKeyspace() string
- func (m *ShardGtid) GetShard() string
- func (m *ShardGtid) GetTablePKs() []*TableLastPK
- func (*ShardGtid) ProtoMessage()
- func (m *ShardGtid) Reset()
- func (m *ShardGtid) String() string
- func (m *ShardGtid) XXX_DiscardUnknown()
- func (m *ShardGtid) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ShardGtid) XXX_Merge(src proto.Message)
- func (m *ShardGtid) XXX_Size() int
- func (m *ShardGtid) XXX_Unmarshal(b []byte) error
- type StreamKeyRangeRequest
- 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 (m *StreamKeyRangeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamKeyRangeRequest) XXX_Merge(src proto.Message)
- func (m *StreamKeyRangeRequest) XXX_Size() int
- func (m *StreamKeyRangeRequest) XXX_Unmarshal(b []byte) error
- type StreamKeyRangeResponse
- 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 (m *StreamKeyRangeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamKeyRangeResponse) XXX_Merge(src proto.Message)
- func (m *StreamKeyRangeResponse) XXX_Size() int
- func (m *StreamKeyRangeResponse) XXX_Unmarshal(b []byte) error
- type StreamTablesRequest
- 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 (m *StreamTablesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamTablesRequest) XXX_Merge(src proto.Message)
- func (m *StreamTablesRequest) XXX_Size() int
- func (m *StreamTablesRequest) XXX_Unmarshal(b []byte) error
- type StreamTablesResponse
- 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 (m *StreamTablesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamTablesResponse) XXX_Merge(src proto.Message)
- func (m *StreamTablesResponse) XXX_Size() int
- func (m *StreamTablesResponse) XXX_Unmarshal(b []byte) error
- type TableLastPK
- func (*TableLastPK) Descriptor() ([]byte, []int)
- func (m *TableLastPK) GetLastpk() *query.QueryResult
- func (m *TableLastPK) GetTableName() string
- func (*TableLastPK) ProtoMessage()
- func (m *TableLastPK) Reset()
- func (m *TableLastPK) String() string
- func (m *TableLastPK) XXX_DiscardUnknown()
- func (m *TableLastPK) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TableLastPK) XXX_Merge(src proto.Message)
- func (m *TableLastPK) XXX_Size() int
- func (m *TableLastPK) XXX_Unmarshal(b []byte) error
- type VEvent
- func (*VEvent) Descriptor() ([]byte, []int)
- func (m *VEvent) GetCurrentTime() int64
- func (m *VEvent) GetDml() string
- func (m *VEvent) GetFieldEvent() *FieldEvent
- func (m *VEvent) GetGtid() string
- func (m *VEvent) GetJournal() *Journal
- func (m *VEvent) GetLastPKEvent() *LastPKEvent
- func (m *VEvent) GetRowEvent() *RowEvent
- func (m *VEvent) GetStatement() string
- func (m *VEvent) GetTimestamp() int64
- func (m *VEvent) GetType() VEventType
- func (m *VEvent) GetVgtid() *VGtid
- func (*VEvent) ProtoMessage()
- func (m *VEvent) Reset()
- func (m *VEvent) String() string
- func (m *VEvent) XXX_DiscardUnknown()
- func (m *VEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *VEvent) XXX_Merge(src proto.Message)
- func (m *VEvent) XXX_Size() int
- func (m *VEvent) XXX_Unmarshal(b []byte) error
- type VEventType
- type VGtid
- func (*VGtid) Descriptor() ([]byte, []int)
- func (m *VGtid) GetShardGtids() []*ShardGtid
- func (*VGtid) ProtoMessage()
- func (m *VGtid) Reset()
- func (m *VGtid) String() string
- func (m *VGtid) XXX_DiscardUnknown()
- func (m *VGtid) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *VGtid) XXX_Merge(src proto.Message)
- func (m *VGtid) XXX_Size() int
- func (m *VGtid) XXX_Unmarshal(b []byte) error
- type VStreamRequest
- 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) GetTableLastPKs() []*TableLastPK
- func (m *VStreamRequest) GetTarget() *query.Target
- func (*VStreamRequest) ProtoMessage()
- func (m *VStreamRequest) Reset()
- func (m *VStreamRequest) String() string
- func (m *VStreamRequest) XXX_DiscardUnknown()
- func (m *VStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *VStreamRequest) XXX_Merge(src proto.Message)
- func (m *VStreamRequest) XXX_Size() int
- func (m *VStreamRequest) XXX_Unmarshal(b []byte) error
- type VStreamResponse
- 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 (m *VStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *VStreamResponse) XXX_Merge(src proto.Message)
- func (m *VStreamResponse) XXX_Size() int
- func (m *VStreamResponse) XXX_Unmarshal(b []byte) error
- type VStreamResultsRequest
- func (*VStreamResultsRequest) Descriptor() ([]byte, []int)
- func (m *VStreamResultsRequest) GetEffectiveCallerId() *vtrpc.CallerID
- func (m *VStreamResultsRequest) GetImmediateCallerId() *query.VTGateCallerID
- func (m *VStreamResultsRequest) GetQuery() string
- func (m *VStreamResultsRequest) GetTarget() *query.Target
- func (*VStreamResultsRequest) ProtoMessage()
- func (m *VStreamResultsRequest) Reset()
- func (m *VStreamResultsRequest) String() string
- func (m *VStreamResultsRequest) XXX_DiscardUnknown()
- func (m *VStreamResultsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *VStreamResultsRequest) XXX_Merge(src proto.Message)
- func (m *VStreamResultsRequest) XXX_Size() int
- func (m *VStreamResultsRequest) XXX_Unmarshal(b []byte) error
- type VStreamResultsResponse
- func (*VStreamResultsResponse) Descriptor() ([]byte, []int)
- func (m *VStreamResultsResponse) GetFields() []*query.Field
- func (m *VStreamResultsResponse) GetGtid() string
- func (m *VStreamResultsResponse) GetRows() []*query.Row
- func (*VStreamResultsResponse) ProtoMessage()
- func (m *VStreamResultsResponse) Reset()
- func (m *VStreamResultsResponse) String() string
- func (m *VStreamResultsResponse) XXX_DiscardUnknown()
- func (m *VStreamResultsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *VStreamResultsResponse) XXX_Merge(src proto.Message)
- func (m *VStreamResultsResponse) XXX_Size() int
- func (m *VStreamResultsResponse) XXX_Unmarshal(b []byte) error
- type VStreamRowsRequest
- 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 (m *VStreamRowsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *VStreamRowsRequest) XXX_Merge(src proto.Message)
- func (m *VStreamRowsRequest) XXX_Size() int
- func (m *VStreamRowsRequest) XXX_Unmarshal(b []byte) error
- type VStreamRowsResponse
- 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 (m *VStreamRowsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *VStreamRowsResponse) XXX_Merge(src proto.Message)
- func (m *VStreamRowsResponse) XXX_Size() int
- func (m *VStreamRowsResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
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 Filter_FieldEventMode_name = map[int32]string{
0: "ERR_ON_MISMATCH",
1: "BEST_EFFORT",
}
var Filter_FieldEventMode_value = map[string]int32{
"ERR_ON_MISMATCH": 0,
"BEST_EFFORT": 1,
}
var MigrationType_name = map[int32]string{
0: "TABLES",
1: "SHARDS",
}
var MigrationType_value = map[string]int32{
"TABLES": 0,
"SHARDS": 1,
}
var OnDDLAction_name = map[int32]string{
0: "IGNORE",
1: "STOP",
2: "EXEC",
3: "EXEC_IGNORE",
}
var OnDDLAction_value = map[string]int32{
"IGNORE": 0,
"STOP": 1,
"EXEC": 2,
"EXEC_IGNORE": 3,
}
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",
15: "VGTID",
16: "JOURNAL",
17: "VERSION",
18: "LASTPK",
19: "SAVEPOINT",
}
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,
"VGTID": 15,
"JOURNAL": 16,
"VERSION": 17,
"LASTPK": 18,
"SAVEPOINT": 19,
}
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"` // KeyRange 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"` // OnDdl 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"` // Source is an external mysql. This attribute should be set to the username // to use in the connection ExternalMysql string `protobuf:"bytes,8,opt,name=external_mysql,json=externalMysql,proto3" json:"external_mysql,omitempty"` // StopAfterCopy specifies if vreplication should be stopped // after copying is done. StopAfterCopy bool `protobuf:"varint,9,opt,name=stop_after_copy,json=stopAfterCopy,proto3" json:"stop_after_copy,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
BinlogSource specifies the source and filter parameters for Filtered Replication. KeyRange and Tables are legacy. Filter is the new way to specify the filtering rules.
func (*BinlogSource) Descriptor ¶
func (*BinlogSource) Descriptor() ([]byte, []int)
func (*BinlogSource) GetExternalMysql ¶
func (m *BinlogSource) GetExternalMysql() string
func (*BinlogSource) GetFilter ¶
func (m *BinlogSource) GetFilter() *Filter
func (*BinlogSource) GetKeyRange ¶
func (m *BinlogSource) GetKeyRange() *topodata.KeyRange
func (*BinlogSource) GetKeyspace ¶
func (m *BinlogSource) GetKeyspace() string
func (*BinlogSource) GetOnDdl ¶
func (m *BinlogSource) GetOnDdl() OnDDLAction
func (*BinlogSource) GetShard ¶
func (m *BinlogSource) GetShard() string
func (*BinlogSource) GetStopAfterCopy ¶
func (m *BinlogSource) GetStopAfterCopy() bool
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 (m *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 (m *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 (m *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) ProtoMessage ¶
func (*Charset) ProtoMessage()
func (*Charset) XXX_DiscardUnknown ¶
func (m *Charset) XXX_DiscardUnknown()
func (*Charset) XXX_Marshal ¶
func (*Charset) XXX_Unmarshal ¶
type FieldEvent ¶
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:"-"` }
FieldEvent represents the field info for a table.
func (*FieldEvent) Descriptor ¶
func (*FieldEvent) Descriptor() ([]byte, []int)
func (*FieldEvent) GetFields ¶
func (m *FieldEvent) GetFields() []*query.Field
func (*FieldEvent) GetTableName ¶
func (m *FieldEvent) GetTableName() string
func (*FieldEvent) ProtoMessage ¶
func (*FieldEvent) ProtoMessage()
func (*FieldEvent) Reset ¶
func (m *FieldEvent) Reset()
func (*FieldEvent) String ¶
func (m *FieldEvent) String() string
func (*FieldEvent) XXX_DiscardUnknown ¶
func (m *FieldEvent) XXX_DiscardUnknown()
func (*FieldEvent) XXX_Marshal ¶
func (m *FieldEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FieldEvent) XXX_Merge ¶
func (m *FieldEvent) XXX_Merge(src proto.Message)
func (*FieldEvent) XXX_Size ¶
func (m *FieldEvent) XXX_Size() int
func (*FieldEvent) XXX_Unmarshal ¶
func (m *FieldEvent) XXX_Unmarshal(b []byte) error
type Filter ¶
type Filter struct { Rules []*Rule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"` // FieldEventMode specifies the behavior if there is a mismatch // between the current schema and the fields in the binlog. This // can happen if the binlog position is before a DDL that would // cause the fields to change. If vstreamer detects such // an inconsistency, the behavior depends on the FieldEventMode. // If the value is ERR_ON_MISMATCH (default), then it errors out. // If it's BEST_EFFORT, it sends a field event with fake column // names as "@1", "@2", etc. FieldEventMode Filter_FieldEventMode `protobuf:"varint,2,opt,name=fieldEventMode,proto3,enum=binlogdata.Filter_FieldEventMode" json:"fieldEventMode,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Filter represents a list of ordered rules. The first match wins.
func (*Filter) Descriptor ¶
func (*Filter) GetFieldEventMode ¶
func (m *Filter) GetFieldEventMode() Filter_FieldEventMode
func (*Filter) ProtoMessage ¶
func (*Filter) ProtoMessage()
func (*Filter) XXX_DiscardUnknown ¶
func (m *Filter) XXX_DiscardUnknown()
func (*Filter) XXX_Marshal ¶
func (*Filter) XXX_Unmarshal ¶
type Filter_FieldEventMode ¶
type Filter_FieldEventMode int32
const ( Filter_ERR_ON_MISMATCH Filter_FieldEventMode = 0 Filter_BEST_EFFORT Filter_FieldEventMode = 1 )
func (Filter_FieldEventMode) EnumDescriptor ¶
func (Filter_FieldEventMode) EnumDescriptor() ([]byte, []int)
func (Filter_FieldEventMode) String ¶
func (x Filter_FieldEventMode) String() string
type Journal ¶
type Journal struct { // Id represents a unique journal id. Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` MigrationType MigrationType `` /* 131-byte string literal not displayed */ // Tables is set if the journal represents a TABLES migration. Tables []string `protobuf:"bytes,3,rep,name=tables,proto3" json:"tables,omitempty"` // LocalPosition is the source position at which the migration happened. LocalPosition string `protobuf:"bytes,4,opt,name=local_position,json=localPosition,proto3" json:"local_position,omitempty"` // ShardGtids is the list of targets to which the migration took place. ShardGtids []*ShardGtid `protobuf:"bytes,5,rep,name=shard_gtids,json=shardGtids,proto3" json:"shard_gtids,omitempty"` // Participants is the list of source participants for a migration. // Every participant is expected to have an identical journal entry. // While streaming, the client must wait for the journal entry to // be received from all pariticipants, and then replace them with new // streams specified by ShardGtid. // If a stream does not have all participants, a consistent migration // is not possible. Participants []*KeyspaceShard `protobuf:"bytes,6,rep,name=participants,proto3" json:"participants,omitempty"` // SourceWorkflows is the list of workflows in the source shard that // were migrated to the target. If a migration fails after a Journal // is committed, this information is used to start the target streams // that were created prior to the creation of the journal. SourceWorkflows []string `protobuf:"bytes,7,rep,name=source_workflows,json=sourceWorkflows,proto3" json:"source_workflows,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Journal contains the metadata for a journal event. The commit of a journal event indicates the point of no return for a migration.
func (*Journal) Descriptor ¶
func (*Journal) GetLocalPosition ¶
func (*Journal) GetMigrationType ¶
func (m *Journal) GetMigrationType() MigrationType
func (*Journal) GetParticipants ¶
func (m *Journal) GetParticipants() []*KeyspaceShard
func (*Journal) GetShardGtids ¶
func (*Journal) GetSourceWorkflows ¶
func (*Journal) ProtoMessage ¶
func (*Journal) ProtoMessage()
func (*Journal) XXX_DiscardUnknown ¶
func (m *Journal) XXX_DiscardUnknown()
func (*Journal) XXX_Marshal ¶
func (*Journal) XXX_Unmarshal ¶
type KeyspaceShard ¶
type KeyspaceShard struct { Keyspace string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"` Shard string `protobuf:"bytes,2,opt,name=shard,proto3" json:"shard,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
KeyspaceShard represents a keyspace and shard.
func (*KeyspaceShard) Descriptor ¶
func (*KeyspaceShard) Descriptor() ([]byte, []int)
func (*KeyspaceShard) GetKeyspace ¶
func (m *KeyspaceShard) GetKeyspace() string
func (*KeyspaceShard) GetShard ¶
func (m *KeyspaceShard) GetShard() string
func (*KeyspaceShard) ProtoMessage ¶
func (*KeyspaceShard) ProtoMessage()
func (*KeyspaceShard) Reset ¶
func (m *KeyspaceShard) Reset()
func (*KeyspaceShard) String ¶
func (m *KeyspaceShard) String() string
func (*KeyspaceShard) XXX_DiscardUnknown ¶
func (m *KeyspaceShard) XXX_DiscardUnknown()
func (*KeyspaceShard) XXX_Marshal ¶
func (m *KeyspaceShard) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KeyspaceShard) XXX_Merge ¶
func (m *KeyspaceShard) XXX_Merge(src proto.Message)
func (*KeyspaceShard) XXX_Size ¶
func (m *KeyspaceShard) XXX_Size() int
func (*KeyspaceShard) XXX_Unmarshal ¶
func (m *KeyspaceShard) XXX_Unmarshal(b []byte) error
type LastPKEvent ¶
type LastPKEvent struct { TableLastPK *TableLastPK `protobuf:"bytes,1,opt,name=table_last_p_k,json=tableLastPK,proto3" json:"table_last_p_k,omitempty"` Completed bool `protobuf:"varint,2,opt,name=completed,proto3" json:"completed,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LastPKEvent) Descriptor ¶
func (*LastPKEvent) Descriptor() ([]byte, []int)
func (*LastPKEvent) GetCompleted ¶
func (m *LastPKEvent) GetCompleted() bool
func (*LastPKEvent) GetTableLastPK ¶
func (m *LastPKEvent) GetTableLastPK() *TableLastPK
func (*LastPKEvent) ProtoMessage ¶
func (*LastPKEvent) ProtoMessage()
func (*LastPKEvent) Reset ¶
func (m *LastPKEvent) Reset()
func (*LastPKEvent) String ¶
func (m *LastPKEvent) String() string
func (*LastPKEvent) XXX_DiscardUnknown ¶
func (m *LastPKEvent) XXX_DiscardUnknown()
func (*LastPKEvent) XXX_Marshal ¶
func (m *LastPKEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LastPKEvent) XXX_Merge ¶
func (m *LastPKEvent) XXX_Merge(src proto.Message)
func (*LastPKEvent) XXX_Size ¶
func (m *LastPKEvent) XXX_Size() int
func (*LastPKEvent) XXX_Unmarshal ¶
func (m *LastPKEvent) XXX_Unmarshal(b []byte) error
type MigrationType ¶
type MigrationType int32
MigrationType specifies the type of migration for the Journal.
const ( MigrationType_TABLES MigrationType = 0 MigrationType_SHARDS MigrationType = 1 )
func (MigrationType) EnumDescriptor ¶
func (MigrationType) EnumDescriptor() ([]byte, []int)
func (MigrationType) String ¶
func (x MigrationType) String() string
type MinimalSchema ¶
type MinimalSchema struct { Tables []*MinimalTable `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MinimalSchema) Descriptor ¶
func (*MinimalSchema) Descriptor() ([]byte, []int)
func (*MinimalSchema) GetTables ¶
func (m *MinimalSchema) GetTables() []*MinimalTable
func (*MinimalSchema) ProtoMessage ¶
func (*MinimalSchema) ProtoMessage()
func (*MinimalSchema) Reset ¶
func (m *MinimalSchema) Reset()
func (*MinimalSchema) String ¶
func (m *MinimalSchema) String() string
func (*MinimalSchema) XXX_DiscardUnknown ¶
func (m *MinimalSchema) XXX_DiscardUnknown()
func (*MinimalSchema) XXX_Marshal ¶
func (m *MinimalSchema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MinimalSchema) XXX_Merge ¶
func (m *MinimalSchema) XXX_Merge(src proto.Message)
func (*MinimalSchema) XXX_Size ¶
func (m *MinimalSchema) XXX_Size() int
func (*MinimalSchema) XXX_Unmarshal ¶
func (m *MinimalSchema) XXX_Unmarshal(b []byte) error
type MinimalTable ¶
type MinimalTable struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Fields []*query.Field `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"` PKColumns []int64 `protobuf:"varint,3,rep,packed,name=p_k_columns,json=pKColumns,proto3" json:"p_k_columns,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MinimalTable) Descriptor ¶
func (*MinimalTable) Descriptor() ([]byte, []int)
func (*MinimalTable) GetFields ¶
func (m *MinimalTable) GetFields() []*query.Field
func (*MinimalTable) GetName ¶
func (m *MinimalTable) GetName() string
func (*MinimalTable) GetPKColumns ¶
func (m *MinimalTable) GetPKColumns() []int64
func (*MinimalTable) ProtoMessage ¶
func (*MinimalTable) ProtoMessage()
func (*MinimalTable) Reset ¶
func (m *MinimalTable) Reset()
func (*MinimalTable) String ¶
func (m *MinimalTable) String() string
func (*MinimalTable) XXX_DiscardUnknown ¶
func (m *MinimalTable) XXX_DiscardUnknown()
func (*MinimalTable) XXX_Marshal ¶
func (m *MinimalTable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MinimalTable) XXX_Merge ¶
func (m *MinimalTable) XXX_Merge(src proto.Message)
func (*MinimalTable) XXX_Size ¶
func (m *MinimalTable) XXX_Size() int
func (*MinimalTable) XXX_Unmarshal ¶
func (m *MinimalTable) XXX_Unmarshal(b []byte) error
type OnDDLAction ¶
type OnDDLAction int32
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 ¶
func (OnDDLAction) EnumDescriptor() ([]byte, []int)
func (OnDDLAction) String ¶
func (x OnDDLAction) String() string
type RowChange ¶
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. If Before is set and not After, it's a delete. If After is set and not Before, it's an insert. If both are set, it's an update.
func (*RowChange) Descriptor ¶
func (*RowChange) ProtoMessage ¶
func (*RowChange) ProtoMessage()
func (*RowChange) XXX_DiscardUnknown ¶
func (m *RowChange) XXX_DiscardUnknown()
func (*RowChange) XXX_Marshal ¶
func (*RowChange) XXX_Unmarshal ¶
type RowEvent ¶
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.
func (*RowEvent) Descriptor ¶
func (*RowEvent) GetRowChanges ¶
func (*RowEvent) GetTableName ¶
func (*RowEvent) ProtoMessage ¶
func (*RowEvent) ProtoMessage()
func (*RowEvent) XXX_DiscardUnknown ¶
func (m *RowEvent) XXX_DiscardUnknown()
func (*RowEvent) XXX_Marshal ¶
func (*RowEvent) XXX_Unmarshal ¶
type Rule ¶
type Rule struct { // Match can be a table name or a regular expression. // If it starts with a '/', it's a regular expression. // For example, "t" matches a table named "t", whereas // "/t.*" matches all tables that begin with 't'. Match string `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"` // Filter: If empty, all columns and rows of the matching tables // are sent. If it's a keyrange like "-80", only rows that // match the keyrange are sent. // If Match is a table name instead of a regular expression, // the Filter can also be a select expression like this: // "select * from t", same as an empty Filter, or // "select * from t where in_keyrange('-80')", same as "-80", or // "select col1, col2 from t where in_keyrange(col1, 'hash', '-80'), or // What is allowed in a select expression depends on whether // it's a vstreamer or vreplication request. For more details, // please refer to the specific package documentation. // On the vreplication side, Filter can also accept a special // "exclude" value, which will cause the matched tables // to be excluded. // TODO(sougou): support this on vstreamer side also. 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 in a Filter.
func (*Rule) Descriptor ¶
func (*Rule) ProtoMessage ¶
func (*Rule) ProtoMessage()
func (*Rule) XXX_DiscardUnknown ¶
func (m *Rule) XXX_DiscardUnknown()
func (*Rule) XXX_Unmarshal ¶
type ShardGtid ¶
type ShardGtid struct { Keyspace string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"` Shard string `protobuf:"bytes,2,opt,name=shard,proto3" json:"shard,omitempty"` Gtid string `protobuf:"bytes,3,opt,name=gtid,proto3" json:"gtid,omitempty"` TablePKs []*TableLastPK `protobuf:"bytes,4,rep,name=table_p_ks,json=tablePKs,proto3" json:"table_p_ks,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ShardGtid contains the GTID position for one shard. It's used in a request for requesting a starting position. It's used in a response to transmit the current position of a shard. It's also used in a Journal to indicate the list of targets and shard positions to migrate to.
func (*ShardGtid) Descriptor ¶
func (*ShardGtid) GetKeyspace ¶
func (*ShardGtid) GetTablePKs ¶
func (m *ShardGtid) GetTablePKs() []*TableLastPK
func (*ShardGtid) ProtoMessage ¶
func (*ShardGtid) ProtoMessage()
func (*ShardGtid) XXX_DiscardUnknown ¶
func (m *ShardGtid) XXX_DiscardUnknown()
func (*ShardGtid) XXX_Marshal ¶
func (*ShardGtid) XXX_Unmarshal ¶
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 (m *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 (m *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 (m *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 (m *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
type TableLastPK ¶
type TableLastPK struct { TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` Lastpk *query.QueryResult `protobuf:"bytes,3,opt,name=lastpk,proto3" json:"lastpk,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*TableLastPK) Descriptor ¶
func (*TableLastPK) Descriptor() ([]byte, []int)
func (*TableLastPK) GetLastpk ¶
func (m *TableLastPK) GetLastpk() *query.QueryResult
func (*TableLastPK) GetTableName ¶
func (m *TableLastPK) GetTableName() string
func (*TableLastPK) ProtoMessage ¶
func (*TableLastPK) ProtoMessage()
func (*TableLastPK) Reset ¶
func (m *TableLastPK) Reset()
func (*TableLastPK) String ¶
func (m *TableLastPK) String() string
func (*TableLastPK) XXX_DiscardUnknown ¶
func (m *TableLastPK) XXX_DiscardUnknown()
func (*TableLastPK) XXX_Marshal ¶
func (m *TableLastPK) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TableLastPK) XXX_Merge ¶
func (m *TableLastPK) XXX_Merge(src proto.Message)
func (*TableLastPK) XXX_Size ¶
func (m *TableLastPK) XXX_Size() int
func (*TableLastPK) XXX_Unmarshal ¶
func (m *TableLastPK) XXX_Unmarshal(b []byte) error
type VEvent ¶
type VEvent struct { Type VEventType `protobuf:"varint,1,opt,name=type,proto3,enum=binlogdata.VEventType" json:"type,omitempty"` // Timestamp is the binlog timestamp in seconds. // The value should be ignored if 0. Timestamp int64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // Gtid is set if the event type is GTID. Gtid string `protobuf:"bytes,3,opt,name=gtid,proto3" json:"gtid,omitempty"` // Statement is set if the event type is DDL, DML or SAVEPOINT. Statement string `protobuf:"bytes,4,opt,name=statement,proto3" json:"statement,omitempty"` // RowEvent is set if the event type is ROW. RowEvent *RowEvent `protobuf:"bytes,5,opt,name=row_event,json=rowEvent,proto3" json:"row_event,omitempty"` // FieldEvent is set if the event type is FIELD. FieldEvent *FieldEvent `protobuf:"bytes,6,opt,name=field_event,json=fieldEvent,proto3" json:"field_event,omitempty"` // Vgtid is set if the event type is VGTID. // This event is only generated by VTGate's VStream function. Vgtid *VGtid `protobuf:"bytes,7,opt,name=vgtid,proto3" json:"vgtid,omitempty"` // Journal is set if the event type is JOURNAL. Journal *Journal `protobuf:"bytes,8,opt,name=journal,proto3" json:"journal,omitempty"` // Dml is set if the event type is INSERT, REPLACE, UPDATE or DELETE. Dml string `protobuf:"bytes,9,opt,name=dml,proto3" json:"dml,omitempty"` // CurrentTime specifies the current time when the message was sent. // This can be used to compenssate for clock skew. CurrentTime int64 `protobuf:"varint,20,opt,name=current_time,json=currentTime,proto3" json:"current_time,omitempty"` // LastPK is the last PK for a table LastPKEvent *LastPKEvent `protobuf:"bytes,21,opt,name=last_p_k_event,json=lastPKEvent,proto3" json:"last_p_k_event,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
VEvent represents a vstream event. A FieldEvent is sent once for every table, just before the first event for that table. The client is expected to cache this information and match it against the RowEvent which contains the table name. A GTID event always precedes a commitable event, which can be COMMIT, DDL or OTHER. OTHER events are non-material events that have no additional metadata.
func (*VEvent) Descriptor ¶
func (*VEvent) GetCurrentTime ¶
func (*VEvent) GetFieldEvent ¶
func (m *VEvent) GetFieldEvent() *FieldEvent
func (*VEvent) GetJournal ¶
func (*VEvent) GetLastPKEvent ¶
func (m *VEvent) GetLastPKEvent() *LastPKEvent
func (*VEvent) GetRowEvent ¶
func (*VEvent) GetStatement ¶
func (*VEvent) GetTimestamp ¶
func (*VEvent) GetType ¶
func (m *VEvent) GetType() VEventType
func (*VEvent) ProtoMessage ¶
func (*VEvent) ProtoMessage()
func (*VEvent) XXX_DiscardUnknown ¶
func (m *VEvent) XXX_DiscardUnknown()
func (*VEvent) XXX_Marshal ¶
func (*VEvent) XXX_Unmarshal ¶
type VEventType ¶
type VEventType int32
VEventType enumerates the event types. 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 // INSERT, REPLACE, UPDATE, DELETE and SET will not be seen in RBR mode. VEventType_INSERT VEventType = 6 VEventType_REPLACE VEventType = 7 VEventType_UPDATE VEventType = 8 VEventType_DELETE VEventType = 9 VEventType_SET VEventType = 10 // OTHER is a dummy event. If encountered, the current GTID must be // recorded by the client to be able to resume. VEventType_OTHER VEventType = 11 VEventType_ROW VEventType = 12 VEventType_FIELD VEventType = 13 // HEARTBEAT is sent if there is inactivity. If a client does not // receive events beyond the hearbeat interval, it can assume that it's // lost connection to the vstreamer. VEventType_HEARTBEAT VEventType = 14 // VGTID is generated by VTGate's VStream that combines multiple // GTIDs. VEventType_VGTID VEventType = 15 VEventType_JOURNAL VEventType = 16 VEventType_VERSION VEventType = 17 VEventType_LASTPK VEventType = 18 VEventType_SAVEPOINT VEventType = 19 )
func (VEventType) EnumDescriptor ¶
func (VEventType) EnumDescriptor() ([]byte, []int)
func (VEventType) String ¶
func (x VEventType) String() string
type VGtid ¶
type VGtid struct { ShardGtids []*ShardGtid `protobuf:"bytes,1,rep,name=shard_gtids,json=shardGtids,proto3" json:"shard_gtids,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A VGtid is a list of ShardGtids.
func (*VGtid) Descriptor ¶
func (*VGtid) GetShardGtids ¶
func (*VGtid) ProtoMessage ¶
func (*VGtid) ProtoMessage()
func (*VGtid) XXX_DiscardUnknown ¶
func (m *VGtid) XXX_DiscardUnknown()
func (*VGtid) XXX_Marshal ¶
func (*VGtid) XXX_Unmarshal ¶
type VStreamRequest ¶
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"` TableLastPKs []*TableLastPK `protobuf:"bytes,6,rep,name=table_last_p_ks,json=tableLastPKs,proto3" json:"table_last_p_ks,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
VStreamRequest is the payload for VStreamer
func (*VStreamRequest) Descriptor ¶
func (*VStreamRequest) Descriptor() ([]byte, []int)
func (*VStreamRequest) GetEffectiveCallerId ¶
func (m *VStreamRequest) GetEffectiveCallerId() *vtrpc.CallerID
func (*VStreamRequest) GetFilter ¶
func (m *VStreamRequest) GetFilter() *Filter
func (*VStreamRequest) GetImmediateCallerId ¶
func (m *VStreamRequest) GetImmediateCallerId() *query.VTGateCallerID
func (*VStreamRequest) GetPosition ¶
func (m *VStreamRequest) GetPosition() string
func (*VStreamRequest) GetTableLastPKs ¶
func (m *VStreamRequest) GetTableLastPKs() []*TableLastPK
func (*VStreamRequest) GetTarget ¶
func (m *VStreamRequest) GetTarget() *query.Target
func (*VStreamRequest) ProtoMessage ¶
func (*VStreamRequest) ProtoMessage()
func (*VStreamRequest) Reset ¶
func (m *VStreamRequest) Reset()
func (*VStreamRequest) String ¶
func (m *VStreamRequest) String() string
func (*VStreamRequest) XXX_DiscardUnknown ¶
func (m *VStreamRequest) XXX_DiscardUnknown()
func (*VStreamRequest) XXX_Marshal ¶
func (m *VStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*VStreamRequest) XXX_Merge ¶
func (m *VStreamRequest) XXX_Merge(src proto.Message)
func (*VStreamRequest) XXX_Size ¶
func (m *VStreamRequest) XXX_Size() int
func (*VStreamRequest) XXX_Unmarshal ¶
func (m *VStreamRequest) XXX_Unmarshal(b []byte) error
type VStreamResponse ¶
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 VStreamer
func (*VStreamResponse) Descriptor ¶
func (*VStreamResponse) Descriptor() ([]byte, []int)
func (*VStreamResponse) GetEvents ¶
func (m *VStreamResponse) GetEvents() []*VEvent
func (*VStreamResponse) ProtoMessage ¶
func (*VStreamResponse) ProtoMessage()
func (*VStreamResponse) Reset ¶
func (m *VStreamResponse) Reset()
func (*VStreamResponse) String ¶
func (m *VStreamResponse) String() string
func (*VStreamResponse) XXX_DiscardUnknown ¶
func (m *VStreamResponse) XXX_DiscardUnknown()
func (*VStreamResponse) XXX_Marshal ¶
func (m *VStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*VStreamResponse) XXX_Merge ¶
func (m *VStreamResponse) XXX_Merge(src proto.Message)
func (*VStreamResponse) XXX_Size ¶
func (m *VStreamResponse) XXX_Size() int
func (*VStreamResponse) XXX_Unmarshal ¶
func (m *VStreamResponse) XXX_Unmarshal(b []byte) error
type VStreamResultsRequest ¶
type VStreamResultsRequest 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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
VStreamResultsRequest is the payload for VStreamResults The ids match VStreamRows, in case we decide to merge the two. The ids match VStreamRows, in case we decide to merge the two.
func (*VStreamResultsRequest) Descriptor ¶
func (*VStreamResultsRequest) Descriptor() ([]byte, []int)
func (*VStreamResultsRequest) GetEffectiveCallerId ¶
func (m *VStreamResultsRequest) GetEffectiveCallerId() *vtrpc.CallerID
func (*VStreamResultsRequest) GetImmediateCallerId ¶
func (m *VStreamResultsRequest) GetImmediateCallerId() *query.VTGateCallerID
func (*VStreamResultsRequest) GetQuery ¶
func (m *VStreamResultsRequest) GetQuery() string
func (*VStreamResultsRequest) GetTarget ¶
func (m *VStreamResultsRequest) GetTarget() *query.Target
func (*VStreamResultsRequest) ProtoMessage ¶
func (*VStreamResultsRequest) ProtoMessage()
func (*VStreamResultsRequest) Reset ¶
func (m *VStreamResultsRequest) Reset()
func (*VStreamResultsRequest) String ¶
func (m *VStreamResultsRequest) String() string
func (*VStreamResultsRequest) XXX_DiscardUnknown ¶
func (m *VStreamResultsRequest) XXX_DiscardUnknown()
func (*VStreamResultsRequest) XXX_Marshal ¶
func (m *VStreamResultsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*VStreamResultsRequest) XXX_Merge ¶
func (m *VStreamResultsRequest) XXX_Merge(src proto.Message)
func (*VStreamResultsRequest) XXX_Size ¶
func (m *VStreamResultsRequest) XXX_Size() int
func (*VStreamResultsRequest) XXX_Unmarshal ¶
func (m *VStreamResultsRequest) XXX_Unmarshal(b []byte) error
type VStreamResultsResponse ¶
type VStreamResultsResponse struct { Fields []*query.Field `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
VStreamResultsResponse is the response from VStreamResults The ids match VStreamRows, in case we decide to merge the two.
func (*VStreamResultsResponse) Descriptor ¶
func (*VStreamResultsResponse) Descriptor() ([]byte, []int)
func (*VStreamResultsResponse) GetFields ¶
func (m *VStreamResultsResponse) GetFields() []*query.Field
func (*VStreamResultsResponse) GetGtid ¶
func (m *VStreamResultsResponse) GetGtid() string
func (*VStreamResultsResponse) GetRows ¶
func (m *VStreamResultsResponse) GetRows() []*query.Row
func (*VStreamResultsResponse) ProtoMessage ¶
func (*VStreamResultsResponse) ProtoMessage()
func (*VStreamResultsResponse) Reset ¶
func (m *VStreamResultsResponse) Reset()
func (*VStreamResultsResponse) String ¶
func (m *VStreamResultsResponse) String() string
func (*VStreamResultsResponse) XXX_DiscardUnknown ¶
func (m *VStreamResultsResponse) XXX_DiscardUnknown()
func (*VStreamResultsResponse) XXX_Marshal ¶
func (m *VStreamResultsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*VStreamResultsResponse) XXX_Merge ¶
func (m *VStreamResultsResponse) XXX_Merge(src proto.Message)
func (*VStreamResultsResponse) XXX_Size ¶
func (m *VStreamResultsResponse) XXX_Size() int
func (*VStreamResultsResponse) XXX_Unmarshal ¶
func (m *VStreamResultsResponse) XXX_Unmarshal(b []byte) error
type VStreamRowsRequest ¶
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 ¶
func (*VStreamRowsRequest) Descriptor() ([]byte, []int)
func (*VStreamRowsRequest) GetEffectiveCallerId ¶
func (m *VStreamRowsRequest) GetEffectiveCallerId() *vtrpc.CallerID
func (*VStreamRowsRequest) GetImmediateCallerId ¶
func (m *VStreamRowsRequest) GetImmediateCallerId() *query.VTGateCallerID
func (*VStreamRowsRequest) GetLastpk ¶
func (m *VStreamRowsRequest) GetLastpk() *query.QueryResult
func (*VStreamRowsRequest) GetQuery ¶
func (m *VStreamRowsRequest) GetQuery() string
func (*VStreamRowsRequest) GetTarget ¶
func (m *VStreamRowsRequest) GetTarget() *query.Target
func (*VStreamRowsRequest) ProtoMessage ¶
func (*VStreamRowsRequest) ProtoMessage()
func (*VStreamRowsRequest) Reset ¶
func (m *VStreamRowsRequest) Reset()
func (*VStreamRowsRequest) String ¶
func (m *VStreamRowsRequest) String() string
func (*VStreamRowsRequest) XXX_DiscardUnknown ¶
func (m *VStreamRowsRequest) XXX_DiscardUnknown()
func (*VStreamRowsRequest) XXX_Marshal ¶
func (m *VStreamRowsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*VStreamRowsRequest) XXX_Merge ¶
func (m *VStreamRowsRequest) XXX_Merge(src proto.Message)
func (*VStreamRowsRequest) XXX_Size ¶
func (m *VStreamRowsRequest) XXX_Size() int
func (*VStreamRowsRequest) XXX_Unmarshal ¶
func (m *VStreamRowsRequest) XXX_Unmarshal(b []byte) error
type VStreamRowsResponse ¶
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 ¶
func (*VStreamRowsResponse) Descriptor() ([]byte, []int)
func (*VStreamRowsResponse) GetFields ¶
func (m *VStreamRowsResponse) GetFields() []*query.Field
func (*VStreamRowsResponse) GetGtid ¶
func (m *VStreamRowsResponse) GetGtid() string
func (*VStreamRowsResponse) GetLastpk ¶
func (m *VStreamRowsResponse) GetLastpk() *query.Row
func (*VStreamRowsResponse) GetPkfields ¶
func (m *VStreamRowsResponse) GetPkfields() []*query.Field
func (*VStreamRowsResponse) GetRows ¶
func (m *VStreamRowsResponse) GetRows() []*query.Row
func (*VStreamRowsResponse) ProtoMessage ¶
func (*VStreamRowsResponse) ProtoMessage()
func (*VStreamRowsResponse) Reset ¶
func (m *VStreamRowsResponse) Reset()
func (*VStreamRowsResponse) String ¶
func (m *VStreamRowsResponse) String() string
func (*VStreamRowsResponse) XXX_DiscardUnknown ¶
func (m *VStreamRowsResponse) XXX_DiscardUnknown()
func (*VStreamRowsResponse) XXX_Marshal ¶
func (m *VStreamRowsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*VStreamRowsResponse) XXX_Merge ¶
func (m *VStreamRowsResponse) XXX_Merge(src proto.Message)
func (*VStreamRowsResponse) XXX_Size ¶
func (m *VStreamRowsResponse) XXX_Size() int
func (*VStreamRowsResponse) XXX_Unmarshal ¶
func (m *VStreamRowsResponse) XXX_Unmarshal(b []byte) error