Versions in this module Expand all Collapse all v0 v0.0.3 Jun 14, 2023 v0.0.2 Jun 14, 2023 v0.0.1 Jun 14, 2023 v0.0.0 Jun 13, 2023 Changes in this version + var BinlogTransaction_Statement_Category_name = map[int32]string + var BinlogTransaction_Statement_Category_value = map[string]int32 + var Filter_FieldEventMode_name = map[int32]string + var Filter_FieldEventMode_value = map[string]int32 + var MigrationType_name = map[int32]string + var MigrationType_value = map[string]int32 + var OnDDLAction_name = map[int32]string + var OnDDLAction_value = map[string]int32 + var VEventType_name = map[int32]string + var VEventType_value = map[string]int32 + type BinlogSource struct + ExternalMysql string + Filter *Filter + KeyRange *topodata.KeyRange + Keyspace string + OnDdl OnDDLAction + Shard string + Tables []string + TabletType topodata.TabletType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BinlogSource) Descriptor() ([]byte, []int) + func (*BinlogSource) ProtoMessage() + 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) GetTables() []string + func (m *BinlogSource) GetTabletType() topodata.TabletType + 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 struct + EventToken *query.EventToken + Statements []*BinlogTransaction_Statement + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BinlogTransaction) Descriptor() ([]byte, []int) + func (*BinlogTransaction) ProtoMessage() + func (m *BinlogTransaction) GetEventToken() *query.EventToken + func (m *BinlogTransaction) GetStatements() []*BinlogTransaction_Statement + 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 struct + Category BinlogTransaction_Statement_Category + Charset *Charset + Sql []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BinlogTransaction_Statement) Descriptor() ([]byte, []int) + func (*BinlogTransaction_Statement) ProtoMessage() + func (m *BinlogTransaction_Statement) GetCategory() BinlogTransaction_Statement_Category + func (m *BinlogTransaction_Statement) GetCharset() *Charset + func (m *BinlogTransaction_Statement) GetSql() []byte + 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 int32 + const BinlogTransaction_Statement_BL_BEGIN + const BinlogTransaction_Statement_BL_COMMIT + const BinlogTransaction_Statement_BL_DDL + const BinlogTransaction_Statement_BL_DELETE + const BinlogTransaction_Statement_BL_DML_DEPRECATED + const BinlogTransaction_Statement_BL_INSERT + const BinlogTransaction_Statement_BL_ROLLBACK + const BinlogTransaction_Statement_BL_SET + const BinlogTransaction_Statement_BL_UNRECOGNIZED + const BinlogTransaction_Statement_BL_UPDATE + func (BinlogTransaction_Statement_Category) EnumDescriptor() ([]byte, []int) + func (x BinlogTransaction_Statement_Category) String() string + type Charset struct + Client int32 + Conn int32 + Server int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Charset) Descriptor() ([]byte, []int) + func (*Charset) ProtoMessage() + func (m *Charset) GetClient() int32 + func (m *Charset) GetConn() int32 + func (m *Charset) GetServer() int32 + 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 struct + Fields []*query.Field + TableName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FieldEvent) Descriptor() ([]byte, []int) + func (*FieldEvent) ProtoMessage() + func (m *FieldEvent) GetFields() []*query.Field + func (m *FieldEvent) GetTableName() string + 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 struct + FieldEventMode Filter_FieldEventMode + Rules []*Rule + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Filter) Descriptor() ([]byte, []int) + func (*Filter) ProtoMessage() + func (m *Filter) GetFieldEventMode() Filter_FieldEventMode + func (m *Filter) GetRules() []*Rule + 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 int32 + const Filter_BEST_EFFORT + const Filter_ERR_ON_MISMATCH + func (Filter_FieldEventMode) EnumDescriptor() ([]byte, []int) + func (x Filter_FieldEventMode) String() string + type Journal struct + Id int64 + LocalPosition string + MigrationType MigrationType + Participants []*KeyspaceShard + ShardGtids []*ShardGtid + SourceWorkflows []string + Tables []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Journal) Descriptor() ([]byte, []int) + func (*Journal) ProtoMessage() + 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 (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 struct + Keyspace string + Shard string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*KeyspaceShard) Descriptor() ([]byte, []int) + func (*KeyspaceShard) ProtoMessage() + func (m *KeyspaceShard) GetKeyspace() string + func (m *KeyspaceShard) GetShard() string + 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 MigrationType int32 + const MigrationType_SHARDS + const MigrationType_TABLES + func (MigrationType) EnumDescriptor() ([]byte, []int) + func (x MigrationType) String() string + type OnDDLAction int32 + const OnDDLAction_EXEC + const OnDDLAction_EXEC_IGNORE + const OnDDLAction_IGNORE + const OnDDLAction_STOP + func (OnDDLAction) EnumDescriptor() ([]byte, []int) + func (x OnDDLAction) String() string + type RowChange struct + After *query.Row + Before *query.Row + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RowChange) Descriptor() ([]byte, []int) + func (*RowChange) ProtoMessage() + func (m *RowChange) GetAfter() *query.Row + func (m *RowChange) GetBefore() *query.Row + 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 struct + RowChanges []*RowChange + TableName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RowEvent) Descriptor() ([]byte, []int) + func (*RowEvent) ProtoMessage() + func (m *RowEvent) GetRowChanges() []*RowChange + func (m *RowEvent) GetTableName() string + 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 struct + Filter string + Match string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Rule) Descriptor() ([]byte, []int) + func (*Rule) ProtoMessage() + func (m *Rule) GetFilter() string + func (m *Rule) GetMatch() string + 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 struct + Gtid string + Keyspace string + Shard string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShardGtid) Descriptor() ([]byte, []int) + func (*ShardGtid) ProtoMessage() + func (m *ShardGtid) GetGtid() string + func (m *ShardGtid) GetKeyspace() string + func (m *ShardGtid) GetShard() string + 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 struct + Charset *Charset + KeyRange *topodata.KeyRange + Position string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamKeyRangeRequest) Descriptor() ([]byte, []int) + func (*StreamKeyRangeRequest) ProtoMessage() + func (m *StreamKeyRangeRequest) GetCharset() *Charset + func (m *StreamKeyRangeRequest) GetKeyRange() *topodata.KeyRange + func (m *StreamKeyRangeRequest) GetPosition() string + 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 struct + BinlogTransaction *BinlogTransaction + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamKeyRangeResponse) Descriptor() ([]byte, []int) + func (*StreamKeyRangeResponse) ProtoMessage() + func (m *StreamKeyRangeResponse) GetBinlogTransaction() *BinlogTransaction + 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 struct + Charset *Charset + Position string + Tables []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamTablesRequest) Descriptor() ([]byte, []int) + func (*StreamTablesRequest) ProtoMessage() + func (m *StreamTablesRequest) GetCharset() *Charset + func (m *StreamTablesRequest) GetPosition() string + func (m *StreamTablesRequest) GetTables() []string + 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 struct + BinlogTransaction *BinlogTransaction + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamTablesResponse) Descriptor() ([]byte, []int) + func (*StreamTablesResponse) ProtoMessage() + func (m *StreamTablesResponse) GetBinlogTransaction() *BinlogTransaction + 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 VEvent struct + CurrentTime int64 + Ddl string + Dml string + FieldEvent *FieldEvent + Gtid string + Journal *Journal + RowEvent *RowEvent + Timestamp int64 + Type VEventType + Vgtid *VGtid + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*VEvent) Descriptor() ([]byte, []int) + func (*VEvent) ProtoMessage() + func (m *VEvent) GetCurrentTime() int64 + func (m *VEvent) GetDdl() string + func (m *VEvent) GetDml() string + func (m *VEvent) GetFieldEvent() *FieldEvent + func (m *VEvent) GetGtid() string + func (m *VEvent) GetJournal() *Journal + func (m *VEvent) GetRowEvent() *RowEvent + func (m *VEvent) GetTimestamp() int64 + func (m *VEvent) GetType() VEventType + func (m *VEvent) GetVgtid() *VGtid + 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 int32 + const VEventType_BEGIN + const VEventType_COMMIT + const VEventType_DDL + const VEventType_DELETE + const VEventType_FIELD + const VEventType_GTID + const VEventType_HEARTBEAT + const VEventType_INSERT + const VEventType_JOURNAL + const VEventType_OTHER + const VEventType_REPLACE + const VEventType_ROLLBACK + const VEventType_ROW + const VEventType_SET + const VEventType_UNKNOWN + const VEventType_UPDATE + const VEventType_VGTID + func (VEventType) EnumDescriptor() ([]byte, []int) + func (x VEventType) String() string + type VGtid struct + ShardGtids []*ShardGtid + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*VGtid) Descriptor() ([]byte, []int) + func (*VGtid) ProtoMessage() + func (m *VGtid) GetShardGtids() []*ShardGtid + 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 struct + EffectiveCallerId *vtrpc.CallerID + Filter *Filter + ImmediateCallerId *query.VTGateCallerID + Position string + Target *query.Target + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*VStreamRequest) Descriptor() ([]byte, []int) + func (*VStreamRequest) ProtoMessage() + 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 (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 struct + Events []*VEvent + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*VStreamResponse) Descriptor() ([]byte, []int) + func (*VStreamResponse) ProtoMessage() + func (m *VStreamResponse) GetEvents() []*VEvent + 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 struct + EffectiveCallerId *vtrpc.CallerID + ImmediateCallerId *query.VTGateCallerID + Query string + Target *query.Target + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*VStreamResultsRequest) Descriptor() ([]byte, []int) + func (*VStreamResultsRequest) ProtoMessage() + func (m *VStreamResultsRequest) GetEffectiveCallerId() *vtrpc.CallerID + func (m *VStreamResultsRequest) GetImmediateCallerId() *query.VTGateCallerID + func (m *VStreamResultsRequest) GetQuery() string + func (m *VStreamResultsRequest) GetTarget() *query.Target + 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 struct + Fields []*query.Field + Gtid string + Rows []*query.Row + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*VStreamResultsResponse) Descriptor() ([]byte, []int) + func (*VStreamResultsResponse) ProtoMessage() + func (m *VStreamResultsResponse) GetFields() []*query.Field + func (m *VStreamResultsResponse) GetGtid() string + func (m *VStreamResultsResponse) GetRows() []*query.Row + 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 struct + EffectiveCallerId *vtrpc.CallerID + ImmediateCallerId *query.VTGateCallerID + Lastpk *query.QueryResult + Query string + Target *query.Target + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*VStreamRowsRequest) Descriptor() ([]byte, []int) + func (*VStreamRowsRequest) ProtoMessage() + 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 (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 struct + Fields []*query.Field + Gtid string + Lastpk *query.Row + Pkfields []*query.Field + Rows []*query.Row + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*VStreamRowsResponse) Descriptor() ([]byte, []int) + func (*VStreamRowsResponse) ProtoMessage() + 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 (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
Go to main page