binlogdata

package
v0.12.1 Latest Latest
Warning

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

Go to latest
Published: Dec 14, 2021 License: Apache-2.0 Imports: 10 Imported by: 11

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	OnDDLAction_name = map[int32]string{
		0: "IGNORE",
		1: "STOP",
		2: "EXEC",
		3: "EXEC_IGNORE",
	}
	OnDDLAction_value = map[string]int32{
		"IGNORE":      0,
		"STOP":        1,
		"EXEC":        2,
		"EXEC_IGNORE": 3,
	}
)

Enum value maps for OnDDLAction.

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",
		17: "VERSION",
		18: "LASTPK",
		19: "SAVEPOINT",
	}
	VEventType_value = map[string]int32{
		"UNKNOWN":   0,
		"GTID":      1,
		"BEGIN":     2,
		"COMMIT":    3,
		"ROLLBACK":  4,
		"DDL":       5,
		"INSERT":    6,
		"REPLACE":   7,
		"UPDATE":    8,
		"DELETE":    9,
		"SET":       10,
		"OTHER":     11,
		"ROW":       12,
		"FIELD":     13,
		"HEARTBEAT": 14,
		"VGTID":     15,
		"JOURNAL":   16,
		"VERSION":   17,
		"LASTPK":    18,
		"SAVEPOINT": 19,
	}
)

Enum value maps for VEventType.

View Source
var (
	MigrationType_name = map[int32]string{
		0: "TABLES",
		1: "SHARDS",
	}
	MigrationType_value = map[string]int32{
		"TABLES": 0,
		"SHARDS": 1,
	}
)

Enum value maps for MigrationType.

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",
	}
	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,
	}
)

Enum value maps for BinlogTransaction_Statement_Category.

View Source
var (
	Filter_FieldEventMode_name = map[int32]string{
		0: "ERR_ON_MISMATCH",
		1: "BEST_EFFORT",
	}
	Filter_FieldEventMode_value = map[string]int32{
		"ERR_ON_MISMATCH": 0,
		"BEST_EFFORT":     1,
	}
)

Enum value maps for Filter_FieldEventMode.

View Source
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source
var File_binlogdata_proto protoreflect.FileDescriptor

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"`
	// ExternalCluster is the name of the mounted cluster which has the source keyspace/db for this workflow
	// it is of the type <cluster_type.cluster_name>
	ExternalCluster string `protobuf:"bytes,10,opt,name=external_cluster,json=externalCluster,proto3" json:"external_cluster,omitempty"`
	// contains filtered or unexported fields
}

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 deprecated

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

Deprecated: Use BinlogSource.ProtoReflect.Descriptor instead.

func (*BinlogSource) GetExternalCluster added in v0.10.0

func (x *BinlogSource) GetExternalCluster() string

func (*BinlogSource) GetExternalMysql

func (x *BinlogSource) GetExternalMysql() string

func (*BinlogSource) GetFilter

func (x *BinlogSource) GetFilter() *Filter

func (*BinlogSource) GetKeyRange

func (x *BinlogSource) GetKeyRange() *topodata.KeyRange

func (*BinlogSource) GetKeyspace

func (x *BinlogSource) GetKeyspace() string

func (*BinlogSource) GetOnDdl

func (x *BinlogSource) GetOnDdl() OnDDLAction

func (*BinlogSource) GetShard

func (x *BinlogSource) GetShard() string

func (*BinlogSource) GetStopAfterCopy

func (x *BinlogSource) GetStopAfterCopy() bool

func (*BinlogSource) GetTables

func (x *BinlogSource) GetTables() []string

func (*BinlogSource) GetTabletType

func (x *BinlogSource) GetTabletType() topodata.TabletType

func (*BinlogSource) MarshalToSizedBufferVT added in v0.11.0

func (m *BinlogSource) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*BinlogSource) MarshalToVT added in v0.11.0

func (m *BinlogSource) MarshalToVT(dAtA []byte) (int, error)

func (*BinlogSource) MarshalVT added in v0.11.0

func (m *BinlogSource) MarshalVT() (dAtA []byte, err error)

func (*BinlogSource) ProtoMessage

func (*BinlogSource) ProtoMessage()

func (*BinlogSource) ProtoReflect added in v0.11.0

func (x *BinlogSource) ProtoReflect() protoreflect.Message

func (*BinlogSource) Reset

func (x *BinlogSource) Reset()

func (*BinlogSource) SizeVT added in v0.11.0

func (m *BinlogSource) SizeVT() (n int)

func (*BinlogSource) String

func (x *BinlogSource) String() string

func (*BinlogSource) UnmarshalVT added in v0.11.0

func (m *BinlogSource) UnmarshalVT(dAtA []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"`
	// contains filtered or unexported fields
}

BinlogTransaction describes a transaction inside the binlogs. It is streamed by vttablet for filtered replication, used during resharding.

func (*BinlogTransaction) Descriptor deprecated

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

Deprecated: Use BinlogTransaction.ProtoReflect.Descriptor instead.

func (*BinlogTransaction) GetEventToken

func (x *BinlogTransaction) GetEventToken() *query.EventToken

func (*BinlogTransaction) GetStatements

func (x *BinlogTransaction) GetStatements() []*BinlogTransaction_Statement

func (*BinlogTransaction) MarshalToSizedBufferVT added in v0.11.0

func (m *BinlogTransaction) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*BinlogTransaction) MarshalToVT added in v0.11.0

func (m *BinlogTransaction) MarshalToVT(dAtA []byte) (int, error)

func (*BinlogTransaction) MarshalVT added in v0.11.0

func (m *BinlogTransaction) MarshalVT() (dAtA []byte, err error)

func (*BinlogTransaction) ProtoMessage

func (*BinlogTransaction) ProtoMessage()

func (*BinlogTransaction) ProtoReflect added in v0.11.0

func (x *BinlogTransaction) ProtoReflect() protoreflect.Message

func (*BinlogTransaction) Reset

func (x *BinlogTransaction) Reset()

func (*BinlogTransaction) SizeVT added in v0.11.0

func (m *BinlogTransaction) SizeVT() (n int)

func (*BinlogTransaction) String

func (x *BinlogTransaction) String() string

func (*BinlogTransaction) UnmarshalVT added in v0.11.0

func (m *BinlogTransaction) UnmarshalVT(dAtA []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"`
	// contains filtered or unexported fields
}

func (*BinlogTransaction_Statement) Descriptor deprecated

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

Deprecated: Use BinlogTransaction_Statement.ProtoReflect.Descriptor instead.

func (*BinlogTransaction_Statement) GetCategory

func (*BinlogTransaction_Statement) GetCharset

func (x *BinlogTransaction_Statement) GetCharset() *Charset

func (*BinlogTransaction_Statement) GetSql

func (x *BinlogTransaction_Statement) GetSql() []byte

func (*BinlogTransaction_Statement) MarshalToSizedBufferVT added in v0.11.0

func (m *BinlogTransaction_Statement) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*BinlogTransaction_Statement) MarshalToVT added in v0.11.0

func (m *BinlogTransaction_Statement) MarshalToVT(dAtA []byte) (int, error)

func (*BinlogTransaction_Statement) MarshalVT added in v0.11.0

func (m *BinlogTransaction_Statement) MarshalVT() (dAtA []byte, err error)

func (*BinlogTransaction_Statement) ProtoMessage

func (*BinlogTransaction_Statement) ProtoMessage()

func (*BinlogTransaction_Statement) ProtoReflect added in v0.11.0

func (*BinlogTransaction_Statement) Reset

func (x *BinlogTransaction_Statement) Reset()

func (*BinlogTransaction_Statement) SizeVT added in v0.11.0

func (m *BinlogTransaction_Statement) SizeVT() (n int)

func (*BinlogTransaction_Statement) String

func (x *BinlogTransaction_Statement) String() string

func (*BinlogTransaction_Statement) UnmarshalVT added in v0.11.0

func (m *BinlogTransaction_Statement) UnmarshalVT(dAtA []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) Descriptor added in v0.11.0

func (BinlogTransaction_Statement_Category) Enum added in v0.11.0

func (BinlogTransaction_Statement_Category) EnumDescriptor deprecated

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

Deprecated: Use BinlogTransaction_Statement_Category.Descriptor instead.

func (BinlogTransaction_Statement_Category) Number added in v0.11.0

func (BinlogTransaction_Statement_Category) String

func (BinlogTransaction_Statement_Category) Type added in v0.11.0

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"`
	// contains filtered or unexported fields
}

Charset is the per-statement charset info from a QUERY_EVENT binlog entry.

func (*Charset) Descriptor deprecated

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

Deprecated: Use Charset.ProtoReflect.Descriptor instead.

func (*Charset) GetClient

func (x *Charset) GetClient() int32

func (*Charset) GetConn

func (x *Charset) GetConn() int32

func (*Charset) GetServer

func (x *Charset) GetServer() int32

func (*Charset) MarshalToSizedBufferVT added in v0.11.0

func (m *Charset) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Charset) MarshalToVT added in v0.11.0

func (m *Charset) MarshalToVT(dAtA []byte) (int, error)

func (*Charset) MarshalVT added in v0.11.0

func (m *Charset) MarshalVT() (dAtA []byte, err error)

func (*Charset) ProtoMessage

func (*Charset) ProtoMessage()

func (*Charset) ProtoReflect added in v0.11.0

func (x *Charset) ProtoReflect() protoreflect.Message

func (*Charset) Reset

func (x *Charset) Reset()

func (*Charset) SizeVT added in v0.11.0

func (m *Charset) SizeVT() (n int)

func (*Charset) String

func (x *Charset) String() string

func (*Charset) UnmarshalVT added in v0.11.0

func (m *Charset) UnmarshalVT(dAtA []byte) error

type CharsetConversion added in v0.11.0

type CharsetConversion struct {

	// FromCharset is the charset name from which we convert the text (e.g. latin1)
	FromCharset string `protobuf:"bytes,1,opt,name=from_charset,json=fromCharset,proto3" json:"from_charset,omitempty"`
	// ToCharset is the charset name to which we convert the text (e.g. utf8mb4)
	ToCharset string `protobuf:"bytes,2,opt,name=to_charset,json=toCharset,proto3" json:"to_charset,omitempty"`
	// contains filtered or unexported fields
}

CharsetConversion represent a conversion of text from one charset to another

func (*CharsetConversion) Descriptor deprecated added in v0.11.0

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

Deprecated: Use CharsetConversion.ProtoReflect.Descriptor instead.

func (*CharsetConversion) GetFromCharset added in v0.11.0

func (x *CharsetConversion) GetFromCharset() string

func (*CharsetConversion) GetToCharset added in v0.11.0

func (x *CharsetConversion) GetToCharset() string

func (*CharsetConversion) MarshalToSizedBufferVT added in v0.11.0

func (m *CharsetConversion) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*CharsetConversion) MarshalToVT added in v0.11.0

func (m *CharsetConversion) MarshalToVT(dAtA []byte) (int, error)

func (*CharsetConversion) MarshalVT added in v0.11.0

func (m *CharsetConversion) MarshalVT() (dAtA []byte, err error)

func (*CharsetConversion) ProtoMessage added in v0.11.0

func (*CharsetConversion) ProtoMessage()

func (*CharsetConversion) ProtoReflect added in v0.11.0

func (x *CharsetConversion) ProtoReflect() protoreflect.Message

func (*CharsetConversion) Reset added in v0.11.0

func (x *CharsetConversion) Reset()

func (*CharsetConversion) SizeVT added in v0.11.0

func (m *CharsetConversion) SizeVT() (n int)

func (*CharsetConversion) String added in v0.11.0

func (x *CharsetConversion) String() string

func (*CharsetConversion) UnmarshalVT added in v0.11.0

func (m *CharsetConversion) UnmarshalVT(dAtA []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"`
	Keyspace  string         `protobuf:"bytes,3,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Shard     string         `protobuf:"bytes,4,opt,name=shard,proto3" json:"shard,omitempty"`
	// contains filtered or unexported fields
}

FieldEvent represents the field info for a table.

func (*FieldEvent) Descriptor deprecated

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

Deprecated: Use FieldEvent.ProtoReflect.Descriptor instead.

func (*FieldEvent) GetFields

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

func (*FieldEvent) GetKeyspace added in v0.12.0

func (x *FieldEvent) GetKeyspace() string

func (*FieldEvent) GetShard added in v0.12.0

func (x *FieldEvent) GetShard() string

func (*FieldEvent) GetTableName

func (x *FieldEvent) GetTableName() string

func (*FieldEvent) MarshalToSizedBufferVT added in v0.11.0

func (m *FieldEvent) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*FieldEvent) MarshalToVT added in v0.11.0

func (m *FieldEvent) MarshalToVT(dAtA []byte) (int, error)

func (*FieldEvent) MarshalVT added in v0.11.0

func (m *FieldEvent) MarshalVT() (dAtA []byte, err error)

func (*FieldEvent) ProtoMessage

func (*FieldEvent) ProtoMessage()

func (*FieldEvent) ProtoReflect added in v0.11.0

func (x *FieldEvent) ProtoReflect() protoreflect.Message

func (*FieldEvent) Reset

func (x *FieldEvent) Reset()

func (*FieldEvent) SizeVT added in v0.11.0

func (m *FieldEvent) SizeVT() (n int)

func (*FieldEvent) String

func (x *FieldEvent) String() string

func (*FieldEvent) UnmarshalVT added in v0.11.0

func (m *FieldEvent) UnmarshalVT(dAtA []byte) error

type Filter

type Filter struct {
	Rules []*Rule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"`
	// FieldEventMode specifies the behavior if there is a mismatch
	// between the current schema and the fields in the binlog. This
	// can happen if the binlog position is before a DDL that would
	// cause the fields to change. If vstreamer detects such
	// an inconsistency, the behavior depends on the FieldEventMode.
	// If the value is ERR_ON_MISMATCH (default), then it errors out.
	// If it's BEST_EFFORT, it sends a field event with fake column
	// names as "@1", "@2", etc.
	FieldEventMode Filter_FieldEventMode `protobuf:"varint,2,opt,name=fieldEventMode,proto3,enum=binlogdata.Filter_FieldEventMode" json:"fieldEventMode,omitempty"`
	// contains filtered or unexported fields
}

Filter represents a list of ordered rules. The first match wins.

func (*Filter) Descriptor deprecated

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

Deprecated: Use Filter.ProtoReflect.Descriptor instead.

func (*Filter) GetFieldEventMode

func (x *Filter) GetFieldEventMode() Filter_FieldEventMode

func (*Filter) GetRules

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

func (*Filter) MarshalToSizedBufferVT added in v0.11.0

func (m *Filter) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Filter) MarshalToVT added in v0.11.0

func (m *Filter) MarshalToVT(dAtA []byte) (int, error)

func (*Filter) MarshalVT added in v0.11.0

func (m *Filter) MarshalVT() (dAtA []byte, err error)

func (*Filter) ProtoMessage

func (*Filter) ProtoMessage()

func (*Filter) ProtoReflect added in v0.11.0

func (x *Filter) ProtoReflect() protoreflect.Message

func (*Filter) Reset

func (x *Filter) Reset()

func (*Filter) SizeVT added in v0.11.0

func (m *Filter) SizeVT() (n int)

func (*Filter) String

func (x *Filter) String() string

func (*Filter) UnmarshalVT added in v0.11.0

func (m *Filter) UnmarshalVT(dAtA []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) Descriptor added in v0.11.0

func (Filter_FieldEventMode) Enum added in v0.11.0

func (Filter_FieldEventMode) EnumDescriptor deprecated

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

Deprecated: Use Filter_FieldEventMode.Descriptor instead.

func (Filter_FieldEventMode) Number added in v0.11.0

func (Filter_FieldEventMode) String

func (x Filter_FieldEventMode) String() string

func (Filter_FieldEventMode) Type added in v0.11.0

type Journal

type Journal struct {

	// Id represents a unique journal id.
	Id            int64         `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	MigrationType MigrationType `` /* 131-byte string literal not displayed */
	// Tables is set if the journal represents a TABLES migration.
	Tables []string `protobuf:"bytes,3,rep,name=tables,proto3" json:"tables,omitempty"`
	// LocalPosition is the source position at which the migration happened.
	LocalPosition string `protobuf:"bytes,4,opt,name=local_position,json=localPosition,proto3" json:"local_position,omitempty"`
	// ShardGtids is the list of targets to which the migration took place.
	ShardGtids []*ShardGtid `protobuf:"bytes,5,rep,name=shard_gtids,json=shardGtids,proto3" json:"shard_gtids,omitempty"`
	// Participants is the list of source participants for a migration.
	// Every participant is expected to have an identical journal entry.
	// While streaming, the client must wait for the journal entry to
	// be received from all pariticipants, and then replace them with new
	// streams specified by ShardGtid.
	// If a stream does not have all participants, a consistent migration
	// is not possible.
	Participants []*KeyspaceShard `protobuf:"bytes,6,rep,name=participants,proto3" json:"participants,omitempty"`
	// SourceWorkflows is the list of workflows in the source shard that
	// were migrated to the target. If a migration fails after a Journal
	// is committed, this information is used to start the target streams
	// that were created prior to the creation of the journal.
	SourceWorkflows []string `protobuf:"bytes,7,rep,name=source_workflows,json=sourceWorkflows,proto3" json:"source_workflows,omitempty"`
	// contains filtered or unexported fields
}

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 deprecated

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

Deprecated: Use Journal.ProtoReflect.Descriptor instead.

func (*Journal) GetId

func (x *Journal) GetId() int64

func (*Journal) GetLocalPosition

func (x *Journal) GetLocalPosition() string

func (*Journal) GetMigrationType

func (x *Journal) GetMigrationType() MigrationType

func (*Journal) GetParticipants

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

func (*Journal) GetShardGtids

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

func (*Journal) GetSourceWorkflows

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

func (*Journal) GetTables

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

func (*Journal) MarshalToSizedBufferVT added in v0.11.0

func (m *Journal) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Journal) MarshalToVT added in v0.11.0

func (m *Journal) MarshalToVT(dAtA []byte) (int, error)

func (*Journal) MarshalVT added in v0.11.0

func (m *Journal) MarshalVT() (dAtA []byte, err error)

func (*Journal) ProtoMessage

func (*Journal) ProtoMessage()

func (*Journal) ProtoReflect added in v0.11.0

func (x *Journal) ProtoReflect() protoreflect.Message

func (*Journal) Reset

func (x *Journal) Reset()

func (*Journal) SizeVT added in v0.11.0

func (m *Journal) SizeVT() (n int)

func (*Journal) String

func (x *Journal) String() string

func (*Journal) UnmarshalVT added in v0.11.0

func (m *Journal) UnmarshalVT(dAtA []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"`
	// contains filtered or unexported fields
}

KeyspaceShard represents a keyspace and shard.

func (*KeyspaceShard) Descriptor deprecated

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

Deprecated: Use KeyspaceShard.ProtoReflect.Descriptor instead.

func (*KeyspaceShard) GetKeyspace

func (x *KeyspaceShard) GetKeyspace() string

func (*KeyspaceShard) GetShard

func (x *KeyspaceShard) GetShard() string

func (*KeyspaceShard) MarshalToSizedBufferVT added in v0.11.0

func (m *KeyspaceShard) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*KeyspaceShard) MarshalToVT added in v0.11.0

func (m *KeyspaceShard) MarshalToVT(dAtA []byte) (int, error)

func (*KeyspaceShard) MarshalVT added in v0.11.0

func (m *KeyspaceShard) MarshalVT() (dAtA []byte, err error)

func (*KeyspaceShard) ProtoMessage

func (*KeyspaceShard) ProtoMessage()

func (*KeyspaceShard) ProtoReflect added in v0.11.0

func (x *KeyspaceShard) ProtoReflect() protoreflect.Message

func (*KeyspaceShard) Reset

func (x *KeyspaceShard) Reset()

func (*KeyspaceShard) SizeVT added in v0.11.0

func (m *KeyspaceShard) SizeVT() (n int)

func (*KeyspaceShard) String

func (x *KeyspaceShard) String() string

func (*KeyspaceShard) UnmarshalVT added in v0.11.0

func (m *KeyspaceShard) UnmarshalVT(dAtA []byte) error

type LastPKEvent

type LastPKEvent struct {
	TableLastPK *TableLastPK `protobuf:"bytes,1,opt,name=table_last_p_k,json=tableLastPK,proto3" json:"table_last_p_k,omitempty"`
	Completed   bool         `protobuf:"varint,2,opt,name=completed,proto3" json:"completed,omitempty"`
	// contains filtered or unexported fields
}

func (*LastPKEvent) Descriptor deprecated

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

Deprecated: Use LastPKEvent.ProtoReflect.Descriptor instead.

func (*LastPKEvent) GetCompleted

func (x *LastPKEvent) GetCompleted() bool

func (*LastPKEvent) GetTableLastPK

func (x *LastPKEvent) GetTableLastPK() *TableLastPK

func (*LastPKEvent) MarshalToSizedBufferVT added in v0.11.0

func (m *LastPKEvent) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*LastPKEvent) MarshalToVT added in v0.11.0

func (m *LastPKEvent) MarshalToVT(dAtA []byte) (int, error)

func (*LastPKEvent) MarshalVT added in v0.11.0

func (m *LastPKEvent) MarshalVT() (dAtA []byte, err error)

func (*LastPKEvent) ProtoMessage

func (*LastPKEvent) ProtoMessage()

func (*LastPKEvent) ProtoReflect added in v0.11.0

func (x *LastPKEvent) ProtoReflect() protoreflect.Message

func (*LastPKEvent) Reset

func (x *LastPKEvent) Reset()

func (*LastPKEvent) SizeVT added in v0.11.0

func (m *LastPKEvent) SizeVT() (n int)

func (*LastPKEvent) String

func (x *LastPKEvent) String() string

func (*LastPKEvent) UnmarshalVT added in v0.11.0

func (m *LastPKEvent) UnmarshalVT(dAtA []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) Descriptor added in v0.11.0

func (MigrationType) Enum added in v0.11.0

func (x MigrationType) Enum() *MigrationType

func (MigrationType) EnumDescriptor deprecated

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

Deprecated: Use MigrationType.Descriptor instead.

func (MigrationType) Number added in v0.11.0

func (MigrationType) String

func (x MigrationType) String() string

func (MigrationType) Type added in v0.11.0

type MinimalSchema

type MinimalSchema struct {
	Tables []*MinimalTable `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

func (*MinimalSchema) Descriptor deprecated

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

Deprecated: Use MinimalSchema.ProtoReflect.Descriptor instead.

func (*MinimalSchema) GetTables

func (x *MinimalSchema) GetTables() []*MinimalTable

func (*MinimalSchema) MarshalToSizedBufferVT added in v0.11.0

func (m *MinimalSchema) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MinimalSchema) MarshalToVT added in v0.11.0

func (m *MinimalSchema) MarshalToVT(dAtA []byte) (int, error)

func (*MinimalSchema) MarshalVT added in v0.11.0

func (m *MinimalSchema) MarshalVT() (dAtA []byte, err error)

func (*MinimalSchema) ProtoMessage

func (*MinimalSchema) ProtoMessage()

func (*MinimalSchema) ProtoReflect added in v0.11.0

func (x *MinimalSchema) ProtoReflect() protoreflect.Message

func (*MinimalSchema) Reset

func (x *MinimalSchema) Reset()

func (*MinimalSchema) SizeVT added in v0.11.0

func (m *MinimalSchema) SizeVT() (n int)

func (*MinimalSchema) String

func (x *MinimalSchema) String() string

func (*MinimalSchema) UnmarshalVT added in v0.11.0

func (m *MinimalSchema) UnmarshalVT(dAtA []byte) error

type MinimalTable

type MinimalTable struct {
	Name      string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Fields    []*query.Field `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
	PKColumns []int64        `protobuf:"varint,3,rep,packed,name=p_k_columns,json=pKColumns,proto3" json:"p_k_columns,omitempty"`
	// contains filtered or unexported fields
}

func (*MinimalTable) Descriptor deprecated

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

Deprecated: Use MinimalTable.ProtoReflect.Descriptor instead.

func (*MinimalTable) GetFields

func (x *MinimalTable) GetFields() []*query.Field

func (*MinimalTable) GetName

func (x *MinimalTable) GetName() string

func (*MinimalTable) GetPKColumns

func (x *MinimalTable) GetPKColumns() []int64

func (*MinimalTable) MarshalToSizedBufferVT added in v0.11.0

func (m *MinimalTable) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MinimalTable) MarshalToVT added in v0.11.0

func (m *MinimalTable) MarshalToVT(dAtA []byte) (int, error)

func (*MinimalTable) MarshalVT added in v0.11.0

func (m *MinimalTable) MarshalVT() (dAtA []byte, err error)

func (*MinimalTable) ProtoMessage

func (*MinimalTable) ProtoMessage()

func (*MinimalTable) ProtoReflect added in v0.11.0

func (x *MinimalTable) ProtoReflect() protoreflect.Message

func (*MinimalTable) Reset

func (x *MinimalTable) Reset()

func (*MinimalTable) SizeVT added in v0.11.0

func (m *MinimalTable) SizeVT() (n int)

func (*MinimalTable) String

func (x *MinimalTable) String() string

func (*MinimalTable) UnmarshalVT added in v0.11.0

func (m *MinimalTable) UnmarshalVT(dAtA []byte) error

type OnDDLAction

type OnDDLAction int32

OnDDLAction lists the possible actions for DDLs.

const (
	OnDDLAction_IGNORE      OnDDLAction = 0
	OnDDLAction_STOP        OnDDLAction = 1
	OnDDLAction_EXEC        OnDDLAction = 2
	OnDDLAction_EXEC_IGNORE OnDDLAction = 3
)

func (OnDDLAction) Descriptor added in v0.11.0

func (OnDDLAction) Enum added in v0.11.0

func (x OnDDLAction) Enum() *OnDDLAction

func (OnDDLAction) EnumDescriptor deprecated

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

Deprecated: Use OnDDLAction.Descriptor instead.

func (OnDDLAction) Number added in v0.11.0

func (x OnDDLAction) Number() protoreflect.EnumNumber

func (OnDDLAction) String

func (x OnDDLAction) String() string

func (OnDDLAction) Type added in v0.11.0

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"`
	// contains filtered or unexported fields
}

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 deprecated

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

Deprecated: Use RowChange.ProtoReflect.Descriptor instead.

func (*RowChange) GetAfter

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

func (*RowChange) GetBefore

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

func (*RowChange) MarshalToSizedBufferVT added in v0.11.0

func (m *RowChange) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RowChange) MarshalToVT added in v0.11.0

func (m *RowChange) MarshalToVT(dAtA []byte) (int, error)

func (*RowChange) MarshalVT added in v0.11.0

func (m *RowChange) MarshalVT() (dAtA []byte, err error)

func (*RowChange) ProtoMessage

func (*RowChange) ProtoMessage()

func (*RowChange) ProtoReflect added in v0.11.0

func (x *RowChange) ProtoReflect() protoreflect.Message

func (*RowChange) Reset

func (x *RowChange) Reset()

func (*RowChange) SizeVT added in v0.11.0

func (m *RowChange) SizeVT() (n int)

func (*RowChange) String

func (x *RowChange) String() string

func (*RowChange) UnmarshalVT added in v0.11.0

func (m *RowChange) UnmarshalVT(dAtA []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"`
	Keyspace   string       `protobuf:"bytes,3,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Shard      string       `protobuf:"bytes,4,opt,name=shard,proto3" json:"shard,omitempty"`
	// contains filtered or unexported fields
}

RowEvent represent row events for one table.

func (*RowEvent) Descriptor deprecated

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

Deprecated: Use RowEvent.ProtoReflect.Descriptor instead.

func (*RowEvent) GetKeyspace added in v0.12.0

func (x *RowEvent) GetKeyspace() string

func (*RowEvent) GetRowChanges

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

func (*RowEvent) GetShard added in v0.12.0

func (x *RowEvent) GetShard() string

func (*RowEvent) GetTableName

func (x *RowEvent) GetTableName() string

func (*RowEvent) MarshalToSizedBufferVT added in v0.11.0

func (m *RowEvent) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RowEvent) MarshalToVT added in v0.11.0

func (m *RowEvent) MarshalToVT(dAtA []byte) (int, error)

func (*RowEvent) MarshalVT added in v0.11.0

func (m *RowEvent) MarshalVT() (dAtA []byte, err error)

func (*RowEvent) ProtoMessage

func (*RowEvent) ProtoMessage()

func (*RowEvent) ProtoReflect added in v0.11.0

func (x *RowEvent) ProtoReflect() protoreflect.Message

func (*RowEvent) Reset

func (x *RowEvent) Reset()

func (*RowEvent) SizeVT added in v0.11.0

func (m *RowEvent) SizeVT() (n int)

func (*RowEvent) String

func (x *RowEvent) String() string

func (*RowEvent) UnmarshalVT added in v0.11.0

func (m *RowEvent) UnmarshalVT(dAtA []byte) error

type Rule

type Rule struct {

	// Match can be a table name or a regular expression.
	// If it starts with a '/', it's a regular expression.
	// For example, "t" matches a table named "t", whereas
	// "/t.*" matches all tables that begin with 't'.
	Match string `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
	// Filter: If empty, all columns and rows of the matching tables
	// are sent. If it's a keyrange like "-80", only rows that
	// match the keyrange are sent.
	// If Match is a table name instead of a regular expression,
	// the Filter can also be a select expression like this:
	// "select * from t", same as an empty Filter, or
	// "select * from t where in_keyrange('-80')", same as "-80", or
	// "select col1, col2 from t where in_keyrange(col1, 'hash', '-80'), or
	// What is allowed in a select expression depends on whether
	// it's a vstreamer or vreplication request. For more details,
	// please refer to the specific package documentation.
	// On the vreplication side, Filter can also accept a special
	// "exclude" value, which will cause the matched tables
	// to be excluded.
	// TODO(sougou): support this on vstreamer side also.
	Filter string `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
	// Example: key="color", value="'red','green','blue'"
	ConvertEnumToText map[string]string `` /* 204-byte string literal not displayed */
	// ConvertCharset: optional mapping, between column name and a CharsetConversion.
	// This hints to vreplication that columns are encoded from/to non-trivial charsets
	// The map is only populated when either "from" or "to" charset of a column are non-trivial
	// trivial charsets are utf8 and ascii variants.
	ConvertCharset map[string]*CharsetConversion `` /* 191-byte string literal not displayed */
	// SourceUniqueKeyColumns represents the ordered columns in the index used by rowstreamer to iterate the table
	// It is comma delimited, as in col1,col2,col3 (tokens are escaped via net/url)
	SourceUniqueKeyColumns string `` /* 131-byte string literal not displayed */
	// TargetUniqueKeyColumns represents the ordered columns in that index used by vcopier and vplayer to apply rows
	// It is comma delimited, as in col1,col2,col3 (tokens are escaped via net/url)
	TargetUniqueKeyColumns string `` /* 131-byte string literal not displayed */
	// SourceUniqueKeyTargetColumns represents the names of columns in target table, mapped from the chosen unique
	// key on source tables (some columns may be renamed from source to target)
	SourceUniqueKeyTargetColumns string `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

Rule represents one rule in a Filter.

func (*Rule) Descriptor deprecated

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

Deprecated: Use Rule.ProtoReflect.Descriptor instead.

func (*Rule) GetConvertCharset added in v0.11.0

func (x *Rule) GetConvertCharset() map[string]*CharsetConversion

func (*Rule) GetConvertEnumToText added in v0.11.0

func (x *Rule) GetConvertEnumToText() map[string]string

func (*Rule) GetFilter

func (x *Rule) GetFilter() string

func (*Rule) GetMatch

func (x *Rule) GetMatch() string

func (*Rule) GetSourceUniqueKeyColumns added in v0.12.0

func (x *Rule) GetSourceUniqueKeyColumns() string

func (*Rule) GetSourceUniqueKeyTargetColumns added in v0.12.0

func (x *Rule) GetSourceUniqueKeyTargetColumns() string

func (*Rule) GetTargetUniqueKeyColumns added in v0.12.0

func (x *Rule) GetTargetUniqueKeyColumns() string

func (*Rule) MarshalToSizedBufferVT added in v0.11.0

func (m *Rule) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Rule) MarshalToVT added in v0.11.0

func (m *Rule) MarshalToVT(dAtA []byte) (int, error)

func (*Rule) MarshalVT added in v0.11.0

func (m *Rule) MarshalVT() (dAtA []byte, err error)

func (*Rule) ProtoMessage

func (*Rule) ProtoMessage()

func (*Rule) ProtoReflect added in v0.11.0

func (x *Rule) ProtoReflect() protoreflect.Message

func (*Rule) Reset

func (x *Rule) Reset()

func (*Rule) SizeVT added in v0.11.0

func (m *Rule) SizeVT() (n int)

func (*Rule) String

func (x *Rule) String() string

func (*Rule) UnmarshalVT added in v0.11.0

func (m *Rule) UnmarshalVT(dAtA []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"`
	TablePKs []*TableLastPK `protobuf:"bytes,4,rep,name=table_p_ks,json=tablePKs,proto3" json:"table_p_ks,omitempty"`
	// contains filtered or unexported fields
}

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 deprecated

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

Deprecated: Use ShardGtid.ProtoReflect.Descriptor instead.

func (*ShardGtid) GetGtid

func (x *ShardGtid) GetGtid() string

func (*ShardGtid) GetKeyspace

func (x *ShardGtid) GetKeyspace() string

func (*ShardGtid) GetShard

func (x *ShardGtid) GetShard() string

func (*ShardGtid) GetTablePKs

func (x *ShardGtid) GetTablePKs() []*TableLastPK

func (*ShardGtid) MarshalToSizedBufferVT added in v0.11.0

func (m *ShardGtid) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ShardGtid) MarshalToVT added in v0.11.0

func (m *ShardGtid) MarshalToVT(dAtA []byte) (int, error)

func (*ShardGtid) MarshalVT added in v0.11.0

func (m *ShardGtid) MarshalVT() (dAtA []byte, err error)

func (*ShardGtid) ProtoMessage

func (*ShardGtid) ProtoMessage()

func (*ShardGtid) ProtoReflect added in v0.11.0

func (x *ShardGtid) ProtoReflect() protoreflect.Message

func (*ShardGtid) Reset

func (x *ShardGtid) Reset()

func (*ShardGtid) SizeVT added in v0.11.0

func (m *ShardGtid) SizeVT() (n int)

func (*ShardGtid) String

func (x *ShardGtid) String() string

func (*ShardGtid) UnmarshalVT added in v0.11.0

func (m *ShardGtid) UnmarshalVT(dAtA []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"`
	// contains filtered or unexported fields
}

StreamKeyRangeRequest is the payload to StreamKeyRange

func (*StreamKeyRangeRequest) Descriptor deprecated

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

Deprecated: Use StreamKeyRangeRequest.ProtoReflect.Descriptor instead.

func (*StreamKeyRangeRequest) GetCharset

func (x *StreamKeyRangeRequest) GetCharset() *Charset

func (*StreamKeyRangeRequest) GetKeyRange

func (x *StreamKeyRangeRequest) GetKeyRange() *topodata.KeyRange

func (*StreamKeyRangeRequest) GetPosition

func (x *StreamKeyRangeRequest) GetPosition() string

func (*StreamKeyRangeRequest) MarshalToSizedBufferVT added in v0.11.0

func (m *StreamKeyRangeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StreamKeyRangeRequest) MarshalToVT added in v0.11.0

func (m *StreamKeyRangeRequest) MarshalToVT(dAtA []byte) (int, error)

func (*StreamKeyRangeRequest) MarshalVT added in v0.11.0

func (m *StreamKeyRangeRequest) MarshalVT() (dAtA []byte, err error)

func (*StreamKeyRangeRequest) ProtoMessage

func (*StreamKeyRangeRequest) ProtoMessage()

func (*StreamKeyRangeRequest) ProtoReflect added in v0.11.0

func (x *StreamKeyRangeRequest) ProtoReflect() protoreflect.Message

func (*StreamKeyRangeRequest) Reset

func (x *StreamKeyRangeRequest) Reset()

func (*StreamKeyRangeRequest) SizeVT added in v0.11.0

func (m *StreamKeyRangeRequest) SizeVT() (n int)

func (*StreamKeyRangeRequest) String

func (x *StreamKeyRangeRequest) String() string

func (*StreamKeyRangeRequest) UnmarshalVT added in v0.11.0

func (m *StreamKeyRangeRequest) UnmarshalVT(dAtA []byte) error

type StreamKeyRangeResponse

type StreamKeyRangeResponse struct {
	BinlogTransaction *BinlogTransaction `protobuf:"bytes,1,opt,name=binlog_transaction,json=binlogTransaction,proto3" json:"binlog_transaction,omitempty"`
	// contains filtered or unexported fields
}

StreamKeyRangeResponse is the response from StreamKeyRange

func (*StreamKeyRangeResponse) Descriptor deprecated

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

Deprecated: Use StreamKeyRangeResponse.ProtoReflect.Descriptor instead.

func (*StreamKeyRangeResponse) GetBinlogTransaction

func (x *StreamKeyRangeResponse) GetBinlogTransaction() *BinlogTransaction

func (*StreamKeyRangeResponse) MarshalToSizedBufferVT added in v0.11.0

func (m *StreamKeyRangeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StreamKeyRangeResponse) MarshalToVT added in v0.11.0

func (m *StreamKeyRangeResponse) MarshalToVT(dAtA []byte) (int, error)

func (*StreamKeyRangeResponse) MarshalVT added in v0.11.0

func (m *StreamKeyRangeResponse) MarshalVT() (dAtA []byte, err error)

func (*StreamKeyRangeResponse) ProtoMessage

func (*StreamKeyRangeResponse) ProtoMessage()

func (*StreamKeyRangeResponse) ProtoReflect added in v0.11.0

func (x *StreamKeyRangeResponse) ProtoReflect() protoreflect.Message

func (*StreamKeyRangeResponse) Reset

func (x *StreamKeyRangeResponse) Reset()

func (*StreamKeyRangeResponse) SizeVT added in v0.11.0

func (m *StreamKeyRangeResponse) SizeVT() (n int)

func (*StreamKeyRangeResponse) String

func (x *StreamKeyRangeResponse) String() string

func (*StreamKeyRangeResponse) UnmarshalVT added in v0.11.0

func (m *StreamKeyRangeResponse) UnmarshalVT(dAtA []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"`
	// contains filtered or unexported fields
}

StreamTablesRequest is the payload to StreamTables

func (*StreamTablesRequest) Descriptor deprecated

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

Deprecated: Use StreamTablesRequest.ProtoReflect.Descriptor instead.

func (*StreamTablesRequest) GetCharset

func (x *StreamTablesRequest) GetCharset() *Charset

func (*StreamTablesRequest) GetPosition

func (x *StreamTablesRequest) GetPosition() string

func (*StreamTablesRequest) GetTables

func (x *StreamTablesRequest) GetTables() []string

func (*StreamTablesRequest) MarshalToSizedBufferVT added in v0.11.0

func (m *StreamTablesRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StreamTablesRequest) MarshalToVT added in v0.11.0

func (m *StreamTablesRequest) MarshalToVT(dAtA []byte) (int, error)

func (*StreamTablesRequest) MarshalVT added in v0.11.0

func (m *StreamTablesRequest) MarshalVT() (dAtA []byte, err error)

func (*StreamTablesRequest) ProtoMessage

func (*StreamTablesRequest) ProtoMessage()

func (*StreamTablesRequest) ProtoReflect added in v0.11.0

func (x *StreamTablesRequest) ProtoReflect() protoreflect.Message

func (*StreamTablesRequest) Reset

func (x *StreamTablesRequest) Reset()

func (*StreamTablesRequest) SizeVT added in v0.11.0

func (m *StreamTablesRequest) SizeVT() (n int)

func (*StreamTablesRequest) String

func (x *StreamTablesRequest) String() string

func (*StreamTablesRequest) UnmarshalVT added in v0.11.0

func (m *StreamTablesRequest) UnmarshalVT(dAtA []byte) error

type StreamTablesResponse

type StreamTablesResponse struct {
	BinlogTransaction *BinlogTransaction `protobuf:"bytes,1,opt,name=binlog_transaction,json=binlogTransaction,proto3" json:"binlog_transaction,omitempty"`
	// contains filtered or unexported fields
}

StreamTablesResponse is the response from StreamTables

func (*StreamTablesResponse) Descriptor deprecated

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

Deprecated: Use StreamTablesResponse.ProtoReflect.Descriptor instead.

func (*StreamTablesResponse) GetBinlogTransaction

func (x *StreamTablesResponse) GetBinlogTransaction() *BinlogTransaction

func (*StreamTablesResponse) MarshalToSizedBufferVT added in v0.11.0

func (m *StreamTablesResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StreamTablesResponse) MarshalToVT added in v0.11.0

func (m *StreamTablesResponse) MarshalToVT(dAtA []byte) (int, error)

func (*StreamTablesResponse) MarshalVT added in v0.11.0

func (m *StreamTablesResponse) MarshalVT() (dAtA []byte, err error)

func (*StreamTablesResponse) ProtoMessage

func (*StreamTablesResponse) ProtoMessage()

func (*StreamTablesResponse) ProtoReflect added in v0.11.0

func (x *StreamTablesResponse) ProtoReflect() protoreflect.Message

func (*StreamTablesResponse) Reset

func (x *StreamTablesResponse) Reset()

func (*StreamTablesResponse) SizeVT added in v0.11.0

func (m *StreamTablesResponse) SizeVT() (n int)

func (*StreamTablesResponse) String

func (x *StreamTablesResponse) String() string

func (*StreamTablesResponse) UnmarshalVT added in v0.11.0

func (m *StreamTablesResponse) UnmarshalVT(dAtA []byte) error

type TableLastPK

type TableLastPK struct {
	TableName string             `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	Lastpk    *query.QueryResult `protobuf:"bytes,3,opt,name=lastpk,proto3" json:"lastpk,omitempty"`
	// contains filtered or unexported fields
}

func (*TableLastPK) Descriptor deprecated

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

Deprecated: Use TableLastPK.ProtoReflect.Descriptor instead.

func (*TableLastPK) GetLastpk

func (x *TableLastPK) GetLastpk() *query.QueryResult

func (*TableLastPK) GetTableName

func (x *TableLastPK) GetTableName() string

func (*TableLastPK) MarshalToSizedBufferVT added in v0.11.0

func (m *TableLastPK) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TableLastPK) MarshalToVT added in v0.11.0

func (m *TableLastPK) MarshalToVT(dAtA []byte) (int, error)

func (*TableLastPK) MarshalVT added in v0.11.0

func (m *TableLastPK) MarshalVT() (dAtA []byte, err error)

func (*TableLastPK) ProtoMessage

func (*TableLastPK) ProtoMessage()

func (*TableLastPK) ProtoReflect added in v0.11.0

func (x *TableLastPK) ProtoReflect() protoreflect.Message

func (*TableLastPK) Reset

func (x *TableLastPK) Reset()

func (*TableLastPK) SizeVT added in v0.11.0

func (m *TableLastPK) SizeVT() (n int)

func (*TableLastPK) String

func (x *TableLastPK) String() string

func (*TableLastPK) UnmarshalVT added in v0.11.0

func (m *TableLastPK) UnmarshalVT(dAtA []byte) error

type VEvent

type VEvent struct {
	Type VEventType `protobuf:"varint,1,opt,name=type,proto3,enum=binlogdata.VEventType" json:"type,omitempty"`
	// Timestamp is the binlog timestamp in seconds.
	// The value should be ignored if 0.
	Timestamp int64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Gtid is set if the event type is GTID.
	Gtid string `protobuf:"bytes,3,opt,name=gtid,proto3" json:"gtid,omitempty"`
	// Statement is set if the event type is DDL, DML or SAVEPOINT.
	Statement string `protobuf:"bytes,4,opt,name=statement,proto3" json:"statement,omitempty"`
	// RowEvent is set if the event type is ROW.
	RowEvent *RowEvent `protobuf:"bytes,5,opt,name=row_event,json=rowEvent,proto3" json:"row_event,omitempty"`
	// FieldEvent is set if the event type is FIELD.
	FieldEvent *FieldEvent `protobuf:"bytes,6,opt,name=field_event,json=fieldEvent,proto3" json:"field_event,omitempty"`
	// Vgtid is set if the event type is VGTID.
	// This event is only generated by VTGate's VStream function.
	Vgtid *VGtid `protobuf:"bytes,7,opt,name=vgtid,proto3" json:"vgtid,omitempty"`
	// Journal is set if the event type is JOURNAL.
	Journal *Journal `protobuf:"bytes,8,opt,name=journal,proto3" json:"journal,omitempty"`
	// Dml is set if the event type is INSERT, REPLACE, UPDATE or DELETE.
	Dml string `protobuf:"bytes,9,opt,name=dml,proto3" json:"dml,omitempty"`
	// CurrentTime specifies the current time when the message was sent.
	// This can be used to compenssate for clock skew.
	CurrentTime int64 `protobuf:"varint,20,opt,name=current_time,json=currentTime,proto3" json:"current_time,omitempty"`
	// LastPK is the last PK for a table
	LastPKEvent *LastPKEvent `protobuf:"bytes,21,opt,name=last_p_k_event,json=lastPKEvent,proto3" json:"last_p_k_event,omitempty"`
	// contains filtered or unexported fields
}

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 deprecated

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

Deprecated: Use VEvent.ProtoReflect.Descriptor instead.

func (*VEvent) GetCurrentTime

func (x *VEvent) GetCurrentTime() int64

func (*VEvent) GetDml

func (x *VEvent) GetDml() string

func (*VEvent) GetFieldEvent

func (x *VEvent) GetFieldEvent() *FieldEvent

func (*VEvent) GetGtid

func (x *VEvent) GetGtid() string

func (*VEvent) GetJournal

func (x *VEvent) GetJournal() *Journal

func (*VEvent) GetLastPKEvent

func (x *VEvent) GetLastPKEvent() *LastPKEvent

func (*VEvent) GetRowEvent

func (x *VEvent) GetRowEvent() *RowEvent

func (*VEvent) GetStatement

func (x *VEvent) GetStatement() string

func (*VEvent) GetTimestamp

func (x *VEvent) GetTimestamp() int64

func (*VEvent) GetType

func (x *VEvent) GetType() VEventType

func (*VEvent) GetVgtid

func (x *VEvent) GetVgtid() *VGtid

func (*VEvent) MarshalToSizedBufferVT added in v0.11.0

func (m *VEvent) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VEvent) MarshalToVT added in v0.11.0

func (m *VEvent) MarshalToVT(dAtA []byte) (int, error)

func (*VEvent) MarshalVT added in v0.11.0

func (m *VEvent) MarshalVT() (dAtA []byte, err error)

func (*VEvent) ProtoMessage

func (*VEvent) ProtoMessage()

func (*VEvent) ProtoReflect added in v0.11.0

func (x *VEvent) ProtoReflect() protoreflect.Message

func (*VEvent) Reset

func (x *VEvent) Reset()

func (*VEvent) SizeVT added in v0.11.0

func (m *VEvent) SizeVT() (n int)

func (*VEvent) String

func (x *VEvent) String() string

func (*VEvent) UnmarshalVT added in v0.11.0

func (m *VEvent) UnmarshalVT(dAtA []byte) error

type VEventType

type VEventType int32

VEventType enumerates the event types. Many of these types will not be encountered in RBR mode.

const (
	VEventType_UNKNOWN  VEventType = 0
	VEventType_GTID     VEventType = 1
	VEventType_BEGIN    VEventType = 2
	VEventType_COMMIT   VEventType = 3
	VEventType_ROLLBACK VEventType = 4
	VEventType_DDL      VEventType = 5
	// INSERT, REPLACE, UPDATE, DELETE and SET will not be seen in RBR mode.
	VEventType_INSERT  VEventType = 6
	VEventType_REPLACE VEventType = 7
	VEventType_UPDATE  VEventType = 8
	VEventType_DELETE  VEventType = 9
	VEventType_SET     VEventType = 10
	// OTHER is a dummy event. If encountered, the current GTID must be
	// recorded by the client to be able to resume.
	VEventType_OTHER VEventType = 11
	VEventType_ROW   VEventType = 12
	VEventType_FIELD VEventType = 13
	// HEARTBEAT is sent if there is inactivity. If a client does not
	// receive events beyond the hearbeat interval, it can assume that it's
	// lost connection to the vstreamer.
	VEventType_HEARTBEAT VEventType = 14
	// VGTID is generated by VTGate's VStream that combines multiple
	// GTIDs.
	VEventType_VGTID     VEventType = 15
	VEventType_JOURNAL   VEventType = 16
	VEventType_VERSION   VEventType = 17
	VEventType_LASTPK    VEventType = 18
	VEventType_SAVEPOINT VEventType = 19
)

func (VEventType) Descriptor added in v0.11.0

func (VEventType) Descriptor() protoreflect.EnumDescriptor

func (VEventType) Enum added in v0.11.0

func (x VEventType) Enum() *VEventType

func (VEventType) EnumDescriptor deprecated

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

Deprecated: Use VEventType.Descriptor instead.

func (VEventType) Number added in v0.11.0

func (x VEventType) Number() protoreflect.EnumNumber

func (VEventType) String

func (x VEventType) String() string

func (VEventType) Type added in v0.11.0

type VGtid

type VGtid struct {
	ShardGtids []*ShardGtid `protobuf:"bytes,1,rep,name=shard_gtids,json=shardGtids,proto3" json:"shard_gtids,omitempty"`
	// contains filtered or unexported fields
}

A VGtid is a list of ShardGtids.

func (*VGtid) Descriptor deprecated

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

Deprecated: Use VGtid.ProtoReflect.Descriptor instead.

func (*VGtid) GetShardGtids

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

func (*VGtid) MarshalToSizedBufferVT added in v0.11.0

func (m *VGtid) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VGtid) MarshalToVT added in v0.11.0

func (m *VGtid) MarshalToVT(dAtA []byte) (int, error)

func (*VGtid) MarshalVT added in v0.11.0

func (m *VGtid) MarshalVT() (dAtA []byte, err error)

func (*VGtid) ProtoMessage

func (*VGtid) ProtoMessage()

func (*VGtid) ProtoReflect added in v0.11.0

func (x *VGtid) ProtoReflect() protoreflect.Message

func (*VGtid) Reset

func (x *VGtid) Reset()

func (*VGtid) SizeVT added in v0.11.0

func (m *VGtid) SizeVT() (n int)

func (*VGtid) String

func (x *VGtid) String() string

func (*VGtid) UnmarshalVT added in v0.11.0

func (m *VGtid) UnmarshalVT(dAtA []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"`
	TableLastPKs      []*TableLastPK        `protobuf:"bytes,6,rep,name=table_last_p_ks,json=tableLastPKs,proto3" json:"table_last_p_ks,omitempty"`
	// contains filtered or unexported fields
}

VStreamRequest is the payload for VStreamer

func (*VStreamRequest) Descriptor deprecated

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

Deprecated: Use VStreamRequest.ProtoReflect.Descriptor instead.

func (*VStreamRequest) GetEffectiveCallerId

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

func (*VStreamRequest) GetFilter

func (x *VStreamRequest) GetFilter() *Filter

func (*VStreamRequest) GetImmediateCallerId

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

func (*VStreamRequest) GetPosition

func (x *VStreamRequest) GetPosition() string

func (*VStreamRequest) GetTableLastPKs

func (x *VStreamRequest) GetTableLastPKs() []*TableLastPK

func (*VStreamRequest) GetTarget

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

func (*VStreamRequest) MarshalToSizedBufferVT added in v0.11.0

func (m *VStreamRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VStreamRequest) MarshalToVT added in v0.11.0

func (m *VStreamRequest) MarshalToVT(dAtA []byte) (int, error)

func (*VStreamRequest) MarshalVT added in v0.11.0

func (m *VStreamRequest) MarshalVT() (dAtA []byte, err error)

func (*VStreamRequest) ProtoMessage

func (*VStreamRequest) ProtoMessage()

func (*VStreamRequest) ProtoReflect added in v0.11.0

func (x *VStreamRequest) ProtoReflect() protoreflect.Message

func (*VStreamRequest) Reset

func (x *VStreamRequest) Reset()

func (*VStreamRequest) SizeVT added in v0.11.0

func (m *VStreamRequest) SizeVT() (n int)

func (*VStreamRequest) String

func (x *VStreamRequest) String() string

func (*VStreamRequest) UnmarshalVT added in v0.11.0

func (m *VStreamRequest) UnmarshalVT(dAtA []byte) error

type VStreamResponse

type VStreamResponse struct {
	Events []*VEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

VStreamResponse is the response from VStreamer

func (*VStreamResponse) Descriptor deprecated

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

Deprecated: Use VStreamResponse.ProtoReflect.Descriptor instead.

func (*VStreamResponse) GetEvents

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

func (*VStreamResponse) MarshalToSizedBufferVT added in v0.11.0

func (m *VStreamResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VStreamResponse) MarshalToVT added in v0.11.0

func (m *VStreamResponse) MarshalToVT(dAtA []byte) (int, error)

func (*VStreamResponse) MarshalVT added in v0.11.0

func (m *VStreamResponse) MarshalVT() (dAtA []byte, err error)

func (*VStreamResponse) ProtoMessage

func (*VStreamResponse) ProtoMessage()

func (*VStreamResponse) ProtoReflect added in v0.11.0

func (x *VStreamResponse) ProtoReflect() protoreflect.Message

func (*VStreamResponse) Reset

func (x *VStreamResponse) Reset()

func (*VStreamResponse) SizeVT added in v0.11.0

func (m *VStreamResponse) SizeVT() (n int)

func (*VStreamResponse) String

func (x *VStreamResponse) String() string

func (*VStreamResponse) UnmarshalVT added in v0.11.0

func (m *VStreamResponse) UnmarshalVT(dAtA []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"`
	// contains filtered or unexported fields
}

VStreamResultsRequest is the payload for VStreamResults The ids match VStreamRows, in case we decide to merge the two. The ids match VStreamRows, in case we decide to merge the two.

func (*VStreamResultsRequest) Descriptor deprecated

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

Deprecated: Use VStreamResultsRequest.ProtoReflect.Descriptor instead.

func (*VStreamResultsRequest) GetEffectiveCallerId

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

func (*VStreamResultsRequest) GetImmediateCallerId

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

func (*VStreamResultsRequest) GetQuery

func (x *VStreamResultsRequest) GetQuery() string

func (*VStreamResultsRequest) GetTarget

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

func (*VStreamResultsRequest) MarshalToSizedBufferVT added in v0.11.0

func (m *VStreamResultsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VStreamResultsRequest) MarshalToVT added in v0.11.0

func (m *VStreamResultsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*VStreamResultsRequest) MarshalVT added in v0.11.0

func (m *VStreamResultsRequest) MarshalVT() (dAtA []byte, err error)

func (*VStreamResultsRequest) ProtoMessage

func (*VStreamResultsRequest) ProtoMessage()

func (*VStreamResultsRequest) ProtoReflect added in v0.11.0

func (x *VStreamResultsRequest) ProtoReflect() protoreflect.Message

func (*VStreamResultsRequest) Reset

func (x *VStreamResultsRequest) Reset()

func (*VStreamResultsRequest) SizeVT added in v0.11.0

func (m *VStreamResultsRequest) SizeVT() (n int)

func (*VStreamResultsRequest) String

func (x *VStreamResultsRequest) String() string

func (*VStreamResultsRequest) UnmarshalVT added in v0.11.0

func (m *VStreamResultsRequest) UnmarshalVT(dAtA []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"`
	// contains filtered or unexported fields
}

VStreamResultsResponse is the response from VStreamResults The ids match VStreamRows, in case we decide to merge the two.

func (*VStreamResultsResponse) Descriptor deprecated

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

Deprecated: Use VStreamResultsResponse.ProtoReflect.Descriptor instead.

func (*VStreamResultsResponse) GetFields

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

func (*VStreamResultsResponse) GetGtid

func (x *VStreamResultsResponse) GetGtid() string

func (*VStreamResultsResponse) GetRows

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

func (*VStreamResultsResponse) MarshalToSizedBufferVT added in v0.11.0

func (m *VStreamResultsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VStreamResultsResponse) MarshalToVT added in v0.11.0

func (m *VStreamResultsResponse) MarshalToVT(dAtA []byte) (int, error)

func (*VStreamResultsResponse) MarshalVT added in v0.11.0

func (m *VStreamResultsResponse) MarshalVT() (dAtA []byte, err error)

func (*VStreamResultsResponse) ProtoMessage

func (*VStreamResultsResponse) ProtoMessage()

func (*VStreamResultsResponse) ProtoReflect added in v0.11.0

func (x *VStreamResultsResponse) ProtoReflect() protoreflect.Message

func (*VStreamResultsResponse) Reset

func (x *VStreamResultsResponse) Reset()

func (*VStreamResultsResponse) SizeVT added in v0.11.0

func (m *VStreamResultsResponse) SizeVT() (n int)

func (*VStreamResultsResponse) String

func (x *VStreamResultsResponse) String() string

func (*VStreamResultsResponse) UnmarshalVT added in v0.11.0

func (m *VStreamResultsResponse) UnmarshalVT(dAtA []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"`
	// contains filtered or unexported fields
}

VStreamRowsRequest is the payload for VStreamRows

func (*VStreamRowsRequest) Descriptor deprecated

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

Deprecated: Use VStreamRowsRequest.ProtoReflect.Descriptor instead.

func (*VStreamRowsRequest) GetEffectiveCallerId

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

func (*VStreamRowsRequest) GetImmediateCallerId

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

func (*VStreamRowsRequest) GetLastpk

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

func (*VStreamRowsRequest) GetQuery

func (x *VStreamRowsRequest) GetQuery() string

func (*VStreamRowsRequest) GetTarget

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

func (*VStreamRowsRequest) MarshalToSizedBufferVT added in v0.11.0

func (m *VStreamRowsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VStreamRowsRequest) MarshalToVT added in v0.11.0

func (m *VStreamRowsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*VStreamRowsRequest) MarshalVT added in v0.11.0

func (m *VStreamRowsRequest) MarshalVT() (dAtA []byte, err error)

func (*VStreamRowsRequest) ProtoMessage

func (*VStreamRowsRequest) ProtoMessage()

func (*VStreamRowsRequest) ProtoReflect added in v0.11.0

func (x *VStreamRowsRequest) ProtoReflect() protoreflect.Message

func (*VStreamRowsRequest) Reset

func (x *VStreamRowsRequest) Reset()

func (*VStreamRowsRequest) SizeVT added in v0.11.0

func (m *VStreamRowsRequest) SizeVT() (n int)

func (*VStreamRowsRequest) String

func (x *VStreamRowsRequest) String() string

func (*VStreamRowsRequest) UnmarshalVT added in v0.11.0

func (m *VStreamRowsRequest) UnmarshalVT(dAtA []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"`
	// contains filtered or unexported fields
}

VStreamRowsResponse is the response from VStreamRows

func VStreamRowsResponseFromVTPool added in v0.11.0

func VStreamRowsResponseFromVTPool() *VStreamRowsResponse

func (*VStreamRowsResponse) Descriptor deprecated

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

Deprecated: Use VStreamRowsResponse.ProtoReflect.Descriptor instead.

func (*VStreamRowsResponse) GetFields

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

func (*VStreamRowsResponse) GetGtid

func (x *VStreamRowsResponse) GetGtid() string

func (*VStreamRowsResponse) GetLastpk

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

func (*VStreamRowsResponse) GetPkfields

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

func (*VStreamRowsResponse) GetRows

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

func (*VStreamRowsResponse) MarshalToSizedBufferVT added in v0.11.0

func (m *VStreamRowsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*VStreamRowsResponse) MarshalToVT added in v0.11.0

func (m *VStreamRowsResponse) MarshalToVT(dAtA []byte) (int, error)

func (*VStreamRowsResponse) MarshalVT added in v0.11.0

func (m *VStreamRowsResponse) MarshalVT() (dAtA []byte, err error)

func (*VStreamRowsResponse) ProtoMessage

func (*VStreamRowsResponse) ProtoMessage()

func (*VStreamRowsResponse) ProtoReflect added in v0.11.0

func (x *VStreamRowsResponse) ProtoReflect() protoreflect.Message

func (*VStreamRowsResponse) Reset

func (x *VStreamRowsResponse) Reset()

func (*VStreamRowsResponse) ResetVT added in v0.11.0

func (m *VStreamRowsResponse) ResetVT()

func (*VStreamRowsResponse) ReturnToVTPool added in v0.11.0

func (m *VStreamRowsResponse) ReturnToVTPool()

func (*VStreamRowsResponse) SizeVT added in v0.11.0

func (m *VStreamRowsResponse) SizeVT() (n int)

func (*VStreamRowsResponse) String

func (x *VStreamRowsResponse) String() string

func (*VStreamRowsResponse) UnmarshalVT added in v0.11.0

func (m *VStreamRowsResponse) UnmarshalVT(dAtA []byte) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL