Versions in this module Expand all Collapse all v1 v1.0.1 Dec 2, 2020 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 + ColumnType string + 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) GetColumnType() string + 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
Go to main page