binlogdatav19

package
v1.36.10-2025040823455... Latest Latest
Warning

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

 Go to latest Published: unknown License: Apache-2.0 Imports: 7 Imported by: 0

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 (
	VReplicationWorkflowType_name = map[int32]string{
		0: "Materialize",
		1: "MoveTables",
		2: "CreateLookupIndex",
		3: "Migrate",
		4: "Reshard",
		5: "OnlineDDL",
	}
	VReplicationWorkflowType_value = map[string]int32{
		"Materialize":       0,
		"MoveTables":        1,
		"CreateLookupIndex": 2,
		"Migrate":           3,
		"Reshard":           4,
		"OnlineDDL":         5,
	}
)

Enum value maps for VReplicationWorkflowType.

View Source 
var (
	VReplicationWorkflowSubType_name = map[int32]string{
		0: "None",
		1: "Partial",
		2: "AtomicCopy",
	}
	VReplicationWorkflowSubType_value = map[string]int32{
		"None":       0,
		"Partial":    1,
		"AtomicCopy": 2,
	}
)

Enum value maps for VReplicationWorkflowSubType.

View Source 
var (
	VReplicationWorkflowState_name = map[int32]string{
		0: "Unknown",
		1: "Init",
		2: "Stopped",
		3: "Copying",
		4: "Running",
		5: "Error",
		6: "Lagging",
	}
	VReplicationWorkflowState_value = map[string]int32{
		"Unknown": 0,
		"Init":    1,
		"Stopped": 2,
		"Copying": 3,
		"Running": 4,
		"Error":   5,
		"Lagging": 6,
	}
)

Enum value maps for VReplicationWorkflowState.

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

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 File_vitess_binlogdata_v19_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 v191.TabletType `` /* 128-byte string literal not displayed */
	// KeyRange is set if the request is for a keyrange
	KeyRange *v191.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=vitess.binlogdata.v19.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"`
	// SourceTimeZone is the time zone in which datetimes on the source were stored, provided as an option in MoveTables
	SourceTimeZone string `protobuf:"bytes,11,opt,name=source_time_zone,json=sourceTimeZone,proto3" json:"source_time_zone,omitempty"`
	// TargetTimeZone is not currently specifiable by the user, defaults to UTC for the forward workflows
	// and to the SourceTimeZone in reverse workflows
	TargetTimeZone string `protobuf:"bytes,12,opt,name=target_time_zone,json=targetTimeZone,proto3" json:"target_time_zone,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) ClearFilter 

func (x *BinlogSource) ClearFilter()

func (*BinlogSource) ClearKeyRange 

func (x *BinlogSource) ClearKeyRange()

func (*BinlogSource) GetExternalCluster 

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() *v191.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) GetSourceTimeZone 

func (x *BinlogSource) GetSourceTimeZone() string

func (*BinlogSource) GetStopAfterCopy 

func (x *BinlogSource) GetStopAfterCopy() bool

func (*BinlogSource) GetTables 

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

func (*BinlogSource) GetTabletType 

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

func (*BinlogSource) GetTargetTimeZone 

func (x *BinlogSource) GetTargetTimeZone() string

func (*BinlogSource) HasFilter 

func (x *BinlogSource) HasFilter() bool

func (*BinlogSource) HasKeyRange 

func (x *BinlogSource) HasKeyRange() bool

func (*BinlogSource) ProtoMessage 

func (*BinlogSource) ProtoMessage()

func (*BinlogSource) ProtoReflect 

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

func (*BinlogSource) Reset 

func (x *BinlogSource) Reset()

func (*BinlogSource) SetExternalCluster 

func (x *BinlogSource) SetExternalCluster(v string)

func (*BinlogSource) SetExternalMysql 

func (x *BinlogSource) SetExternalMysql(v string)

func (*BinlogSource) SetFilter 

func (x *BinlogSource) SetFilter(v *Filter)

func (*BinlogSource) SetKeyRange 

func (x *BinlogSource) SetKeyRange(v *v191.KeyRange)

func (*BinlogSource) SetKeyspace 

func (x *BinlogSource) SetKeyspace(v string)

func (*BinlogSource) SetOnDdl 

func (x *BinlogSource) SetOnDdl(v OnDDLAction)

func (*BinlogSource) SetShard 

func (x *BinlogSource) SetShard(v string)

func (*BinlogSource) SetSourceTimeZone 

func (x *BinlogSource) SetSourceTimeZone(v string)

func (*BinlogSource) SetStopAfterCopy 

func (x *BinlogSource) SetStopAfterCopy(v bool)

func (*BinlogSource) SetTables 

func (x *BinlogSource) SetTables(v []string)

func (*BinlogSource) SetTabletType 

func (x *BinlogSource) SetTabletType(v v191.TabletType)

func (*BinlogSource) SetTargetTimeZone 

func (x *BinlogSource) SetTargetTimeZone(v string)

func (*BinlogSource) String 

func (x *BinlogSource) String() string

type BinlogSource_builder 

type BinlogSource_builder struct {

	// the source keyspace
	Keyspace string
	// the source shard
	Shard string
	// the source tablet type
	TabletType v191.TabletType
	// KeyRange is set if the request is for a keyrange
	KeyRange *v191.KeyRange
	// Tables is set if the request is for a list of tables
	Tables []string
	// Filter is set if we're using the generalized representation
	// for the filter.
	Filter *Filter
	// OnDdl specifies the action to be taken when a DDL is encountered.
	OnDdl OnDDLAction
	// Source is an external mysql. This attribute should be set to the username
	// to use in the connection
	ExternalMysql string
	// StopAfterCopy specifies if vreplication should be stopped
	// after copying is done.
	StopAfterCopy bool
	// 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
	// SourceTimeZone is the time zone in which datetimes on the source were stored, provided as an option in MoveTables
	SourceTimeZone string
	// TargetTimeZone is not currently specifiable by the user, defaults to UTC for the forward workflows
	// and to the SourceTimeZone in reverse workflows
	TargetTimeZone string
	// contains filtered or unexported fields
}

func (BinlogSource_builder) Build 

func (b0 BinlogSource_builder) Build() *BinlogSource

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 *v19.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) ClearEventToken 

func (x *BinlogTransaction) ClearEventToken()

func (*BinlogTransaction) GetEventToken 

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

func (*BinlogTransaction) GetStatements 

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

func (*BinlogTransaction) HasEventToken 

func (x *BinlogTransaction) HasEventToken() bool

func (*BinlogTransaction) ProtoMessage 

func (*BinlogTransaction) ProtoMessage()

func (*BinlogTransaction) ProtoReflect 

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

func (*BinlogTransaction) Reset 

func (x *BinlogTransaction) Reset()

func (*BinlogTransaction) SetEventToken 

func (x *BinlogTransaction) SetEventToken(v *v19.EventToken)

func (*BinlogTransaction) SetStatements 

func (x *BinlogTransaction) SetStatements(v []*BinlogTransaction_Statement)

func (*BinlogTransaction) String 

func (x *BinlogTransaction) String() string

type BinlogTransaction_Statement 

type BinlogTransaction_Statement struct {

	// what type of statement is this?
	Category BinlogTransaction_Statement_Category `` /* 134-byte string literal not displayed */
	// 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) ClearCharset 

func (x *BinlogTransaction_Statement) ClearCharset()

func (*BinlogTransaction_Statement) GetCategory 

func (x *BinlogTransaction_Statement) GetCategory() BinlogTransaction_Statement_Category

func (*BinlogTransaction_Statement) GetCharset 

func (x *BinlogTransaction_Statement) GetCharset() *Charset

func (*BinlogTransaction_Statement) GetSql 

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

func (*BinlogTransaction_Statement) HasCharset 

func (x *BinlogTransaction_Statement) HasCharset() bool

func (*BinlogTransaction_Statement) ProtoMessage 

func (*BinlogTransaction_Statement) ProtoMessage()

func (*BinlogTransaction_Statement) ProtoReflect 

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

func (*BinlogTransaction_Statement) Reset 

func (x *BinlogTransaction_Statement) Reset()

func (*BinlogTransaction_Statement) SetCategory 

func (x *BinlogTransaction_Statement) SetCategory(v BinlogTransaction_Statement_Category)

func (*BinlogTransaction_Statement) SetCharset 

func (x *BinlogTransaction_Statement) SetCharset(v *Charset)

func (*BinlogTransaction_Statement) SetSql 

func (x *BinlogTransaction_Statement) SetSql(v []byte)

func (*BinlogTransaction_Statement) String 

func (x *BinlogTransaction_Statement) String() string

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 

func (BinlogTransaction_Statement_Category) Descriptor() protoreflect.EnumDescriptor

func (BinlogTransaction_Statement_Category) Enum 

func (x BinlogTransaction_Statement_Category) Enum() *BinlogTransaction_Statement_Category

func (BinlogTransaction_Statement_Category) Number 

func (x BinlogTransaction_Statement_Category) Number() protoreflect.EnumNumber

func (BinlogTransaction_Statement_Category) String 

func (x BinlogTransaction_Statement_Category) String() string

func (BinlogTransaction_Statement_Category) Type 

func (BinlogTransaction_Statement_Category) Type() protoreflect.EnumType

type BinlogTransaction_Statement_builder 

type BinlogTransaction_Statement_builder struct {

	// what type of statement is this?
	Category BinlogTransaction_Statement_Category
	// charset of this statement, if different from pre-negotiated default.
	Charset *Charset
	// the sql
	Sql []byte
	// contains filtered or unexported fields
}

func (BinlogTransaction_Statement_builder) Build 

func (b0 BinlogTransaction_Statement_builder) Build() *BinlogTransaction_Statement

type BinlogTransaction_builder 

type BinlogTransaction_builder struct {

	// the statements in this transaction
	Statements []*BinlogTransaction_Statement
	// The Event Token for this event.
	EventToken *v19.EventToken
	// contains filtered or unexported fields
}

func (BinlogTransaction_builder) Build 

func (b0 BinlogTransaction_builder) Build() *BinlogTransaction

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

func (x *Charset) GetClient() int32

func (*Charset) GetConn 

func (x *Charset) GetConn() int32

func (*Charset) GetServer 

func (x *Charset) GetServer() int32

func (*Charset) ProtoMessage 

func (*Charset) ProtoMessage()

func (*Charset) ProtoReflect 

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

func (*Charset) Reset 

func (x *Charset) Reset()

func (*Charset) SetClient 

func (x *Charset) SetClient(v int32)

func (*Charset) SetConn 

func (x *Charset) SetConn(v int32)

func (*Charset) SetServer 

func (x *Charset) SetServer(v int32)

func (*Charset) String 

func (x *Charset) String() string

type CharsetConversion 

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

func (x *CharsetConversion) GetFromCharset() string

func (*CharsetConversion) GetToCharset 

func (x *CharsetConversion) GetToCharset() string

func (*CharsetConversion) ProtoMessage 

func (*CharsetConversion) ProtoMessage()

func (*CharsetConversion) ProtoReflect 

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

func (*CharsetConversion) Reset 

func (x *CharsetConversion) Reset()

func (*CharsetConversion) SetFromCharset 

func (x *CharsetConversion) SetFromCharset(v string)

func (*CharsetConversion) SetToCharset 

func (x *CharsetConversion) SetToCharset(v string)

func (*CharsetConversion) String 

func (x *CharsetConversion) String() string

type CharsetConversion_builder 

type CharsetConversion_builder struct {

	// FromCharset is the charset name from which we convert the text (e.g. latin1)
	FromCharset string
	// ToCharset is the charset name to which we convert the text (e.g. utf8mb4)
	ToCharset string
	// contains filtered or unexported fields
}

func (CharsetConversion_builder) Build 

func (b0 CharsetConversion_builder) Build() *CharsetConversion

type Charset_builder 

type Charset_builder struct {

	// @@session.character_set_client
	Client int32
	// @@session.collation_connection
	Conn int32
	// @@session.collation_server
	Server int32
	// contains filtered or unexported fields
}

func (Charset_builder) Build 

func (b0 Charset_builder) Build() *Charset

type FieldEvent 

type FieldEvent struct {
	TableName string       `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	Fields    []*v19.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) GetFields 

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

func (*FieldEvent) GetKeyspace 

func (x *FieldEvent) GetKeyspace() string

func (*FieldEvent) GetShard 

func (x *FieldEvent) GetShard() string

func (*FieldEvent) GetTableName 

func (x *FieldEvent) GetTableName() string

func (*FieldEvent) ProtoMessage 

func (*FieldEvent) ProtoMessage()

func (*FieldEvent) ProtoReflect 

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

func (*FieldEvent) Reset 

func (x *FieldEvent) Reset()

func (*FieldEvent) SetFields 

func (x *FieldEvent) SetFields(v []*v19.Field)

func (*FieldEvent) SetKeyspace 

func (x *FieldEvent) SetKeyspace(v string)

func (*FieldEvent) SetShard 

func (x *FieldEvent) SetShard(v string)

func (*FieldEvent) SetTableName 

func (x *FieldEvent) SetTableName(v string)

func (*FieldEvent) String 

func (x *FieldEvent) String() string

type FieldEvent_builder 

type FieldEvent_builder struct {
	TableName string
	Fields    []*v19.Field
	Keyspace  string
	Shard     string
	// contains filtered or unexported fields
}

func (FieldEvent_builder) Build 

func (b0 FieldEvent_builder) Build() *FieldEvent

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 `` /* 155-byte string literal not displayed */
	WorkflowType   int64                 `protobuf:"varint,3,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	WorkflowName   string                `protobuf:"bytes,4,opt,name=workflow_name,json=workflowName,proto3" json:"workflow_name,omitempty"`
	// contains filtered or unexported fields
}

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

func (*Filter) GetFieldEventMode 

func (x *Filter) GetFieldEventMode() Filter_FieldEventMode

func (*Filter) GetRules 

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

func (*Filter) GetWorkflowName 

func (x *Filter) GetWorkflowName() string

func (*Filter) GetWorkflowType 

func (x *Filter) GetWorkflowType() int64

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) ProtoReflect 

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

func (*Filter) Reset 

func (x *Filter) Reset()

func (*Filter) SetFieldEventMode 

func (x *Filter) SetFieldEventMode(v Filter_FieldEventMode)

func (*Filter) SetRules 

func (x *Filter) SetRules(v []*Rule)

func (*Filter) SetWorkflowName 

func (x *Filter) SetWorkflowName(v string)

func (*Filter) SetWorkflowType 

func (x *Filter) SetWorkflowType(v int64)

func (*Filter) String 

func (x *Filter) String() string

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 

func (Filter_FieldEventMode) Descriptor() protoreflect.EnumDescriptor

func (Filter_FieldEventMode) Enum 

func (x Filter_FieldEventMode) Enum() *Filter_FieldEventMode

func (Filter_FieldEventMode) Number 

func (x Filter_FieldEventMode) Number() protoreflect.EnumNumber

func (Filter_FieldEventMode) String 

func (x Filter_FieldEventMode) String() string

func (Filter_FieldEventMode) Type 

func (Filter_FieldEventMode) Type() protoreflect.EnumType

type Filter_builder 

type Filter_builder struct {
	Rules []*Rule
	// 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
	WorkflowType   int64
	WorkflowName   string
	// contains filtered or unexported fields
}

func (Filter_builder) Build 

func (b0 Filter_builder) Build() *Filter

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 `` /* 142-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) 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) ProtoMessage 

func (*Journal) ProtoMessage()

func (*Journal) ProtoReflect 

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

func (*Journal) Reset 

func (x *Journal) Reset()

func (*Journal) SetId 

func (x *Journal) SetId(v int64)

func (*Journal) SetLocalPosition 

func (x *Journal) SetLocalPosition(v string)

func (*Journal) SetMigrationType 

func (x *Journal) SetMigrationType(v MigrationType)

func (*Journal) SetParticipants 

func (x *Journal) SetParticipants(v []*KeyspaceShard)

func (*Journal) SetShardGtids 

func (x *Journal) SetShardGtids(v []*ShardGtid)

func (*Journal) SetSourceWorkflows 

func (x *Journal) SetSourceWorkflows(v []string)

func (*Journal) SetTables 

func (x *Journal) SetTables(v []string)

func (*Journal) String 

func (x *Journal) String() string

type Journal_builder 

type Journal_builder struct {

	// Id represents a unique journal id.
	Id            int64
	MigrationType MigrationType
	// Tables is set if the journal represents a TABLES migration.
	Tables []string
	// LocalPosition is the source position at which the migration happened.
	LocalPosition string
	// ShardGtids is the list of targets to which the migration took place.
	ShardGtids []*ShardGtid
	// 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
	// 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
	// contains filtered or unexported fields
}

func (Journal_builder) Build 

func (b0 Journal_builder) Build() *Journal

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

func (x *KeyspaceShard) GetKeyspace() string

func (*KeyspaceShard) GetShard 

func (x *KeyspaceShard) GetShard() string

func (*KeyspaceShard) ProtoMessage 

func (*KeyspaceShard) ProtoMessage()

func (*KeyspaceShard) ProtoReflect 

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

func (*KeyspaceShard) Reset 

func (x *KeyspaceShard) Reset()

func (*KeyspaceShard) SetKeyspace 

func (x *KeyspaceShard) SetKeyspace(v string)

func (*KeyspaceShard) SetShard 

func (x *KeyspaceShard) SetShard(v string)

func (*KeyspaceShard) String 

func (x *KeyspaceShard) String() string

type KeyspaceShard_builder 

type KeyspaceShard_builder struct {
	Keyspace string
	Shard    string
	// contains filtered or unexported fields
}

func (KeyspaceShard_builder) Build 

func (b0 KeyspaceShard_builder) Build() *KeyspaceShard

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

func (x *LastPKEvent) ClearTableLastPK()

func (*LastPKEvent) GetCompleted 

func (x *LastPKEvent) GetCompleted() bool

func (*LastPKEvent) GetTableLastPK 

func (x *LastPKEvent) GetTableLastPK() *TableLastPK

func (*LastPKEvent) HasTableLastPK 

func (x *LastPKEvent) HasTableLastPK() bool

func (*LastPKEvent) ProtoMessage 

func (*LastPKEvent) ProtoMessage()

func (*LastPKEvent) ProtoReflect 

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

func (*LastPKEvent) Reset 

func (x *LastPKEvent) Reset()

func (*LastPKEvent) SetCompleted 

func (x *LastPKEvent) SetCompleted(v bool)

func (*LastPKEvent) SetTableLastPK 

func (x *LastPKEvent) SetTableLastPK(v *TableLastPK)

func (*LastPKEvent) String 

func (x *LastPKEvent) String() string

type LastPKEvent_builder 

type LastPKEvent_builder struct {
	TableLastPK *TableLastPK
	Completed   bool
	// contains filtered or unexported fields
}

func (LastPKEvent_builder) Build 

func (b0 LastPKEvent_builder) Build() *LastPKEvent

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 

func (MigrationType) Descriptor() protoreflect.EnumDescriptor

func (MigrationType) Enum 

func (x MigrationType) Enum() *MigrationType

func (MigrationType) Number 

func (x MigrationType) Number() protoreflect.EnumNumber

func (MigrationType) String 

func (x MigrationType) String() string

func (MigrationType) Type 

func (MigrationType) Type() protoreflect.EnumType

type MinimalSchema 

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

func (*MinimalSchema) GetTables 

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

func (*MinimalSchema) ProtoMessage 

func (*MinimalSchema) ProtoMessage()

func (*MinimalSchema) ProtoReflect 

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

func (*MinimalSchema) Reset 

func (x *MinimalSchema) Reset()

func (*MinimalSchema) SetTables 

func (x *MinimalSchema) SetTables(v []*MinimalTable)

func (*MinimalSchema) String 

func (x *MinimalSchema) String() string

type MinimalSchema_builder 

type MinimalSchema_builder struct {
	Tables []*MinimalTable
	// contains filtered or unexported fields
}

func (MinimalSchema_builder) Build 

func (b0 MinimalSchema_builder) Build() *MinimalSchema

type MinimalTable 

type MinimalTable struct {
	Name      string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Fields    []*v19.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"`
	// This will be PRIMARY when the actual primary key is used and it
	// will be the name of the Primary Key equivalent if one is used
	// instead. Otherwise it will be empty.
	PKIndexName string `protobuf:"bytes,4,opt,name=p_k_index_name,json=pKIndexName,proto3" json:"p_k_index_name,omitempty"`
	// contains filtered or unexported fields
}

func (*MinimalTable) GetFields 

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

func (*MinimalTable) GetName 

func (x *MinimalTable) GetName() string

func (*MinimalTable) GetPKColumns 

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

func (*MinimalTable) GetPKIndexName 

func (x *MinimalTable) GetPKIndexName() string

func (*MinimalTable) ProtoMessage 

func (*MinimalTable) ProtoMessage()

func (*MinimalTable) ProtoReflect 

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

func (*MinimalTable) Reset 

func (x *MinimalTable) Reset()

func (*MinimalTable) SetFields 

func (x *MinimalTable) SetFields(v []*v19.Field)

func (*MinimalTable) SetName 

func (x *MinimalTable) SetName(v string)

func (*MinimalTable) SetPKColumns 

func (x *MinimalTable) SetPKColumns(v []int64)

func (*MinimalTable) SetPKIndexName 

func (x *MinimalTable) SetPKIndexName(v string)

func (*MinimalTable) String 

func (x *MinimalTable) String() string

type MinimalTable_builder 

type MinimalTable_builder struct {
	Name      string
	Fields    []*v19.Field
	PKColumns []int64
	// This will be PRIMARY when the actual primary key is used and it
	// will be the name of the Primary Key equivalent if one is used
	// instead. Otherwise it will be empty.
	PKIndexName string
	// contains filtered or unexported fields
}

func (MinimalTable_builder) Build 

func (b0 MinimalTable_builder) Build() *MinimalTable

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 

func (OnDDLAction) Descriptor() protoreflect.EnumDescriptor

func (OnDDLAction) Enum 

func (x OnDDLAction) Enum() *OnDDLAction

func (OnDDLAction) Number 

func (x OnDDLAction) Number() protoreflect.EnumNumber

func (OnDDLAction) String 

func (x OnDDLAction) String() string

func (OnDDLAction) Type 

func (OnDDLAction) Type() protoreflect.EnumType

type RowChange 

type RowChange struct {
	Before *v19.Row `protobuf:"bytes,1,opt,name=before,proto3" json:"before,omitempty"`
	After  *v19.Row `protobuf:"bytes,2,opt,name=after,proto3" json:"after,omitempty"`
	// DataColumns is a bitmap of all columns: bit is set if column is present in the after image
	DataColumns *RowChange_Bitmap `protobuf:"bytes,3,opt,name=data_columns,json=dataColumns,proto3" json:"data_columns,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) ClearAfter 

func (x *RowChange) ClearAfter()

func (*RowChange) ClearBefore 

func (x *RowChange) ClearBefore()

func (*RowChange) ClearDataColumns 

func (x *RowChange) ClearDataColumns()

func (*RowChange) GetAfter 

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

func (*RowChange) GetBefore 

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

func (*RowChange) GetDataColumns 

func (x *RowChange) GetDataColumns() *RowChange_Bitmap

func (*RowChange) HasAfter 

func (x *RowChange) HasAfter() bool

func (*RowChange) HasBefore 

func (x *RowChange) HasBefore() bool

func (*RowChange) HasDataColumns 

func (x *RowChange) HasDataColumns() bool

func (*RowChange) ProtoMessage 

func (*RowChange) ProtoMessage()

func (*RowChange) ProtoReflect 

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

func (*RowChange) Reset 

func (x *RowChange) Reset()

func (*RowChange) SetAfter 

func (x *RowChange) SetAfter(v *v19.Row)

func (*RowChange) SetBefore 

func (x *RowChange) SetBefore(v *v19.Row)

func (*RowChange) SetDataColumns 

func (x *RowChange) SetDataColumns(v *RowChange_Bitmap)

func (*RowChange) String 

func (x *RowChange) String() string

type RowChange_Bitmap 

type RowChange_Bitmap struct {
	Count int64  `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	Cols  []byte `protobuf:"bytes,2,opt,name=cols,proto3" json:"cols,omitempty"`
	// contains filtered or unexported fields
}

func (*RowChange_Bitmap) GetCols 

func (x *RowChange_Bitmap) GetCols() []byte

func (*RowChange_Bitmap) GetCount 

func (x *RowChange_Bitmap) GetCount() int64

func (*RowChange_Bitmap) ProtoMessage 

func (*RowChange_Bitmap) ProtoMessage()

func (*RowChange_Bitmap) ProtoReflect 

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

func (*RowChange_Bitmap) Reset 

func (x *RowChange_Bitmap) Reset()

func (*RowChange_Bitmap) SetCols 

func (x *RowChange_Bitmap) SetCols(v []byte)

func (*RowChange_Bitmap) SetCount 

func (x *RowChange_Bitmap) SetCount(v int64)

func (*RowChange_Bitmap) String 

func (x *RowChange_Bitmap) String() string

type RowChange_Bitmap_builder 

type RowChange_Bitmap_builder struct {
	Count int64
	Cols  []byte
	// contains filtered or unexported fields
}

func (RowChange_Bitmap_builder) Build 

func (b0 RowChange_Bitmap_builder) Build() *RowChange_Bitmap

type RowChange_builder 

type RowChange_builder struct {
	Before *v19.Row
	After  *v19.Row
	// DataColumns is a bitmap of all columns: bit is set if column is present in the after image
	DataColumns *RowChange_Bitmap
	// contains filtered or unexported fields
}

func (RowChange_builder) Build 

func (b0 RowChange_builder) Build() *RowChange

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"`
	Flags      uint32       `protobuf:"varint,5,opt,name=flags,proto3" json:"flags,omitempty"` // https://dev.mysql.com/doc/dev/mysql-server/latest/classbinary__log_1_1Rows__event.html
	// contains filtered or unexported fields
}

RowEvent represent row events for one table.

func (*RowEvent) GetFlags 

func (x *RowEvent) GetFlags() uint32

func (*RowEvent) GetKeyspace 

func (x *RowEvent) GetKeyspace() string

func (*RowEvent) GetRowChanges 

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

func (*RowEvent) GetShard 

func (x *RowEvent) GetShard() string

func (*RowEvent) GetTableName 

func (x *RowEvent) GetTableName() string

func (*RowEvent) ProtoMessage 

func (*RowEvent) ProtoMessage()

func (*RowEvent) ProtoReflect 

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

func (*RowEvent) Reset 

func (x *RowEvent) Reset()

func (*RowEvent) SetFlags 

func (x *RowEvent) SetFlags(v uint32)

func (*RowEvent) SetKeyspace 

func (x *RowEvent) SetKeyspace(v string)

func (*RowEvent) SetRowChanges 

func (x *RowEvent) SetRowChanges(v []*RowChange)

func (*RowEvent) SetShard 

func (x *RowEvent) SetShard(v string)

func (*RowEvent) SetTableName 

func (x *RowEvent) SetTableName(v string)

func (*RowEvent) String 

func (x *RowEvent) String() string

type RowEvent_builder 

type RowEvent_builder struct {
	TableName  string
	RowChanges []*RowChange
	Keyspace   string
	Shard      string
	Flags      uint32
	// contains filtered or unexported fields
}

func (RowEvent_builder) Build 

func (b0 RowEvent_builder) Build() *RowEvent

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 `` /* 190-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 `` /* 177-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 */
	// ConvertIntToEnum lists any columns that are converted from an integral value into an enum.
	// such columns need to have special transofrmation of the data, from an integral format into a
	// string format. e.g. the value 0 needs to be converted to '0'.
	ConvertIntToEnum map[string]bool `` /* 188-byte string literal not displayed */
	// ForceUniqueKey gives vtreamer a hint for `FORCE INDEX (...)` usage.
	ForceUniqueKey string `protobuf:"bytes,9,opt,name=force_unique_key,json=forceUniqueKey,proto3" json:"force_unique_key,omitempty"`
	// contains filtered or unexported fields
}

Rule represents one rule in a Filter.

func (*Rule) GetConvertCharset 

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

func (*Rule) GetConvertEnumToText 

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

func (*Rule) GetConvertIntToEnum 

func (x *Rule) GetConvertIntToEnum() map[string]bool

func (*Rule) GetFilter 

func (x *Rule) GetFilter() string

func (*Rule) GetForceUniqueKey 

func (x *Rule) GetForceUniqueKey() string

func (*Rule) GetMatch 

func (x *Rule) GetMatch() string

func (*Rule) GetSourceUniqueKeyColumns 

func (x *Rule) GetSourceUniqueKeyColumns() string

func (*Rule) GetSourceUniqueKeyTargetColumns 

func (x *Rule) GetSourceUniqueKeyTargetColumns() string

func (*Rule) GetTargetUniqueKeyColumns 

func (x *Rule) GetTargetUniqueKeyColumns() string

func (*Rule) ProtoMessage 

func (*Rule) ProtoMessage()

func (*Rule) ProtoReflect 

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

func (*Rule) Reset 

func (x *Rule) Reset()

func (*Rule) SetConvertCharset 

func (x *Rule) SetConvertCharset(v map[string]*CharsetConversion)

func (*Rule) SetConvertEnumToText 

func (x *Rule) SetConvertEnumToText(v map[string]string)

func (*Rule) SetConvertIntToEnum 

func (x *Rule) SetConvertIntToEnum(v map[string]bool)

func (*Rule) SetFilter 

func (x *Rule) SetFilter(v string)

func (*Rule) SetForceUniqueKey 

func (x *Rule) SetForceUniqueKey(v string)

func (*Rule) SetMatch 

func (x *Rule) SetMatch(v string)

func (*Rule) SetSourceUniqueKeyColumns 

func (x *Rule) SetSourceUniqueKeyColumns(v string)

func (*Rule) SetSourceUniqueKeyTargetColumns 

func (x *Rule) SetSourceUniqueKeyTargetColumns(v string)

func (*Rule) SetTargetUniqueKeyColumns 

func (x *Rule) SetTargetUniqueKeyColumns(v string)

func (*Rule) String 

func (x *Rule) String() string

type Rule_builder 

type Rule_builder 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
	// 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
	// Example: key="color", value="'red','green','blue'"
	ConvertEnumToText map[string]string
	// 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
	// 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
	// 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
	// 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
	// ConvertIntToEnum lists any columns that are converted from an integral value into an enum.
	// such columns need to have special transofrmation of the data, from an integral format into a
	// string format. e.g. the value 0 needs to be converted to '0'.
	ConvertIntToEnum map[string]bool
	// ForceUniqueKey gives vtreamer a hint for `FORCE INDEX (...)` usage.
	ForceUniqueKey string
	// contains filtered or unexported fields
}

func (Rule_builder) Build 

func (b0 Rule_builder) Build() *Rule

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

func (*ShardGtid) ProtoMessage()

func (*ShardGtid) ProtoReflect 

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

func (*ShardGtid) Reset 

func (x *ShardGtid) Reset()

func (*ShardGtid) SetGtid 

func (x *ShardGtid) SetGtid(v string)

func (*ShardGtid) SetKeyspace 

func (x *ShardGtid) SetKeyspace(v string)

func (*ShardGtid) SetShard 

func (x *ShardGtid) SetShard(v string)

func (*ShardGtid) SetTablePKs 

func (x *ShardGtid) SetTablePKs(v []*TableLastPK)

func (*ShardGtid) String 

func (x *ShardGtid) String() string

type ShardGtid_builder 

type ShardGtid_builder struct {
	Keyspace string
	Shard    string
	Gtid     string
	TablePKs []*TableLastPK
	// contains filtered or unexported fields
}

func (ShardGtid_builder) Build 

func (b0 ShardGtid_builder) Build() *ShardGtid

type StreamKeyRangeRequest 

type StreamKeyRangeRequest struct {

	// where to start
	Position string `protobuf:"bytes,1,opt,name=position,proto3" json:"position,omitempty"`
	// what to get
	KeyRange *v191.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) ClearCharset 

func (x *StreamKeyRangeRequest) ClearCharset()

func (*StreamKeyRangeRequest) ClearKeyRange 

func (x *StreamKeyRangeRequest) ClearKeyRange()

func (*StreamKeyRangeRequest) GetCharset 

func (x *StreamKeyRangeRequest) GetCharset() *Charset

func (*StreamKeyRangeRequest) GetKeyRange 

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

func (*StreamKeyRangeRequest) GetPosition 

func (x *StreamKeyRangeRequest) GetPosition() string

func (*StreamKeyRangeRequest) HasCharset 

func (x *StreamKeyRangeRequest) HasCharset() bool

func (*StreamKeyRangeRequest) HasKeyRange 

func (x *StreamKeyRangeRequest) HasKeyRange() bool

func (*StreamKeyRangeRequest) ProtoMessage 

func (*StreamKeyRangeRequest) ProtoMessage()

func (*StreamKeyRangeRequest) ProtoReflect 

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

func (*StreamKeyRangeRequest) Reset 

func (x *StreamKeyRangeRequest) Reset()

func (*StreamKeyRangeRequest) SetCharset 

func (x *StreamKeyRangeRequest) SetCharset(v *Charset)

func (*StreamKeyRangeRequest) SetKeyRange 

func (x *StreamKeyRangeRequest) SetKeyRange(v *v191.KeyRange)

func (*StreamKeyRangeRequest) SetPosition 

func (x *StreamKeyRangeRequest) SetPosition(v string)

func (*StreamKeyRangeRequest) String 

func (x *StreamKeyRangeRequest) String() string

type StreamKeyRangeRequest_builder 

type StreamKeyRangeRequest_builder struct {

	// where to start
	Position string
	// what to get
	KeyRange *v191.KeyRange
	// default charset on the player side
	Charset *Charset
	// contains filtered or unexported fields
}

func (StreamKeyRangeRequest_builder) Build 

func (b0 StreamKeyRangeRequest_builder) Build() *StreamKeyRangeRequest

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

func (x *StreamKeyRangeResponse) ClearBinlogTransaction()

func (*StreamKeyRangeResponse) GetBinlogTransaction 

func (x *StreamKeyRangeResponse) GetBinlogTransaction() *BinlogTransaction

func (*StreamKeyRangeResponse) HasBinlogTransaction 

func (x *StreamKeyRangeResponse) HasBinlogTransaction() bool

func (*StreamKeyRangeResponse) ProtoMessage 

func (*StreamKeyRangeResponse) ProtoMessage()

func (*StreamKeyRangeResponse) ProtoReflect 

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

func (*StreamKeyRangeResponse) Reset 

func (x *StreamKeyRangeResponse) Reset()

func (*StreamKeyRangeResponse) SetBinlogTransaction 

func (x *StreamKeyRangeResponse) SetBinlogTransaction(v *BinlogTransaction)

func (*StreamKeyRangeResponse) String 

func (x *StreamKeyRangeResponse) String() string

type StreamKeyRangeResponse_builder 

type StreamKeyRangeResponse_builder struct {
	BinlogTransaction *BinlogTransaction
	// contains filtered or unexported fields
}

func (StreamKeyRangeResponse_builder) Build 

func (b0 StreamKeyRangeResponse_builder) Build() *StreamKeyRangeResponse

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

func (x *StreamTablesRequest) ClearCharset()

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

func (x *StreamTablesRequest) HasCharset() bool

func (*StreamTablesRequest) ProtoMessage 

func (*StreamTablesRequest) ProtoMessage()

func (*StreamTablesRequest) ProtoReflect 

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

func (*StreamTablesRequest) Reset 

func (x *StreamTablesRequest) Reset()

func (*StreamTablesRequest) SetCharset 

func (x *StreamTablesRequest) SetCharset(v *Charset)

func (*StreamTablesRequest) SetPosition 

func (x *StreamTablesRequest) SetPosition(v string)

func (*StreamTablesRequest) SetTables 

func (x *StreamTablesRequest) SetTables(v []string)

func (*StreamTablesRequest) String 

func (x *StreamTablesRequest) String() string

type StreamTablesRequest_builder 

type StreamTablesRequest_builder struct {

	// where to start
	Position string
	// what to get
	Tables []string
	// default charset on the player side
	Charset *Charset
	// contains filtered or unexported fields
}

func (StreamTablesRequest_builder) Build 

func (b0 StreamTablesRequest_builder) Build() *StreamTablesRequest

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

func (x *StreamTablesResponse) ClearBinlogTransaction()

func (*StreamTablesResponse) GetBinlogTransaction 

func (x *StreamTablesResponse) GetBinlogTransaction() *BinlogTransaction

func (*StreamTablesResponse) HasBinlogTransaction 

func (x *StreamTablesResponse) HasBinlogTransaction() bool

func (*StreamTablesResponse) ProtoMessage 

func (*StreamTablesResponse) ProtoMessage()

func (*StreamTablesResponse) ProtoReflect 

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

func (*StreamTablesResponse) Reset 

func (x *StreamTablesResponse) Reset()

func (*StreamTablesResponse) SetBinlogTransaction 

func (x *StreamTablesResponse) SetBinlogTransaction(v *BinlogTransaction)

func (*StreamTablesResponse) String 

func (x *StreamTablesResponse) String() string

type StreamTablesResponse_builder 

type StreamTablesResponse_builder struct {
	BinlogTransaction *BinlogTransaction
	// contains filtered or unexported fields
}

func (StreamTablesResponse_builder) Build 

func (b0 StreamTablesResponse_builder) Build() *StreamTablesResponse

type TableLastPK 

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

func (*TableLastPK) ClearLastpk 

func (x *TableLastPK) ClearLastpk()

func (*TableLastPK) GetLastpk 

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

func (*TableLastPK) GetTableName 

func (x *TableLastPK) GetTableName() string

func (*TableLastPK) HasLastpk 

func (x *TableLastPK) HasLastpk() bool

func (*TableLastPK) ProtoMessage 

func (*TableLastPK) ProtoMessage()

func (*TableLastPK) ProtoReflect 

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

func (*TableLastPK) Reset 

func (x *TableLastPK) Reset()

func (*TableLastPK) SetLastpk 

func (x *TableLastPK) SetLastpk(v *v19.QueryResult)

func (*TableLastPK) SetTableName 

func (x *TableLastPK) SetTableName(v string)

func (*TableLastPK) String 

func (x *TableLastPK) String() string

type TableLastPK_builder 

type TableLastPK_builder struct {
	TableName string
	Lastpk    *v19.QueryResult
	// contains filtered or unexported fields
}

func (TableLastPK_builder) Build 

func (b0 TableLastPK_builder) Build() *TableLastPK

type VEvent 

type VEvent struct {
	Type VEventType `protobuf:"varint,1,opt,name=type,proto3,enum=vitess.binlogdata.v19.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"`
	// the source keyspace
	Keyspace string `protobuf:"bytes,22,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	// the source shard
	Shard string `protobuf:"bytes,23,opt,name=shard,proto3" json:"shard,omitempty"`
	// indicate that we are being throttled right now
	Throttled bool `protobuf:"varint,24,opt,name=throttled,proto3" json:"throttled,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) ClearFieldEvent 

func (x *VEvent) ClearFieldEvent()

func (*VEvent) ClearJournal 

func (x *VEvent) ClearJournal()

func (*VEvent) ClearLastPKEvent 

func (x *VEvent) ClearLastPKEvent()

func (*VEvent) ClearRowEvent 

func (x *VEvent) ClearRowEvent()

func (*VEvent) ClearVgtid 

func (x *VEvent) ClearVgtid()

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

func (x *VEvent) GetKeyspace() string

func (*VEvent) GetLastPKEvent 

func (x *VEvent) GetLastPKEvent() *LastPKEvent

func (*VEvent) GetRowEvent 

func (x *VEvent) GetRowEvent() *RowEvent

func (*VEvent) GetShard 

func (x *VEvent) GetShard() string

func (*VEvent) GetStatement 

func (x *VEvent) GetStatement() string

func (*VEvent) GetThrottled 

func (x *VEvent) GetThrottled() bool

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

func (x *VEvent) HasFieldEvent() bool

func (*VEvent) HasJournal 

func (x *VEvent) HasJournal() bool

func (*VEvent) HasLastPKEvent 

func (x *VEvent) HasLastPKEvent() bool

func (*VEvent) HasRowEvent 

func (x *VEvent) HasRowEvent() bool

func (*VEvent) HasVgtid 

func (x *VEvent) HasVgtid() bool

func (*VEvent) ProtoMessage 

func (*VEvent) ProtoMessage()

func (*VEvent) ProtoReflect 

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

func (*VEvent) Reset 

func (x *VEvent) Reset()

func (*VEvent) SetCurrentTime 

func (x *VEvent) SetCurrentTime(v int64)

func (*VEvent) SetDml 

func (x *VEvent) SetDml(v string)

func (*VEvent) SetFieldEvent 

func (x *VEvent) SetFieldEvent(v *FieldEvent)

func (*VEvent) SetGtid 

func (x *VEvent) SetGtid(v string)

func (*VEvent) SetJournal 

func (x *VEvent) SetJournal(v *Journal)

func (*VEvent) SetKeyspace 

func (x *VEvent) SetKeyspace(v string)

func (*VEvent) SetLastPKEvent 

func (x *VEvent) SetLastPKEvent(v *LastPKEvent)

func (*VEvent) SetRowEvent 

func (x *VEvent) SetRowEvent(v *RowEvent)

func (*VEvent) SetShard 

func (x *VEvent) SetShard(v string)

func (*VEvent) SetStatement 

func (x *VEvent) SetStatement(v string)

func (*VEvent) SetThrottled 

func (x *VEvent) SetThrottled(v bool)

func (*VEvent) SetTimestamp 

func (x *VEvent) SetTimestamp(v int64)

func (*VEvent) SetType 

func (x *VEvent) SetType(v VEventType)

func (*VEvent) SetVgtid 

func (x *VEvent) SetVgtid(v *VGtid)

func (*VEvent) String 

func (x *VEvent) String() string

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
	// COPY_COMPLETED is sent when VTGate's VStream copy operation is done.
	// If a client experiences some disruptions before receiving the event,
	// the client should restart the copy operation.
	VEventType_COPY_COMPLETED VEventType = 20
)

func (VEventType) Descriptor 

func (VEventType) Descriptor() protoreflect.EnumDescriptor

func (VEventType) Enum 

func (x VEventType) Enum() *VEventType

func (VEventType) Number 

func (x VEventType) Number() protoreflect.EnumNumber

func (VEventType) String 

func (x VEventType) String() string

func (VEventType) Type 

func (VEventType) Type() protoreflect.EnumType

type VEvent_builder 

type VEvent_builder struct {
	Type VEventType
	// Timestamp is the binlog timestamp in seconds.
	// The value should be ignored if 0.
	Timestamp int64
	// Gtid is set if the event type is GTID.
	Gtid string
	// Statement is set if the event type is DDL, DML or SAVEPOINT.
	Statement string
	// RowEvent is set if the event type is ROW.
	RowEvent *RowEvent
	// FieldEvent is set if the event type is FIELD.
	FieldEvent *FieldEvent
	// Vgtid is set if the event type is VGTID.
	// This event is only generated by VTGate's VStream function.
	Vgtid *VGtid
	// Journal is set if the event type is JOURNAL.
	Journal *Journal
	// Dml is set if the event type is INSERT, REPLACE, UPDATE or DELETE.
	Dml string
	// CurrentTime specifies the current time when the message was sent.
	// This can be used to compenssate for clock skew.
	CurrentTime int64
	// LastPK is the last PK for a table
	LastPKEvent *LastPKEvent
	// the source keyspace
	Keyspace string
	// the source shard
	Shard string
	// indicate that we are being throttled right now
	Throttled bool
	// contains filtered or unexported fields
}

func (VEvent_builder) Build 

func (b0 VEvent_builder) Build() *VEvent

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

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

func (*VGtid) ProtoMessage 

func (*VGtid) ProtoMessage()

func (*VGtid) ProtoReflect 

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

func (*VGtid) Reset 

func (x *VGtid) Reset()

func (*VGtid) SetShardGtids 

func (x *VGtid) SetShardGtids(v []*ShardGtid)

func (*VGtid) String 

func (x *VGtid) String() string

type VGtid_builder 

type VGtid_builder struct {
	ShardGtids []*ShardGtid
	// contains filtered or unexported fields
}

func (VGtid_builder) Build 

func (b0 VGtid_builder) Build() *VGtid

type VReplicationWorkflowState 

type VReplicationWorkflowState int32

VReplicationWorklfowState defines the valid states that a workflow can be in. 

const (
	VReplicationWorkflowState_Unknown VReplicationWorkflowState = 0
	VReplicationWorkflowState_Init    VReplicationWorkflowState = 1
	VReplicationWorkflowState_Stopped VReplicationWorkflowState = 2
	VReplicationWorkflowState_Copying VReplicationWorkflowState = 3
	VReplicationWorkflowState_Running VReplicationWorkflowState = 4
	VReplicationWorkflowState_Error   VReplicationWorkflowState = 5
	VReplicationWorkflowState_Lagging VReplicationWorkflowState = 6
)

func (VReplicationWorkflowState) Descriptor 

func (VReplicationWorkflowState) Descriptor() protoreflect.EnumDescriptor

func (VReplicationWorkflowState) Enum 

func (x VReplicationWorkflowState) Enum() *VReplicationWorkflowState

func (VReplicationWorkflowState) Number 

func (x VReplicationWorkflowState) Number() protoreflect.EnumNumber

func (VReplicationWorkflowState) String 

func (x VReplicationWorkflowState) String() string

func (VReplicationWorkflowState) Type 

func (VReplicationWorkflowState) Type() protoreflect.EnumType

type VReplicationWorkflowSubType 

type VReplicationWorkflowSubType int32

VReplicationWorkflowSubType define types of vreplication workflows. 

const (
	VReplicationWorkflowSubType_None       VReplicationWorkflowSubType = 0
	VReplicationWorkflowSubType_Partial    VReplicationWorkflowSubType = 1
	VReplicationWorkflowSubType_AtomicCopy VReplicationWorkflowSubType = 2
)

func (VReplicationWorkflowSubType) Descriptor 

func (VReplicationWorkflowSubType) Descriptor() protoreflect.EnumDescriptor

func (VReplicationWorkflowSubType) Enum 

func (x VReplicationWorkflowSubType) Enum() *VReplicationWorkflowSubType

func (VReplicationWorkflowSubType) Number 

func (x VReplicationWorkflowSubType) Number() protoreflect.EnumNumber

func (VReplicationWorkflowSubType) String 

func (x VReplicationWorkflowSubType) String() string

func (VReplicationWorkflowSubType) Type 

func (VReplicationWorkflowSubType) Type() protoreflect.EnumType

type VReplicationWorkflowType 

type VReplicationWorkflowType int32

VReplicationWorkflowType define types of vreplication workflows. 

const (
	VReplicationWorkflowType_Materialize       VReplicationWorkflowType = 0
	VReplicationWorkflowType_MoveTables        VReplicationWorkflowType = 1
	VReplicationWorkflowType_CreateLookupIndex VReplicationWorkflowType = 2
	VReplicationWorkflowType_Migrate           VReplicationWorkflowType = 3
	VReplicationWorkflowType_Reshard           VReplicationWorkflowType = 4
	VReplicationWorkflowType_OnlineDDL         VReplicationWorkflowType = 5
)

func (VReplicationWorkflowType) Descriptor 

func (VReplicationWorkflowType) Descriptor() protoreflect.EnumDescriptor

func (VReplicationWorkflowType) Enum 

func (x VReplicationWorkflowType) Enum() *VReplicationWorkflowType

func (VReplicationWorkflowType) Number 

func (x VReplicationWorkflowType) Number() protoreflect.EnumNumber

func (VReplicationWorkflowType) String 

func (x VReplicationWorkflowType) String() string

func (VReplicationWorkflowType) Type 

func (VReplicationWorkflowType) Type() protoreflect.EnumType

type VStreamRequest 

type VStreamRequest struct {
	EffectiveCallerId *v192.CallerID      `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
	ImmediateCallerId *v19.VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
	Target            *v19.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) ClearEffectiveCallerId 

func (x *VStreamRequest) ClearEffectiveCallerId()

func (*VStreamRequest) ClearFilter 

func (x *VStreamRequest) ClearFilter()

func (*VStreamRequest) ClearImmediateCallerId 

func (x *VStreamRequest) ClearImmediateCallerId()

func (*VStreamRequest) ClearTarget 

func (x *VStreamRequest) ClearTarget()

func (*VStreamRequest) GetEffectiveCallerId 

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

func (*VStreamRequest) GetFilter 

func (x *VStreamRequest) GetFilter() *Filter

func (*VStreamRequest) GetImmediateCallerId 

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

func (*VStreamRequest) GetPosition 

func (x *VStreamRequest) GetPosition() string

func (*VStreamRequest) GetTableLastPKs 

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

func (*VStreamRequest) GetTarget 

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

func (*VStreamRequest) HasEffectiveCallerId 

func (x *VStreamRequest) HasEffectiveCallerId() bool

func (*VStreamRequest) HasFilter 

func (x *VStreamRequest) HasFilter() bool

func (*VStreamRequest) HasImmediateCallerId 

func (x *VStreamRequest) HasImmediateCallerId() bool

func (*VStreamRequest) HasTarget 

func (x *VStreamRequest) HasTarget() bool

func (*VStreamRequest) ProtoMessage 

func (*VStreamRequest) ProtoMessage()

func (*VStreamRequest) ProtoReflect 

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

func (*VStreamRequest) Reset 

func (x *VStreamRequest) Reset()

func (*VStreamRequest) SetEffectiveCallerId 

func (x *VStreamRequest) SetEffectiveCallerId(v *v192.CallerID)

func (*VStreamRequest) SetFilter 

func (x *VStreamRequest) SetFilter(v *Filter)

func (*VStreamRequest) SetImmediateCallerId 

func (x *VStreamRequest) SetImmediateCallerId(v *v19.VTGateCallerID)

func (*VStreamRequest) SetPosition 

func (x *VStreamRequest) SetPosition(v string)

func (*VStreamRequest) SetTableLastPKs 

func (x *VStreamRequest) SetTableLastPKs(v []*TableLastPK)

func (*VStreamRequest) SetTarget 

func (x *VStreamRequest) SetTarget(v *v19.Target)

func (*VStreamRequest) String 

func (x *VStreamRequest) String() string

type VStreamRequest_builder 

type VStreamRequest_builder struct {
	EffectiveCallerId *v192.CallerID
	ImmediateCallerId *v19.VTGateCallerID
	Target            *v19.Target
	Position          string
	Filter            *Filter
	TableLastPKs      []*TableLastPK
	// contains filtered or unexported fields
}

func (VStreamRequest_builder) Build 

func (b0 VStreamRequest_builder) Build() *VStreamRequest

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

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

func (*VStreamResponse) ProtoMessage 

func (*VStreamResponse) ProtoMessage()

func (*VStreamResponse) ProtoReflect 

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

func (*VStreamResponse) Reset 

func (x *VStreamResponse) Reset()

func (*VStreamResponse) SetEvents 

func (x *VStreamResponse) SetEvents(v []*VEvent)

func (*VStreamResponse) String 

func (x *VStreamResponse) String() string

type VStreamResponse_builder 

type VStreamResponse_builder struct {
	Events []*VEvent
	// contains filtered or unexported fields
}

func (VStreamResponse_builder) Build 

func (b0 VStreamResponse_builder) Build() *VStreamResponse

type VStreamResultsRequest 

type VStreamResultsRequest struct {
	EffectiveCallerId *v192.CallerID      `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
	ImmediateCallerId *v19.VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
	Target            *v19.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) ClearEffectiveCallerId 

func (x *VStreamResultsRequest) ClearEffectiveCallerId()

func (*VStreamResultsRequest) ClearImmediateCallerId 

func (x *VStreamResultsRequest) ClearImmediateCallerId()

func (*VStreamResultsRequest) ClearTarget 

func (x *VStreamResultsRequest) ClearTarget()

func (*VStreamResultsRequest) GetEffectiveCallerId 

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

func (*VStreamResultsRequest) GetImmediateCallerId 

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

func (*VStreamResultsRequest) GetQuery 

func (x *VStreamResultsRequest) GetQuery() string

func (*VStreamResultsRequest) GetTarget 

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

func (*VStreamResultsRequest) HasEffectiveCallerId 

func (x *VStreamResultsRequest) HasEffectiveCallerId() bool

func (*VStreamResultsRequest) HasImmediateCallerId 

func (x *VStreamResultsRequest) HasImmediateCallerId() bool

func (*VStreamResultsRequest) HasTarget 

func (x *VStreamResultsRequest) HasTarget() bool

func (*VStreamResultsRequest) ProtoMessage 

func (*VStreamResultsRequest) ProtoMessage()

func (*VStreamResultsRequest) ProtoReflect 

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

func (*VStreamResultsRequest) Reset 

func (x *VStreamResultsRequest) Reset()

func (*VStreamResultsRequest) SetEffectiveCallerId 

func (x *VStreamResultsRequest) SetEffectiveCallerId(v *v192.CallerID)

func (*VStreamResultsRequest) SetImmediateCallerId 

func (x *VStreamResultsRequest) SetImmediateCallerId(v *v19.VTGateCallerID)

func (*VStreamResultsRequest) SetQuery 

func (x *VStreamResultsRequest) SetQuery(v string)

func (*VStreamResultsRequest) SetTarget 

func (x *VStreamResultsRequest) SetTarget(v *v19.Target)

func (*VStreamResultsRequest) String 

func (x *VStreamResultsRequest) String() string

type VStreamResultsRequest_builder 

type VStreamResultsRequest_builder struct {
	EffectiveCallerId *v192.CallerID
	ImmediateCallerId *v19.VTGateCallerID
	Target            *v19.Target
	Query             string
	// contains filtered or unexported fields
}

func (VStreamResultsRequest_builder) Build 

func (b0 VStreamResultsRequest_builder) Build() *VStreamResultsRequest

type VStreamResultsResponse 

type VStreamResultsResponse struct {
	Fields []*v19.Field `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	Gtid   string       `protobuf:"bytes,3,opt,name=gtid,proto3" json:"gtid,omitempty"`
	Rows   []*v19.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) GetFields 

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

func (*VStreamResultsResponse) GetGtid 

func (x *VStreamResultsResponse) GetGtid() string

func (*VStreamResultsResponse) GetRows 

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

func (*VStreamResultsResponse) ProtoMessage 

func (*VStreamResultsResponse) ProtoMessage()

func (*VStreamResultsResponse) ProtoReflect 

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

func (*VStreamResultsResponse) Reset 

func (x *VStreamResultsResponse) Reset()

func (*VStreamResultsResponse) SetFields 

func (x *VStreamResultsResponse) SetFields(v []*v19.Field)

func (*VStreamResultsResponse) SetGtid 

func (x *VStreamResultsResponse) SetGtid(v string)

func (*VStreamResultsResponse) SetRows 

func (x *VStreamResultsResponse) SetRows(v []*v19.Row)

func (*VStreamResultsResponse) String 

func (x *VStreamResultsResponse) String() string

type VStreamResultsResponse_builder 

type VStreamResultsResponse_builder struct {
	Fields []*v19.Field
	Gtid   string
	Rows   []*v19.Row
	// contains filtered or unexported fields
}

func (VStreamResultsResponse_builder) Build 

func (b0 VStreamResultsResponse_builder) Build() *VStreamResultsResponse

type VStreamRowsRequest 

type VStreamRowsRequest struct {
	EffectiveCallerId *v192.CallerID      `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
	ImmediateCallerId *v19.VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
	Target            *v19.Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	Query             string              `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
	Lastpk            *v19.QueryResult    `protobuf:"bytes,5,opt,name=lastpk,proto3" json:"lastpk,omitempty"`
	// contains filtered or unexported fields
}

VStreamRowsRequest is the payload for VStreamRows

func (*VStreamRowsRequest) ClearEffectiveCallerId 

func (x *VStreamRowsRequest) ClearEffectiveCallerId()

func (*VStreamRowsRequest) ClearImmediateCallerId 

func (x *VStreamRowsRequest) ClearImmediateCallerId()

func (*VStreamRowsRequest) ClearLastpk 

func (x *VStreamRowsRequest) ClearLastpk()

func (*VStreamRowsRequest) ClearTarget 

func (x *VStreamRowsRequest) ClearTarget()

func (*VStreamRowsRequest) GetEffectiveCallerId 

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

func (*VStreamRowsRequest) GetImmediateCallerId 

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

func (*VStreamRowsRequest) GetLastpk 

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

func (*VStreamRowsRequest) GetQuery 

func (x *VStreamRowsRequest) GetQuery() string

func (*VStreamRowsRequest) GetTarget 

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

func (*VStreamRowsRequest) HasEffectiveCallerId 

func (x *VStreamRowsRequest) HasEffectiveCallerId() bool

func (*VStreamRowsRequest) HasImmediateCallerId 

func (x *VStreamRowsRequest) HasImmediateCallerId() bool

func (*VStreamRowsRequest) HasLastpk 

func (x *VStreamRowsRequest) HasLastpk() bool

func (*VStreamRowsRequest) HasTarget 

func (x *VStreamRowsRequest) HasTarget() bool

func (*VStreamRowsRequest) ProtoMessage 

func (*VStreamRowsRequest) ProtoMessage()

func (*VStreamRowsRequest) ProtoReflect 

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

func (*VStreamRowsRequest) Reset 

func (x *VStreamRowsRequest) Reset()

func (*VStreamRowsRequest) SetEffectiveCallerId 

func (x *VStreamRowsRequest) SetEffectiveCallerId(v *v192.CallerID)

func (*VStreamRowsRequest) SetImmediateCallerId 

func (x *VStreamRowsRequest) SetImmediateCallerId(v *v19.VTGateCallerID)

func (*VStreamRowsRequest) SetLastpk 

func (x *VStreamRowsRequest) SetLastpk(v *v19.QueryResult)

func (*VStreamRowsRequest) SetQuery 

func (x *VStreamRowsRequest) SetQuery(v string)

func (*VStreamRowsRequest) SetTarget 

func (x *VStreamRowsRequest) SetTarget(v *v19.Target)

func (*VStreamRowsRequest) String 

func (x *VStreamRowsRequest) String() string

type VStreamRowsRequest_builder 

type VStreamRowsRequest_builder struct {
	EffectiveCallerId *v192.CallerID
	ImmediateCallerId *v19.VTGateCallerID
	Target            *v19.Target
	Query             string
	Lastpk            *v19.QueryResult
	// contains filtered or unexported fields
}

func (VStreamRowsRequest_builder) Build 

func (b0 VStreamRowsRequest_builder) Build() *VStreamRowsRequest

type VStreamRowsResponse 

type VStreamRowsResponse struct {
	Fields   []*v19.Field `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	Pkfields []*v19.Field `protobuf:"bytes,2,rep,name=pkfields,proto3" json:"pkfields,omitempty"`
	Gtid     string       `protobuf:"bytes,3,opt,name=gtid,proto3" json:"gtid,omitempty"`
	Rows     []*v19.Row   `protobuf:"bytes,4,rep,name=rows,proto3" json:"rows,omitempty"`
	Lastpk   *v19.Row     `protobuf:"bytes,5,opt,name=lastpk,proto3" json:"lastpk,omitempty"`
	// Throttled indicates that rowstreamer is being throttled right now
	Throttled bool `protobuf:"varint,6,opt,name=throttled,proto3" json:"throttled,omitempty"`
	// Heartbeat indicates that this is a heartbeat message
	Heartbeat bool `protobuf:"varint,7,opt,name=heartbeat,proto3" json:"heartbeat,omitempty"`
	// contains filtered or unexported fields
}

VStreamRowsResponse is the response from VStreamRows

func (*VStreamRowsResponse) ClearLastpk 

func (x *VStreamRowsResponse) ClearLastpk()

func (*VStreamRowsResponse) GetFields 

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

func (*VStreamRowsResponse) GetGtid 

func (x *VStreamRowsResponse) GetGtid() string

func (*VStreamRowsResponse) GetHeartbeat 

func (x *VStreamRowsResponse) GetHeartbeat() bool

func (*VStreamRowsResponse) GetLastpk 

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

func (*VStreamRowsResponse) GetPkfields 

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

func (*VStreamRowsResponse) GetRows 

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

func (*VStreamRowsResponse) GetThrottled 

func (x *VStreamRowsResponse) GetThrottled() bool

func (*VStreamRowsResponse) HasLastpk 

func (x *VStreamRowsResponse) HasLastpk() bool

func (*VStreamRowsResponse) ProtoMessage 

func (*VStreamRowsResponse) ProtoMessage()

func (*VStreamRowsResponse) ProtoReflect 

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

func (*VStreamRowsResponse) Reset 

func (x *VStreamRowsResponse) Reset()

func (*VStreamRowsResponse) SetFields 

func (x *VStreamRowsResponse) SetFields(v []*v19.Field)

func (*VStreamRowsResponse) SetGtid 

func (x *VStreamRowsResponse) SetGtid(v string)

func (*VStreamRowsResponse) SetHeartbeat 

func (x *VStreamRowsResponse) SetHeartbeat(v bool)

func (*VStreamRowsResponse) SetLastpk 

func (x *VStreamRowsResponse) SetLastpk(v *v19.Row)

func (*VStreamRowsResponse) SetPkfields 

func (x *VStreamRowsResponse) SetPkfields(v []*v19.Field)

func (*VStreamRowsResponse) SetRows 

func (x *VStreamRowsResponse) SetRows(v []*v19.Row)

func (*VStreamRowsResponse) SetThrottled 

func (x *VStreamRowsResponse) SetThrottled(v bool)

func (*VStreamRowsResponse) String 

func (x *VStreamRowsResponse) String() string

type VStreamRowsResponse_builder 

type VStreamRowsResponse_builder struct {
	Fields   []*v19.Field
	Pkfields []*v19.Field
	Gtid     string
	Rows     []*v19.Row
	Lastpk   *v19.Row
	// Throttled indicates that rowstreamer is being throttled right now
	Throttled bool
	// Heartbeat indicates that this is a heartbeat message
	Heartbeat bool
	// contains filtered or unexported fields
}

func (VStreamRowsResponse_builder) Build 

func (b0 VStreamRowsResponse_builder) Build() *VStreamRowsResponse

type VStreamTablesRequest 

type VStreamTablesRequest struct {
	EffectiveCallerId *v192.CallerID      `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
	ImmediateCallerId *v19.VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
	Target            *v19.Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

VStreamTablesRequest is the payload for VStreamTables

func (*VStreamTablesRequest) ClearEffectiveCallerId 

func (x *VStreamTablesRequest) ClearEffectiveCallerId()

func (*VStreamTablesRequest) ClearImmediateCallerId 

func (x *VStreamTablesRequest) ClearImmediateCallerId()

func (*VStreamTablesRequest) ClearTarget 

func (x *VStreamTablesRequest) ClearTarget()

func (*VStreamTablesRequest) GetEffectiveCallerId 

func (x *VStreamTablesRequest) GetEffectiveCallerId() *v192.CallerID

func (*VStreamTablesRequest) GetImmediateCallerId 

func (x *VStreamTablesRequest) GetImmediateCallerId() *v19.VTGateCallerID

func (*VStreamTablesRequest) GetTarget 

func (x *VStreamTablesRequest) GetTarget() *v19.Target

func (*VStreamTablesRequest) HasEffectiveCallerId 

func (x *VStreamTablesRequest) HasEffectiveCallerId() bool

func (*VStreamTablesRequest) HasImmediateCallerId 

func (x *VStreamTablesRequest) HasImmediateCallerId() bool

func (*VStreamTablesRequest) HasTarget 

func (x *VStreamTablesRequest) HasTarget() bool

func (*VStreamTablesRequest) ProtoMessage 

func (*VStreamTablesRequest) ProtoMessage()

func (*VStreamTablesRequest) ProtoReflect 

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

func (*VStreamTablesRequest) Reset 

func (x *VStreamTablesRequest) Reset()

func (*VStreamTablesRequest) SetEffectiveCallerId 

func (x *VStreamTablesRequest) SetEffectiveCallerId(v *v192.CallerID)

func (*VStreamTablesRequest) SetImmediateCallerId 

func (x *VStreamTablesRequest) SetImmediateCallerId(v *v19.VTGateCallerID)

func (*VStreamTablesRequest) SetTarget 

func (x *VStreamTablesRequest) SetTarget(v *v19.Target)

func (*VStreamTablesRequest) String 

func (x *VStreamTablesRequest) String() string

type VStreamTablesRequest_builder 

type VStreamTablesRequest_builder struct {
	EffectiveCallerId *v192.CallerID
	ImmediateCallerId *v19.VTGateCallerID
	Target            *v19.Target
	// contains filtered or unexported fields
}

func (VStreamTablesRequest_builder) Build 

func (b0 VStreamTablesRequest_builder) Build() *VStreamTablesRequest

type VStreamTablesResponse 

type VStreamTablesResponse struct {
	TableName string       `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	Fields    []*v19.Field `protobuf:"bytes,2,rep,name=fields,proto3" json:"fields,omitempty"`
	Pkfields  []*v19.Field `protobuf:"bytes,3,rep,name=pkfields,proto3" json:"pkfields,omitempty"`
	Gtid      string       `protobuf:"bytes,4,opt,name=gtid,proto3" json:"gtid,omitempty"`
	Rows      []*v19.Row   `protobuf:"bytes,5,rep,name=rows,proto3" json:"rows,omitempty"`
	Lastpk    *v19.Row     `protobuf:"bytes,6,opt,name=lastpk,proto3" json:"lastpk,omitempty"`
	// contains filtered or unexported fields
}

VStreamTablesResponse is the response from VStreamTables

func (*VStreamTablesResponse) ClearLastpk 

func (x *VStreamTablesResponse) ClearLastpk()

func (*VStreamTablesResponse) GetFields 

func (x *VStreamTablesResponse) GetFields() []*v19.Field

func (*VStreamTablesResponse) GetGtid 

func (x *VStreamTablesResponse) GetGtid() string

func (*VStreamTablesResponse) GetLastpk 

func (x *VStreamTablesResponse) GetLastpk() *v19.Row

func (*VStreamTablesResponse) GetPkfields 

func (x *VStreamTablesResponse) GetPkfields() []*v19.Field

func (*VStreamTablesResponse) GetRows 

func (x *VStreamTablesResponse) GetRows() []*v19.Row

func (*VStreamTablesResponse) GetTableName 

func (x *VStreamTablesResponse) GetTableName() string

func (*VStreamTablesResponse) HasLastpk 

func (x *VStreamTablesResponse) HasLastpk() bool

func (*VStreamTablesResponse) ProtoMessage 

func (*VStreamTablesResponse) ProtoMessage()

func (*VStreamTablesResponse) ProtoReflect 

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

func (*VStreamTablesResponse) Reset 

func (x *VStreamTablesResponse) Reset()

func (*VStreamTablesResponse) SetFields 

func (x *VStreamTablesResponse) SetFields(v []*v19.Field)

func (*VStreamTablesResponse) SetGtid 

func (x *VStreamTablesResponse) SetGtid(v string)

func (*VStreamTablesResponse) SetLastpk 

func (x *VStreamTablesResponse) SetLastpk(v *v19.Row)

func (*VStreamTablesResponse) SetPkfields 

func (x *VStreamTablesResponse) SetPkfields(v []*v19.Field)

func (*VStreamTablesResponse) SetRows 

func (x *VStreamTablesResponse) SetRows(v []*v19.Row)

func (*VStreamTablesResponse) SetTableName 

func (x *VStreamTablesResponse) SetTableName(v string)

func (*VStreamTablesResponse) String 

func (x *VStreamTablesResponse) String() string

type VStreamTablesResponse_builder 

type VStreamTablesResponse_builder struct {
	TableName string
	Fields    []*v19.Field
	Pkfields  []*v19.Field
	Gtid      string
	Rows      []*v19.Row
	Lastpk    *v19.Row
	// contains filtered or unexported fields
}

func (VStreamTablesResponse_builder) Build 

func (b0 VStreamTablesResponse_builder) Build() *VStreamTablesResponse

Source Files

  • binlogdata.pb.go

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.