query

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 ExecuteOptions

+ Timeout isExecuteOptions_Timeout

+ func (m *ExecuteOptions) GetTimeout() isExecuteOptions_Timeout

+ func (x *ExecuteOptions) GetAuthoritativeTimeout() int64

+ type ExecuteOptions_AuthoritativeTimeout struct

+ AuthoritativeTimeout int64

+ func (m *ExecuteOptions_AuthoritativeTimeout) CloneVT() isExecuteOptions_Timeout

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

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

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

type RealtimeStats

+ TxUnresolved bool

+ func (x *RealtimeStats) GetTxUnresolved() bool

type Type

+ const Type_VECTOR

+ type UnresolvedTransactionsRequest struct

+ AbandonAge int64

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Target *Target

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

+ func (*UnresolvedTransactionsRequest) ProtoMessage()

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

+ func (m *UnresolvedTransactionsRequest) CloneVT() *UnresolvedTransactionsRequest

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

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

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

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

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

+ func (x *UnresolvedTransactionsRequest) GetAbandonAge() int64

+ func (x *UnresolvedTransactionsRequest) GetEffectiveCallerId() *vtrpc.CallerID

+ func (x *UnresolvedTransactionsRequest) GetImmediateCallerId() *VTGateCallerID

+ func (x *UnresolvedTransactionsRequest) GetTarget() *Target

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

+ func (x *UnresolvedTransactionsRequest) Reset()

+ func (x *UnresolvedTransactionsRequest) String() string

+ type UnresolvedTransactionsResponse struct

+ Transactions []*TransactionMetadata

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

+ func (*UnresolvedTransactionsResponse) ProtoMessage()

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

+ func (m *UnresolvedTransactionsResponse) CloneVT() *UnresolvedTransactionsResponse

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

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

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

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

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

+ func (x *UnresolvedTransactionsResponse) GetTransactions() []*TransactionMetadata

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

+ func (x *UnresolvedTransactionsResponse) Reset()

+ func (x *UnresolvedTransactionsResponse) String() string

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 GetSchemaResponse

+ Udfs []*UDFInfo

+ func (x *GetSchemaResponse) GetUdfs() []*UDFInfo

type RealtimeStats

+ UdfsChanged bool

+ func (x *RealtimeStats) GetUdfsChanged() bool

type SchemaTableType

+ const SchemaTableType_UDFS

+ type UDFInfo struct

+ Aggregating bool

+ Name string

+ ReturnType Type

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

+ func (*UDFInfo) ProtoMessage()

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

+ func (m *UDFInfo) CloneVT() *UDFInfo

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

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

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

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

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

+ func (x *UDFInfo) GetAggregating() bool

+ func (x *UDFInfo) GetName() string

+ func (x *UDFInfo) GetReturnType() Type

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

+ func (x *UDFInfo) Reset()

+ func (x *UDFInfo) String() string

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

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

Changes in this version

type Type

+ const Type_RAW

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

type AggregateStats

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

+ func (m *AggregateStats) CloneVT() *AggregateStats

type BeginExecuteRequest

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

+ func (m *BeginExecuteRequest) CloneVT() *BeginExecuteRequest

type BeginExecuteResponse

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

+ func (m *BeginExecuteResponse) CloneVT() *BeginExecuteResponse

type BeginRequest

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

+ func (m *BeginRequest) CloneVT() *BeginRequest

type BeginResponse

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

+ func (m *BeginResponse) CloneVT() *BeginResponse

type BeginStreamExecuteRequest

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

+ func (m *BeginStreamExecuteRequest) CloneVT() *BeginStreamExecuteRequest

type BeginStreamExecuteResponse

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

+ func (m *BeginStreamExecuteResponse) CloneVT() *BeginStreamExecuteResponse

type BindVariable

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

+ func (m *BindVariable) CloneVT() *BindVariable

type BoundQuery

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

+ func (m *BoundQuery) CloneVT() *BoundQuery

type CommitPreparedRequest

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

+ func (m *CommitPreparedRequest) CloneVT() *CommitPreparedRequest

type CommitPreparedResponse

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

+ func (m *CommitPreparedResponse) CloneVT() *CommitPreparedResponse

type CommitRequest

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

+ func (m *CommitRequest) CloneVT() *CommitRequest

type CommitResponse

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

+ func (m *CommitResponse) CloneVT() *CommitResponse

type ConcludeTransactionRequest

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

+ func (m *ConcludeTransactionRequest) CloneVT() *ConcludeTransactionRequest

type ConcludeTransactionResponse

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

+ func (m *ConcludeTransactionResponse) CloneVT() *ConcludeTransactionResponse

type CreateTransactionRequest

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

+ func (m *CreateTransactionRequest) CloneVT() *CreateTransactionRequest

type CreateTransactionResponse

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

+ func (m *CreateTransactionResponse) CloneVT() *CreateTransactionResponse

type EventToken

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

+ func (m *EventToken) CloneVT() *EventToken

type ExecuteOptions

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

+ func (m *ExecuteOptions) CloneVT() *ExecuteOptions

type ExecuteRequest

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

+ func (m *ExecuteRequest) CloneVT() *ExecuteRequest

type ExecuteResponse

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

+ func (m *ExecuteResponse) CloneVT() *ExecuteResponse

type Field

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

+ func (m *Field) CloneVT() *Field

type GetSchemaRequest

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

+ func (m *GetSchemaRequest) CloneVT() *GetSchemaRequest

type GetSchemaResponse

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

+ func (m *GetSchemaResponse) CloneVT() *GetSchemaResponse

type MessageAckRequest

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

+ func (m *MessageAckRequest) CloneVT() *MessageAckRequest

type MessageAckResponse

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

+ func (m *MessageAckResponse) CloneVT() *MessageAckResponse

type MessageStreamRequest

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

+ func (m *MessageStreamRequest) CloneVT() *MessageStreamRequest

type MessageStreamResponse

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

+ func (m *MessageStreamResponse) CloneVT() *MessageStreamResponse

type PrepareRequest

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

+ func (m *PrepareRequest) CloneVT() *PrepareRequest

type PrepareResponse

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

+ func (m *PrepareResponse) CloneVT() *PrepareResponse

type QueryResult

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

+ func (m *QueryResult) CloneVT() *QueryResult

type QueryWarning

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

+ func (m *QueryWarning) CloneVT() *QueryWarning

type ReadTransactionRequest

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

+ func (m *ReadTransactionRequest) CloneVT() *ReadTransactionRequest

type ReadTransactionResponse

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

+ func (m *ReadTransactionResponse) CloneVT() *ReadTransactionResponse

type RealtimeStats

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

+ func (m *RealtimeStats) CloneVT() *RealtimeStats

type ReleaseRequest

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

+ func (m *ReleaseRequest) CloneVT() *ReleaseRequest

type ReleaseResponse

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

+ func (m *ReleaseResponse) CloneVT() *ReleaseResponse

type ReserveBeginExecuteRequest

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

+ func (m *ReserveBeginExecuteRequest) CloneVT() *ReserveBeginExecuteRequest

type ReserveBeginExecuteResponse

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

+ func (m *ReserveBeginExecuteResponse) CloneVT() *ReserveBeginExecuteResponse

type ReserveBeginStreamExecuteRequest

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

+ func (m *ReserveBeginStreamExecuteRequest) CloneVT() *ReserveBeginStreamExecuteRequest

type ReserveBeginStreamExecuteResponse

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

+ func (m *ReserveBeginStreamExecuteResponse) CloneVT() *ReserveBeginStreamExecuteResponse

type ReserveExecuteRequest

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

+ func (m *ReserveExecuteRequest) CloneVT() *ReserveExecuteRequest

type ReserveExecuteResponse

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

+ func (m *ReserveExecuteResponse) CloneVT() *ReserveExecuteResponse

type ReserveStreamExecuteRequest

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

+ func (m *ReserveStreamExecuteRequest) CloneVT() *ReserveStreamExecuteRequest

type ReserveStreamExecuteResponse

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

+ func (m *ReserveStreamExecuteResponse) CloneVT() *ReserveStreamExecuteResponse

type ResultWithError

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

+ func (m *ResultWithError) CloneVT() *ResultWithError

type RollbackPreparedRequest

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

+ func (m *RollbackPreparedRequest) CloneVT() *RollbackPreparedRequest

type RollbackPreparedResponse

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

+ func (m *RollbackPreparedResponse) CloneVT() *RollbackPreparedResponse

type RollbackRequest

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

+ func (m *RollbackRequest) CloneVT() *RollbackRequest

type RollbackResponse

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

+ func (m *RollbackResponse) CloneVT() *RollbackResponse

type Row

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

+ func (m *Row) CloneVT() *Row

type SetRollbackRequest

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

+ func (m *SetRollbackRequest) CloneVT() *SetRollbackRequest

type SetRollbackResponse

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

+ func (m *SetRollbackResponse) CloneVT() *SetRollbackResponse

type StartCommitRequest

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

+ func (m *StartCommitRequest) CloneVT() *StartCommitRequest

type StartCommitResponse

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

+ func (m *StartCommitResponse) CloneVT() *StartCommitResponse

type StreamEvent

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

+ func (m *StreamEvent) CloneVT() *StreamEvent

type StreamEvent_Statement

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

+ func (m *StreamEvent_Statement) CloneVT() *StreamEvent_Statement

type StreamExecuteRequest

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

+ func (m *StreamExecuteRequest) CloneVT() *StreamExecuteRequest

type StreamExecuteResponse

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

+ func (m *StreamExecuteResponse) CloneVT() *StreamExecuteResponse

type StreamHealthRequest

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

+ func (m *StreamHealthRequest) CloneVT() *StreamHealthRequest

type StreamHealthResponse

+ PrimaryTermStartTimestamp int64

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

+ func (m *StreamHealthResponse) CloneVT() *StreamHealthResponse

+ func (x *StreamHealthResponse) GetPrimaryTermStartTimestamp() int64

type Target

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

+ func (m *Target) CloneVT() *Target

type TransactionMetadata

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

+ func (m *TransactionMetadata) CloneVT() *TransactionMetadata

type VTGateCallerID

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

+ func (m *VTGateCallerID) CloneVT() *VTGateCallerID

type Value

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

+ func (m *Value) CloneVT() *Value

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 ExecuteOptions

+ Priority string

+ WorkloadName string

+ func (x *ExecuteOptions) GetPriority() string

+ func (x *ExecuteOptions) GetWorkloadName() string

type ExecuteOptions_PlannerVersion

+ const ExecuteOptions_V3Insert

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

+ var ExecuteOptions_Consolidator_name = map[int32]string

+ var ExecuteOptions_Consolidator_value = map[string]int32

+ var ExecuteOptions_TransactionAccessMode_name = map[int32]string

+ var ExecuteOptions_TransactionAccessMode_value = map[string]int32

+ var SchemaTableType_name = map[int32]string

+ var SchemaTableType_value = map[string]int32

type ExecuteOptions

+ Consolidator ExecuteOptions_Consolidator

+ TransactionAccessMode []ExecuteOptions_TransactionAccessMode

+ func (x *ExecuteOptions) GetConsolidator() ExecuteOptions_Consolidator

+ func (x *ExecuteOptions) GetTransactionAccessMode() []ExecuteOptions_TransactionAccessMode

+ type ExecuteOptions_Consolidator int32

+ const ExecuteOptions_CONSOLIDATOR_DISABLED

+ const ExecuteOptions_CONSOLIDATOR_ENABLED

+ const ExecuteOptions_CONSOLIDATOR_ENABLED_REPLICAS

+ const ExecuteOptions_CONSOLIDATOR_UNSPECIFIED

+ func (ExecuteOptions_Consolidator) Descriptor() protoreflect.EnumDescriptor

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

+ func (ExecuteOptions_Consolidator) Type() protoreflect.EnumType

+ func (x ExecuteOptions_Consolidator) Enum() *ExecuteOptions_Consolidator

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

+ func (x ExecuteOptions_Consolidator) String() string

+ type ExecuteOptions_TransactionAccessMode int32

+ const ExecuteOptions_CONSISTENT_SNAPSHOT

+ const ExecuteOptions_READ_ONLY

+ const ExecuteOptions_READ_WRITE

+ func (ExecuteOptions_TransactionAccessMode) Descriptor() protoreflect.EnumDescriptor

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

+ func (ExecuteOptions_TransactionAccessMode) Type() protoreflect.EnumType

+ func (x ExecuteOptions_TransactionAccessMode) Enum() *ExecuteOptions_TransactionAccessMode

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

+ func (x ExecuteOptions_TransactionAccessMode) String() string

+ type GetSchemaRequest struct

+ TableNames []string

+ TableType SchemaTableType

+ Target *Target

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

+ func (*GetSchemaRequest) ProtoMessage()

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

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

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

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

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

+ func (x *GetSchemaRequest) GetTableNames() []string

+ func (x *GetSchemaRequest) GetTableType() SchemaTableType

+ func (x *GetSchemaRequest) GetTarget() *Target

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

+ func (x *GetSchemaRequest) Reset()

+ func (x *GetSchemaRequest) String() string

+ type GetSchemaResponse struct

+ TableDefinition map[string]string

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

+ func (*GetSchemaResponse) ProtoMessage()

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

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

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

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

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

+ func (x *GetSchemaResponse) GetTableDefinition() map[string]string

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

+ func (x *GetSchemaResponse) Reset()

+ func (x *GetSchemaResponse) String() string

type RealtimeStats

+ ViewSchemaChanged []string

+ func (x *RealtimeStats) GetViewSchemaChanged() []string

+ type SchemaTableType int32

+ const SchemaTableType_ALL

+ const SchemaTableType_TABLES

+ const SchemaTableType_VIEWS

+ func (SchemaTableType) Descriptor() protoreflect.EnumDescriptor

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

+ func (SchemaTableType) Type() protoreflect.EnumType

+ func (x SchemaTableType) Enum() *SchemaTableType

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

+ func (x SchemaTableType) String() string

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

type BeginExecuteResponse

+ SessionStateChanges string

+ func (x *BeginExecuteResponse) GetSessionStateChanges() string

type BeginResponse

+ SessionStateChanges string

+ func (x *BeginResponse) GetSessionStateChanges() string

type BeginStreamExecuteResponse

+ SessionStateChanges string

+ func (x *BeginStreamExecuteResponse) GetSessionStateChanges() string

type QueryResult

+ SessionStateChanges string

+ func (x *QueryResult) GetSessionStateChanges() string

type ReserveBeginExecuteResponse

+ SessionStateChanges string

+ func (x *ReserveBeginExecuteResponse) GetSessionStateChanges() string

type ReserveBeginStreamExecuteResponse

+ SessionStateChanges string

+ func (x *ReserveBeginStreamExecuteResponse) GetSessionStateChanges() string

type Type

+ const Type_BITNUM

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

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

type QueryResult

+ Info string

+ func (x *QueryResult) GetInfo() 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 BeginStreamExecuteRequest struct

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Options *ExecuteOptions

+ PreQueries []string

+ Query *BoundQuery

+ ReservedId int64

+ Target *Target

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

+ func (*BeginStreamExecuteRequest) ProtoMessage()

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

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

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

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

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

+ func (x *BeginStreamExecuteRequest) GetEffectiveCallerId() *vtrpc.CallerID

+ func (x *BeginStreamExecuteRequest) GetImmediateCallerId() *VTGateCallerID

+ func (x *BeginStreamExecuteRequest) GetOptions() *ExecuteOptions

+ func (x *BeginStreamExecuteRequest) GetPreQueries() []string

+ func (x *BeginStreamExecuteRequest) GetQuery() *BoundQuery

+ func (x *BeginStreamExecuteRequest) GetReservedId() int64

+ func (x *BeginStreamExecuteRequest) GetTarget() *Target

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

+ func (x *BeginStreamExecuteRequest) Reset()

+ func (x *BeginStreamExecuteRequest) String() string

+ type BeginStreamExecuteResponse struct

+ Error *vtrpc.RPCError

+ Result *QueryResult

+ TabletAlias *topodata.TabletAlias

+ TransactionId int64

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

+ func (*BeginStreamExecuteResponse) ProtoMessage()

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

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

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

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

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

+ func (x *BeginStreamExecuteResponse) GetError() *vtrpc.RPCError

+ func (x *BeginStreamExecuteResponse) GetResult() *QueryResult

+ func (x *BeginStreamExecuteResponse) GetTabletAlias() *topodata.TabletAlias

+ func (x *BeginStreamExecuteResponse) GetTransactionId() int64

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

+ func (x *BeginStreamExecuteResponse) Reset()

+ func (x *BeginStreamExecuteResponse) String() string

+ type ReserveBeginStreamExecuteRequest struct

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Options *ExecuteOptions

+ PostBeginQueries []string

+ PreQueries []string

+ Query *BoundQuery

+ Target *Target

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

+ func (*ReserveBeginStreamExecuteRequest) ProtoMessage()

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

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

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

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

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

+ func (x *ReserveBeginStreamExecuteRequest) GetEffectiveCallerId() *vtrpc.CallerID

+ func (x *ReserveBeginStreamExecuteRequest) GetImmediateCallerId() *VTGateCallerID

+ func (x *ReserveBeginStreamExecuteRequest) GetOptions() *ExecuteOptions

+ func (x *ReserveBeginStreamExecuteRequest) GetPostBeginQueries() []string

+ func (x *ReserveBeginStreamExecuteRequest) GetPreQueries() []string

+ func (x *ReserveBeginStreamExecuteRequest) GetQuery() *BoundQuery

+ func (x *ReserveBeginStreamExecuteRequest) GetTarget() *Target

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

+ func (x *ReserveBeginStreamExecuteRequest) Reset()

+ func (x *ReserveBeginStreamExecuteRequest) String() string

+ type ReserveBeginStreamExecuteResponse struct

+ Error *vtrpc.RPCError

+ ReservedId int64

+ Result *QueryResult

+ TabletAlias *topodata.TabletAlias

+ TransactionId int64

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

+ func (*ReserveBeginStreamExecuteResponse) ProtoMessage()

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

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

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

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

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

+ func (x *ReserveBeginStreamExecuteResponse) GetError() *vtrpc.RPCError

+ func (x *ReserveBeginStreamExecuteResponse) GetReservedId() int64

+ func (x *ReserveBeginStreamExecuteResponse) GetResult() *QueryResult

+ func (x *ReserveBeginStreamExecuteResponse) GetTabletAlias() *topodata.TabletAlias

+ func (x *ReserveBeginStreamExecuteResponse) GetTransactionId() int64

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

+ func (x *ReserveBeginStreamExecuteResponse) Reset()

+ func (x *ReserveBeginStreamExecuteResponse) String() string

+ type ReserveStreamExecuteRequest struct

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Options *ExecuteOptions

+ PreQueries []string

+ Query *BoundQuery

+ Target *Target

+ TransactionId int64

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

+ func (*ReserveStreamExecuteRequest) ProtoMessage()

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

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

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

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

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

+ func (x *ReserveStreamExecuteRequest) GetEffectiveCallerId() *vtrpc.CallerID

+ func (x *ReserveStreamExecuteRequest) GetImmediateCallerId() *VTGateCallerID

+ func (x *ReserveStreamExecuteRequest) GetOptions() *ExecuteOptions

+ func (x *ReserveStreamExecuteRequest) GetPreQueries() []string

+ func (x *ReserveStreamExecuteRequest) GetQuery() *BoundQuery

+ func (x *ReserveStreamExecuteRequest) GetTarget() *Target

+ func (x *ReserveStreamExecuteRequest) GetTransactionId() int64

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

+ func (x *ReserveStreamExecuteRequest) Reset()

+ func (x *ReserveStreamExecuteRequest) String() string

+ type ReserveStreamExecuteResponse struct

+ Error *vtrpc.RPCError

+ ReservedId int64

+ Result *QueryResult

+ TabletAlias *topodata.TabletAlias

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

+ func (*ReserveStreamExecuteResponse) ProtoMessage()

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

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

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

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

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

+ func (x *ReserveStreamExecuteResponse) GetError() *vtrpc.RPCError

+ func (x *ReserveStreamExecuteResponse) GetReservedId() int64

+ func (x *ReserveStreamExecuteResponse) GetResult() *QueryResult

+ func (x *ReserveStreamExecuteResponse) GetTabletAlias() *topodata.TabletAlias

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

+ func (x *ReserveStreamExecuteResponse) Reset()

+ func (x *ReserveStreamExecuteResponse) String() string

type StreamExecuteRequest

+ ReservedId int64

+ func (x *StreamExecuteRequest) GetReservedId() int64

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

Changes in this version

type Type

+ const Type_HEXNUM

+ const Type_HEXVAL

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 AggregateStats

+ ReplicationLagSecondsMax uint32

+ ReplicationLagSecondsMin uint32

+ func (x *AggregateStats) GetReplicationLagSecondsMax() uint32

+ func (x *AggregateStats) GetReplicationLagSecondsMin() uint32

type ExecuteOptions_PlannerVersion

+ const ExecuteOptions_Gen4CompareV3

type RealtimeStats

+ FilteredReplicationLagSeconds int64

+ ReplicationLagSeconds uint32

+ func (x *RealtimeStats) GetFilteredReplicationLagSeconds() int64

+ func (x *RealtimeStats) GetReplicationLagSeconds() uint32

type ReserveBeginExecuteRequest

+ PostBeginQueries []string

+ func (x *ReserveBeginExecuteRequest) GetPostBeginQueries() []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_query_proto protoreflect.FileDescriptor

type AggregateStats

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

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

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

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

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

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

type BeginExecuteBatchRequest

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

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

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

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

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

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

type BeginExecuteBatchResponse

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

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

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

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

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

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

type BeginExecuteRequest

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

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

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

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

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

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

type BeginExecuteResponse

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

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

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

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

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

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

type BeginRequest

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

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

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

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

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

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

type BeginResponse

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

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

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

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

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

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

type BindVariable

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

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

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

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

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

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

type BoundQuery

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

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

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

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

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

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

type CommitPreparedRequest

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

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

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

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

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

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

type CommitPreparedResponse

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

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

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

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

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

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

type CommitRequest

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

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

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

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

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

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

type CommitResponse

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

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

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

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

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

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

type ConcludeTransactionRequest

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

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

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

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

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

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

type ConcludeTransactionResponse

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

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

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

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

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

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

type CreateTransactionRequest

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

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

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

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

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

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

type CreateTransactionResponse

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

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

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

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

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

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

type EventToken

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

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

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

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

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

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

type ExecuteBatchRequest

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

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

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

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

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

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

type ExecuteBatchResponse

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

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

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

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

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

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

type ExecuteOptions

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

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

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

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

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

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

type ExecuteOptions_IncludedFields

+ func (ExecuteOptions_IncludedFields) Descriptor() protoreflect.EnumDescriptor

+ func (ExecuteOptions_IncludedFields) Type() protoreflect.EnumType

+ func (x ExecuteOptions_IncludedFields) Enum() *ExecuteOptions_IncludedFields

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

type ExecuteOptions_PlannerVersion

+ func (ExecuteOptions_PlannerVersion) Descriptor() protoreflect.EnumDescriptor

+ func (ExecuteOptions_PlannerVersion) Type() protoreflect.EnumType

+ func (x ExecuteOptions_PlannerVersion) Enum() *ExecuteOptions_PlannerVersion

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

type ExecuteOptions_TransactionIsolation

+ func (ExecuteOptions_TransactionIsolation) Descriptor() protoreflect.EnumDescriptor

+ func (ExecuteOptions_TransactionIsolation) Type() protoreflect.EnumType

+ func (x ExecuteOptions_TransactionIsolation) Enum() *ExecuteOptions_TransactionIsolation

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

type ExecuteOptions_Workload

+ func (ExecuteOptions_Workload) Descriptor() protoreflect.EnumDescriptor

+ func (ExecuteOptions_Workload) Type() protoreflect.EnumType

+ func (x ExecuteOptions_Workload) Enum() *ExecuteOptions_Workload

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

type ExecuteRequest

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

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

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

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

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

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

type ExecuteResponse

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

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

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

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

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

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

type Field

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

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

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

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

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

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

type Flag

+ func (Flag) Descriptor() protoreflect.EnumDescriptor

+ func (Flag) Type() protoreflect.EnumType

+ func (x Flag) Enum() *Flag

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

type MessageAckRequest

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

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

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

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

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

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

type MessageAckResponse

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

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

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

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

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

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

type MessageStreamRequest

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

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

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

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

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

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

type MessageStreamResponse

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

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

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

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

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

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

type MySqlFlag

+ func (MySqlFlag) Descriptor() protoreflect.EnumDescriptor

+ func (MySqlFlag) Type() protoreflect.EnumType

+ func (x MySqlFlag) Enum() *MySqlFlag

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

type PrepareRequest

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

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

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

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

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

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

type PrepareResponse

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

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

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

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

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

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

type QueryResult

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

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

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

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

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

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

type QueryWarning

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

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

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

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

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

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

type ReadTransactionRequest

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

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

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

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

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

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

type ReadTransactionResponse

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

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

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

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

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

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

type RealtimeStats

+ TableSchemaChanged []string

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

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

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

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

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

+ func (x *RealtimeStats) GetTableSchemaChanged() []string

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

type ReleaseRequest

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

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

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

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

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

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

type ReleaseResponse

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

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

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

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

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

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

type ReserveBeginExecuteRequest

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

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

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

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

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

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

type ReserveBeginExecuteResponse

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

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

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

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

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

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

type ReserveExecuteRequest

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

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

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

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

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

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

type ReserveExecuteResponse

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

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

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

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

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

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

type ResultWithError

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

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

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

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

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

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

type RollbackPreparedRequest

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

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

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

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

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

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

type RollbackPreparedResponse

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

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

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

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

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

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

type RollbackRequest

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

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

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

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

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

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

type RollbackResponse

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

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

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

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

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

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

type Row

+ func RowFromVTPool() *Row

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

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

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

+ func (m *Row) ResetVT()

+ func (m *Row) ReturnToVTPool()

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

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

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

type SetRollbackRequest

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

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

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

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

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

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

type SetRollbackResponse

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

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

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

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

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

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

type StartCommitRequest

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

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

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

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

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

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

type StartCommitResponse

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

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

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

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

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

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

type StreamEvent

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

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

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

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

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

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

type StreamEvent_Statement

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

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

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

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

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

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

type StreamEvent_Statement_Category

+ func (StreamEvent_Statement_Category) Descriptor() protoreflect.EnumDescriptor

+ func (StreamEvent_Statement_Category) Type() protoreflect.EnumType

+ func (x StreamEvent_Statement_Category) Enum() *StreamEvent_Statement_Category

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

type StreamExecuteRequest

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

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

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

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

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

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

type StreamExecuteResponse

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

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

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

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

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

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

type StreamHealthRequest

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

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

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

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

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

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

type StreamHealthResponse

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

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

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

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

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

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

type Target

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

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

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

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

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

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

type TransactionMetadata

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

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

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

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

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

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

type TransactionState

+ func (TransactionState) Descriptor() protoreflect.EnumDescriptor

+ func (TransactionState) Type() protoreflect.EnumType

+ func (x TransactionState) Enum() *TransactionState

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

type Type

+ func (Type) Descriptor() protoreflect.EnumDescriptor

+ func (Type) Type() protoreflect.EnumType

+ func (x Type) Enum() *Type

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

type VTGateCallerID

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

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

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

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

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

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

type Value

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

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

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

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

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

+ func (x *Value) 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 ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow")

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

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

+ var ExecuteOptions_PlannerVersion_name = map[int32]string

+ var ExecuteOptions_PlannerVersion_value = map[string]int32

type AggregateStats

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

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

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

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

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

type BeginExecuteBatchRequest

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

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

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

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

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

type BeginExecuteBatchResponse

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

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

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

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

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

type BeginExecuteRequest

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

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

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

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

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

type BeginExecuteResponse

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

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

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

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

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

type BeginRequest

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

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

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

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

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

type BeginResponse

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

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

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

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

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

type BindVariable

+ func (cached *BindVariable) CachedSize(alloc bool) int64

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

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

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

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

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

type BoundQuery

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

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

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

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

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

type CommitPreparedRequest

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

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

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

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

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

type CommitPreparedResponse

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

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

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

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

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

type CommitRequest

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

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

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

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

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

type CommitResponse

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

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

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

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

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

type ConcludeTransactionRequest

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

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

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

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

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

type ConcludeTransactionResponse

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

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

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

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

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

type CreateTransactionRequest

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

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

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

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

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

type CreateTransactionResponse

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

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

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

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

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

type EventToken

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

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

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

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

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

type ExecuteBatchRequest

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

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

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

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

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

type ExecuteBatchResponse

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

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

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

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

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

type ExecuteOptions

+ HasCreatedTempTables bool

+ PlannerVersion ExecuteOptions_PlannerVersion

+ func (m *ExecuteOptions) GetHasCreatedTempTables() bool

+ func (m *ExecuteOptions) GetPlannerVersion() ExecuteOptions_PlannerVersion

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

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

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

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

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

+ type ExecuteOptions_PlannerVersion int32

+ const ExecuteOptions_DEFAULT_PLANNER

+ const ExecuteOptions_Gen4

+ const ExecuteOptions_Gen4Greedy

+ const ExecuteOptions_Gen4Left2Right

+ const ExecuteOptions_Gen4WithFallback

+ const ExecuteOptions_V3

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

+ func (x ExecuteOptions_PlannerVersion) String() string

type ExecuteRequest

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

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

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

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

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

type ExecuteResponse

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

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

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

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

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

type Field

+ func (cached *Field) CachedSize(alloc bool) int64

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

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

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

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

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

type MessageAckRequest

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

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

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

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

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

type MessageAckResponse

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

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

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

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

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

type MessageStreamRequest

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

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

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

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

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

type MessageStreamResponse

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

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

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

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

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

type PrepareRequest

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

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

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

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

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

type PrepareResponse

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

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

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

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

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

type QueryResult

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

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

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

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

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

type QueryWarning

+ func (cached *QueryWarning) CachedSize(alloc bool) int64

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

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

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

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

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

type ReadTransactionRequest

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

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

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

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

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

type ReadTransactionResponse

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

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

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

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

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

type RealtimeStats

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

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

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

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

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

type ReleaseRequest

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

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

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

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

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

type ReleaseResponse

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

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

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

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

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

type ReserveBeginExecuteRequest

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

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

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

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

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

type ReserveBeginExecuteResponse

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

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

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

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

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

type ReserveExecuteRequest

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

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

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

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

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

type ReserveExecuteResponse

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

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

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

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

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

type ResultWithError

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

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

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

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

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

type RollbackPreparedRequest

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

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

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

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

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

type RollbackPreparedResponse

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

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

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

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

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

type RollbackRequest

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

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

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

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

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

type RollbackResponse

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

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

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

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

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

type Row

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

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

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

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

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

type SetRollbackRequest

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

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

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

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

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

type SetRollbackResponse

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

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

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

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

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

type StartCommitRequest

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

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

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

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

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

type StartCommitResponse

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

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

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

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

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

type StreamEvent

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

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

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

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

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

type StreamEvent_Statement

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

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

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

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

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

type StreamExecuteRequest

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

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

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

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

+ func (m *StreamExecuteRequest) Unmarshal(dAtA []byte) error

type StreamExecuteResponse

+ func (m *StreamExecuteResponse) Marshal() (dAtA []byte, err error)

+ func (m *StreamExecuteResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *StreamExecuteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StreamExecuteResponse) Size() (n int)

+ func (m *StreamExecuteResponse) Unmarshal(dAtA []byte) error

type StreamHealthRequest

+ func (m *StreamHealthRequest) Marshal() (dAtA []byte, err error)

+ func (m *StreamHealthRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *StreamHealthRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StreamHealthRequest) Size() (n int)

+ func (m *StreamHealthRequest) Unmarshal(dAtA []byte) error

type StreamHealthResponse

+ func (m *StreamHealthResponse) Marshal() (dAtA []byte, err error)

+ func (m *StreamHealthResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *StreamHealthResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StreamHealthResponse) Size() (n int)

+ func (m *StreamHealthResponse) Unmarshal(dAtA []byte) error

type Target

+ func (cached *Target) CachedSize(alloc bool) int64

+ func (m *Target) Marshal() (dAtA []byte, err error)

+ func (m *Target) MarshalTo(dAtA []byte) (int, error)

+ func (m *Target) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Target) Size() (n int)

+ func (m *Target) Unmarshal(dAtA []byte) error

type TransactionMetadata

+ func (m *TransactionMetadata) Marshal() (dAtA []byte, err error)

+ func (m *TransactionMetadata) MarshalTo(dAtA []byte) (int, error)

+ func (m *TransactionMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TransactionMetadata) Size() (n int)

+ func (m *TransactionMetadata) Unmarshal(dAtA []byte) error

type VTGateCallerID

+ func (m *VTGateCallerID) Marshal() (dAtA []byte, err error)

+ func (m *VTGateCallerID) MarshalTo(dAtA []byte) (int, error)

+ func (m *VTGateCallerID) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *VTGateCallerID) Size() (n int)

+ func (m *VTGateCallerID) Unmarshal(dAtA []byte) error

type Value

+ func (cached *Value) CachedSize(alloc bool) int64

+ func (m *Value) Marshal() (dAtA []byte, err error)

+ func (m *Value) MarshalTo(dAtA []byte) (int, error)

+ func (m *Value) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Value) Size() (n int)

+ func (m *Value) 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

Changes in this version

type Field

+ ColumnType string

+ func (m *Field) GetColumnType() string

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 ExecuteOptions_IncludedFields_name = map[int32]string

+ var ExecuteOptions_IncludedFields_value = map[string]int32

+ var ExecuteOptions_TransactionIsolation_name = map[int32]string

+ var ExecuteOptions_TransactionIsolation_value = map[string]int32

+ var ExecuteOptions_Workload_name = map[int32]string

+ var ExecuteOptions_Workload_value = map[string]int32

+ var Flag_name = map[int32]string

+ var Flag_value = map[string]int32

+ var MySqlFlag_name = map[int32]string

+ var MySqlFlag_value = map[string]int32

+ var StreamEvent_Statement_Category_name = map[int32]string

+ var StreamEvent_Statement_Category_value = map[string]int32

+ var TransactionState_name = map[int32]string

+ var TransactionState_value = map[string]int32

+ var Type_name = map[int32]string

+ var Type_value = map[string]int32

+ type AggregateStats struct

+ HealthyTabletCount int32

+ SecondsBehindMasterMax uint32

+ SecondsBehindMasterMin uint32

+ UnhealthyTabletCount int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AggregateStats) Descriptor() ([]byte, []int)

+ func (*AggregateStats) ProtoMessage()

+ func (m *AggregateStats) GetHealthyTabletCount() int32

+ func (m *AggregateStats) GetSecondsBehindMasterMax() uint32

+ func (m *AggregateStats) GetSecondsBehindMasterMin() uint32

+ func (m *AggregateStats) GetUnhealthyTabletCount() int32

+ func (m *AggregateStats) Reset()

+ func (m *AggregateStats) String() string

+ func (m *AggregateStats) XXX_DiscardUnknown()

+ func (m *AggregateStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AggregateStats) XXX_Merge(src proto.Message)

+ func (m *AggregateStats) XXX_Size() int

+ func (m *AggregateStats) XXX_Unmarshal(b []byte) error

+ type BeginExecuteBatchRequest struct

+ AsTransaction bool

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Options *ExecuteOptions

+ Queries []*BoundQuery

+ Target *Target

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BeginExecuteBatchRequest) Descriptor() ([]byte, []int)

+ func (*BeginExecuteBatchRequest) ProtoMessage()

+ func (m *BeginExecuteBatchRequest) GetAsTransaction() bool

+ func (m *BeginExecuteBatchRequest) GetEffectiveCallerId() *vtrpc.CallerID

+ func (m *BeginExecuteBatchRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *BeginExecuteBatchRequest) GetOptions() *ExecuteOptions

+ func (m *BeginExecuteBatchRequest) GetQueries() []*BoundQuery

+ func (m *BeginExecuteBatchRequest) GetTarget() *Target

+ func (m *BeginExecuteBatchRequest) Reset()

+ func (m *BeginExecuteBatchRequest) String() string

+ func (m *BeginExecuteBatchRequest) XXX_DiscardUnknown()

+ func (m *BeginExecuteBatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BeginExecuteBatchRequest) XXX_Merge(src proto.Message)

+ func (m *BeginExecuteBatchRequest) XXX_Size() int

+ func (m *BeginExecuteBatchRequest) XXX_Unmarshal(b []byte) error

+ type BeginExecuteBatchResponse struct

+ Error *vtrpc.RPCError

+ Results []*QueryResult

+ TabletAlias *topodata.TabletAlias

+ TransactionId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BeginExecuteBatchResponse) Descriptor() ([]byte, []int)

+ func (*BeginExecuteBatchResponse) ProtoMessage()

+ func (m *BeginExecuteBatchResponse) GetError() *vtrpc.RPCError

+ func (m *BeginExecuteBatchResponse) GetResults() []*QueryResult

+ func (m *BeginExecuteBatchResponse) GetTabletAlias() *topodata.TabletAlias

+ func (m *BeginExecuteBatchResponse) GetTransactionId() int64

+ func (m *BeginExecuteBatchResponse) Reset()

+ func (m *BeginExecuteBatchResponse) String() string

+ func (m *BeginExecuteBatchResponse) XXX_DiscardUnknown()

+ func (m *BeginExecuteBatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BeginExecuteBatchResponse) XXX_Merge(src proto.Message)

+ func (m *BeginExecuteBatchResponse) XXX_Size() int

+ func (m *BeginExecuteBatchResponse) XXX_Unmarshal(b []byte) error

+ type BeginExecuteRequest struct

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Options *ExecuteOptions

+ PreQueries []string

+ Query *BoundQuery

+ ReservedId int64

+ Target *Target

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BeginExecuteRequest) Descriptor() ([]byte, []int)

+ func (*BeginExecuteRequest) ProtoMessage()

+ func (m *BeginExecuteRequest) GetEffectiveCallerId() *vtrpc.CallerID

+ func (m *BeginExecuteRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *BeginExecuteRequest) GetOptions() *ExecuteOptions

+ func (m *BeginExecuteRequest) GetPreQueries() []string

+ func (m *BeginExecuteRequest) GetQuery() *BoundQuery

+ func (m *BeginExecuteRequest) GetReservedId() int64

+ func (m *BeginExecuteRequest) GetTarget() *Target

+ func (m *BeginExecuteRequest) Reset()

+ func (m *BeginExecuteRequest) String() string

+ func (m *BeginExecuteRequest) XXX_DiscardUnknown()

+ func (m *BeginExecuteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BeginExecuteRequest) XXX_Merge(src proto.Message)

+ func (m *BeginExecuteRequest) XXX_Size() int

+ func (m *BeginExecuteRequest) XXX_Unmarshal(b []byte) error

+ type BeginExecuteResponse struct

+ Error *vtrpc.RPCError

+ Result *QueryResult

+ TabletAlias *topodata.TabletAlias

+ TransactionId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BeginExecuteResponse) Descriptor() ([]byte, []int)

+ func (*BeginExecuteResponse) ProtoMessage()

+ func (m *BeginExecuteResponse) GetError() *vtrpc.RPCError

+ func (m *BeginExecuteResponse) GetResult() *QueryResult

+ func (m *BeginExecuteResponse) GetTabletAlias() *topodata.TabletAlias

+ func (m *BeginExecuteResponse) GetTransactionId() int64

+ func (m *BeginExecuteResponse) Reset()

+ func (m *BeginExecuteResponse) String() string

+ func (m *BeginExecuteResponse) XXX_DiscardUnknown()

+ func (m *BeginExecuteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BeginExecuteResponse) XXX_Merge(src proto.Message)

+ func (m *BeginExecuteResponse) XXX_Size() int

+ func (m *BeginExecuteResponse) XXX_Unmarshal(b []byte) error

+ type BeginRequest struct

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Options *ExecuteOptions

+ Target *Target

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BeginRequest) Descriptor() ([]byte, []int)

+ func (*BeginRequest) ProtoMessage()

+ func (m *BeginRequest) GetEffectiveCallerId() *vtrpc.CallerID

+ func (m *BeginRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *BeginRequest) GetOptions() *ExecuteOptions

+ func (m *BeginRequest) GetTarget() *Target

+ func (m *BeginRequest) Reset()

+ func (m *BeginRequest) String() string

+ func (m *BeginRequest) XXX_DiscardUnknown()

+ func (m *BeginRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BeginRequest) XXX_Merge(src proto.Message)

+ func (m *BeginRequest) XXX_Size() int

+ func (m *BeginRequest) XXX_Unmarshal(b []byte) error

+ type BeginResponse struct

+ TabletAlias *topodata.TabletAlias

+ TransactionId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BeginResponse) Descriptor() ([]byte, []int)

+ func (*BeginResponse) ProtoMessage()

+ func (m *BeginResponse) GetTabletAlias() *topodata.TabletAlias

+ func (m *BeginResponse) GetTransactionId() int64

+ func (m *BeginResponse) Reset()

+ func (m *BeginResponse) String() string

+ func (m *BeginResponse) XXX_DiscardUnknown()

+ func (m *BeginResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BeginResponse) XXX_Merge(src proto.Message)

+ func (m *BeginResponse) XXX_Size() int

+ func (m *BeginResponse) XXX_Unmarshal(b []byte) error

+ type BindVariable struct

+ Type Type

+ Value []byte

+ Values []*Value

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BindVariable) Descriptor() ([]byte, []int)

+ func (*BindVariable) ProtoMessage()

+ func (m *BindVariable) GetType() Type

+ func (m *BindVariable) GetValue() []byte

+ func (m *BindVariable) GetValues() []*Value

+ func (m *BindVariable) Reset()

+ func (m *BindVariable) String() string

+ func (m *BindVariable) XXX_DiscardUnknown()

+ func (m *BindVariable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BindVariable) XXX_Merge(src proto.Message)

+ func (m *BindVariable) XXX_Size() int

+ func (m *BindVariable) XXX_Unmarshal(b []byte) error

+ type BoundQuery struct

+ BindVariables map[string]*BindVariable

+ Sql string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BoundQuery) Descriptor() ([]byte, []int)

+ func (*BoundQuery) ProtoMessage()

+ func (m *BoundQuery) GetBindVariables() map[string]*BindVariable

+ func (m *BoundQuery) GetSql() string

+ func (m *BoundQuery) Reset()

+ func (m *BoundQuery) String() string

+ func (m *BoundQuery) XXX_DiscardUnknown()

+ func (m *BoundQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BoundQuery) XXX_Merge(src proto.Message)

+ func (m *BoundQuery) XXX_Size() int

+ func (m *BoundQuery) XXX_Unmarshal(b []byte) error

+ type CommitPreparedRequest struct

+ Dtid string

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Target *Target

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CommitPreparedRequest) Descriptor() ([]byte, []int)

+ func (*CommitPreparedRequest) ProtoMessage()

+ func (m *CommitPreparedRequest) GetDtid() string

+ func (m *CommitPreparedRequest) GetEffectiveCallerId() *vtrpc.CallerID

+ func (m *CommitPreparedRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *CommitPreparedRequest) GetTarget() *Target

+ func (m *CommitPreparedRequest) Reset()

+ func (m *CommitPreparedRequest) String() string

+ func (m *CommitPreparedRequest) XXX_DiscardUnknown()

+ func (m *CommitPreparedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CommitPreparedRequest) XXX_Merge(src proto.Message)

+ func (m *CommitPreparedRequest) XXX_Size() int

+ func (m *CommitPreparedRequest) XXX_Unmarshal(b []byte) error

+ type CommitPreparedResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CommitPreparedResponse) Descriptor() ([]byte, []int)

+ func (*CommitPreparedResponse) ProtoMessage()

+ func (m *CommitPreparedResponse) Reset()

+ func (m *CommitPreparedResponse) String() string

+ func (m *CommitPreparedResponse) XXX_DiscardUnknown()

+ func (m *CommitPreparedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CommitPreparedResponse) XXX_Merge(src proto.Message)

+ func (m *CommitPreparedResponse) XXX_Size() int

+ func (m *CommitPreparedResponse) XXX_Unmarshal(b []byte) error

+ type CommitRequest struct

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Target *Target

+ TransactionId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CommitRequest) Descriptor() ([]byte, []int)

+ func (*CommitRequest) ProtoMessage()

+ func (m *CommitRequest) GetEffectiveCallerId() *vtrpc.CallerID

+ func (m *CommitRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *CommitRequest) GetTarget() *Target

+ func (m *CommitRequest) GetTransactionId() int64

+ func (m *CommitRequest) Reset()

+ func (m *CommitRequest) String() string

+ func (m *CommitRequest) XXX_DiscardUnknown()

+ func (m *CommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CommitRequest) XXX_Merge(src proto.Message)

+ func (m *CommitRequest) XXX_Size() int

+ func (m *CommitRequest) XXX_Unmarshal(b []byte) error

+ type CommitResponse struct

+ ReservedId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CommitResponse) Descriptor() ([]byte, []int)

+ func (*CommitResponse) ProtoMessage()

+ func (m *CommitResponse) GetReservedId() int64

+ func (m *CommitResponse) Reset()

+ func (m *CommitResponse) String() string

+ func (m *CommitResponse) XXX_DiscardUnknown()

+ func (m *CommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CommitResponse) XXX_Merge(src proto.Message)

+ func (m *CommitResponse) XXX_Size() int

+ func (m *CommitResponse) XXX_Unmarshal(b []byte) error

+ type ConcludeTransactionRequest struct

+ Dtid string

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Target *Target

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ConcludeTransactionRequest) Descriptor() ([]byte, []int)

+ func (*ConcludeTransactionRequest) ProtoMessage()

+ func (m *ConcludeTransactionRequest) GetDtid() string

+ func (m *ConcludeTransactionRequest) GetEffectiveCallerId() *vtrpc.CallerID

+ func (m *ConcludeTransactionRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *ConcludeTransactionRequest) GetTarget() *Target

+ func (m *ConcludeTransactionRequest) Reset()

+ func (m *ConcludeTransactionRequest) String() string

+ func (m *ConcludeTransactionRequest) XXX_DiscardUnknown()

+ func (m *ConcludeTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ConcludeTransactionRequest) XXX_Merge(src proto.Message)

+ func (m *ConcludeTransactionRequest) XXX_Size() int

+ func (m *ConcludeTransactionRequest) XXX_Unmarshal(b []byte) error

+ type ConcludeTransactionResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ConcludeTransactionResponse) Descriptor() ([]byte, []int)

+ func (*ConcludeTransactionResponse) ProtoMessage()

+ func (m *ConcludeTransactionResponse) Reset()

+ func (m *ConcludeTransactionResponse) String() string

+ func (m *ConcludeTransactionResponse) XXX_DiscardUnknown()

+ func (m *ConcludeTransactionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ConcludeTransactionResponse) XXX_Merge(src proto.Message)

+ func (m *ConcludeTransactionResponse) XXX_Size() int

+ func (m *ConcludeTransactionResponse) XXX_Unmarshal(b []byte) error

+ type CreateTransactionRequest struct

+ Dtid string

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Participants []*Target

+ Target *Target

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CreateTransactionRequest) Descriptor() ([]byte, []int)

+ func (*CreateTransactionRequest) ProtoMessage()

+ func (m *CreateTransactionRequest) GetDtid() string

+ func (m *CreateTransactionRequest) GetEffectiveCallerId() *vtrpc.CallerID

+ func (m *CreateTransactionRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *CreateTransactionRequest) GetParticipants() []*Target

+ func (m *CreateTransactionRequest) GetTarget() *Target

+ func (m *CreateTransactionRequest) Reset()

+ func (m *CreateTransactionRequest) String() string

+ func (m *CreateTransactionRequest) XXX_DiscardUnknown()

+ func (m *CreateTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CreateTransactionRequest) XXX_Merge(src proto.Message)

+ func (m *CreateTransactionRequest) XXX_Size() int

+ func (m *CreateTransactionRequest) XXX_Unmarshal(b []byte) error

+ type CreateTransactionResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CreateTransactionResponse) Descriptor() ([]byte, []int)

+ func (*CreateTransactionResponse) ProtoMessage()

+ func (m *CreateTransactionResponse) Reset()

+ func (m *CreateTransactionResponse) String() string

+ func (m *CreateTransactionResponse) XXX_DiscardUnknown()

+ func (m *CreateTransactionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CreateTransactionResponse) XXX_Merge(src proto.Message)

+ func (m *CreateTransactionResponse) XXX_Size() int

+ func (m *CreateTransactionResponse) XXX_Unmarshal(b []byte) error

+ type EventToken struct

+ Position string

+ Shard string

+ Timestamp int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*EventToken) Descriptor() ([]byte, []int)

+ func (*EventToken) ProtoMessage()

+ func (m *EventToken) GetPosition() string

+ func (m *EventToken) GetShard() string

+ func (m *EventToken) GetTimestamp() int64

+ func (m *EventToken) Reset()

+ func (m *EventToken) String() string

+ func (m *EventToken) XXX_DiscardUnknown()

+ func (m *EventToken) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EventToken) XXX_Merge(src proto.Message)

+ func (m *EventToken) XXX_Size() int

+ func (m *EventToken) XXX_Unmarshal(b []byte) error

+ type ExecuteBatchRequest struct

+ AsTransaction bool

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Options *ExecuteOptions

+ Queries []*BoundQuery

+ Target *Target

+ TransactionId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ExecuteBatchRequest) Descriptor() ([]byte, []int)

+ func (*ExecuteBatchRequest) ProtoMessage()

+ func (m *ExecuteBatchRequest) GetAsTransaction() bool

+ func (m *ExecuteBatchRequest) GetEffectiveCallerId() *vtrpc.CallerID

+ func (m *ExecuteBatchRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *ExecuteBatchRequest) GetOptions() *ExecuteOptions

+ func (m *ExecuteBatchRequest) GetQueries() []*BoundQuery

+ func (m *ExecuteBatchRequest) GetTarget() *Target

+ func (m *ExecuteBatchRequest) GetTransactionId() int64

+ func (m *ExecuteBatchRequest) Reset()

+ func (m *ExecuteBatchRequest) String() string

+ func (m *ExecuteBatchRequest) XXX_DiscardUnknown()

+ func (m *ExecuteBatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ExecuteBatchRequest) XXX_Merge(src proto.Message)

+ func (m *ExecuteBatchRequest) XXX_Size() int

+ func (m *ExecuteBatchRequest) XXX_Unmarshal(b []byte) error

+ type ExecuteBatchResponse struct

+ Results []*QueryResult

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ExecuteBatchResponse) Descriptor() ([]byte, []int)

+ func (*ExecuteBatchResponse) ProtoMessage()

+ func (m *ExecuteBatchResponse) GetResults() []*QueryResult

+ func (m *ExecuteBatchResponse) Reset()

+ func (m *ExecuteBatchResponse) String() string

+ func (m *ExecuteBatchResponse) XXX_DiscardUnknown()

+ func (m *ExecuteBatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ExecuteBatchResponse) XXX_Merge(src proto.Message)

+ func (m *ExecuteBatchResponse) XXX_Size() int

+ func (m *ExecuteBatchResponse) XXX_Unmarshal(b []byte) error

+ type ExecuteOptions struct

+ ClientFoundRows bool

+ IncludedFields ExecuteOptions_IncludedFields

+ SkipQueryPlanCache bool

+ SqlSelectLimit int64

+ TransactionIsolation ExecuteOptions_TransactionIsolation

+ Workload ExecuteOptions_Workload

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ExecuteOptions) Descriptor() ([]byte, []int)

+ func (*ExecuteOptions) ProtoMessage()

+ func (m *ExecuteOptions) GetClientFoundRows() bool

+ func (m *ExecuteOptions) GetIncludedFields() ExecuteOptions_IncludedFields

+ func (m *ExecuteOptions) GetSkipQueryPlanCache() bool

+ func (m *ExecuteOptions) GetSqlSelectLimit() int64

+ func (m *ExecuteOptions) GetTransactionIsolation() ExecuteOptions_TransactionIsolation

+ func (m *ExecuteOptions) GetWorkload() ExecuteOptions_Workload

+ func (m *ExecuteOptions) Reset()

+ func (m *ExecuteOptions) String() string

+ func (m *ExecuteOptions) XXX_DiscardUnknown()

+ func (m *ExecuteOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ExecuteOptions) XXX_Merge(src proto.Message)

+ func (m *ExecuteOptions) XXX_Size() int

+ func (m *ExecuteOptions) XXX_Unmarshal(b []byte) error

+ type ExecuteOptions_IncludedFields int32

+ const ExecuteOptions_ALL

+ const ExecuteOptions_TYPE_AND_NAME

+ const ExecuteOptions_TYPE_ONLY

+ func (ExecuteOptions_IncludedFields) EnumDescriptor() ([]byte, []int)

+ func (x ExecuteOptions_IncludedFields) String() string

+ type ExecuteOptions_TransactionIsolation int32

+ const ExecuteOptions_AUTOCOMMIT

+ const ExecuteOptions_CONSISTENT_SNAPSHOT_READ_ONLY

+ const ExecuteOptions_DEFAULT

+ const ExecuteOptions_READ_COMMITTED

+ const ExecuteOptions_READ_UNCOMMITTED

+ const ExecuteOptions_REPEATABLE_READ

+ const ExecuteOptions_SERIALIZABLE

+ func (ExecuteOptions_TransactionIsolation) EnumDescriptor() ([]byte, []int)

+ func (x ExecuteOptions_TransactionIsolation) String() string

+ type ExecuteOptions_Workload int32

+ const ExecuteOptions_DBA

+ const ExecuteOptions_OLAP

+ const ExecuteOptions_OLTP

+ const ExecuteOptions_UNSPECIFIED

+ func (ExecuteOptions_Workload) EnumDescriptor() ([]byte, []int)

+ func (x ExecuteOptions_Workload) String() string

+ type ExecuteRequest struct

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Options *ExecuteOptions

+ Query *BoundQuery

+ ReservedId int64

+ Target *Target

+ TransactionId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ExecuteRequest) Descriptor() ([]byte, []int)

+ func (*ExecuteRequest) ProtoMessage()

+ func (m *ExecuteRequest) GetEffectiveCallerId() *vtrpc.CallerID

+ func (m *ExecuteRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *ExecuteRequest) GetOptions() *ExecuteOptions

+ func (m *ExecuteRequest) GetQuery() *BoundQuery

+ func (m *ExecuteRequest) GetReservedId() int64

+ func (m *ExecuteRequest) GetTarget() *Target

+ func (m *ExecuteRequest) GetTransactionId() int64

+ func (m *ExecuteRequest) Reset()

+ func (m *ExecuteRequest) String() string

+ func (m *ExecuteRequest) XXX_DiscardUnknown()

+ func (m *ExecuteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ExecuteRequest) XXX_Merge(src proto.Message)

+ func (m *ExecuteRequest) XXX_Size() int

+ func (m *ExecuteRequest) XXX_Unmarshal(b []byte) error

+ type ExecuteResponse struct

+ Result *QueryResult

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ExecuteResponse) Descriptor() ([]byte, []int)

+ func (*ExecuteResponse) ProtoMessage()

+ func (m *ExecuteResponse) GetResult() *QueryResult

+ func (m *ExecuteResponse) Reset()

+ func (m *ExecuteResponse) String() string

+ func (m *ExecuteResponse) XXX_DiscardUnknown()

+ func (m *ExecuteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ExecuteResponse) XXX_Merge(src proto.Message)

+ func (m *ExecuteResponse) XXX_Size() int

+ func (m *ExecuteResponse) XXX_Unmarshal(b []byte) error

+ type Field struct

+ Charset uint32

+ ColumnLength uint32

+ Database string

+ Decimals uint32

+ Flags uint32

+ Name string

+ OrgName string

+ OrgTable string

+ Table string

+ Type Type

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Field) Descriptor() ([]byte, []int)

+ func (*Field) ProtoMessage()

+ func (m *Field) GetCharset() uint32

+ func (m *Field) GetColumnLength() uint32

+ func (m *Field) GetDatabase() string

+ func (m *Field) GetDecimals() uint32

+ func (m *Field) GetFlags() uint32

+ func (m *Field) GetName() string

+ func (m *Field) GetOrgName() string

+ func (m *Field) GetOrgTable() string

+ func (m *Field) GetTable() string

+ func (m *Field) GetType() Type

+ func (m *Field) Reset()

+ func (m *Field) String() string

+ func (m *Field) XXX_DiscardUnknown()

+ func (m *Field) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Field) XXX_Merge(src proto.Message)

+ func (m *Field) XXX_Size() int

+ func (m *Field) XXX_Unmarshal(b []byte) error

+ type Flag int32

+ const Flag_ISBINARY

+ const Flag_ISFLOAT

+ const Flag_ISINTEGRAL

+ const Flag_ISQUOTED

+ const Flag_ISTEXT

+ const Flag_ISUNSIGNED

+ const Flag_NONE

+ func (Flag) EnumDescriptor() ([]byte, []int)

+ func (x Flag) String() string

+ type MessageAckRequest struct

+ EffectiveCallerId *vtrpc.CallerID

+ Ids []*Value

+ ImmediateCallerId *VTGateCallerID

+ Name string

+ Target *Target

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*MessageAckRequest) Descriptor() ([]byte, []int)

+ func (*MessageAckRequest) ProtoMessage()

+ func (m *MessageAckRequest) GetEffectiveCallerId() *vtrpc.CallerID

+ func (m *MessageAckRequest) GetIds() []*Value

+ func (m *MessageAckRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *MessageAckRequest) GetName() string

+ func (m *MessageAckRequest) GetTarget() *Target

+ func (m *MessageAckRequest) Reset()

+ func (m *MessageAckRequest) String() string

+ func (m *MessageAckRequest) XXX_DiscardUnknown()

+ func (m *MessageAckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MessageAckRequest) XXX_Merge(src proto.Message)

+ func (m *MessageAckRequest) XXX_Size() int

+ func (m *MessageAckRequest) XXX_Unmarshal(b []byte) error

+ type MessageAckResponse struct

+ Result *QueryResult

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*MessageAckResponse) Descriptor() ([]byte, []int)

+ func (*MessageAckResponse) ProtoMessage()

+ func (m *MessageAckResponse) GetResult() *QueryResult

+ func (m *MessageAckResponse) Reset()

+ func (m *MessageAckResponse) String() string

+ func (m *MessageAckResponse) XXX_DiscardUnknown()

+ func (m *MessageAckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MessageAckResponse) XXX_Merge(src proto.Message)

+ func (m *MessageAckResponse) XXX_Size() int

+ func (m *MessageAckResponse) XXX_Unmarshal(b []byte) error

+ type MessageStreamRequest struct

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Name string

+ Target *Target

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*MessageStreamRequest) Descriptor() ([]byte, []int)

+ func (*MessageStreamRequest) ProtoMessage()

+ func (m *MessageStreamRequest) GetEffectiveCallerId() *vtrpc.CallerID

+ func (m *MessageStreamRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *MessageStreamRequest) GetName() string

+ func (m *MessageStreamRequest) GetTarget() *Target

+ func (m *MessageStreamRequest) Reset()

+ func (m *MessageStreamRequest) String() string

+ func (m *MessageStreamRequest) XXX_DiscardUnknown()

+ func (m *MessageStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MessageStreamRequest) XXX_Merge(src proto.Message)

+ func (m *MessageStreamRequest) XXX_Size() int

+ func (m *MessageStreamRequest) XXX_Unmarshal(b []byte) error

+ type MessageStreamResponse struct

+ Result *QueryResult

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*MessageStreamResponse) Descriptor() ([]byte, []int)

+ func (*MessageStreamResponse) ProtoMessage()

+ func (m *MessageStreamResponse) GetResult() *QueryResult

+ func (m *MessageStreamResponse) Reset()

+ func (m *MessageStreamResponse) String() string

+ func (m *MessageStreamResponse) XXX_DiscardUnknown()

+ func (m *MessageStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MessageStreamResponse) XXX_Merge(src proto.Message)

+ func (m *MessageStreamResponse) XXX_Size() int

+ func (m *MessageStreamResponse) XXX_Unmarshal(b []byte) error

+ type MySqlFlag int32

+ const MySqlFlag_AUTO_INCREMENT_FLAG

+ const MySqlFlag_BINARY_FLAG

+ const MySqlFlag_BINCMP_FLAG

+ const MySqlFlag_BLOB_FLAG

+ const MySqlFlag_EMPTY

+ const MySqlFlag_ENUM_FLAG

+ const MySqlFlag_GROUP_FLAG

+ const MySqlFlag_MULTIPLE_KEY_FLAG

+ const MySqlFlag_NOT_NULL_FLAG

+ const MySqlFlag_NO_DEFAULT_VALUE_FLAG

+ const MySqlFlag_NUM_FLAG

+ const MySqlFlag_ON_UPDATE_NOW_FLAG

+ const MySqlFlag_PART_KEY_FLAG

+ const MySqlFlag_PRI_KEY_FLAG

+ const MySqlFlag_SET_FLAG

+ const MySqlFlag_TIMESTAMP_FLAG

+ const MySqlFlag_UNIQUE_FLAG

+ const MySqlFlag_UNIQUE_KEY_FLAG

+ const MySqlFlag_UNSIGNED_FLAG

+ const MySqlFlag_ZEROFILL_FLAG

+ func (MySqlFlag) EnumDescriptor() ([]byte, []int)

+ func (x MySqlFlag) String() string

+ type PrepareRequest struct

+ Dtid string

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Target *Target

+ TransactionId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PrepareRequest) Descriptor() ([]byte, []int)

+ func (*PrepareRequest) ProtoMessage()

+ func (m *PrepareRequest) GetDtid() string

+ func (m *PrepareRequest) GetEffectiveCallerId() *vtrpc.CallerID

+ func (m *PrepareRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *PrepareRequest) GetTarget() *Target

+ func (m *PrepareRequest) GetTransactionId() int64

+ func (m *PrepareRequest) Reset()

+ func (m *PrepareRequest) String() string

+ func (m *PrepareRequest) XXX_DiscardUnknown()

+ func (m *PrepareRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PrepareRequest) XXX_Merge(src proto.Message)

+ func (m *PrepareRequest) XXX_Size() int

+ func (m *PrepareRequest) XXX_Unmarshal(b []byte) error

+ type PrepareResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PrepareResponse) Descriptor() ([]byte, []int)

+ func (*PrepareResponse) ProtoMessage()

+ func (m *PrepareResponse) Reset()

+ func (m *PrepareResponse) String() string

+ func (m *PrepareResponse) XXX_DiscardUnknown()

+ func (m *PrepareResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PrepareResponse) XXX_Merge(src proto.Message)

+ func (m *PrepareResponse) XXX_Size() int

+ func (m *PrepareResponse) XXX_Unmarshal(b []byte) error

+ type QueryResult struct

+ Fields []*Field

+ InsertId uint64

+ Rows []*Row

+ RowsAffected uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*QueryResult) Descriptor() ([]byte, []int)

+ func (*QueryResult) ProtoMessage()

+ func (m *QueryResult) GetFields() []*Field

+ func (m *QueryResult) GetInsertId() uint64

+ func (m *QueryResult) GetRows() []*Row

+ func (m *QueryResult) GetRowsAffected() uint64

+ func (m *QueryResult) Reset()

+ func (m *QueryResult) String() string

+ func (m *QueryResult) XXX_DiscardUnknown()

+ func (m *QueryResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *QueryResult) XXX_Merge(src proto.Message)

+ func (m *QueryResult) XXX_Size() int

+ func (m *QueryResult) XXX_Unmarshal(b []byte) error

+ type QueryWarning struct

+ Code uint32

+ Message string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*QueryWarning) Descriptor() ([]byte, []int)

+ func (*QueryWarning) ProtoMessage()

+ func (m *QueryWarning) GetCode() uint32

+ func (m *QueryWarning) GetMessage() string

+ func (m *QueryWarning) Reset()

+ func (m *QueryWarning) String() string

+ func (m *QueryWarning) XXX_DiscardUnknown()

+ func (m *QueryWarning) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *QueryWarning) XXX_Merge(src proto.Message)

+ func (m *QueryWarning) XXX_Size() int

+ func (m *QueryWarning) XXX_Unmarshal(b []byte) error

+ type ReadTransactionRequest struct

+ Dtid string

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Target *Target

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReadTransactionRequest) Descriptor() ([]byte, []int)

+ func (*ReadTransactionRequest) ProtoMessage()

+ func (m *ReadTransactionRequest) GetDtid() string

+ func (m *ReadTransactionRequest) GetEffectiveCallerId() *vtrpc.CallerID

+ func (m *ReadTransactionRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *ReadTransactionRequest) GetTarget() *Target

+ func (m *ReadTransactionRequest) Reset()

+ func (m *ReadTransactionRequest) String() string

+ func (m *ReadTransactionRequest) XXX_DiscardUnknown()

+ func (m *ReadTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReadTransactionRequest) XXX_Merge(src proto.Message)

+ func (m *ReadTransactionRequest) XXX_Size() int

+ func (m *ReadTransactionRequest) XXX_Unmarshal(b []byte) error

+ type ReadTransactionResponse struct

+ Metadata *TransactionMetadata

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReadTransactionResponse) Descriptor() ([]byte, []int)

+ func (*ReadTransactionResponse) ProtoMessage()

+ func (m *ReadTransactionResponse) GetMetadata() *TransactionMetadata

+ func (m *ReadTransactionResponse) Reset()

+ func (m *ReadTransactionResponse) String() string

+ func (m *ReadTransactionResponse) XXX_DiscardUnknown()

+ func (m *ReadTransactionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReadTransactionResponse) XXX_Merge(src proto.Message)

+ func (m *ReadTransactionResponse) XXX_Size() int

+ func (m *ReadTransactionResponse) XXX_Unmarshal(b []byte) error

+ type RealtimeStats struct

+ BinlogPlayersCount int32

+ CpuUsage float64

+ HealthError string

+ Qps float64

+ SecondsBehindMaster uint32

+ SecondsBehindMasterFilteredReplication int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RealtimeStats) Descriptor() ([]byte, []int)

+ func (*RealtimeStats) ProtoMessage()

+ func (m *RealtimeStats) GetBinlogPlayersCount() int32

+ func (m *RealtimeStats) GetCpuUsage() float64

+ func (m *RealtimeStats) GetHealthError() string

+ func (m *RealtimeStats) GetQps() float64

+ func (m *RealtimeStats) GetSecondsBehindMaster() uint32

+ func (m *RealtimeStats) GetSecondsBehindMasterFilteredReplication() int64

+ func (m *RealtimeStats) Reset()

+ func (m *RealtimeStats) String() string

+ func (m *RealtimeStats) XXX_DiscardUnknown()

+ func (m *RealtimeStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RealtimeStats) XXX_Merge(src proto.Message)

+ func (m *RealtimeStats) XXX_Size() int

+ func (m *RealtimeStats) XXX_Unmarshal(b []byte) error

+ type ReleaseRequest struct

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ ReservedId int64

+ Target *Target

+ TransactionId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReleaseRequest) Descriptor() ([]byte, []int)

+ func (*ReleaseRequest) ProtoMessage()

+ func (m *ReleaseRequest) GetEffectiveCallerId() *vtrpc.CallerID

+ func (m *ReleaseRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *ReleaseRequest) GetReservedId() int64

+ func (m *ReleaseRequest) GetTarget() *Target

+ func (m *ReleaseRequest) GetTransactionId() int64

+ func (m *ReleaseRequest) Reset()

+ func (m *ReleaseRequest) String() string

+ func (m *ReleaseRequest) XXX_DiscardUnknown()

+ func (m *ReleaseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReleaseRequest) XXX_Merge(src proto.Message)

+ func (m *ReleaseRequest) XXX_Size() int

+ func (m *ReleaseRequest) XXX_Unmarshal(b []byte) error

+ type ReleaseResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReleaseResponse) Descriptor() ([]byte, []int)

+ func (*ReleaseResponse) ProtoMessage()

+ func (m *ReleaseResponse) Reset()

+ func (m *ReleaseResponse) String() string

+ func (m *ReleaseResponse) XXX_DiscardUnknown()

+ func (m *ReleaseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReleaseResponse) XXX_Merge(src proto.Message)

+ func (m *ReleaseResponse) XXX_Size() int

+ func (m *ReleaseResponse) XXX_Unmarshal(b []byte) error

+ type ReserveBeginExecuteRequest struct

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Options *ExecuteOptions

+ PreQueries []string

+ Query *BoundQuery

+ Target *Target

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReserveBeginExecuteRequest) Descriptor() ([]byte, []int)

+ func (*ReserveBeginExecuteRequest) ProtoMessage()

+ func (m *ReserveBeginExecuteRequest) GetEffectiveCallerId() *vtrpc.CallerID

+ func (m *ReserveBeginExecuteRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *ReserveBeginExecuteRequest) GetOptions() *ExecuteOptions

+ func (m *ReserveBeginExecuteRequest) GetPreQueries() []string

+ func (m *ReserveBeginExecuteRequest) GetQuery() *BoundQuery

+ func (m *ReserveBeginExecuteRequest) GetTarget() *Target

+ func (m *ReserveBeginExecuteRequest) Reset()

+ func (m *ReserveBeginExecuteRequest) String() string

+ func (m *ReserveBeginExecuteRequest) XXX_DiscardUnknown()

+ func (m *ReserveBeginExecuteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReserveBeginExecuteRequest) XXX_Merge(src proto.Message)

+ func (m *ReserveBeginExecuteRequest) XXX_Size() int

+ func (m *ReserveBeginExecuteRequest) XXX_Unmarshal(b []byte) error

+ type ReserveBeginExecuteResponse struct

+ Error *vtrpc.RPCError

+ ReservedId int64

+ Result *QueryResult

+ TabletAlias *topodata.TabletAlias

+ TransactionId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReserveBeginExecuteResponse) Descriptor() ([]byte, []int)

+ func (*ReserveBeginExecuteResponse) ProtoMessage()

+ func (m *ReserveBeginExecuteResponse) GetError() *vtrpc.RPCError

+ func (m *ReserveBeginExecuteResponse) GetReservedId() int64

+ func (m *ReserveBeginExecuteResponse) GetResult() *QueryResult

+ func (m *ReserveBeginExecuteResponse) GetTabletAlias() *topodata.TabletAlias

+ func (m *ReserveBeginExecuteResponse) GetTransactionId() int64

+ func (m *ReserveBeginExecuteResponse) Reset()

+ func (m *ReserveBeginExecuteResponse) String() string

+ func (m *ReserveBeginExecuteResponse) XXX_DiscardUnknown()

+ func (m *ReserveBeginExecuteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReserveBeginExecuteResponse) XXX_Merge(src proto.Message)

+ func (m *ReserveBeginExecuteResponse) XXX_Size() int

+ func (m *ReserveBeginExecuteResponse) XXX_Unmarshal(b []byte) error

+ type ReserveExecuteRequest struct

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Options *ExecuteOptions

+ PreQueries []string

+ Query *BoundQuery

+ Target *Target

+ TransactionId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReserveExecuteRequest) Descriptor() ([]byte, []int)

+ func (*ReserveExecuteRequest) ProtoMessage()

+ func (m *ReserveExecuteRequest) GetEffectiveCallerId() *vtrpc.CallerID

+ func (m *ReserveExecuteRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *ReserveExecuteRequest) GetOptions() *ExecuteOptions

+ func (m *ReserveExecuteRequest) GetPreQueries() []string

+ func (m *ReserveExecuteRequest) GetQuery() *BoundQuery

+ func (m *ReserveExecuteRequest) GetTarget() *Target

+ func (m *ReserveExecuteRequest) GetTransactionId() int64

+ func (m *ReserveExecuteRequest) Reset()

+ func (m *ReserveExecuteRequest) String() string

+ func (m *ReserveExecuteRequest) XXX_DiscardUnknown()

+ func (m *ReserveExecuteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReserveExecuteRequest) XXX_Merge(src proto.Message)

+ func (m *ReserveExecuteRequest) XXX_Size() int

+ func (m *ReserveExecuteRequest) XXX_Unmarshal(b []byte) error

+ type ReserveExecuteResponse struct

+ Error *vtrpc.RPCError

+ ReservedId int64

+ Result *QueryResult

+ TabletAlias *topodata.TabletAlias

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReserveExecuteResponse) Descriptor() ([]byte, []int)

+ func (*ReserveExecuteResponse) ProtoMessage()

+ func (m *ReserveExecuteResponse) GetError() *vtrpc.RPCError

+ func (m *ReserveExecuteResponse) GetReservedId() int64

+ func (m *ReserveExecuteResponse) GetResult() *QueryResult

+ func (m *ReserveExecuteResponse) GetTabletAlias() *topodata.TabletAlias

+ func (m *ReserveExecuteResponse) Reset()

+ func (m *ReserveExecuteResponse) String() string

+ func (m *ReserveExecuteResponse) XXX_DiscardUnknown()

+ func (m *ReserveExecuteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReserveExecuteResponse) XXX_Merge(src proto.Message)

+ func (m *ReserveExecuteResponse) XXX_Size() int

+ func (m *ReserveExecuteResponse) XXX_Unmarshal(b []byte) error

+ type ResultWithError struct

+ Error *vtrpc.RPCError

+ Result *QueryResult

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ResultWithError) Descriptor() ([]byte, []int)

+ func (*ResultWithError) ProtoMessage()

+ func (m *ResultWithError) GetError() *vtrpc.RPCError

+ func (m *ResultWithError) GetResult() *QueryResult

+ func (m *ResultWithError) Reset()

+ func (m *ResultWithError) String() string

+ func (m *ResultWithError) XXX_DiscardUnknown()

+ func (m *ResultWithError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ResultWithError) XXX_Merge(src proto.Message)

+ func (m *ResultWithError) XXX_Size() int

+ func (m *ResultWithError) XXX_Unmarshal(b []byte) error

+ type RollbackPreparedRequest struct

+ Dtid string

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Target *Target

+ TransactionId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RollbackPreparedRequest) Descriptor() ([]byte, []int)

+ func (*RollbackPreparedRequest) ProtoMessage()

+ func (m *RollbackPreparedRequest) GetDtid() string

+ func (m *RollbackPreparedRequest) GetEffectiveCallerId() *vtrpc.CallerID

+ func (m *RollbackPreparedRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *RollbackPreparedRequest) GetTarget() *Target

+ func (m *RollbackPreparedRequest) GetTransactionId() int64

+ func (m *RollbackPreparedRequest) Reset()

+ func (m *RollbackPreparedRequest) String() string

+ func (m *RollbackPreparedRequest) XXX_DiscardUnknown()

+ func (m *RollbackPreparedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RollbackPreparedRequest) XXX_Merge(src proto.Message)

+ func (m *RollbackPreparedRequest) XXX_Size() int

+ func (m *RollbackPreparedRequest) XXX_Unmarshal(b []byte) error

+ type RollbackPreparedResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RollbackPreparedResponse) Descriptor() ([]byte, []int)

+ func (*RollbackPreparedResponse) ProtoMessage()

+ func (m *RollbackPreparedResponse) Reset()

+ func (m *RollbackPreparedResponse) String() string

+ func (m *RollbackPreparedResponse) XXX_DiscardUnknown()

+ func (m *RollbackPreparedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RollbackPreparedResponse) XXX_Merge(src proto.Message)

+ func (m *RollbackPreparedResponse) XXX_Size() int

+ func (m *RollbackPreparedResponse) XXX_Unmarshal(b []byte) error

+ type RollbackRequest struct

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Target *Target

+ TransactionId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RollbackRequest) Descriptor() ([]byte, []int)

+ func (*RollbackRequest) ProtoMessage()

+ func (m *RollbackRequest) GetEffectiveCallerId() *vtrpc.CallerID

+ func (m *RollbackRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *RollbackRequest) GetTarget() *Target

+ func (m *RollbackRequest) GetTransactionId() int64

+ func (m *RollbackRequest) Reset()

+ func (m *RollbackRequest) String() string

+ func (m *RollbackRequest) XXX_DiscardUnknown()

+ func (m *RollbackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RollbackRequest) XXX_Merge(src proto.Message)

+ func (m *RollbackRequest) XXX_Size() int

+ func (m *RollbackRequest) XXX_Unmarshal(b []byte) error

+ type RollbackResponse struct

+ ReservedId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RollbackResponse) Descriptor() ([]byte, []int)

+ func (*RollbackResponse) ProtoMessage()

+ func (m *RollbackResponse) GetReservedId() int64

+ func (m *RollbackResponse) Reset()

+ func (m *RollbackResponse) String() string

+ func (m *RollbackResponse) XXX_DiscardUnknown()

+ func (m *RollbackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RollbackResponse) XXX_Merge(src proto.Message)

+ func (m *RollbackResponse) XXX_Size() int

+ func (m *RollbackResponse) XXX_Unmarshal(b []byte) error

+ type Row struct

+ Lengths []int64

+ Values []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Row) Descriptor() ([]byte, []int)

+ func (*Row) ProtoMessage()

+ func (m *Row) GetLengths() []int64

+ func (m *Row) GetValues() []byte

+ func (m *Row) Reset()

+ func (m *Row) String() string

+ func (m *Row) XXX_DiscardUnknown()

+ func (m *Row) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Row) XXX_Merge(src proto.Message)

+ func (m *Row) XXX_Size() int

+ func (m *Row) XXX_Unmarshal(b []byte) error

+ type SetRollbackRequest struct

+ Dtid string

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Target *Target

+ TransactionId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SetRollbackRequest) Descriptor() ([]byte, []int)

+ func (*SetRollbackRequest) ProtoMessage()

+ func (m *SetRollbackRequest) GetDtid() string

+ func (m *SetRollbackRequest) GetEffectiveCallerId() *vtrpc.CallerID

+ func (m *SetRollbackRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *SetRollbackRequest) GetTarget() *Target

+ func (m *SetRollbackRequest) GetTransactionId() int64

+ func (m *SetRollbackRequest) Reset()

+ func (m *SetRollbackRequest) String() string

+ func (m *SetRollbackRequest) XXX_DiscardUnknown()

+ func (m *SetRollbackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SetRollbackRequest) XXX_Merge(src proto.Message)

+ func (m *SetRollbackRequest) XXX_Size() int

+ func (m *SetRollbackRequest) XXX_Unmarshal(b []byte) error

+ type SetRollbackResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SetRollbackResponse) Descriptor() ([]byte, []int)

+ func (*SetRollbackResponse) ProtoMessage()

+ func (m *SetRollbackResponse) Reset()

+ func (m *SetRollbackResponse) String() string

+ func (m *SetRollbackResponse) XXX_DiscardUnknown()

+ func (m *SetRollbackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SetRollbackResponse) XXX_Merge(src proto.Message)

+ func (m *SetRollbackResponse) XXX_Size() int

+ func (m *SetRollbackResponse) XXX_Unmarshal(b []byte) error

+ type StartCommitRequest struct

+ Dtid string

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Target *Target

+ TransactionId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StartCommitRequest) Descriptor() ([]byte, []int)

+ func (*StartCommitRequest) ProtoMessage()

+ func (m *StartCommitRequest) GetDtid() string

+ func (m *StartCommitRequest) GetEffectiveCallerId() *vtrpc.CallerID

+ func (m *StartCommitRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *StartCommitRequest) GetTarget() *Target

+ func (m *StartCommitRequest) GetTransactionId() int64

+ func (m *StartCommitRequest) Reset()

+ func (m *StartCommitRequest) String() string

+ func (m *StartCommitRequest) XXX_DiscardUnknown()

+ func (m *StartCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *StartCommitRequest) XXX_Merge(src proto.Message)

+ func (m *StartCommitRequest) XXX_Size() int

+ func (m *StartCommitRequest) XXX_Unmarshal(b []byte) error

+ type StartCommitResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StartCommitResponse) Descriptor() ([]byte, []int)

+ func (*StartCommitResponse) ProtoMessage()

+ func (m *StartCommitResponse) Reset()

+ func (m *StartCommitResponse) String() string

+ func (m *StartCommitResponse) XXX_DiscardUnknown()

+ func (m *StartCommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *StartCommitResponse) XXX_Merge(src proto.Message)

+ func (m *StartCommitResponse) XXX_Size() int

+ func (m *StartCommitResponse) XXX_Unmarshal(b []byte) error

+ type StreamEvent struct

+ EventToken *EventToken

+ Statements []*StreamEvent_Statement

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StreamEvent) Descriptor() ([]byte, []int)

+ func (*StreamEvent) ProtoMessage()

+ func (m *StreamEvent) GetEventToken() *EventToken

+ func (m *StreamEvent) GetStatements() []*StreamEvent_Statement

+ func (m *StreamEvent) Reset()

+ func (m *StreamEvent) String() string

+ func (m *StreamEvent) XXX_DiscardUnknown()

+ func (m *StreamEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *StreamEvent) XXX_Merge(src proto.Message)

+ func (m *StreamEvent) XXX_Size() int

+ func (m *StreamEvent) XXX_Unmarshal(b []byte) error

+ type StreamEvent_Statement struct

+ Category StreamEvent_Statement_Category

+ PrimaryKeyFields []*Field

+ PrimaryKeyValues []*Row

+ Sql []byte

+ TableName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StreamEvent_Statement) Descriptor() ([]byte, []int)

+ func (*StreamEvent_Statement) ProtoMessage()

+ func (m *StreamEvent_Statement) GetCategory() StreamEvent_Statement_Category

+ func (m *StreamEvent_Statement) GetPrimaryKeyFields() []*Field

+ func (m *StreamEvent_Statement) GetPrimaryKeyValues() []*Row

+ func (m *StreamEvent_Statement) GetSql() []byte

+ func (m *StreamEvent_Statement) GetTableName() string

+ func (m *StreamEvent_Statement) Reset()

+ func (m *StreamEvent_Statement) String() string

+ func (m *StreamEvent_Statement) XXX_DiscardUnknown()

+ func (m *StreamEvent_Statement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *StreamEvent_Statement) XXX_Merge(src proto.Message)

+ func (m *StreamEvent_Statement) XXX_Size() int

+ func (m *StreamEvent_Statement) XXX_Unmarshal(b []byte) error

+ type StreamEvent_Statement_Category int32

+ const StreamEvent_Statement_DDL

+ const StreamEvent_Statement_DML

+ const StreamEvent_Statement_Error

+ func (StreamEvent_Statement_Category) EnumDescriptor() ([]byte, []int)

+ func (x StreamEvent_Statement_Category) String() string

+ type StreamExecuteRequest struct

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Options *ExecuteOptions

+ Query *BoundQuery

+ Target *Target

+ TransactionId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StreamExecuteRequest) Descriptor() ([]byte, []int)

+ func (*StreamExecuteRequest) ProtoMessage()

+ func (m *StreamExecuteRequest) GetEffectiveCallerId() *vtrpc.CallerID

+ func (m *StreamExecuteRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *StreamExecuteRequest) GetOptions() *ExecuteOptions

+ func (m *StreamExecuteRequest) GetQuery() *BoundQuery

+ func (m *StreamExecuteRequest) GetTarget() *Target

+ func (m *StreamExecuteRequest) GetTransactionId() int64

+ func (m *StreamExecuteRequest) Reset()

+ func (m *StreamExecuteRequest) String() string

+ func (m *StreamExecuteRequest) XXX_DiscardUnknown()

+ func (m *StreamExecuteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *StreamExecuteRequest) XXX_Merge(src proto.Message)

+ func (m *StreamExecuteRequest) XXX_Size() int

+ func (m *StreamExecuteRequest) XXX_Unmarshal(b []byte) error

+ type StreamExecuteResponse struct

+ Result *QueryResult

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StreamExecuteResponse) Descriptor() ([]byte, []int)

+ func (*StreamExecuteResponse) ProtoMessage()

+ func (m *StreamExecuteResponse) GetResult() *QueryResult

+ func (m *StreamExecuteResponse) Reset()

+ func (m *StreamExecuteResponse) String() string

+ func (m *StreamExecuteResponse) XXX_DiscardUnknown()

+ func (m *StreamExecuteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *StreamExecuteResponse) XXX_Merge(src proto.Message)

+ func (m *StreamExecuteResponse) XXX_Size() int

+ func (m *StreamExecuteResponse) XXX_Unmarshal(b []byte) error

+ type StreamHealthRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StreamHealthRequest) Descriptor() ([]byte, []int)

+ func (*StreamHealthRequest) ProtoMessage()

+ func (m *StreamHealthRequest) Reset()

+ func (m *StreamHealthRequest) String() string

+ func (m *StreamHealthRequest) XXX_DiscardUnknown()

+ func (m *StreamHealthRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *StreamHealthRequest) XXX_Merge(src proto.Message)

+ func (m *StreamHealthRequest) XXX_Size() int

+ func (m *StreamHealthRequest) XXX_Unmarshal(b []byte) error

+ type StreamHealthResponse struct

+ RealtimeStats *RealtimeStats

+ Serving bool

+ TabletAlias *topodata.TabletAlias

+ TabletExternallyReparentedTimestamp int64

+ Target *Target

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StreamHealthResponse) Descriptor() ([]byte, []int)

+ func (*StreamHealthResponse) ProtoMessage()

+ func (m *StreamHealthResponse) GetRealtimeStats() *RealtimeStats

+ func (m *StreamHealthResponse) GetServing() bool

+ func (m *StreamHealthResponse) GetTabletAlias() *topodata.TabletAlias

+ func (m *StreamHealthResponse) GetTabletExternallyReparentedTimestamp() int64

+ func (m *StreamHealthResponse) GetTarget() *Target

+ func (m *StreamHealthResponse) Reset()

+ func (m *StreamHealthResponse) String() string

+ func (m *StreamHealthResponse) XXX_DiscardUnknown()

+ func (m *StreamHealthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *StreamHealthResponse) XXX_Merge(src proto.Message)

+ func (m *StreamHealthResponse) XXX_Size() int

+ func (m *StreamHealthResponse) XXX_Unmarshal(b []byte) error

+ type Target struct

+ Cell string

+ Keyspace string

+ Shard string

+ TabletType topodata.TabletType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Target) Descriptor() ([]byte, []int)

+ func (*Target) ProtoMessage()

+ func (m *Target) GetCell() string

+ func (m *Target) GetKeyspace() string

+ func (m *Target) GetShard() string

+ func (m *Target) GetTabletType() topodata.TabletType

+ func (m *Target) Reset()

+ func (m *Target) String() string

+ func (m *Target) XXX_DiscardUnknown()

+ func (m *Target) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Target) XXX_Merge(src proto.Message)

+ func (m *Target) XXX_Size() int

+ func (m *Target) XXX_Unmarshal(b []byte) error

+ type TransactionMetadata struct

+ Dtid string

+ Participants []*Target

+ State TransactionState

+ TimeCreated int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TransactionMetadata) Descriptor() ([]byte, []int)

+ func (*TransactionMetadata) ProtoMessage()

+ func (m *TransactionMetadata) GetDtid() string

+ func (m *TransactionMetadata) GetParticipants() []*Target

+ func (m *TransactionMetadata) GetState() TransactionState

+ func (m *TransactionMetadata) GetTimeCreated() int64

+ func (m *TransactionMetadata) Reset()

+ func (m *TransactionMetadata) String() string

+ func (m *TransactionMetadata) XXX_DiscardUnknown()

+ func (m *TransactionMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TransactionMetadata) XXX_Merge(src proto.Message)

+ func (m *TransactionMetadata) XXX_Size() int

+ func (m *TransactionMetadata) XXX_Unmarshal(b []byte) error

+ type TransactionState int32

+ const TransactionState_COMMIT

+ const TransactionState_PREPARE

+ const TransactionState_ROLLBACK

+ const TransactionState_UNKNOWN

+ func (TransactionState) EnumDescriptor() ([]byte, []int)

+ func (x TransactionState) String() string

+ type Type int32

+ const Type_BINARY

+ const Type_BIT

+ const Type_BLOB

+ const Type_CHAR

+ const Type_DATE

+ const Type_DATETIME

+ const Type_DECIMAL

+ const Type_ENUM

+ const Type_EXPRESSION

+ const Type_FLOAT32

+ const Type_FLOAT64

+ const Type_GEOMETRY

+ const Type_INT16

+ const Type_INT24

+ const Type_INT32

+ const Type_INT64

+ const Type_INT8

+ const Type_JSON

+ const Type_NULL_TYPE

+ const Type_SET

+ const Type_TEXT

+ const Type_TIME

+ const Type_TIMESTAMP

+ const Type_TUPLE

+ const Type_UINT16

+ const Type_UINT24

+ const Type_UINT32

+ const Type_UINT64

+ const Type_UINT8

+ const Type_VARBINARY

+ const Type_VARCHAR

+ const Type_YEAR

+ func (Type) EnumDescriptor() ([]byte, []int)

+ func (x Type) String() string

+ type VTGateCallerID struct

+ Groups []string

+ Username string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*VTGateCallerID) Descriptor() ([]byte, []int)

+ func (*VTGateCallerID) ProtoMessage()

+ func (m *VTGateCallerID) GetGroups() []string

+ func (m *VTGateCallerID) GetUsername() string

+ func (m *VTGateCallerID) Reset()

+ func (m *VTGateCallerID) String() string

+ func (m *VTGateCallerID) XXX_DiscardUnknown()

+ func (m *VTGateCallerID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *VTGateCallerID) XXX_Merge(src proto.Message)

+ func (m *VTGateCallerID) XXX_Size() int

+ func (m *VTGateCallerID) XXX_Unmarshal(b []byte) error

+ type Value struct

+ Type Type

+ Value []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Value) Descriptor() ([]byte, []int)

+ func (*Value) ProtoMessage()

+ func (m *Value) GetType() Type

+ func (m *Value) GetValue() []byte

+ func (m *Value) Reset()

+ func (m *Value) String() string

+ func (m *Value) XXX_DiscardUnknown()

+ func (m *Value) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Value) XXX_Merge(src proto.Message)

+ func (m *Value) XXX_Size() int

+ func (m *Value) XXX_Unmarshal(b []byte) error