binlogdata

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Mar 25, 2020 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"`
	// 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 added in v1.0.1 

func (m *BinlogSource) GetExternalMysql() string

func (*BinlogSource) GetFilter added in v1.0.1 

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 added in v1.0.1 

func (m *BinlogSource) GetOnDdl() OnDDLAction

func (*BinlogSource) GetShard 

func (m *BinlogSource) GetShard() string

func (*BinlogSource) GetStopAfterCopy added in v1.0.1 

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) 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 added in v1.0.1 

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 added in v1.0.1 

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

func (*FieldEvent) GetFields added in v1.0.1 

func (m *FieldEvent) GetFields() []*query.Field

func (*FieldEvent) GetTableName added in v1.0.1 

func (m *FieldEvent) GetTableName() string

func (*FieldEvent) ProtoMessage added in v1.0.1 

func (*FieldEvent) ProtoMessage()

func (*FieldEvent) Reset added in v1.0.1 

func (m *FieldEvent) Reset()

func (*FieldEvent) String added in v1.0.1 

func (m *FieldEvent) String() string

func (*FieldEvent) XXX_DiscardUnknown added in v1.0.1 

func (m *FieldEvent) XXX_DiscardUnknown()

func (*FieldEvent) XXX_Marshal added in v1.0.1 

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

func (*FieldEvent) XXX_Merge added in v1.0.1 

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

func (*FieldEvent) XXX_Size added in v1.0.1 

func (m *FieldEvent) XXX_Size() int

func (*FieldEvent) XXX_Unmarshal added in v1.0.1 

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

type Filter added in v1.0.1 

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 added in v1.0.1 

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

func (*Filter) GetFieldEventMode added in v1.0.1 

func (m *Filter) GetFieldEventMode() Filter_FieldEventMode

func (*Filter) GetRules added in v1.0.1 

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

func (*Filter) ProtoMessage added in v1.0.1 

func (*Filter) ProtoMessage()

func (*Filter) Reset added in v1.0.1 

func (m *Filter) Reset()

func (*Filter) String added in v1.0.1 

func (m *Filter) String() string

func (*Filter) XXX_DiscardUnknown added in v1.0.1 

func (m *Filter) XXX_DiscardUnknown()

func (*Filter) XXX_Marshal added in v1.0.1 

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

func (*Filter) XXX_Merge added in v1.0.1 

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

func (*Filter) XXX_Size added in v1.0.1 

func (m *Filter) XXX_Size() int

func (*Filter) XXX_Unmarshal added in v1.0.1 

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

type Filter_FieldEventMode added in v1.0.1 

type Filter_FieldEventMode int32
const (
	Filter_ERR_ON_MISMATCH Filter_FieldEventMode = 0
	Filter_BEST_EFFORT     Filter_FieldEventMode = 1
)

func (Filter_FieldEventMode) EnumDescriptor added in v1.0.1 

func (Filter_FieldEventMode) EnumDescriptor() ([]byte, []int)

func (Filter_FieldEventMode) String added in v1.0.1 

func (x Filter_FieldEventMode) String() string

type Journal added in v1.0.1 

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 added in v1.0.1 

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

func (*Journal) GetId added in v1.0.1 

func (m *Journal) GetId() int64

func (*Journal) GetLocalPosition added in v1.0.1 

func (m *Journal) GetLocalPosition() string

func (*Journal) GetMigrationType added in v1.0.1 

func (m *Journal) GetMigrationType() MigrationType

func (*Journal) GetParticipants added in v1.0.1 

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

func (*Journal) GetShardGtids added in v1.0.1 

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

func (*Journal) GetSourceWorkflows added in v1.0.1 

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

func (*Journal) GetTables added in v1.0.1 

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

func (*Journal) ProtoMessage added in v1.0.1 

func (*Journal) ProtoMessage()

func (*Journal) Reset added in v1.0.1 

func (m *Journal) Reset()

func (*Journal) String added in v1.0.1 

func (m *Journal) String() string

func (*Journal) XXX_DiscardUnknown added in v1.0.1 

func (m *Journal) XXX_DiscardUnknown()

func (*Journal) XXX_Marshal added in v1.0.1 

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

func (*Journal) XXX_Merge added in v1.0.1 

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

func (*Journal) XXX_Size added in v1.0.1 

func (m *Journal) XXX_Size() int

func (*Journal) XXX_Unmarshal added in v1.0.1 

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

type KeyspaceShard added in v1.0.1 

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 added in v1.0.1 

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

func (*KeyspaceShard) GetKeyspace added in v1.0.1 

func (m *KeyspaceShard) GetKeyspace() string

func (*KeyspaceShard) GetShard added in v1.0.1 

func (m *KeyspaceShard) GetShard() string

func (*KeyspaceShard) ProtoMessage added in v1.0.1 

func (*KeyspaceShard) ProtoMessage()

func (*KeyspaceShard) Reset added in v1.0.1 

func (m *KeyspaceShard) Reset()

func (*KeyspaceShard) String added in v1.0.1 

func (m *KeyspaceShard) String() string

func (*KeyspaceShard) XXX_DiscardUnknown added in v1.0.1 

func (m *KeyspaceShard) XXX_DiscardUnknown()

func (*KeyspaceShard) XXX_Marshal added in v1.0.1 

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

func (*KeyspaceShard) XXX_Merge added in v1.0.1 

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

func (*KeyspaceShard) XXX_Size added in v1.0.1 

func (m *KeyspaceShard) XXX_Size() int

func (*KeyspaceShard) XXX_Unmarshal added in v1.0.1 

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

type MigrationType added in v1.0.1 

type MigrationType int32

MigrationType specifies the type of migration for the Journal. 

const (
	MigrationType_TABLES MigrationType = 0
	MigrationType_SHARDS MigrationType = 1
)

func (MigrationType) EnumDescriptor added in v1.0.1 

func (MigrationType) EnumDescriptor() ([]byte, []int)

func (MigrationType) String added in v1.0.1 

func (x MigrationType) String() string

type OnDDLAction added in v1.0.1 

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 added in v1.0.1 

func (OnDDLAction) EnumDescriptor() ([]byte, []int)

func (OnDDLAction) String added in v1.0.1 

func (x OnDDLAction) String() string

type RowChange added in v1.0.1 

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 added in v1.0.1 

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

func (*RowChange) GetAfter added in v1.0.1 

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

func (*RowChange) GetBefore added in v1.0.1 

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

func (*RowChange) ProtoMessage added in v1.0.1 

func (*RowChange) ProtoMessage()

func (*RowChange) Reset added in v1.0.1 

func (m *RowChange) Reset()

func (*RowChange) String added in v1.0.1 

func (m *RowChange) String() string

func (*RowChange) XXX_DiscardUnknown added in v1.0.1 

func (m *RowChange) XXX_DiscardUnknown()

func (*RowChange) XXX_Marshal added in v1.0.1 

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

func (*RowChange) XXX_Merge added in v1.0.1 

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

func (*RowChange) XXX_Size added in v1.0.1 

func (m *RowChange) XXX_Size() int

func (*RowChange) XXX_Unmarshal added in v1.0.1 

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

type RowEvent added in v1.0.1 

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 added in v1.0.1 

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

func (*RowEvent) GetRowChanges added in v1.0.1 

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

func (*RowEvent) GetTableName added in v1.0.1 

func (m *RowEvent) GetTableName() string

func (*RowEvent) ProtoMessage added in v1.0.1 

func (*RowEvent) ProtoMessage()

func (*RowEvent) Reset added in v1.0.1 

func (m *RowEvent) Reset()

func (*RowEvent) String added in v1.0.1 

func (m *RowEvent) String() string

func (*RowEvent) XXX_DiscardUnknown added in v1.0.1 

func (m *RowEvent) XXX_DiscardUnknown()

func (*RowEvent) XXX_Marshal added in v1.0.1 

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

func (*RowEvent) XXX_Merge added in v1.0.1 

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

func (*RowEvent) XXX_Size added in v1.0.1 

func (m *RowEvent) XXX_Size() int

func (*RowEvent) XXX_Unmarshal added in v1.0.1 

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

type Rule added in v1.0.1 

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 added in v1.0.1 

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

func (*Rule) GetFilter added in v1.0.1 

func (m *Rule) GetFilter() string

func (*Rule) GetMatch added in v1.0.1 

func (m *Rule) GetMatch() string

func (*Rule) ProtoMessage added in v1.0.1 

func (*Rule) ProtoMessage()

func (*Rule) Reset added in v1.0.1 

func (m *Rule) Reset()

func (*Rule) String added in v1.0.1 

func (m *Rule) String() string

func (*Rule) XXX_DiscardUnknown added in v1.0.1 

func (m *Rule) XXX_DiscardUnknown()

func (*Rule) XXX_Marshal added in v1.0.1 

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

func (*Rule) XXX_Merge added in v1.0.1 

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

func (*Rule) XXX_Size added in v1.0.1 

func (m *Rule) XXX_Size() int

func (*Rule) XXX_Unmarshal added in v1.0.1 

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

type ShardGtid added in v1.0.1 

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

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 added in v1.0.1 

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

func (*ShardGtid) GetGtid added in v1.0.1 

func (m *ShardGtid) GetGtid() string

func (*ShardGtid) GetKeyspace added in v1.0.1 

func (m *ShardGtid) GetKeyspace() string

func (*ShardGtid) GetShard added in v1.0.1 

func (m *ShardGtid) GetShard() string

func (*ShardGtid) ProtoMessage added in v1.0.1 

func (*ShardGtid) ProtoMessage()

func (*ShardGtid) Reset added in v1.0.1 

func (m *ShardGtid) Reset()

func (*ShardGtid) String added in v1.0.1 

func (m *ShardGtid) String() string

func (*ShardGtid) XXX_DiscardUnknown added in v1.0.1 

func (m *ShardGtid) XXX_DiscardUnknown()

func (*ShardGtid) XXX_Marshal added in v1.0.1 

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

func (*ShardGtid) XXX_Merge added in v1.0.1 

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

func (*ShardGtid) XXX_Size added in v1.0.1 

func (m *ShardGtid) XXX_Size() int

func (*ShardGtid) XXX_Unmarshal added in v1.0.1 

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 added in v1.0.1 

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"`
	// Ddl is set if the event type is DDL.
	Ddl string `protobuf:"bytes,4,opt,name=ddl,proto3" json:"ddl,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"`
	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 added in v1.0.1 

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

func (*VEvent) GetCurrentTime added in v1.0.1 

func (m *VEvent) GetCurrentTime() int64

func (*VEvent) GetDdl added in v1.0.1 

func (m *VEvent) GetDdl() string

func (*VEvent) GetDml added in v1.0.1 

func (m *VEvent) GetDml() string

func (*VEvent) GetFieldEvent added in v1.0.1 

func (m *VEvent) GetFieldEvent() *FieldEvent

func (*VEvent) GetGtid added in v1.0.1 

func (m *VEvent) GetGtid() string

func (*VEvent) GetJournal added in v1.0.1 

func (m *VEvent) GetJournal() *Journal

func (*VEvent) GetRowEvent added in v1.0.1 

func (m *VEvent) GetRowEvent() *RowEvent

func (*VEvent) GetTimestamp added in v1.0.1 

func (m *VEvent) GetTimestamp() int64

func (*VEvent) GetType added in v1.0.1 

func (m *VEvent) GetType() VEventType

func (*VEvent) GetVgtid added in v1.0.1 

func (m *VEvent) GetVgtid() *VGtid

func (*VEvent) ProtoMessage added in v1.0.1 

func (*VEvent) ProtoMessage()

func (*VEvent) Reset added in v1.0.1 

func (m *VEvent) Reset()

func (*VEvent) String added in v1.0.1 

func (m *VEvent) String() string

func (*VEvent) XXX_DiscardUnknown added in v1.0.1 

func (m *VEvent) XXX_DiscardUnknown()

func (*VEvent) XXX_Marshal added in v1.0.1 

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

func (*VEvent) XXX_Merge added in v1.0.1 

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

func (*VEvent) XXX_Size added in v1.0.1 

func (m *VEvent) XXX_Size() int

func (*VEvent) XXX_Unmarshal added in v1.0.1 

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

type VEventType added in v1.0.1 

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
)

func (VEventType) EnumDescriptor added in v1.0.1 

func (VEventType) EnumDescriptor() ([]byte, []int)

func (VEventType) String added in v1.0.1 

func (x VEventType) String() string

type VGtid added in v1.0.1 

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 added in v1.0.1 

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

func (*VGtid) GetShardGtids added in v1.0.1 

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

func (*VGtid) ProtoMessage added in v1.0.1 

func (*VGtid) ProtoMessage()

func (*VGtid) Reset added in v1.0.1 

func (m *VGtid) Reset()

func (*VGtid) String added in v1.0.1 

func (m *VGtid) String() string

func (*VGtid) XXX_DiscardUnknown added in v1.0.1 

func (m *VGtid) XXX_DiscardUnknown()

func (*VGtid) XXX_Marshal added in v1.0.1 

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

func (*VGtid) XXX_Merge added in v1.0.1 

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

func (*VGtid) XXX_Size added in v1.0.1 

func (m *VGtid) XXX_Size() int

func (*VGtid) XXX_Unmarshal added in v1.0.1 

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

type VStreamRequest added in v1.0.1 

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 VStreamer

func (*VStreamRequest) Descriptor added in v1.0.1 

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

func (*VStreamRequest) GetEffectiveCallerId added in v1.0.1 

func (m *VStreamRequest) GetEffectiveCallerId() *vtrpc.CallerID

func (*VStreamRequest) GetFilter added in v1.0.1 

func (m *VStreamRequest) GetFilter() *Filter

func (*VStreamRequest) GetImmediateCallerId added in v1.0.1 

func (m *VStreamRequest) GetImmediateCallerId() *query.VTGateCallerID

func (*VStreamRequest) GetPosition added in v1.0.1 

func (m *VStreamRequest) GetPosition() string

func (*VStreamRequest) GetTarget added in v1.0.1 

func (m *VStreamRequest) GetTarget() *query.Target

func (*VStreamRequest) ProtoMessage added in v1.0.1 

func (*VStreamRequest) ProtoMessage()

func (*VStreamRequest) Reset added in v1.0.1 

func (m *VStreamRequest) Reset()

func (*VStreamRequest) String added in v1.0.1 

func (m *VStreamRequest) String() string

func (*VStreamRequest) XXX_DiscardUnknown added in v1.0.1 

func (m *VStreamRequest) XXX_DiscardUnknown()

func (*VStreamRequest) XXX_Marshal added in v1.0.1 

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

func (*VStreamRequest) XXX_Merge added in v1.0.1 

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

func (*VStreamRequest) XXX_Size added in v1.0.1 

func (m *VStreamRequest) XXX_Size() int

func (*VStreamRequest) XXX_Unmarshal added in v1.0.1 

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

type VStreamResponse added in v1.0.1 

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 added in v1.0.1 

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

func (*VStreamResponse) GetEvents added in v1.0.1 

func (m *VStreamResponse) GetEvents() []*VEvent

func (*VStreamResponse) ProtoMessage added in v1.0.1 

func (*VStreamResponse) ProtoMessage()

func (*VStreamResponse) Reset added in v1.0.1 

func (m *VStreamResponse) Reset()

func (*VStreamResponse) String added in v1.0.1 

func (m *VStreamResponse) String() string

func (*VStreamResponse) XXX_DiscardUnknown added in v1.0.1 

func (m *VStreamResponse) XXX_DiscardUnknown()

func (*VStreamResponse) XXX_Marshal added in v1.0.1 

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

func (*VStreamResponse) XXX_Merge added in v1.0.1 

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

func (*VStreamResponse) XXX_Size added in v1.0.1 

func (m *VStreamResponse) XXX_Size() int

func (*VStreamResponse) XXX_Unmarshal added in v1.0.1 

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

type VStreamResultsRequest added in v1.0.1 

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 added in v1.0.1 

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

func (*VStreamResultsRequest) GetEffectiveCallerId added in v1.0.1 

func (m *VStreamResultsRequest) GetEffectiveCallerId() *vtrpc.CallerID

func (*VStreamResultsRequest) GetImmediateCallerId added in v1.0.1 

func (m *VStreamResultsRequest) GetImmediateCallerId() *query.VTGateCallerID

func (*VStreamResultsRequest) GetQuery added in v1.0.1 

func (m *VStreamResultsRequest) GetQuery() string

func (*VStreamResultsRequest) GetTarget added in v1.0.1 

func (m *VStreamResultsRequest) GetTarget() *query.Target

func (*VStreamResultsRequest) ProtoMessage added in v1.0.1 

func (*VStreamResultsRequest) ProtoMessage()

func (*VStreamResultsRequest) Reset added in v1.0.1 

func (m *VStreamResultsRequest) Reset()

func (*VStreamResultsRequest) String added in v1.0.1 

func (m *VStreamResultsRequest) String() string

func (*VStreamResultsRequest) XXX_DiscardUnknown added in v1.0.1 

func (m *VStreamResultsRequest) XXX_DiscardUnknown()

func (*VStreamResultsRequest) XXX_Marshal added in v1.0.1 

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

func (*VStreamResultsRequest) XXX_Merge added in v1.0.1 

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

func (*VStreamResultsRequest) XXX_Size added in v1.0.1 

func (m *VStreamResultsRequest) XXX_Size() int

func (*VStreamResultsRequest) XXX_Unmarshal added in v1.0.1 

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

type VStreamResultsResponse added in v1.0.1 

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 added in v1.0.1 

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

func (*VStreamResultsResponse) GetFields added in v1.0.1 

func (m *VStreamResultsResponse) GetFields() []*query.Field

func (*VStreamResultsResponse) GetGtid added in v1.0.1 

func (m *VStreamResultsResponse) GetGtid() string

func (*VStreamResultsResponse) GetRows added in v1.0.1 

func (m *VStreamResultsResponse) GetRows() []*query.Row

func (*VStreamResultsResponse) ProtoMessage added in v1.0.1 

func (*VStreamResultsResponse) ProtoMessage()

func (*VStreamResultsResponse) Reset added in v1.0.1 

func (m *VStreamResultsResponse) Reset()

func (*VStreamResultsResponse) String added in v1.0.1 

func (m *VStreamResultsResponse) String() string

func (*VStreamResultsResponse) XXX_DiscardUnknown added in v1.0.1 

func (m *VStreamResultsResponse) XXX_DiscardUnknown()

func (*VStreamResultsResponse) XXX_Marshal added in v1.0.1 

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

func (*VStreamResultsResponse) XXX_Merge added in v1.0.1 

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

func (*VStreamResultsResponse) XXX_Size added in v1.0.1 

func (m *VStreamResultsResponse) XXX_Size() int

func (*VStreamResultsResponse) XXX_Unmarshal added in v1.0.1 

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

type VStreamRowsRequest added in v1.0.1 

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 added in v1.0.1 

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

func (*VStreamRowsRequest) GetEffectiveCallerId added in v1.0.1 

func (m *VStreamRowsRequest) GetEffectiveCallerId() *vtrpc.CallerID

func (*VStreamRowsRequest) GetImmediateCallerId added in v1.0.1 

func (m *VStreamRowsRequest) GetImmediateCallerId() *query.VTGateCallerID

func (*VStreamRowsRequest) GetLastpk added in v1.0.1 

func (m *VStreamRowsRequest) GetLastpk() *query.QueryResult

func (*VStreamRowsRequest) GetQuery added in v1.0.1 

func (m *VStreamRowsRequest) GetQuery() string

func (*VStreamRowsRequest) GetTarget added in v1.0.1 

func (m *VStreamRowsRequest) GetTarget() *query.Target

func (*VStreamRowsRequest) ProtoMessage added in v1.0.1 

func (*VStreamRowsRequest) ProtoMessage()

func (*VStreamRowsRequest) Reset added in v1.0.1 

func (m *VStreamRowsRequest) Reset()

func (*VStreamRowsRequest) String added in v1.0.1 

func (m *VStreamRowsRequest) String() string

func (*VStreamRowsRequest) XXX_DiscardUnknown added in v1.0.1 

func (m *VStreamRowsRequest) XXX_DiscardUnknown()

func (*VStreamRowsRequest) XXX_Marshal added in v1.0.1 

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

func (*VStreamRowsRequest) XXX_Merge added in v1.0.1 

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

func (*VStreamRowsRequest) XXX_Size added in v1.0.1 

func (m *VStreamRowsRequest) XXX_Size() int

func (*VStreamRowsRequest) XXX_Unmarshal added in v1.0.1 

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

type VStreamRowsResponse added in v1.0.1 

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 added in v1.0.1 

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

func (*VStreamRowsResponse) GetFields added in v1.0.1 

func (m *VStreamRowsResponse) GetFields() []*query.Field

func (*VStreamRowsResponse) GetGtid added in v1.0.1 

func (m *VStreamRowsResponse) GetGtid() string

func (*VStreamRowsResponse) GetLastpk added in v1.0.1 

func (m *VStreamRowsResponse) GetLastpk() *query.Row

func (*VStreamRowsResponse) GetPkfields added in v1.0.1 

func (m *VStreamRowsResponse) GetPkfields() []*query.Field

func (*VStreamRowsResponse) GetRows added in v1.0.1 

func (m *VStreamRowsResponse) GetRows() []*query.Row

func (*VStreamRowsResponse) ProtoMessage added in v1.0.1 

func (*VStreamRowsResponse) ProtoMessage()

func (*VStreamRowsResponse) Reset added in v1.0.1 

func (m *VStreamRowsResponse) Reset()

func (*VStreamRowsResponse) String added in v1.0.1 

func (m *VStreamRowsResponse) String() string

func (*VStreamRowsResponse) XXX_DiscardUnknown added in v1.0.1 

func (m *VStreamRowsResponse) XXX_DiscardUnknown()

func (*VStreamRowsResponse) XXX_Marshal added in v1.0.1 

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

func (*VStreamRowsResponse) XXX_Merge added in v1.0.1 

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

func (*VStreamRowsResponse) XXX_Size added in v1.0.1 

func (m *VStreamRowsResponse) XXX_Size() int

func (*VStreamRowsResponse) XXX_Unmarshal added in v1.0.1 

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.