binlogdata

Oct 29, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

type FieldEvent

+ IsInternalTable bool

+ func (x *FieldEvent) GetIsInternalTable() bool

type RowEvent

+ IsInternalTable bool

+ func (x *RowEvent) GetIsInternalTable() bool

type VEvent

+ ThrottledReason string

+ func (x *VEvent) GetThrottledReason() string

+ type VStreamOptions struct

+ ConfigOverrides map[string]string

+ InternalTables []string

+ func (*VStreamOptions) Descriptor() ([]byte, []int)

+ func (*VStreamOptions) ProtoMessage()

+ func (m *VStreamOptions) CloneMessageVT() proto.Message

+ func (m *VStreamOptions) CloneVT() *VStreamOptions

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

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

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

+ func (m *VStreamOptions) SizeVT() (n int)

+ func (m *VStreamOptions) UnmarshalVT(dAtA []byte) error

+ func (x *VStreamOptions) GetConfigOverrides() map[string]string

+ func (x *VStreamOptions) GetInternalTables() []string

+ func (x *VStreamOptions) ProtoReflect() protoreflect.Message

+ func (x *VStreamOptions) Reset()

+ func (x *VStreamOptions) String() string

type VStreamRequest

+ Options *VStreamOptions

+ func (x *VStreamRequest) GetOptions() *VStreamOptions

type VStreamRowsRequest

+ Options *VStreamOptions

+ func (x *VStreamRowsRequest) GetOptions() *VStreamOptions

type VStreamRowsResponse

+ ThrottledReason string

+ func (x *VStreamRowsResponse) GetThrottledReason() string

type VStreamTablesRequest

+ Options *VStreamOptions

+ func (x *VStreamTablesRequest) GetOptions() *VStreamOptions

Nov 6, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Sep 11, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Jul 23, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Jun 27, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

type FieldEvent

+ EnumSetStringValues bool

+ func (x *FieldEvent) GetEnumSetStringValues() bool

Nov 6, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Sep 11, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Jul 23, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

May 8, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Apr 4, 2024 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Apr 4, 2024 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Mar 14, 2024 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Mar 6, 2024 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

type MinimalTable

+ PKIndexName string

+ func (x *MinimalTable) GetPKIndexName() string

type Rule

+ ForceUniqueKey string

+ func (x *Rule) GetForceUniqueKey() string

Feb 7, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Nov 6, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Sep 11, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Jul 23, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

May 8, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Apr 4, 2024 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Mar 14, 2024 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Dec 20, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Nov 22, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Nov 6, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

+ var VReplicationWorkflowState_name = map[int32]string

+ var VReplicationWorkflowState_value = map[string]int32

type BinlogSource

+ func (m *BinlogSource) CloneMessageVT() proto.Message

+ func (m *BinlogSource) CloneVT() *BinlogSource

type BinlogTransaction

+ func (m *BinlogTransaction) CloneMessageVT() proto.Message

+ func (m *BinlogTransaction) CloneVT() *BinlogTransaction

type BinlogTransaction_Statement

+ func (m *BinlogTransaction_Statement) CloneMessageVT() proto.Message

+ func (m *BinlogTransaction_Statement) CloneVT() *BinlogTransaction_Statement

type Charset

+ func (m *Charset) CloneMessageVT() proto.Message

+ func (m *Charset) CloneVT() *Charset

type CharsetConversion

+ func (m *CharsetConversion) CloneMessageVT() proto.Message

+ func (m *CharsetConversion) CloneVT() *CharsetConversion

type FieldEvent

+ func (m *FieldEvent) CloneMessageVT() proto.Message

+ func (m *FieldEvent) CloneVT() *FieldEvent

type Filter

+ func (m *Filter) CloneMessageVT() proto.Message

+ func (m *Filter) CloneVT() *Filter

type Journal

+ func (m *Journal) CloneMessageVT() proto.Message

+ func (m *Journal) CloneVT() *Journal

type KeyspaceShard

+ func (m *KeyspaceShard) CloneMessageVT() proto.Message

+ func (m *KeyspaceShard) CloneVT() *KeyspaceShard

type LastPKEvent

+ func (m *LastPKEvent) CloneMessageVT() proto.Message

+ func (m *LastPKEvent) CloneVT() *LastPKEvent

type MinimalSchema

+ func (m *MinimalSchema) CloneMessageVT() proto.Message

+ func (m *MinimalSchema) CloneVT() *MinimalSchema

type MinimalTable

+ func (m *MinimalTable) CloneMessageVT() proto.Message

+ func (m *MinimalTable) CloneVT() *MinimalTable

type RowChange

+ func (m *RowChange) CloneMessageVT() proto.Message

+ func (m *RowChange) CloneVT() *RowChange

type RowChange_Bitmap

+ func (m *RowChange_Bitmap) CloneMessageVT() proto.Message

+ func (m *RowChange_Bitmap) CloneVT() *RowChange_Bitmap

type RowEvent

+ Flags uint32

+ func (m *RowEvent) CloneMessageVT() proto.Message

+ func (m *RowEvent) CloneVT() *RowEvent

+ func (x *RowEvent) GetFlags() uint32

type Rule

+ func (m *Rule) CloneMessageVT() proto.Message

+ func (m *Rule) CloneVT() *Rule

type ShardGtid

+ func (m *ShardGtid) CloneMessageVT() proto.Message

+ func (m *ShardGtid) CloneVT() *ShardGtid

type StreamKeyRangeRequest

+ func (m *StreamKeyRangeRequest) CloneMessageVT() proto.Message

+ func (m *StreamKeyRangeRequest) CloneVT() *StreamKeyRangeRequest

type StreamKeyRangeResponse

+ func (m *StreamKeyRangeResponse) CloneMessageVT() proto.Message

+ func (m *StreamKeyRangeResponse) CloneVT() *StreamKeyRangeResponse

type StreamTablesRequest

+ func (m *StreamTablesRequest) CloneMessageVT() proto.Message

+ func (m *StreamTablesRequest) CloneVT() *StreamTablesRequest

type StreamTablesResponse

+ func (m *StreamTablesResponse) CloneMessageVT() proto.Message

+ func (m *StreamTablesResponse) CloneVT() *StreamTablesResponse

type TableLastPK

+ func (m *TableLastPK) CloneMessageVT() proto.Message

+ func (m *TableLastPK) CloneVT() *TableLastPK

type VEvent

+ func (m *VEvent) CloneMessageVT() proto.Message

+ func (m *VEvent) CloneVT() *VEvent

type VGtid

+ func (m *VGtid) CloneMessageVT() proto.Message

+ func (m *VGtid) CloneVT() *VGtid

+ 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

+ const VReplicationWorkflowSubType_AtomicCopy

type VStreamRequest

+ func (m *VStreamRequest) CloneMessageVT() proto.Message

+ func (m *VStreamRequest) CloneVT() *VStreamRequest

type VStreamResponse

+ func (m *VStreamResponse) CloneMessageVT() proto.Message

+ func (m *VStreamResponse) CloneVT() *VStreamResponse

type VStreamResultsRequest

+ func (m *VStreamResultsRequest) CloneMessageVT() proto.Message

+ func (m *VStreamResultsRequest) CloneVT() *VStreamResultsRequest

type VStreamResultsResponse

+ func (m *VStreamResultsResponse) CloneMessageVT() proto.Message

+ func (m *VStreamResultsResponse) CloneVT() *VStreamResultsResponse

type VStreamRowsRequest

+ func (m *VStreamRowsRequest) CloneMessageVT() proto.Message

+ func (m *VStreamRowsRequest) CloneVT() *VStreamRowsRequest

type VStreamRowsResponse

+ func (m *VStreamRowsResponse) CloneMessageVT() proto.Message

+ func (m *VStreamRowsResponse) CloneVT() *VStreamRowsResponse

+ 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

Oct 3, 2023 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

May 8, 2024 GO-2024-3306

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Mar 14, 2024 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Dec 20, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Nov 13, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Oct 3, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Aug 18, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Jul 28, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Jun 27, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

type RowChange

+ DataColumns *RowChange_Bitmap

+ func (x *RowChange) GetDataColumns() *RowChange_Bitmap

+ type RowChange_Bitmap struct

+ Cols []byte

+ Count int64

+ func (*RowChange_Bitmap) Descriptor() ([]byte, []int)

+ func (*RowChange_Bitmap) ProtoMessage()

+ 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

Jun 13, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Jun 6, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Dec 20, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Nov 13, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Oct 3, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Aug 18, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Jul 28, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

May 9, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Mar 30, 2023 GO-2024-2826 +1 more

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Feb 28, 2023 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

type Rule

+ ConvertIntToEnum map[string]bool

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

type VEventType

+ const VEventType_COPY_COMPLETED

Feb 8, 2023 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Oct 3, 2023 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Jul 28, 2023 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Mar 30, 2023 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Dec 14, 2022 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Nov 29, 2022 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Oct 25, 2022 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

+ var VReplicationWorkflowSubType_name = map[int32]string

+ var VReplicationWorkflowSubType_value = map[string]int32

+ type VReplicationWorkflowSubType int32

+ 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

+ const VReplicationWorkflowType_CreateLookupIndex

+ const VReplicationWorkflowType_Materialize

+ const VReplicationWorkflowType_Migrate

+ const VReplicationWorkflowType_MoveTables

+ const VReplicationWorkflowType_OnlineDDL

+ const VReplicationWorkflowType_Reshard

Mar 30, 2023 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Nov 29, 2022 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Sep 1, 2022 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

type VEvent

+ Throttled bool

+ func (x *VEvent) GetThrottled() bool

type VStreamRowsResponse

+ Heartbeat bool

+ Throttled bool

+ func (x *VStreamRowsResponse) GetHeartbeat() bool

+ func (x *VStreamRowsResponse) GetThrottled() bool

Jul 26, 2022 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Jun 28, 2022 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

+ var VReplicationWorkflowType_name = map[int32]string

+ var VReplicationWorkflowType_value = map[string]int32

type BinlogSource

+ SourceTimeZone string

+ TargetTimeZone string

+ func (x *BinlogSource) GetSourceTimeZone() string

+ func (x *BinlogSource) GetTargetTimeZone() string

type Filter

+ WorkflowName string

+ WorkflowType int64

+ func (x *Filter) GetWorkflowName() string

+ func (x *Filter) GetWorkflowType() int64

+ 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

Sep 1, 2022 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Jul 26, 2022 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Apr 14, 2022 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Feb 22, 2022 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

type VEvent

+ Keyspace string

+ Shard string

+ func (x *VEvent) GetKeyspace() string

+ func (x *VEvent) GetShard() string

Sep 1, 2022 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Jul 27, 2022 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

May 20, 2022 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Jan 10, 2022 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Dec 17, 2021 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Dec 14, 2021 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Oct 26, 2021 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

type FieldEvent

+ Keyspace string

+ Shard string

+ func (x *FieldEvent) GetKeyspace() string

+ func (x *FieldEvent) GetShard() string

type RowEvent

+ Keyspace string

+ Shard string

+ func (x *RowEvent) GetKeyspace() string

+ func (x *RowEvent) GetShard() string

type Rule

+ SourceUniqueKeyColumns string

+ SourceUniqueKeyTargetColumns string

+ TargetUniqueKeyColumns string

+ func (x *Rule) GetSourceUniqueKeyColumns() string

+ func (x *Rule) GetSourceUniqueKeyTargetColumns() string

+ func (x *Rule) GetTargetUniqueKeyColumns() string

Jan 10, 2022 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Dec 17, 2021 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Dec 14, 2021 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Sep 9, 2021 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Jul 27, 2021 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

+ 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

type 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) ProtoReflect() protoreflect.Message

type 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) ProtoReflect() protoreflect.Message

type 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) ProtoReflect() protoreflect.Message

type BinlogTransaction_Statement_Category

+ func (BinlogTransaction_Statement_Category) Descriptor() protoreflect.EnumDescriptor

+ func (BinlogTransaction_Statement_Category) Type() protoreflect.EnumType

+ func (x BinlogTransaction_Statement_Category) Enum() *BinlogTransaction_Statement_Category

+ func (x BinlogTransaction_Statement_Category) Number() protoreflect.EnumNumber

type 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) ProtoReflect() protoreflect.Message

+ type CharsetConversion struct

+ FromCharset string

+ ToCharset string

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

+ func (*CharsetConversion) ProtoMessage()

+ 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

+ 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) ProtoReflect() protoreflect.Message

type 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) ProtoReflect() protoreflect.Message

type Filter_FieldEventMode

+ func (Filter_FieldEventMode) Descriptor() protoreflect.EnumDescriptor

+ func (Filter_FieldEventMode) Type() protoreflect.EnumType

+ func (x Filter_FieldEventMode) Enum() *Filter_FieldEventMode

+ func (x Filter_FieldEventMode) Number() protoreflect.EnumNumber

type 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) ProtoReflect() protoreflect.Message

type 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) ProtoReflect() protoreflect.Message

type 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) ProtoReflect() protoreflect.Message

type MigrationType

+ func (MigrationType) Descriptor() protoreflect.EnumDescriptor

+ func (MigrationType) Type() protoreflect.EnumType

+ func (x MigrationType) Enum() *MigrationType

+ func (x MigrationType) Number() protoreflect.EnumNumber

type 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) ProtoReflect() protoreflect.Message

type 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) ProtoReflect() protoreflect.Message

type OnDDLAction

+ func (OnDDLAction) Descriptor() protoreflect.EnumDescriptor

+ func (OnDDLAction) Type() protoreflect.EnumType

+ func (x OnDDLAction) Enum() *OnDDLAction

+ func (x OnDDLAction) Number() protoreflect.EnumNumber

type 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) ProtoReflect() protoreflect.Message

type 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) ProtoReflect() protoreflect.Message

type Rule

+ ConvertCharset map[string]*CharsetConversion

+ ConvertEnumToText map[string]string

+ 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) ProtoReflect() protoreflect.Message

type 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) ProtoReflect() protoreflect.Message

type 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) ProtoReflect() protoreflect.Message

type 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) ProtoReflect() protoreflect.Message

type 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) ProtoReflect() protoreflect.Message

type 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) ProtoReflect() protoreflect.Message

type 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) ProtoReflect() protoreflect.Message

type 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) ProtoReflect() protoreflect.Message

type VEventType

+ func (VEventType) Descriptor() protoreflect.EnumDescriptor

+ func (VEventType) Type() protoreflect.EnumType

+ func (x VEventType) Enum() *VEventType

+ func (x VEventType) Number() protoreflect.EnumNumber

type 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) ProtoReflect() protoreflect.Message

type 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) ProtoReflect() protoreflect.Message

type 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) ProtoReflect() protoreflect.Message

type 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) ProtoReflect() protoreflect.Message

type 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) ProtoReflect() protoreflect.Message

type 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) ProtoReflect() protoreflect.Message

type VStreamRowsResponse

+ func VStreamRowsResponseFromVTPool() *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) ProtoReflect() protoreflect.Message

Jan 10, 2022 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Dec 17, 2021 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Dec 14, 2021 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

May 27, 2021 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

May 4, 2021 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Apr 27, 2021 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

+ var ErrIntOverflowBinlogdata = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthBinlogdata = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupBinlogdata = fmt.Errorf("proto: unexpected end of group")

type BinlogSource

+ ExternalCluster string

+ func (m *BinlogSource) GetExternalCluster() string

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

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

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

+ func (m *BinlogSource) Size() (n int)

+ func (m *BinlogSource) Unmarshal(dAtA []byte) error

type BinlogTransaction

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

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

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

+ func (m *BinlogTransaction) Size() (n int)

+ func (m *BinlogTransaction) Unmarshal(dAtA []byte) error

type BinlogTransaction_Statement

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

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

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

+ func (m *BinlogTransaction_Statement) Size() (n int)

+ func (m *BinlogTransaction_Statement) Unmarshal(dAtA []byte) error

type Charset

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

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

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

+ func (m *Charset) Size() (n int)

+ func (m *Charset) Unmarshal(dAtA []byte) error

type FieldEvent

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

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

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

+ func (m *FieldEvent) Size() (n int)

+ func (m *FieldEvent) Unmarshal(dAtA []byte) error

type Filter

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

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

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

+ func (m *Filter) Size() (n int)

+ func (m *Filter) Unmarshal(dAtA []byte) error

type Journal

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

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

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

+ func (m *Journal) Size() (n int)

+ func (m *Journal) Unmarshal(dAtA []byte) error

type KeyspaceShard

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

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

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

+ func (m *KeyspaceShard) Size() (n int)

+ func (m *KeyspaceShard) Unmarshal(dAtA []byte) error

type LastPKEvent

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

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

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

+ func (m *LastPKEvent) Size() (n int)

+ func (m *LastPKEvent) Unmarshal(dAtA []byte) error

type MinimalSchema

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

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

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

+ func (m *MinimalSchema) Size() (n int)

+ func (m *MinimalSchema) Unmarshal(dAtA []byte) error

type MinimalTable

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

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

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

+ func (m *MinimalTable) Size() (n int)

+ func (m *MinimalTable) Unmarshal(dAtA []byte) error

type RowChange

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

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

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

+ func (m *RowChange) Size() (n int)

+ func (m *RowChange) Unmarshal(dAtA []byte) error

type RowEvent

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

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

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

+ func (m *RowEvent) Size() (n int)

+ func (m *RowEvent) Unmarshal(dAtA []byte) error

type Rule

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

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

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

+ func (m *Rule) Size() (n int)

+ func (m *Rule) Unmarshal(dAtA []byte) error

type ShardGtid

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

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

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

+ func (m *ShardGtid) Size() (n int)

+ func (m *ShardGtid) Unmarshal(dAtA []byte) error

type StreamKeyRangeRequest

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

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

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

+ func (m *StreamKeyRangeRequest) Size() (n int)

+ func (m *StreamKeyRangeRequest) Unmarshal(dAtA []byte) error

type StreamKeyRangeResponse

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

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

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

+ func (m *StreamKeyRangeResponse) Size() (n int)

+ func (m *StreamKeyRangeResponse) Unmarshal(dAtA []byte) error

type StreamTablesRequest

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

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

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

+ func (m *StreamTablesRequest) Size() (n int)

+ func (m *StreamTablesRequest) Unmarshal(dAtA []byte) error

type StreamTablesResponse

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

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

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

+ func (m *StreamTablesResponse) Size() (n int)

+ func (m *StreamTablesResponse) Unmarshal(dAtA []byte) error

type TableLastPK

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

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

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

+ func (m *TableLastPK) Size() (n int)

+ func (m *TableLastPK) Unmarshal(dAtA []byte) error

type VEvent

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

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

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

+ func (m *VEvent) Size() (n int)

+ func (m *VEvent) Unmarshal(dAtA []byte) error

type VGtid

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

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

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

+ func (m *VGtid) Size() (n int)

+ func (m *VGtid) Unmarshal(dAtA []byte) error

type VStreamRequest

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

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

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

+ func (m *VStreamRequest) Size() (n int)

+ func (m *VStreamRequest) Unmarshal(dAtA []byte) error

type VStreamResponse

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

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

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

+ func (m *VStreamResponse) Size() (n int)

+ func (m *VStreamResponse) Unmarshal(dAtA []byte) error

type VStreamResultsRequest

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

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

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

+ func (m *VStreamResultsRequest) Size() (n int)

+ func (m *VStreamResultsRequest) Unmarshal(dAtA []byte) error

type VStreamResultsResponse

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

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

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

+ func (m *VStreamResultsResponse) Size() (n int)

+ func (m *VStreamResultsResponse) Unmarshal(dAtA []byte) error

type VStreamRowsRequest

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

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

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

+ func (m *VStreamRowsRequest) Size() (n int)

+ func (m *VStreamRowsRequest) Unmarshal(dAtA []byte) error

type VStreamRowsResponse

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

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

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

+ func (m *VStreamRowsResponse) Size() (n int)

+ func (m *VStreamRowsResponse) Unmarshal(dAtA []byte) error

May 25, 2021 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

May 6, 2021 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Jan 25, 2021 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Oct 27, 2020 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Jul 28, 2020 GO-2023-1717 +2 more

  GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

  GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

  GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

+ var BinlogTransaction_Statement_Category_name = map[int32]string

+ var BinlogTransaction_Statement_Category_value = map[string]int32

+ 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

+ type BinlogSource struct

+ ExternalMysql string

+ Filter *Filter

+ KeyRange *topodata.KeyRange

+ Keyspace string

+ OnDdl OnDDLAction

+ Shard string

+ StopAfterCopy bool

+ Tables []string

+ TabletType topodata.TabletType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BinlogSource) ProtoMessage()

+ func (m *BinlogSource) GetExternalMysql() string

+ func (m *BinlogSource) GetFilter() *Filter

+ func (m *BinlogSource) GetKeyRange() *topodata.KeyRange

+ func (m *BinlogSource) GetKeyspace() string

+ func (m *BinlogSource) GetOnDdl() OnDDLAction

+ func (m *BinlogSource) GetShard() string

+ func (m *BinlogSource) GetStopAfterCopy() bool

+ func (m *BinlogSource) GetTables() []string

+ func (m *BinlogSource) GetTabletType() topodata.TabletType

+ func (m *BinlogSource) Reset()

+ func (m *BinlogSource) String() string

+ func (m *BinlogSource) XXX_DiscardUnknown()

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

+ func (m *BinlogSource) XXX_Merge(src proto.Message)

+ func (m *BinlogSource) XXX_Size() int

+ func (m *BinlogSource) XXX_Unmarshal(b []byte) error

+ type BinlogTransaction struct

+ EventToken *query.EventToken

+ Statements []*BinlogTransaction_Statement

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BinlogTransaction) ProtoMessage()

+ func (m *BinlogTransaction) GetEventToken() *query.EventToken

+ func (m *BinlogTransaction) GetStatements() []*BinlogTransaction_Statement

+ func (m *BinlogTransaction) Reset()

+ func (m *BinlogTransaction) String() string

+ func (m *BinlogTransaction) XXX_DiscardUnknown()

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

+ func (m *BinlogTransaction) XXX_Merge(src proto.Message)

+ func (m *BinlogTransaction) XXX_Size() int

+ func (m *BinlogTransaction) XXX_Unmarshal(b []byte) error

+ type BinlogTransaction_Statement struct

+ Category BinlogTransaction_Statement_Category

+ Charset *Charset

+ Sql []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BinlogTransaction_Statement) ProtoMessage()

+ func (m *BinlogTransaction_Statement) GetCategory() BinlogTransaction_Statement_Category

+ func (m *BinlogTransaction_Statement) GetCharset() *Charset

+ func (m *BinlogTransaction_Statement) GetSql() []byte

+ func (m *BinlogTransaction_Statement) Reset()

+ func (m *BinlogTransaction_Statement) String() string

+ func (m *BinlogTransaction_Statement) XXX_DiscardUnknown()

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

+ func (m *BinlogTransaction_Statement) XXX_Merge(src proto.Message)

+ func (m *BinlogTransaction_Statement) XXX_Size() int

+ func (m *BinlogTransaction_Statement) XXX_Unmarshal(b []byte) error

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

+ func (x BinlogTransaction_Statement_Category) String() string

+ type Charset struct

+ Client int32

+ Conn int32

+ Server int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Charset) ProtoMessage()

+ func (m *Charset) GetClient() int32

+ func (m *Charset) GetConn() int32

+ func (m *Charset) GetServer() int32

+ func (m *Charset) Reset()

+ func (m *Charset) String() string

+ func (m *Charset) XXX_DiscardUnknown()

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

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

+ func (m *Charset) XXX_Size() int

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

+ type FieldEvent struct

+ Fields []*query.Field

+ TableName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*FieldEvent) ProtoMessage()

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

+ func (m *FieldEvent) GetTableName() string

+ func (m *FieldEvent) Reset()

+ func (m *FieldEvent) String() string

+ func (m *FieldEvent) XXX_DiscardUnknown()

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

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

+ func (m *FieldEvent) XXX_Size() int

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

+ type Filter struct

+ FieldEventMode Filter_FieldEventMode

+ Rules []*Rule

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Filter) ProtoMessage()

+ func (m *Filter) GetFieldEventMode() Filter_FieldEventMode

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

+ func (m *Filter) Reset()

+ func (m *Filter) String() string

+ func (m *Filter) XXX_DiscardUnknown()

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

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

+ func (m *Filter) XXX_Size() int

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

+ type Filter_FieldEventMode int32

+ const Filter_BEST_EFFORT

+ const Filter_ERR_ON_MISMATCH

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

+ func (x Filter_FieldEventMode) String() string

+ type Journal struct

+ Id int64

+ LocalPosition string

+ MigrationType MigrationType

+ Participants []*KeyspaceShard

+ ShardGtids []*ShardGtid

+ SourceWorkflows []string

+ Tables []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Journal) ProtoMessage()

+ func (m *Journal) GetId() int64

+ func (m *Journal) GetLocalPosition() string

+ func (m *Journal) GetMigrationType() MigrationType

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

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

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

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

+ func (m *Journal) Reset()

+ func (m *Journal) String() string

+ func (m *Journal) XXX_DiscardUnknown()

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

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

+ func (m *Journal) XXX_Size() int

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

+ type KeyspaceShard struct

+ Keyspace string

+ Shard string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*KeyspaceShard) ProtoMessage()

+ func (m *KeyspaceShard) GetKeyspace() string

+ func (m *KeyspaceShard) GetShard() string

+ func (m *KeyspaceShard) Reset()

+ func (m *KeyspaceShard) String() string

+ func (m *KeyspaceShard) XXX_DiscardUnknown()

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

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

+ func (m *KeyspaceShard) XXX_Size() int

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

+ type LastPKEvent struct

+ Completed bool

+ TableLastPK *TableLastPK

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*LastPKEvent) ProtoMessage()

+ func (m *LastPKEvent) GetCompleted() bool

+ func (m *LastPKEvent) GetTableLastPK() *TableLastPK

+ func (m *LastPKEvent) Reset()

+ func (m *LastPKEvent) String() string

+ func (m *LastPKEvent) XXX_DiscardUnknown()

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

+ func (m *LastPKEvent) XXX_Merge(src proto.Message)

+ func (m *LastPKEvent) XXX_Size() int

+ func (m *LastPKEvent) XXX_Unmarshal(b []byte) error

+ type MigrationType int32

+ const MigrationType_SHARDS

+ const MigrationType_TABLES

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

+ func (x MigrationType) String() string

+ type MinimalSchema struct

+ Tables []*MinimalTable

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MinimalSchema) ProtoMessage()

+ func (m *MinimalSchema) GetTables() []*MinimalTable

+ func (m *MinimalSchema) Reset()

+ func (m *MinimalSchema) String() string

+ func (m *MinimalSchema) XXX_DiscardUnknown()

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

+ func (m *MinimalSchema) XXX_Merge(src proto.Message)

+ func (m *MinimalSchema) XXX_Size() int

+ func (m *MinimalSchema) XXX_Unmarshal(b []byte) error

+ type MinimalTable struct

+ Fields []*query.Field

+ Name string

+ PKColumns []int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MinimalTable) ProtoMessage()

+ func (m *MinimalTable) GetFields() []*query.Field

+ func (m *MinimalTable) GetName() string

+ func (m *MinimalTable) GetPKColumns() []int64

+ func (m *MinimalTable) Reset()

+ func (m *MinimalTable) String() string

+ func (m *MinimalTable) XXX_DiscardUnknown()

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

+ func (m *MinimalTable) XXX_Merge(src proto.Message)

+ func (m *MinimalTable) XXX_Size() int

+ func (m *MinimalTable) XXX_Unmarshal(b []byte) error

+ type OnDDLAction int32

+ const OnDDLAction_EXEC

+ const OnDDLAction_EXEC_IGNORE

+ const OnDDLAction_IGNORE

+ const OnDDLAction_STOP

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

+ func (x OnDDLAction) String() string

+ type RowChange struct

+ After *query.Row

+ Before *query.Row

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RowChange) ProtoMessage()

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

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

+ func (m *RowChange) Reset()

+ func (m *RowChange) String() string

+ func (m *RowChange) XXX_DiscardUnknown()

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

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

+ func (m *RowChange) XXX_Size() int

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

+ type RowEvent struct

+ RowChanges []*RowChange

+ TableName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RowEvent) ProtoMessage()

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

+ func (m *RowEvent) GetTableName() string

+ func (m *RowEvent) Reset()

+ func (m *RowEvent) String() string

+ func (m *RowEvent) XXX_DiscardUnknown()

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

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

+ func (m *RowEvent) XXX_Size() int

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

+ type Rule struct

+ Filter string

+ Match string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Rule) ProtoMessage()

+ func (m *Rule) GetFilter() string

+ func (m *Rule) GetMatch() string

+ func (m *Rule) Reset()

+ func (m *Rule) String() string

+ func (m *Rule) XXX_DiscardUnknown()

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

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

+ func (m *Rule) XXX_Size() int

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

+ type ShardGtid struct

+ Gtid string

+ Keyspace string

+ Shard string

+ TablePKs []*TableLastPK

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ShardGtid) ProtoMessage()

+ func (m *ShardGtid) GetGtid() string

+ func (m *ShardGtid) GetKeyspace() string

+ func (m *ShardGtid) GetShard() string

+ func (m *ShardGtid) GetTablePKs() []*TableLastPK

+ func (m *ShardGtid) Reset()

+ func (m *ShardGtid) String() string

+ func (m *ShardGtid) XXX_DiscardUnknown()

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

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

+ func (m *ShardGtid) XXX_Size() int

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

+ type StreamKeyRangeRequest struct

+ Charset *Charset

+ KeyRange *topodata.KeyRange

+ Position string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamKeyRangeRequest) ProtoMessage()

+ func (m *StreamKeyRangeRequest) GetCharset() *Charset

+ func (m *StreamKeyRangeRequest) GetKeyRange() *topodata.KeyRange

+ func (m *StreamKeyRangeRequest) GetPosition() string

+ func (m *StreamKeyRangeRequest) Reset()

+ func (m *StreamKeyRangeRequest) String() string

+ func (m *StreamKeyRangeRequest) XXX_DiscardUnknown()

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

+ func (m *StreamKeyRangeRequest) XXX_Merge(src proto.Message)

+ func (m *StreamKeyRangeRequest) XXX_Size() int

+ func (m *StreamKeyRangeRequest) XXX_Unmarshal(b []byte) error

+ type StreamKeyRangeResponse struct

+ BinlogTransaction *BinlogTransaction

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamKeyRangeResponse) ProtoMessage()

+ func (m *StreamKeyRangeResponse) GetBinlogTransaction() *BinlogTransaction

+ func (m *StreamKeyRangeResponse) Reset()

+ func (m *StreamKeyRangeResponse) String() string

+ func (m *StreamKeyRangeResponse) XXX_DiscardUnknown()

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

+ func (m *StreamKeyRangeResponse) XXX_Merge(src proto.Message)

+ func (m *StreamKeyRangeResponse) XXX_Size() int

+ func (m *StreamKeyRangeResponse) XXX_Unmarshal(b []byte) error

+ type StreamTablesRequest struct

+ Charset *Charset

+ Position string

+ Tables []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamTablesRequest) ProtoMessage()

+ func (m *StreamTablesRequest) GetCharset() *Charset

+ func (m *StreamTablesRequest) GetPosition() string

+ func (m *StreamTablesRequest) GetTables() []string

+ func (m *StreamTablesRequest) Reset()

+ func (m *StreamTablesRequest) String() string

+ func (m *StreamTablesRequest) XXX_DiscardUnknown()

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

+ func (m *StreamTablesRequest) XXX_Merge(src proto.Message)

+ func (m *StreamTablesRequest) XXX_Size() int

+ func (m *StreamTablesRequest) XXX_Unmarshal(b []byte) error

+ type StreamTablesResponse struct

+ BinlogTransaction *BinlogTransaction

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamTablesResponse) ProtoMessage()

+ func (m *StreamTablesResponse) GetBinlogTransaction() *BinlogTransaction

+ func (m *StreamTablesResponse) Reset()

+ func (m *StreamTablesResponse) String() string

+ func (m *StreamTablesResponse) XXX_DiscardUnknown()

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

+ func (m *StreamTablesResponse) XXX_Merge(src proto.Message)

+ func (m *StreamTablesResponse) XXX_Size() int

+ func (m *StreamTablesResponse) XXX_Unmarshal(b []byte) error

+ type TableLastPK struct

+ Lastpk *query.QueryResult

+ TableName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TableLastPK) ProtoMessage()

+ func (m *TableLastPK) GetLastpk() *query.QueryResult

+ func (m *TableLastPK) GetTableName() string

+ func (m *TableLastPK) Reset()

+ func (m *TableLastPK) String() string

+ func (m *TableLastPK) XXX_DiscardUnknown()

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

+ func (m *TableLastPK) XXX_Merge(src proto.Message)

+ func (m *TableLastPK) XXX_Size() int

+ func (m *TableLastPK) XXX_Unmarshal(b []byte) error

+ type VEvent struct

+ CurrentTime int64

+ Dml string

+ FieldEvent *FieldEvent

+ Gtid string

+ Journal *Journal

+ LastPKEvent *LastPKEvent

+ RowEvent *RowEvent

+ Statement string

+ Timestamp int64

+ Type VEventType

+ Vgtid *VGtid

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*VEvent) ProtoMessage()

+ func (m *VEvent) GetCurrentTime() int64

+ func (m *VEvent) GetDml() string

+ func (m *VEvent) GetFieldEvent() *FieldEvent

+ func (m *VEvent) GetGtid() string

+ func (m *VEvent) GetJournal() *Journal

+ func (m *VEvent) GetLastPKEvent() *LastPKEvent

+ func (m *VEvent) GetRowEvent() *RowEvent

+ func (m *VEvent) GetStatement() string

+ func (m *VEvent) GetTimestamp() int64

+ func (m *VEvent) GetType() VEventType

+ func (m *VEvent) GetVgtid() *VGtid

+ func (m *VEvent) Reset()

+ func (m *VEvent) String() string

+ func (m *VEvent) XXX_DiscardUnknown()

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

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

+ func (m *VEvent) XXX_Size() int

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

+ type VEventType int32

+ const VEventType_BEGIN

+ const VEventType_COMMIT

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

+ func (x VEventType) String() string

+ type VGtid struct

+ ShardGtids []*ShardGtid

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*VGtid) ProtoMessage()

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

+ func (m *VGtid) Reset()

+ func (m *VGtid) String() string

+ func (m *VGtid) XXX_DiscardUnknown()

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

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

+ func (m *VGtid) XXX_Size() int

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

+ type VStreamRequest struct

+ EffectiveCallerId *vtrpc.CallerID

+ Filter *Filter

+ ImmediateCallerId *query.VTGateCallerID

+ Position string

+ TableLastPKs []*TableLastPK

+ Target *query.Target

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*VStreamRequest) ProtoMessage()

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

+ func (m *VStreamRequest) GetFilter() *Filter

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

+ func (m *VStreamRequest) GetPosition() string

+ func (m *VStreamRequest) GetTableLastPKs() []*TableLastPK

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

+ func (m *VStreamRequest) Reset()

+ func (m *VStreamRequest) String() string

+ func (m *VStreamRequest) XXX_DiscardUnknown()

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

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

+ func (m *VStreamRequest) XXX_Size() int

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

+ type VStreamResponse struct

+ Events []*VEvent

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*VStreamResponse) ProtoMessage()

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

+ func (m *VStreamResponse) Reset()

+ func (m *VStreamResponse) String() string

+ func (m *VStreamResponse) XXX_DiscardUnknown()

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

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

+ func (m *VStreamResponse) XXX_Size() int

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

+ type VStreamResultsRequest struct

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *query.VTGateCallerID

+ Query string

+ Target *query.Target

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*VStreamResultsRequest) ProtoMessage()

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

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

+ func (m *VStreamResultsRequest) GetQuery() string

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

+ func (m *VStreamResultsRequest) Reset()

+ func (m *VStreamResultsRequest) String() string

+ func (m *VStreamResultsRequest) XXX_DiscardUnknown()

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

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

+ func (m *VStreamResultsRequest) XXX_Size() int

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

+ type VStreamResultsResponse struct

+ Fields []*query.Field

+ Gtid string

+ Rows []*query.Row

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*VStreamResultsResponse) ProtoMessage()

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

+ func (m *VStreamResultsResponse) GetGtid() string

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

+ func (m *VStreamResultsResponse) Reset()

+ func (m *VStreamResultsResponse) String() string

+ func (m *VStreamResultsResponse) XXX_DiscardUnknown()

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

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

+ func (m *VStreamResultsResponse) XXX_Size() int

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

+ type VStreamRowsRequest struct

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *query.VTGateCallerID

+ Lastpk *query.QueryResult

+ Query string

+ Target *query.Target

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*VStreamRowsRequest) ProtoMessage()

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

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

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

+ func (m *VStreamRowsRequest) GetQuery() string

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

+ func (m *VStreamRowsRequest) Reset()

+ func (m *VStreamRowsRequest) String() string

+ func (m *VStreamRowsRequest) XXX_DiscardUnknown()

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

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

+ func (m *VStreamRowsRequest) XXX_Size() int

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

+ type VStreamRowsResponse struct

+ Fields []*query.Field

+ Gtid string

+ Lastpk *query.Row

+ Pkfields []*query.Field

+ Rows []*query.Row

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*VStreamRowsResponse) ProtoMessage()

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

+ func (m *VStreamRowsResponse) GetGtid() string

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

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

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

+ func (m *VStreamRowsResponse) Reset()

+ func (m *VStreamRowsResponse) String() string

+ func (m *VStreamRowsResponse) XXX_DiscardUnknown()

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

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

+ func (m *VStreamRowsResponse) XXX_Size() int

+ func (m *VStreamRowsResponse) XXX_Unmarshal(b []byte) error