binlogdata

package
v0.0.4 Latest Latest
Warning

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

 Go to latest Published: Jun 14, 2023 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var BinlogTransaction_Statement_Category_name = map[int32]string{
	0: "BL_UNRECOGNIZED",
	1: "BL_BEGIN",
	2: "BL_COMMIT",
	3: "BL_ROLLBACK",
	4: "BL_DML_DEPRECATED",
	5: "BL_DDL",
	6: "BL_SET",
	7: "BL_INSERT",
	8: "BL_UPDATE",
	9: "BL_DELETE",
}
View Source 
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,
}
View Source 
var Filter_FieldEventMode_name = map[int32]string{
	0: "ERR_ON_MISMATCH",
	1: "BEST_EFFORT",
}
View Source 
var Filter_FieldEventMode_value = map[string]int32{
	"ERR_ON_MISMATCH": 0,
	"BEST_EFFORT":     1,
}
View Source 
var MigrationType_name = map[int32]string{
	0: "TABLES",
	1: "SHARDS",
}
View Source 
var MigrationType_value = map[string]int32{
	"TABLES": 0,
	"SHARDS": 1,
}
View Source 
var OnDDLAction_name = map[int32]string{
	0: "IGNORE",
	1: "STOP",
	2: "EXEC",
	3: "EXEC_IGNORE",
}
View Source 
var OnDDLAction_value = map[string]int32{
	"IGNORE":      0,
	"STOP":        1,
	"EXEC":        2,
	"EXEC_IGNORE": 3,
}
View Source 
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",
}
View Source 
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,
}

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"`
	// 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"`
	// 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"`
	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 

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) 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) Descriptor() ([]byte, []int)

func (*Charset) GetClient 

func (m *Charset) GetClient() int32

func (*Charset) GetConn 

func (m *Charset) GetConn() int32

func (*Charset) GetServer 

func (m *Charset) GetServer() int32

func (*Charset) ProtoMessage 

func (*Charset) ProtoMessage()

func (*Charset) Reset 

func (m *Charset) Reset()

func (*Charset) String 

func (m *Charset) String() string

func (*Charset) XXX_DiscardUnknown 

func (m *Charset) XXX_DiscardUnknown()

func (*Charset) XXX_Marshal 

func (m *Charset) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Charset) XXX_Merge 

func (m *Charset) XXX_Merge(src proto.Message)

func (*Charset) XXX_Size 

func (m *Charset) XXX_Size() int

func (*Charset) XXX_Unmarshal 

func (m *Charset) XXX_Unmarshal(b []byte) error

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

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       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. First match wins.

func (*Filter) Descriptor 

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

func (*Filter) GetFieldEventMode 

func (m *Filter) GetFieldEventMode() Filter_FieldEventMode

func (*Filter) GetRules 

func (m *Filter) GetRules() []*Rule

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) Reset 

func (m *Filter) Reset()

func (*Filter) String 

func (m *Filter) String() string

func (*Filter) XXX_DiscardUnknown 

func (m *Filter) XXX_DiscardUnknown()

func (*Filter) XXX_Marshal 

func (m *Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Filter) XXX_Merge 

func (m *Filter) XXX_Merge(src proto.Message)

func (*Filter) XXX_Size 

func (m *Filter) XXX_Size() int

func (*Filter) XXX_Unmarshal 

func (m *Filter) XXX_Unmarshal(b []byte) error

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                   int64            `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	MigrationType        MigrationType    `` /* 131-byte string literal not displayed */
	Tables               []string         `protobuf:"bytes,3,rep,name=tables,proto3" json:"tables,omitempty"`
	LocalPosition        string           `protobuf:"bytes,4,opt,name=local_position,json=localPosition,proto3" json:"local_position,omitempty"`
	ShardGtids           []*ShardGtid     `protobuf:"bytes,5,rep,name=shard_gtids,json=shardGtids,proto3" json:"shard_gtids,omitempty"`
	Participants         []*KeyspaceShard `protobuf:"bytes,6,rep,name=participants,proto3" json:"participants,omitempty"`
	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:"-"`
}

func (*Journal) Descriptor 

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

func (*Journal) GetId 

func (m *Journal) GetId() int64

func (*Journal) GetLocalPosition 

func (m *Journal) GetLocalPosition() string

func (*Journal) GetMigrationType 

func (m *Journal) GetMigrationType() MigrationType

func (*Journal) GetParticipants 

func (m *Journal) GetParticipants() []*KeyspaceShard

func (*Journal) GetShardGtids 

func (m *Journal) GetShardGtids() []*ShardGtid

func (*Journal) GetSourceWorkflows 

func (m *Journal) GetSourceWorkflows() []string

func (*Journal) GetTables 

func (m *Journal) GetTables() []string

func (*Journal) ProtoMessage 

func (*Journal) ProtoMessage()

func (*Journal) Reset 

func (m *Journal) Reset()

func (*Journal) String 

func (m *Journal) String() string

func (*Journal) XXX_DiscardUnknown 

func (m *Journal) XXX_DiscardUnknown()

func (*Journal) XXX_Marshal 

func (m *Journal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Journal) XXX_Merge 

func (m *Journal) XXX_Merge(src proto.Message)

func (*Journal) XXX_Size 

func (m *Journal) XXX_Size() int

func (*Journal) XXX_Unmarshal 

func (m *Journal) XXX_Unmarshal(b []byte) error

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

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

func (*RowChange) Descriptor 

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

func (*RowChange) GetAfter 

func (m *RowChange) GetAfter() *query.Row

func (*RowChange) GetBefore 

func (m *RowChange) GetBefore() *query.Row

func (*RowChange) ProtoMessage 

func (*RowChange) ProtoMessage()

func (*RowChange) Reset 

func (m *RowChange) Reset()

func (*RowChange) String 

func (m *RowChange) String() string

func (*RowChange) XXX_DiscardUnknown 

func (m *RowChange) XXX_DiscardUnknown()

func (*RowChange) XXX_Marshal 

func (m *RowChange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RowChange) XXX_Merge 

func (m *RowChange) XXX_Merge(src proto.Message)

func (*RowChange) XXX_Size 

func (m *RowChange) XXX_Size() int

func (*RowChange) XXX_Unmarshal 

func (m *RowChange) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*RowEvent) GetRowChanges 

func (m *RowEvent) GetRowChanges() []*RowChange

func (*RowEvent) GetTableName 

func (m *RowEvent) GetTableName() string

func (*RowEvent) ProtoMessage 

func (*RowEvent) ProtoMessage()

func (*RowEvent) Reset 

func (m *RowEvent) Reset()

func (*RowEvent) String 

func (m *RowEvent) String() string

func (*RowEvent) XXX_DiscardUnknown 

func (m *RowEvent) XXX_DiscardUnknown()

func (*RowEvent) XXX_Marshal 

func (m *RowEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RowEvent) XXX_Merge 

func (m *RowEvent) XXX_Merge(src proto.Message)

func (*RowEvent) XXX_Size 

func (m *RowEvent) XXX_Size() int

func (*RowEvent) XXX_Unmarshal 

func (m *RowEvent) XXX_Unmarshal(b []byte) error

type Rule 

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.

func (*Rule) Descriptor 

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

func (*Rule) GetFilter 

func (m *Rule) GetFilter() string

func (*Rule) GetMatch 

func (m *Rule) GetMatch() string

func (*Rule) ProtoMessage 

func (*Rule) ProtoMessage()

func (*Rule) Reset 

func (m *Rule) Reset()

func (*Rule) String 

func (m *Rule) String() string

func (*Rule) XXX_DiscardUnknown 

func (m *Rule) XXX_DiscardUnknown()

func (*Rule) XXX_Marshal 

func (m *Rule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Rule) XXX_Merge 

func (m *Rule) XXX_Merge(src proto.Message)

func (*Rule) XXX_Size 

func (m *Rule) XXX_Size() int

func (*Rule) XXX_Unmarshal 

func (m *Rule) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ShardGtid) Descriptor 

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

func (*ShardGtid) GetGtid 

func (m *ShardGtid) GetGtid() string

func (*ShardGtid) GetKeyspace 

func (m *ShardGtid) GetKeyspace() string

func (*ShardGtid) GetShard 

func (m *ShardGtid) GetShard() string

func (*ShardGtid) ProtoMessage 

func (*ShardGtid) ProtoMessage()

func (*ShardGtid) Reset 

func (m *ShardGtid) Reset()

func (*ShardGtid) String 

func (m *ShardGtid) String() string

func (*ShardGtid) XXX_DiscardUnknown 

func (m *ShardGtid) XXX_DiscardUnknown()

func (*ShardGtid) XXX_Marshal 

func (m *ShardGtid) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShardGtid) XXX_Merge 

func (m *ShardGtid) XXX_Merge(src proto.Message)

func (*ShardGtid) XXX_Size 

func (m *ShardGtid) XXX_Size() int

func (*ShardGtid) XXX_Unmarshal 

func (m *ShardGtid) XXX_Unmarshal(b []byte) error

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 VEvent 

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"`
	Vgtid      *VGtid      `protobuf:"bytes,7,opt,name=vgtid,proto3" json:"vgtid,omitempty"`
	Journal    *Journal    `protobuf:"bytes,8,opt,name=journal,proto3" json:"journal,omitempty"`
	Dml        string      `protobuf:"bytes,9,opt,name=dml,proto3" json:"dml,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 (*VEvent) Descriptor 

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

func (*VEvent) GetCurrentTime 

func (m *VEvent) GetCurrentTime() int64

func (*VEvent) GetDdl 

func (m *VEvent) GetDdl() string

func (*VEvent) GetDml 

func (m *VEvent) GetDml() string

func (*VEvent) GetFieldEvent 

func (m *VEvent) GetFieldEvent() *FieldEvent

func (*VEvent) GetGtid 

func (m *VEvent) GetGtid() string

func (*VEvent) GetJournal 

func (m *VEvent) GetJournal() *Journal

func (*VEvent) GetRowEvent 

func (m *VEvent) GetRowEvent() *RowEvent

func (*VEvent) GetTimestamp 

func (m *VEvent) GetTimestamp() int64

func (*VEvent) GetType 

func (m *VEvent) GetType() VEventType

func (*VEvent) GetVgtid 

func (m *VEvent) GetVgtid() *VGtid

func (*VEvent) ProtoMessage 

func (*VEvent) ProtoMessage()

func (*VEvent) Reset 

func (m *VEvent) Reset()

func (*VEvent) String 

func (m *VEvent) String() string

func (*VEvent) XXX_DiscardUnknown 

func (m *VEvent) XXX_DiscardUnknown()

func (*VEvent) XXX_Marshal 

func (m *VEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VEvent) XXX_Merge 

func (m *VEvent) XXX_Merge(src proto.Message)

func (*VEvent) XXX_Size 

func (m *VEvent) XXX_Size() int

func (*VEvent) XXX_Unmarshal 

func (m *VEvent) XXX_Unmarshal(b []byte) error

type VEventType 

type VEventType int32

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
	VEventType_VGTID     VEventType = 15
	VEventType_JOURNAL   VEventType = 16
)

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

func (*VGtid) Descriptor 

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

func (*VGtid) GetShardGtids 

func (m *VGtid) GetShardGtids() []*ShardGtid

func (*VGtid) ProtoMessage 

func (*VGtid) ProtoMessage()

func (*VGtid) Reset 

func (m *VGtid) Reset()

func (*VGtid) String 

func (m *VGtid) String() string

func (*VGtid) XXX_DiscardUnknown 

func (m *VGtid) XXX_DiscardUnknown()

func (*VGtid) XXX_Marshal 

func (m *VGtid) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VGtid) XXX_Merge 

func (m *VGtid) XXX_Merge(src proto.Message)

func (*VGtid) XXX_Size 

func (m *VGtid) XXX_Size() int

func (*VGtid) XXX_Unmarshal 

func (m *VGtid) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

VStreamRequest is the payload for VStream

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

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.

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.