Versions in this module Expand all Collapse all v0 v0.15.10 Jul 31, 2024 v0.15.9 Jul 31, 2024 v0.15.8 Jul 31, 2024 Changes in this version + var BinlogTransaction_Statement_Category_name = map[int32]string + var BinlogTransaction_Statement_Category_value = map[string]int32 + var ErrIntOverflow = fmt.Errorf("proto: integer overflow") + var ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group") + var File_binlogdata_proto protoreflect.FileDescriptor + var Filter_FieldEventMode_name = map[int32]string + var Filter_FieldEventMode_value = map[string]int32 + var MigrationType_name = map[int32]string + var MigrationType_value = map[string]int32 + var OnDDLAction_name = map[int32]string + var OnDDLAction_value = map[string]int32 + var VEventType_name = map[int32]string + var VEventType_value = map[string]int32 + var VReplicationWorkflowState_name = map[int32]string + var VReplicationWorkflowState_value = map[string]int32 + var VReplicationWorkflowSubType_name = map[int32]string + var VReplicationWorkflowSubType_value = map[string]int32 + var VReplicationWorkflowType_name = map[int32]string + var VReplicationWorkflowType_value = map[string]int32 + type BinlogSource struct + ExternalCluster string + ExternalMysql string + Filter *Filter + KeyRange *topodata.KeyRange + Keyspace string + OnDdl OnDDLAction + Shard string + SourceTimeZone string + StopAfterCopy bool + Tables []string + TabletType topodata.TabletType + TargetTimeZone string + func (*BinlogSource) Descriptor() ([]byte, []int) + func (*BinlogSource) ProtoMessage() + func (m *BinlogSource) CloneMessageVT() proto.Message + func (m *BinlogSource) CloneVT() *BinlogSource + func (m *BinlogSource) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *BinlogSource) MarshalToVT(dAtA []byte) (int, error) + func (m *BinlogSource) MarshalVT() (dAtA []byte, err error) + func (m *BinlogSource) SizeVT() (n int) + func (m *BinlogSource) UnmarshalVT(dAtA []byte) error + func (x *BinlogSource) GetExternalCluster() string + func (x *BinlogSource) GetExternalMysql() string + func (x *BinlogSource) GetFilter() *Filter + func (x *BinlogSource) GetKeyRange() *topodata.KeyRange + func (x *BinlogSource) GetKeyspace() string + func (x *BinlogSource) GetOnDdl() OnDDLAction + func (x *BinlogSource) GetShard() string + func (x *BinlogSource) GetSourceTimeZone() string + func (x *BinlogSource) GetStopAfterCopy() bool + func (x *BinlogSource) GetTables() []string + func (x *BinlogSource) GetTabletType() topodata.TabletType + func (x *BinlogSource) GetTargetTimeZone() string + func (x *BinlogSource) ProtoReflect() protoreflect.Message + func (x *BinlogSource) Reset() + func (x *BinlogSource) String() string + type BinlogTransaction struct + EventToken *query.EventToken + Statements []*BinlogTransaction_Statement + func (*BinlogTransaction) Descriptor() ([]byte, []int) + func (*BinlogTransaction) ProtoMessage() + func (m *BinlogTransaction) CloneMessageVT() proto.Message + func (m *BinlogTransaction) CloneVT() *BinlogTransaction + func (m *BinlogTransaction) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *BinlogTransaction) MarshalToVT(dAtA []byte) (int, error) + func (m *BinlogTransaction) MarshalVT() (dAtA []byte, err error) + func (m *BinlogTransaction) SizeVT() (n int) + func (m *BinlogTransaction) UnmarshalVT(dAtA []byte) error + func (x *BinlogTransaction) GetEventToken() *query.EventToken + func (x *BinlogTransaction) GetStatements() []*BinlogTransaction_Statement + func (x *BinlogTransaction) ProtoReflect() protoreflect.Message + func (x *BinlogTransaction) Reset() + func (x *BinlogTransaction) String() string + type BinlogTransaction_Statement struct + Category BinlogTransaction_Statement_Category + Charset *Charset + Sql []byte + func (*BinlogTransaction_Statement) Descriptor() ([]byte, []int) + func (*BinlogTransaction_Statement) ProtoMessage() + func (m *BinlogTransaction_Statement) CloneMessageVT() proto.Message + func (m *BinlogTransaction_Statement) CloneVT() *BinlogTransaction_Statement + func (m *BinlogTransaction_Statement) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *BinlogTransaction_Statement) MarshalToVT(dAtA []byte) (int, error) + func (m *BinlogTransaction_Statement) MarshalVT() (dAtA []byte, err error) + func (m *BinlogTransaction_Statement) SizeVT() (n int) + func (m *BinlogTransaction_Statement) UnmarshalVT(dAtA []byte) error + func (x *BinlogTransaction_Statement) GetCategory() BinlogTransaction_Statement_Category + func (x *BinlogTransaction_Statement) GetCharset() *Charset + func (x *BinlogTransaction_Statement) GetSql() []byte + func (x *BinlogTransaction_Statement) ProtoReflect() protoreflect.Message + func (x *BinlogTransaction_Statement) Reset() + func (x *BinlogTransaction_Statement) String() string + type BinlogTransaction_Statement_Category int32 + const BinlogTransaction_Statement_BL_BEGIN + const BinlogTransaction_Statement_BL_COMMIT + const BinlogTransaction_Statement_BL_DDL + const BinlogTransaction_Statement_BL_DELETE + const BinlogTransaction_Statement_BL_DML_DEPRECATED + const BinlogTransaction_Statement_BL_INSERT + const BinlogTransaction_Statement_BL_ROLLBACK + const BinlogTransaction_Statement_BL_SET + const BinlogTransaction_Statement_BL_UNRECOGNIZED + const BinlogTransaction_Statement_BL_UPDATE + func (BinlogTransaction_Statement_Category) Descriptor() protoreflect.EnumDescriptor + func (BinlogTransaction_Statement_Category) EnumDescriptor() ([]byte, []int) + func (BinlogTransaction_Statement_Category) Type() protoreflect.EnumType + func (x BinlogTransaction_Statement_Category) Enum() *BinlogTransaction_Statement_Category + func (x BinlogTransaction_Statement_Category) Number() protoreflect.EnumNumber + func (x BinlogTransaction_Statement_Category) String() string + type Charset struct + Client int32 + Conn int32 + Server int32 + func (*Charset) Descriptor() ([]byte, []int) + func (*Charset) ProtoMessage() + func (m *Charset) CloneMessageVT() proto.Message + func (m *Charset) CloneVT() *Charset + func (m *Charset) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Charset) MarshalToVT(dAtA []byte) (int, error) + func (m *Charset) MarshalVT() (dAtA []byte, err error) + func (m *Charset) SizeVT() (n int) + func (m *Charset) UnmarshalVT(dAtA []byte) error + func (x *Charset) GetClient() int32 + func (x *Charset) GetConn() int32 + func (x *Charset) GetServer() int32 + func (x *Charset) ProtoReflect() protoreflect.Message + func (x *Charset) Reset() + func (x *Charset) String() string + type CharsetConversion struct + FromCharset string + ToCharset string + func (*CharsetConversion) Descriptor() ([]byte, []int) + func (*CharsetConversion) ProtoMessage() + func (m *CharsetConversion) CloneMessageVT() proto.Message + func (m *CharsetConversion) CloneVT() *CharsetConversion + func (m *CharsetConversion) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *CharsetConversion) MarshalToVT(dAtA []byte) (int, error) + func (m *CharsetConversion) MarshalVT() (dAtA []byte, err error) + func (m *CharsetConversion) SizeVT() (n int) + func (m *CharsetConversion) UnmarshalVT(dAtA []byte) error + func (x *CharsetConversion) GetFromCharset() string + func (x *CharsetConversion) GetToCharset() string + func (x *CharsetConversion) ProtoReflect() protoreflect.Message + func (x *CharsetConversion) Reset() + func (x *CharsetConversion) String() string + type FieldEvent struct + EnumSetStringValues bool + Fields []*query.Field + Keyspace string + Shard string + TableName string + func (*FieldEvent) Descriptor() ([]byte, []int) + func (*FieldEvent) ProtoMessage() + func (m *FieldEvent) CloneMessageVT() proto.Message + func (m *FieldEvent) CloneVT() *FieldEvent + func (m *FieldEvent) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *FieldEvent) MarshalToVT(dAtA []byte) (int, error) + func (m *FieldEvent) MarshalVT() (dAtA []byte, err error) + func (m *FieldEvent) SizeVT() (n int) + func (m *FieldEvent) UnmarshalVT(dAtA []byte) error + func (x *FieldEvent) GetEnumSetStringValues() bool + func (x *FieldEvent) GetFields() []*query.Field + func (x *FieldEvent) GetKeyspace() string + func (x *FieldEvent) GetShard() string + func (x *FieldEvent) GetTableName() string + func (x *FieldEvent) ProtoReflect() protoreflect.Message + func (x *FieldEvent) Reset() + func (x *FieldEvent) String() string + type Filter struct + FieldEventMode Filter_FieldEventMode + Rules []*Rule + WorkflowName string + WorkflowType int64 + func (*Filter) Descriptor() ([]byte, []int) + func (*Filter) ProtoMessage() + func (m *Filter) CloneMessageVT() proto.Message + func (m *Filter) CloneVT() *Filter + func (m *Filter) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Filter) MarshalToVT(dAtA []byte) (int, error) + func (m *Filter) MarshalVT() (dAtA []byte, err error) + func (m *Filter) SizeVT() (n int) + func (m *Filter) UnmarshalVT(dAtA []byte) error + func (x *Filter) GetFieldEventMode() Filter_FieldEventMode + func (x *Filter) GetRules() []*Rule + func (x *Filter) GetWorkflowName() string + func (x *Filter) GetWorkflowType() int64 + func (x *Filter) ProtoReflect() protoreflect.Message + func (x *Filter) Reset() + func (x *Filter) String() string + type Filter_FieldEventMode int32 + const Filter_BEST_EFFORT + const Filter_ERR_ON_MISMATCH + func (Filter_FieldEventMode) Descriptor() protoreflect.EnumDescriptor + func (Filter_FieldEventMode) EnumDescriptor() ([]byte, []int) + func (Filter_FieldEventMode) Type() protoreflect.EnumType + func (x Filter_FieldEventMode) Enum() *Filter_FieldEventMode + func (x Filter_FieldEventMode) Number() protoreflect.EnumNumber + func (x Filter_FieldEventMode) String() string + type Journal struct + Id int64 + LocalPosition string + MigrationType MigrationType + Participants []*KeyspaceShard + ShardGtids []*ShardGtid + SourceWorkflows []string + Tables []string + func (*Journal) Descriptor() ([]byte, []int) + func (*Journal) ProtoMessage() + func (m *Journal) CloneMessageVT() proto.Message + func (m *Journal) CloneVT() *Journal + func (m *Journal) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Journal) MarshalToVT(dAtA []byte) (int, error) + func (m *Journal) MarshalVT() (dAtA []byte, err error) + func (m *Journal) SizeVT() (n int) + func (m *Journal) UnmarshalVT(dAtA []byte) error + func (x *Journal) GetId() int64 + func (x *Journal) GetLocalPosition() string + func (x *Journal) GetMigrationType() MigrationType + func (x *Journal) GetParticipants() []*KeyspaceShard + func (x *Journal) GetShardGtids() []*ShardGtid + func (x *Journal) GetSourceWorkflows() []string + func (x *Journal) GetTables() []string + func (x *Journal) ProtoReflect() protoreflect.Message + func (x *Journal) Reset() + func (x *Journal) String() string + type KeyspaceShard struct + Keyspace string + Shard string + func (*KeyspaceShard) Descriptor() ([]byte, []int) + func (*KeyspaceShard) ProtoMessage() + func (m *KeyspaceShard) CloneMessageVT() proto.Message + func (m *KeyspaceShard) CloneVT() *KeyspaceShard + func (m *KeyspaceShard) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *KeyspaceShard) MarshalToVT(dAtA []byte) (int, error) + func (m *KeyspaceShard) MarshalVT() (dAtA []byte, err error) + func (m *KeyspaceShard) SizeVT() (n int) + func (m *KeyspaceShard) UnmarshalVT(dAtA []byte) error + func (x *KeyspaceShard) GetKeyspace() string + func (x *KeyspaceShard) GetShard() string + func (x *KeyspaceShard) ProtoReflect() protoreflect.Message + func (x *KeyspaceShard) Reset() + func (x *KeyspaceShard) String() string + type LastPKEvent struct + Completed bool + TableLastPK *TableLastPK + func (*LastPKEvent) Descriptor() ([]byte, []int) + func (*LastPKEvent) ProtoMessage() + func (m *LastPKEvent) CloneMessageVT() proto.Message + func (m *LastPKEvent) CloneVT() *LastPKEvent + func (m *LastPKEvent) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *LastPKEvent) MarshalToVT(dAtA []byte) (int, error) + func (m *LastPKEvent) MarshalVT() (dAtA []byte, err error) + func (m *LastPKEvent) SizeVT() (n int) + func (m *LastPKEvent) UnmarshalVT(dAtA []byte) error + func (x *LastPKEvent) GetCompleted() bool + func (x *LastPKEvent) GetTableLastPK() *TableLastPK + func (x *LastPKEvent) ProtoReflect() protoreflect.Message + func (x *LastPKEvent) Reset() + func (x *LastPKEvent) String() string + type MigrationType int32 + const MigrationType_SHARDS + const MigrationType_TABLES + func (MigrationType) Descriptor() protoreflect.EnumDescriptor + func (MigrationType) EnumDescriptor() ([]byte, []int) + func (MigrationType) Type() protoreflect.EnumType + func (x MigrationType) Enum() *MigrationType + func (x MigrationType) Number() protoreflect.EnumNumber + func (x MigrationType) String() string + type MinimalSchema struct + Tables []*MinimalTable + func (*MinimalSchema) Descriptor() ([]byte, []int) + func (*MinimalSchema) ProtoMessage() + func (m *MinimalSchema) CloneMessageVT() proto.Message + func (m *MinimalSchema) CloneVT() *MinimalSchema + func (m *MinimalSchema) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *MinimalSchema) MarshalToVT(dAtA []byte) (int, error) + func (m *MinimalSchema) MarshalVT() (dAtA []byte, err error) + func (m *MinimalSchema) SizeVT() (n int) + func (m *MinimalSchema) UnmarshalVT(dAtA []byte) error + func (x *MinimalSchema) GetTables() []*MinimalTable + func (x *MinimalSchema) ProtoReflect() protoreflect.Message + func (x *MinimalSchema) Reset() + func (x *MinimalSchema) String() string + type MinimalTable struct + Fields []*query.Field + Name string + PKColumns []int64 + PKIndexName string + func (*MinimalTable) Descriptor() ([]byte, []int) + func (*MinimalTable) ProtoMessage() + func (m *MinimalTable) CloneMessageVT() proto.Message + func (m *MinimalTable) CloneVT() *MinimalTable + func (m *MinimalTable) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *MinimalTable) MarshalToVT(dAtA []byte) (int, error) + func (m *MinimalTable) MarshalVT() (dAtA []byte, err error) + func (m *MinimalTable) SizeVT() (n int) + func (m *MinimalTable) UnmarshalVT(dAtA []byte) error + func (x *MinimalTable) GetFields() []*query.Field + func (x *MinimalTable) GetName() string + func (x *MinimalTable) GetPKColumns() []int64 + func (x *MinimalTable) GetPKIndexName() string + func (x *MinimalTable) ProtoReflect() protoreflect.Message + func (x *MinimalTable) Reset() + func (x *MinimalTable) String() string + type OnDDLAction int32 + const OnDDLAction_EXEC + const OnDDLAction_EXEC_IGNORE + const OnDDLAction_IGNORE + const OnDDLAction_STOP + func (OnDDLAction) Descriptor() protoreflect.EnumDescriptor + func (OnDDLAction) EnumDescriptor() ([]byte, []int) + func (OnDDLAction) Type() protoreflect.EnumType + func (x OnDDLAction) Enum() *OnDDLAction + func (x OnDDLAction) Number() protoreflect.EnumNumber + func (x OnDDLAction) String() string + type RowChange struct + After *query.Row + Before *query.Row + DataColumns *RowChange_Bitmap + func (*RowChange) Descriptor() ([]byte, []int) + func (*RowChange) ProtoMessage() + func (m *RowChange) CloneMessageVT() proto.Message + func (m *RowChange) CloneVT() *RowChange + func (m *RowChange) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *RowChange) MarshalToVT(dAtA []byte) (int, error) + func (m *RowChange) MarshalVT() (dAtA []byte, err error) + func (m *RowChange) SizeVT() (n int) + func (m *RowChange) UnmarshalVT(dAtA []byte) error + func (x *RowChange) GetAfter() *query.Row + func (x *RowChange) GetBefore() *query.Row + func (x *RowChange) GetDataColumns() *RowChange_Bitmap + func (x *RowChange) ProtoReflect() protoreflect.Message + func (x *RowChange) Reset() + func (x *RowChange) String() string + type RowChange_Bitmap struct + Cols []byte + Count int64 + func (*RowChange_Bitmap) Descriptor() ([]byte, []int) + func (*RowChange_Bitmap) ProtoMessage() + func (m *RowChange_Bitmap) CloneMessageVT() proto.Message + func (m *RowChange_Bitmap) CloneVT() *RowChange_Bitmap + func (m *RowChange_Bitmap) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *RowChange_Bitmap) MarshalToVT(dAtA []byte) (int, error) + func (m *RowChange_Bitmap) MarshalVT() (dAtA []byte, err error) + func (m *RowChange_Bitmap) SizeVT() (n int) + func (m *RowChange_Bitmap) UnmarshalVT(dAtA []byte) error + func (x *RowChange_Bitmap) GetCols() []byte + func (x *RowChange_Bitmap) GetCount() int64 + func (x *RowChange_Bitmap) ProtoReflect() protoreflect.Message + func (x *RowChange_Bitmap) Reset() + func (x *RowChange_Bitmap) String() string + type RowEvent struct + Flags uint32 + Keyspace string + RowChanges []*RowChange + Shard string + TableName string + func (*RowEvent) Descriptor() ([]byte, []int) + func (*RowEvent) ProtoMessage() + func (m *RowEvent) CloneMessageVT() proto.Message + func (m *RowEvent) CloneVT() *RowEvent + func (m *RowEvent) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *RowEvent) MarshalToVT(dAtA []byte) (int, error) + func (m *RowEvent) MarshalVT() (dAtA []byte, err error) + func (m *RowEvent) SizeVT() (n int) + func (m *RowEvent) UnmarshalVT(dAtA []byte) error + func (x *RowEvent) GetFlags() uint32 + func (x *RowEvent) GetKeyspace() string + func (x *RowEvent) GetRowChanges() []*RowChange + func (x *RowEvent) GetShard() string + func (x *RowEvent) GetTableName() string + func (x *RowEvent) ProtoReflect() protoreflect.Message + func (x *RowEvent) Reset() + func (x *RowEvent) String() string + type Rule struct + ConvertCharset map[string]*CharsetConversion + ConvertEnumToText map[string]string + ConvertIntToEnum map[string]bool + Filter string + ForceUniqueKey string + Match string + SourceUniqueKeyColumns string + SourceUniqueKeyTargetColumns string + TargetUniqueKeyColumns string + func (*Rule) Descriptor() ([]byte, []int) + func (*Rule) ProtoMessage() + func (m *Rule) CloneMessageVT() proto.Message + func (m *Rule) CloneVT() *Rule + func (m *Rule) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Rule) MarshalToVT(dAtA []byte) (int, error) + func (m *Rule) MarshalVT() (dAtA []byte, err error) + func (m *Rule) SizeVT() (n int) + func (m *Rule) UnmarshalVT(dAtA []byte) error + func (x *Rule) GetConvertCharset() map[string]*CharsetConversion + func (x *Rule) GetConvertEnumToText() map[string]string + func (x *Rule) GetConvertIntToEnum() map[string]bool + func (x *Rule) GetFilter() string + func (x *Rule) GetForceUniqueKey() string + func (x *Rule) GetMatch() string + func (x *Rule) GetSourceUniqueKeyColumns() string + func (x *Rule) GetSourceUniqueKeyTargetColumns() string + func (x *Rule) GetTargetUniqueKeyColumns() string + func (x *Rule) ProtoReflect() protoreflect.Message + func (x *Rule) Reset() + func (x *Rule) String() string + type ShardGtid struct + Gtid string + Keyspace string + Shard string + TablePKs []*TableLastPK + func (*ShardGtid) Descriptor() ([]byte, []int) + func (*ShardGtid) ProtoMessage() + func (m *ShardGtid) CloneMessageVT() proto.Message + func (m *ShardGtid) CloneVT() *ShardGtid + func (m *ShardGtid) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *ShardGtid) MarshalToVT(dAtA []byte) (int, error) + func (m *ShardGtid) MarshalVT() (dAtA []byte, err error) + func (m *ShardGtid) SizeVT() (n int) + func (m *ShardGtid) UnmarshalVT(dAtA []byte) error + func (x *ShardGtid) GetGtid() string + func (x *ShardGtid) GetKeyspace() string + func (x *ShardGtid) GetShard() string + func (x *ShardGtid) GetTablePKs() []*TableLastPK + func (x *ShardGtid) ProtoReflect() protoreflect.Message + func (x *ShardGtid) Reset() + func (x *ShardGtid) String() string + type StreamKeyRangeRequest struct + Charset *Charset + KeyRange *topodata.KeyRange + Position string + func (*StreamKeyRangeRequest) Descriptor() ([]byte, []int) + func (*StreamKeyRangeRequest) ProtoMessage() + func (m *StreamKeyRangeRequest) CloneMessageVT() proto.Message + func (m *StreamKeyRangeRequest) CloneVT() *StreamKeyRangeRequest + func (m *StreamKeyRangeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *StreamKeyRangeRequest) MarshalToVT(dAtA []byte) (int, error) + func (m *StreamKeyRangeRequest) MarshalVT() (dAtA []byte, err error) + func (m *StreamKeyRangeRequest) SizeVT() (n int) + func (m *StreamKeyRangeRequest) UnmarshalVT(dAtA []byte) error + func (x *StreamKeyRangeRequest) GetCharset() *Charset + func (x *StreamKeyRangeRequest) GetKeyRange() *topodata.KeyRange + func (x *StreamKeyRangeRequest) GetPosition() string + func (x *StreamKeyRangeRequest) ProtoReflect() protoreflect.Message + func (x *StreamKeyRangeRequest) Reset() + func (x *StreamKeyRangeRequest) String() string + type StreamKeyRangeResponse struct + BinlogTransaction *BinlogTransaction + func (*StreamKeyRangeResponse) Descriptor() ([]byte, []int) + func (*StreamKeyRangeResponse) ProtoMessage() + func (m *StreamKeyRangeResponse) CloneMessageVT() proto.Message + func (m *StreamKeyRangeResponse) CloneVT() *StreamKeyRangeResponse + func (m *StreamKeyRangeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *StreamKeyRangeResponse) MarshalToVT(dAtA []byte) (int, error) + func (m *StreamKeyRangeResponse) MarshalVT() (dAtA []byte, err error) + func (m *StreamKeyRangeResponse) SizeVT() (n int) + func (m *StreamKeyRangeResponse) UnmarshalVT(dAtA []byte) error + func (x *StreamKeyRangeResponse) GetBinlogTransaction() *BinlogTransaction + func (x *StreamKeyRangeResponse) ProtoReflect() protoreflect.Message + func (x *StreamKeyRangeResponse) Reset() + func (x *StreamKeyRangeResponse) String() string + type StreamTablesRequest struct + Charset *Charset + Position string + Tables []string + func (*StreamTablesRequest) Descriptor() ([]byte, []int) + func (*StreamTablesRequest) ProtoMessage() + func (m *StreamTablesRequest) CloneMessageVT() proto.Message + func (m *StreamTablesRequest) CloneVT() *StreamTablesRequest + func (m *StreamTablesRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *StreamTablesRequest) MarshalToVT(dAtA []byte) (int, error) + func (m *StreamTablesRequest) MarshalVT() (dAtA []byte, err error) + func (m *StreamTablesRequest) SizeVT() (n int) + func (m *StreamTablesRequest) UnmarshalVT(dAtA []byte) error + func (x *StreamTablesRequest) GetCharset() *Charset + func (x *StreamTablesRequest) GetPosition() string + func (x *StreamTablesRequest) GetTables() []string + func (x *StreamTablesRequest) ProtoReflect() protoreflect.Message + func (x *StreamTablesRequest) Reset() + func (x *StreamTablesRequest) String() string + type StreamTablesResponse struct + BinlogTransaction *BinlogTransaction + func (*StreamTablesResponse) Descriptor() ([]byte, []int) + func (*StreamTablesResponse) ProtoMessage() + func (m *StreamTablesResponse) CloneMessageVT() proto.Message + func (m *StreamTablesResponse) CloneVT() *StreamTablesResponse + func (m *StreamTablesResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *StreamTablesResponse) MarshalToVT(dAtA []byte) (int, error) + func (m *StreamTablesResponse) MarshalVT() (dAtA []byte, err error) + func (m *StreamTablesResponse) SizeVT() (n int) + func (m *StreamTablesResponse) UnmarshalVT(dAtA []byte) error + func (x *StreamTablesResponse) GetBinlogTransaction() *BinlogTransaction + func (x *StreamTablesResponse) ProtoReflect() protoreflect.Message + func (x *StreamTablesResponse) Reset() + func (x *StreamTablesResponse) String() string + type TableLastPK struct + Lastpk *query.QueryResult + TableName string + func (*TableLastPK) Descriptor() ([]byte, []int) + func (*TableLastPK) ProtoMessage() + func (m *TableLastPK) CloneMessageVT() proto.Message + func (m *TableLastPK) CloneVT() *TableLastPK + func (m *TableLastPK) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *TableLastPK) MarshalToVT(dAtA []byte) (int, error) + func (m *TableLastPK) MarshalVT() (dAtA []byte, err error) + func (m *TableLastPK) SizeVT() (n int) + func (m *TableLastPK) UnmarshalVT(dAtA []byte) error + func (x *TableLastPK) GetLastpk() *query.QueryResult + func (x *TableLastPK) GetTableName() string + func (x *TableLastPK) ProtoReflect() protoreflect.Message + func (x *TableLastPK) Reset() + func (x *TableLastPK) String() string + type VEvent struct + CurrentTime int64 + Dml string + FieldEvent *FieldEvent + Gtid string + Journal *Journal + Keyspace string + LastPKEvent *LastPKEvent + RowEvent *RowEvent + Shard string + Statement string + Throttled bool + Timestamp int64 + Type VEventType + Vgtid *VGtid + func (*VEvent) Descriptor() ([]byte, []int) + func (*VEvent) ProtoMessage() + func (m *VEvent) CloneMessageVT() proto.Message + func (m *VEvent) CloneVT() *VEvent + func (m *VEvent) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *VEvent) MarshalToVT(dAtA []byte) (int, error) + func (m *VEvent) MarshalVT() (dAtA []byte, err error) + func (m *VEvent) SizeVT() (n int) + func (m *VEvent) UnmarshalVT(dAtA []byte) error + func (x *VEvent) GetCurrentTime() int64 + func (x *VEvent) GetDml() string + func (x *VEvent) GetFieldEvent() *FieldEvent + func (x *VEvent) GetGtid() string + func (x *VEvent) GetJournal() *Journal + func (x *VEvent) GetKeyspace() string + func (x *VEvent) GetLastPKEvent() *LastPKEvent + func (x *VEvent) GetRowEvent() *RowEvent + func (x *VEvent) GetShard() string + func (x *VEvent) GetStatement() string + func (x *VEvent) GetThrottled() bool + func (x *VEvent) GetTimestamp() int64 + func (x *VEvent) GetType() VEventType + func (x *VEvent) GetVgtid() *VGtid + func (x *VEvent) ProtoReflect() protoreflect.Message + func (x *VEvent) Reset() + func (x *VEvent) String() string + type VEventType int32 + const VEventType_BEGIN + const VEventType_COMMIT + const VEventType_COPY_COMPLETED + const VEventType_DDL + const VEventType_DELETE + const VEventType_FIELD + const VEventType_GTID + const VEventType_HEARTBEAT + const VEventType_INSERT + const VEventType_JOURNAL + const VEventType_LASTPK + const VEventType_OTHER + const VEventType_REPLACE + const VEventType_ROLLBACK + const VEventType_ROW + const VEventType_SAVEPOINT + const VEventType_SET + const VEventType_UNKNOWN + const VEventType_UPDATE + const VEventType_VERSION + const VEventType_VGTID + func (VEventType) Descriptor() protoreflect.EnumDescriptor + func (VEventType) EnumDescriptor() ([]byte, []int) + func (VEventType) Type() protoreflect.EnumType + func (x VEventType) Enum() *VEventType + func (x VEventType) Number() protoreflect.EnumNumber + func (x VEventType) String() string + type VGtid struct + ShardGtids []*ShardGtid + func (*VGtid) Descriptor() ([]byte, []int) + func (*VGtid) ProtoMessage() + func (m *VGtid) CloneMessageVT() proto.Message + func (m *VGtid) CloneVT() *VGtid + func (m *VGtid) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *VGtid) MarshalToVT(dAtA []byte) (int, error) + func (m *VGtid) MarshalVT() (dAtA []byte, err error) + func (m *VGtid) SizeVT() (n int) + func (m *VGtid) UnmarshalVT(dAtA []byte) error + func (x *VGtid) GetShardGtids() []*ShardGtid + func (x *VGtid) ProtoReflect() protoreflect.Message + func (x *VGtid) Reset() + func (x *VGtid) String() string + type VReplicationWorkflowState int32 + const VReplicationWorkflowState_Copying + const VReplicationWorkflowState_Error + const VReplicationWorkflowState_Init + const VReplicationWorkflowState_Lagging + const VReplicationWorkflowState_Running + const VReplicationWorkflowState_Stopped + const VReplicationWorkflowState_Unknown + func (VReplicationWorkflowState) Descriptor() protoreflect.EnumDescriptor + func (VReplicationWorkflowState) EnumDescriptor() ([]byte, []int) + func (VReplicationWorkflowState) Type() protoreflect.EnumType + func (x VReplicationWorkflowState) Enum() *VReplicationWorkflowState + func (x VReplicationWorkflowState) Number() protoreflect.EnumNumber + func (x VReplicationWorkflowState) String() string + type VReplicationWorkflowSubType int32 + const VReplicationWorkflowSubType_AtomicCopy + const VReplicationWorkflowSubType_None + const VReplicationWorkflowSubType_Partial + func (VReplicationWorkflowSubType) Descriptor() protoreflect.EnumDescriptor + func (VReplicationWorkflowSubType) EnumDescriptor() ([]byte, []int) + func (VReplicationWorkflowSubType) Type() protoreflect.EnumType + func (x VReplicationWorkflowSubType) Enum() *VReplicationWorkflowSubType + func (x VReplicationWorkflowSubType) Number() protoreflect.EnumNumber + func (x VReplicationWorkflowSubType) String() string + type VReplicationWorkflowType int32 + const VReplicationWorkflowType_CreateLookupIndex + const VReplicationWorkflowType_Materialize + const VReplicationWorkflowType_Migrate + const VReplicationWorkflowType_MoveTables + const VReplicationWorkflowType_OnlineDDL + const VReplicationWorkflowType_Reshard + func (VReplicationWorkflowType) Descriptor() protoreflect.EnumDescriptor + func (VReplicationWorkflowType) EnumDescriptor() ([]byte, []int) + func (VReplicationWorkflowType) Type() protoreflect.EnumType + func (x VReplicationWorkflowType) Enum() *VReplicationWorkflowType + func (x VReplicationWorkflowType) Number() protoreflect.EnumNumber + func (x VReplicationWorkflowType) String() string + type VStreamRequest struct + EffectiveCallerId *vtrpc.CallerID + Filter *Filter + ImmediateCallerId *query.VTGateCallerID + Position string + TableLastPKs []*TableLastPK + Target *query.Target + func (*VStreamRequest) Descriptor() ([]byte, []int) + func (*VStreamRequest) ProtoMessage() + func (m *VStreamRequest) CloneMessageVT() proto.Message + func (m *VStreamRequest) CloneVT() *VStreamRequest + func (m *VStreamRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *VStreamRequest) MarshalToVT(dAtA []byte) (int, error) + func (m *VStreamRequest) MarshalVT() (dAtA []byte, err error) + func (m *VStreamRequest) SizeVT() (n int) + func (m *VStreamRequest) UnmarshalVT(dAtA []byte) error + func (x *VStreamRequest) GetEffectiveCallerId() *vtrpc.CallerID + func (x *VStreamRequest) GetFilter() *Filter + func (x *VStreamRequest) GetImmediateCallerId() *query.VTGateCallerID + func (x *VStreamRequest) GetPosition() string + func (x *VStreamRequest) GetTableLastPKs() []*TableLastPK + func (x *VStreamRequest) GetTarget() *query.Target + func (x *VStreamRequest) ProtoReflect() protoreflect.Message + func (x *VStreamRequest) Reset() + func (x *VStreamRequest) String() string + type VStreamResponse struct + Events []*VEvent + func (*VStreamResponse) Descriptor() ([]byte, []int) + func (*VStreamResponse) ProtoMessage() + func (m *VStreamResponse) CloneMessageVT() proto.Message + func (m *VStreamResponse) CloneVT() *VStreamResponse + func (m *VStreamResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *VStreamResponse) MarshalToVT(dAtA []byte) (int, error) + func (m *VStreamResponse) MarshalVT() (dAtA []byte, err error) + func (m *VStreamResponse) SizeVT() (n int) + func (m *VStreamResponse) UnmarshalVT(dAtA []byte) error + func (x *VStreamResponse) GetEvents() []*VEvent + func (x *VStreamResponse) ProtoReflect() protoreflect.Message + func (x *VStreamResponse) Reset() + func (x *VStreamResponse) String() string + type VStreamResultsRequest struct + EffectiveCallerId *vtrpc.CallerID + ImmediateCallerId *query.VTGateCallerID + Query string + Target *query.Target + func (*VStreamResultsRequest) Descriptor() ([]byte, []int) + func (*VStreamResultsRequest) ProtoMessage() + func (m *VStreamResultsRequest) CloneMessageVT() proto.Message + func (m *VStreamResultsRequest) CloneVT() *VStreamResultsRequest + func (m *VStreamResultsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *VStreamResultsRequest) MarshalToVT(dAtA []byte) (int, error) + func (m *VStreamResultsRequest) MarshalVT() (dAtA []byte, err error) + func (m *VStreamResultsRequest) SizeVT() (n int) + func (m *VStreamResultsRequest) UnmarshalVT(dAtA []byte) error + func (x *VStreamResultsRequest) GetEffectiveCallerId() *vtrpc.CallerID + func (x *VStreamResultsRequest) GetImmediateCallerId() *query.VTGateCallerID + func (x *VStreamResultsRequest) GetQuery() string + func (x *VStreamResultsRequest) GetTarget() *query.Target + func (x *VStreamResultsRequest) ProtoReflect() protoreflect.Message + func (x *VStreamResultsRequest) Reset() + func (x *VStreamResultsRequest) String() string + type VStreamResultsResponse struct + Fields []*query.Field + Gtid string + Rows []*query.Row + func (*VStreamResultsResponse) Descriptor() ([]byte, []int) + func (*VStreamResultsResponse) ProtoMessage() + func (m *VStreamResultsResponse) CloneMessageVT() proto.Message + func (m *VStreamResultsResponse) CloneVT() *VStreamResultsResponse + func (m *VStreamResultsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *VStreamResultsResponse) MarshalToVT(dAtA []byte) (int, error) + func (m *VStreamResultsResponse) MarshalVT() (dAtA []byte, err error) + func (m *VStreamResultsResponse) SizeVT() (n int) + func (m *VStreamResultsResponse) UnmarshalVT(dAtA []byte) error + func (x *VStreamResultsResponse) GetFields() []*query.Field + func (x *VStreamResultsResponse) GetGtid() string + func (x *VStreamResultsResponse) GetRows() []*query.Row + func (x *VStreamResultsResponse) ProtoReflect() protoreflect.Message + func (x *VStreamResultsResponse) Reset() + func (x *VStreamResultsResponse) String() string + type VStreamRowsRequest struct + EffectiveCallerId *vtrpc.CallerID + ImmediateCallerId *query.VTGateCallerID + Lastpk *query.QueryResult + Query string + Target *query.Target + func (*VStreamRowsRequest) Descriptor() ([]byte, []int) + func (*VStreamRowsRequest) ProtoMessage() + func (m *VStreamRowsRequest) CloneMessageVT() proto.Message + func (m *VStreamRowsRequest) CloneVT() *VStreamRowsRequest + func (m *VStreamRowsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *VStreamRowsRequest) MarshalToVT(dAtA []byte) (int, error) + func (m *VStreamRowsRequest) MarshalVT() (dAtA []byte, err error) + func (m *VStreamRowsRequest) SizeVT() (n int) + func (m *VStreamRowsRequest) UnmarshalVT(dAtA []byte) error + func (x *VStreamRowsRequest) GetEffectiveCallerId() *vtrpc.CallerID + func (x *VStreamRowsRequest) GetImmediateCallerId() *query.VTGateCallerID + func (x *VStreamRowsRequest) GetLastpk() *query.QueryResult + func (x *VStreamRowsRequest) GetQuery() string + func (x *VStreamRowsRequest) GetTarget() *query.Target + func (x *VStreamRowsRequest) ProtoReflect() protoreflect.Message + func (x *VStreamRowsRequest) Reset() + func (x *VStreamRowsRequest) String() string + type VStreamRowsResponse struct + Fields []*query.Field + Gtid string + Heartbeat bool + Lastpk *query.Row + Pkfields []*query.Field + Rows []*query.Row + Throttled bool + func VStreamRowsResponseFromVTPool() *VStreamRowsResponse + func (*VStreamRowsResponse) Descriptor() ([]byte, []int) + func (*VStreamRowsResponse) ProtoMessage() + func (m *VStreamRowsResponse) CloneMessageVT() proto.Message + func (m *VStreamRowsResponse) CloneVT() *VStreamRowsResponse + func (m *VStreamRowsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *VStreamRowsResponse) MarshalToVT(dAtA []byte) (int, error) + func (m *VStreamRowsResponse) MarshalVT() (dAtA []byte, err error) + func (m *VStreamRowsResponse) ResetVT() + func (m *VStreamRowsResponse) ReturnToVTPool() + func (m *VStreamRowsResponse) SizeVT() (n int) + func (m *VStreamRowsResponse) UnmarshalVT(dAtA []byte) error + func (x *VStreamRowsResponse) GetFields() []*query.Field + func (x *VStreamRowsResponse) GetGtid() string + func (x *VStreamRowsResponse) GetHeartbeat() bool + func (x *VStreamRowsResponse) GetLastpk() *query.Row + func (x *VStreamRowsResponse) GetPkfields() []*query.Field + func (x *VStreamRowsResponse) GetRows() []*query.Row + func (x *VStreamRowsResponse) GetThrottled() bool + func (x *VStreamRowsResponse) ProtoReflect() protoreflect.Message + func (x *VStreamRowsResponse) Reset() + func (x *VStreamRowsResponse) String() string + type VStreamTablesRequest struct + EffectiveCallerId *vtrpc.CallerID + ImmediateCallerId *query.VTGateCallerID + Target *query.Target + func (*VStreamTablesRequest) Descriptor() ([]byte, []int) + func (*VStreamTablesRequest) ProtoMessage() + func (m *VStreamTablesRequest) CloneMessageVT() proto.Message + func (m *VStreamTablesRequest) CloneVT() *VStreamTablesRequest + func (m *VStreamTablesRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *VStreamTablesRequest) MarshalToVT(dAtA []byte) (int, error) + func (m *VStreamTablesRequest) MarshalVT() (dAtA []byte, err error) + func (m *VStreamTablesRequest) SizeVT() (n int) + func (m *VStreamTablesRequest) UnmarshalVT(dAtA []byte) error + func (x *VStreamTablesRequest) GetEffectiveCallerId() *vtrpc.CallerID + func (x *VStreamTablesRequest) GetImmediateCallerId() *query.VTGateCallerID + func (x *VStreamTablesRequest) GetTarget() *query.Target + func (x *VStreamTablesRequest) ProtoReflect() protoreflect.Message + func (x *VStreamTablesRequest) Reset() + func (x *VStreamTablesRequest) String() string + type VStreamTablesResponse struct + Fields []*query.Field + Gtid string + Lastpk *query.Row + Pkfields []*query.Field + Rows []*query.Row + TableName string + func VStreamTablesResponseFromVTPool() *VStreamTablesResponse + func (*VStreamTablesResponse) Descriptor() ([]byte, []int) + func (*VStreamTablesResponse) ProtoMessage() + func (m *VStreamTablesResponse) CloneMessageVT() proto.Message + func (m *VStreamTablesResponse) CloneVT() *VStreamTablesResponse + func (m *VStreamTablesResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *VStreamTablesResponse) MarshalToVT(dAtA []byte) (int, error) + func (m *VStreamTablesResponse) MarshalVT() (dAtA []byte, err error) + func (m *VStreamTablesResponse) ResetVT() + func (m *VStreamTablesResponse) ReturnToVTPool() + func (m *VStreamTablesResponse) SizeVT() (n int) + func (m *VStreamTablesResponse) UnmarshalVT(dAtA []byte) error + func (x *VStreamTablesResponse) GetFields() []*query.Field + func (x *VStreamTablesResponse) GetGtid() string + func (x *VStreamTablesResponse) GetLastpk() *query.Row + func (x *VStreamTablesResponse) GetPkfields() []*query.Field + func (x *VStreamTablesResponse) GetRows() []*query.Row + func (x *VStreamTablesResponse) GetTableName() string + func (x *VStreamTablesResponse) ProtoReflect() protoreflect.Message + func (x *VStreamTablesResponse) Reset() + func (x *VStreamTablesResponse) String() string
Go to main page