Documentation ¶
Index ¶
- Variables
- type AggregateStats
- func (*AggregateStats) Descriptor() ([]byte, []int)
- func (m *AggregateStats) GetHealthyTabletCount() int32
- func (m *AggregateStats) GetSecondsBehindMasterMax() uint32
- func (m *AggregateStats) GetSecondsBehindMasterMin() uint32
- func (m *AggregateStats) GetUnhealthyTabletCount() int32
- func (*AggregateStats) ProtoMessage()
- 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
- func (*BeginExecuteBatchRequest) Descriptor() ([]byte, []int)
- 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 (*BeginExecuteBatchRequest) ProtoMessage()
- 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
- func (*BeginExecuteBatchResponse) Descriptor() ([]byte, []int)
- func (m *BeginExecuteBatchResponse) GetError() *vtrpc.RPCError
- func (m *BeginExecuteBatchResponse) GetResults() []*QueryResult
- func (m *BeginExecuteBatchResponse) GetTabletAlias() *topodata.TabletAlias
- func (m *BeginExecuteBatchResponse) GetTransactionId() int64
- func (*BeginExecuteBatchResponse) ProtoMessage()
- 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
- func (*BeginExecuteRequest) Descriptor() ([]byte, []int)
- func (m *BeginExecuteRequest) GetEffectiveCallerId() *vtrpc.CallerID
- func (m *BeginExecuteRequest) GetImmediateCallerId() *VTGateCallerID
- func (m *BeginExecuteRequest) GetOptions() *ExecuteOptions
- func (m *BeginExecuteRequest) GetQuery() *BoundQuery
- func (m *BeginExecuteRequest) GetReservedId() int64
- func (m *BeginExecuteRequest) GetTarget() *Target
- func (*BeginExecuteRequest) ProtoMessage()
- 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
- func (*BeginExecuteResponse) Descriptor() ([]byte, []int)
- func (m *BeginExecuteResponse) GetError() *vtrpc.RPCError
- func (m *BeginExecuteResponse) GetResult() *QueryResult
- func (m *BeginExecuteResponse) GetTabletAlias() *topodata.TabletAlias
- func (m *BeginExecuteResponse) GetTransactionId() int64
- func (*BeginExecuteResponse) ProtoMessage()
- 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
- func (*BeginRequest) Descriptor() ([]byte, []int)
- func (m *BeginRequest) GetEffectiveCallerId() *vtrpc.CallerID
- func (m *BeginRequest) GetImmediateCallerId() *VTGateCallerID
- func (m *BeginRequest) GetOptions() *ExecuteOptions
- func (m *BeginRequest) GetTarget() *Target
- func (*BeginRequest) ProtoMessage()
- 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
- func (*BeginResponse) Descriptor() ([]byte, []int)
- func (m *BeginResponse) GetTabletAlias() *topodata.TabletAlias
- func (m *BeginResponse) GetTransactionId() int64
- func (*BeginResponse) ProtoMessage()
- 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
- func (*BindVariable) Descriptor() ([]byte, []int)
- func (m *BindVariable) GetType() Type
- func (m *BindVariable) GetValue() []byte
- func (m *BindVariable) GetValues() []*Value
- func (*BindVariable) ProtoMessage()
- 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
- func (*BoundQuery) Descriptor() ([]byte, []int)
- func (m *BoundQuery) GetBindVariables() map[string]*BindVariable
- func (m *BoundQuery) GetSql() string
- func (*BoundQuery) ProtoMessage()
- 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
- func (*CommitPreparedRequest) Descriptor() ([]byte, []int)
- func (m *CommitPreparedRequest) GetDtid() string
- func (m *CommitPreparedRequest) GetEffectiveCallerId() *vtrpc.CallerID
- func (m *CommitPreparedRequest) GetImmediateCallerId() *VTGateCallerID
- func (m *CommitPreparedRequest) GetTarget() *Target
- func (*CommitPreparedRequest) ProtoMessage()
- 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
- 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
- func (*CommitRequest) Descriptor() ([]byte, []int)
- func (m *CommitRequest) GetEffectiveCallerId() *vtrpc.CallerID
- func (m *CommitRequest) GetImmediateCallerId() *VTGateCallerID
- func (m *CommitRequest) GetTarget() *Target
- func (m *CommitRequest) GetTransactionId() int64
- func (*CommitRequest) ProtoMessage()
- 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
- func (*CommitResponse) Descriptor() ([]byte, []int)
- func (m *CommitResponse) GetReservedId() int64
- func (*CommitResponse) ProtoMessage()
- 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
- func (*ConcludeTransactionRequest) Descriptor() ([]byte, []int)
- func (m *ConcludeTransactionRequest) GetDtid() string
- func (m *ConcludeTransactionRequest) GetEffectiveCallerId() *vtrpc.CallerID
- func (m *ConcludeTransactionRequest) GetImmediateCallerId() *VTGateCallerID
- func (m *ConcludeTransactionRequest) GetTarget() *Target
- func (*ConcludeTransactionRequest) ProtoMessage()
- 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
- 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
- func (*CreateTransactionRequest) Descriptor() ([]byte, []int)
- 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 (*CreateTransactionRequest) ProtoMessage()
- 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
- 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
- func (*EventToken) Descriptor() ([]byte, []int)
- func (m *EventToken) GetPosition() string
- func (m *EventToken) GetShard() string
- func (m *EventToken) GetTimestamp() int64
- func (*EventToken) ProtoMessage()
- 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
- func (*ExecuteBatchRequest) Descriptor() ([]byte, []int)
- 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 (*ExecuteBatchRequest) ProtoMessage()
- 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
- func (*ExecuteBatchResponse) Descriptor() ([]byte, []int)
- func (m *ExecuteBatchResponse) GetResults() []*QueryResult
- func (*ExecuteBatchResponse) ProtoMessage()
- 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
- func (*ExecuteOptions) Descriptor() ([]byte, []int)
- 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 (*ExecuteOptions) ProtoMessage()
- 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
- type ExecuteOptions_TransactionIsolation
- type ExecuteOptions_Workload
- type ExecuteRequest
- func (*ExecuteRequest) Descriptor() ([]byte, []int)
- 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 (*ExecuteRequest) ProtoMessage()
- 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
- func (*ExecuteResponse) Descriptor() ([]byte, []int)
- func (m *ExecuteResponse) GetResult() *QueryResult
- func (*ExecuteResponse) ProtoMessage()
- 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
- func (*Field) Descriptor() ([]byte, []int)
- 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 (*Field) ProtoMessage()
- 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
- type MessageAckRequest
- func (*MessageAckRequest) Descriptor() ([]byte, []int)
- 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 (*MessageAckRequest) ProtoMessage()
- 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
- func (*MessageAckResponse) Descriptor() ([]byte, []int)
- func (m *MessageAckResponse) GetResult() *QueryResult
- func (*MessageAckResponse) ProtoMessage()
- 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
- func (*MessageStreamRequest) Descriptor() ([]byte, []int)
- func (m *MessageStreamRequest) GetEffectiveCallerId() *vtrpc.CallerID
- func (m *MessageStreamRequest) GetImmediateCallerId() *VTGateCallerID
- func (m *MessageStreamRequest) GetName() string
- func (m *MessageStreamRequest) GetTarget() *Target
- func (*MessageStreamRequest) ProtoMessage()
- 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
- func (*MessageStreamResponse) Descriptor() ([]byte, []int)
- func (m *MessageStreamResponse) GetResult() *QueryResult
- func (*MessageStreamResponse) ProtoMessage()
- 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
- type PrepareRequest
- func (*PrepareRequest) Descriptor() ([]byte, []int)
- 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 (*PrepareRequest) ProtoMessage()
- 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
- 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
- func (*QueryResult) Descriptor() ([]byte, []int)
- func (m *QueryResult) GetFields() []*Field
- func (m *QueryResult) GetInsertId() uint64
- func (m *QueryResult) GetRows() []*Row
- func (m *QueryResult) GetRowsAffected() uint64
- func (*QueryResult) ProtoMessage()
- 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
- func (*QueryWarning) Descriptor() ([]byte, []int)
- func (m *QueryWarning) GetCode() uint32
- func (m *QueryWarning) GetMessage() string
- func (*QueryWarning) ProtoMessage()
- 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
- func (*ReadTransactionRequest) Descriptor() ([]byte, []int)
- func (m *ReadTransactionRequest) GetDtid() string
- func (m *ReadTransactionRequest) GetEffectiveCallerId() *vtrpc.CallerID
- func (m *ReadTransactionRequest) GetImmediateCallerId() *VTGateCallerID
- func (m *ReadTransactionRequest) GetTarget() *Target
- func (*ReadTransactionRequest) ProtoMessage()
- 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
- func (*ReadTransactionResponse) Descriptor() ([]byte, []int)
- func (m *ReadTransactionResponse) GetMetadata() *TransactionMetadata
- func (*ReadTransactionResponse) ProtoMessage()
- 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
- func (*RealtimeStats) Descriptor() ([]byte, []int)
- 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 (*RealtimeStats) ProtoMessage()
- 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
- func (*ReleaseRequest) Descriptor() ([]byte, []int)
- 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 (*ReleaseRequest) ProtoMessage()
- 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
- 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
- func (*ReserveBeginExecuteRequest) Descriptor() ([]byte, []int)
- 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 (*ReserveBeginExecuteRequest) ProtoMessage()
- 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
- func (*ReserveBeginExecuteResponse) Descriptor() ([]byte, []int)
- 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 (*ReserveBeginExecuteResponse) ProtoMessage()
- 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
- func (*ReserveExecuteRequest) Descriptor() ([]byte, []int)
- 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 (*ReserveExecuteRequest) ProtoMessage()
- 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
- func (*ReserveExecuteResponse) Descriptor() ([]byte, []int)
- func (m *ReserveExecuteResponse) GetError() *vtrpc.RPCError
- func (m *ReserveExecuteResponse) GetReservedId() int64
- func (m *ReserveExecuteResponse) GetResult() *QueryResult
- func (m *ReserveExecuteResponse) GetTabletAlias() *topodata.TabletAlias
- func (*ReserveExecuteResponse) ProtoMessage()
- 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
- func (*ResultWithError) Descriptor() ([]byte, []int)
- func (m *ResultWithError) GetError() *vtrpc.RPCError
- func (m *ResultWithError) GetResult() *QueryResult
- func (*ResultWithError) ProtoMessage()
- 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
- func (*RollbackPreparedRequest) Descriptor() ([]byte, []int)
- 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 (*RollbackPreparedRequest) ProtoMessage()
- 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
- 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
- func (*RollbackRequest) Descriptor() ([]byte, []int)
- func (m *RollbackRequest) GetEffectiveCallerId() *vtrpc.CallerID
- func (m *RollbackRequest) GetImmediateCallerId() *VTGateCallerID
- func (m *RollbackRequest) GetTarget() *Target
- func (m *RollbackRequest) GetTransactionId() int64
- func (*RollbackRequest) ProtoMessage()
- 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
- func (*RollbackResponse) Descriptor() ([]byte, []int)
- func (m *RollbackResponse) GetReservedId() int64
- func (*RollbackResponse) ProtoMessage()
- 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
- func (*Row) Descriptor() ([]byte, []int)
- func (m *Row) GetLengths() []int64
- func (m *Row) GetValues() []byte
- func (*Row) ProtoMessage()
- 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
- func (*SetRollbackRequest) Descriptor() ([]byte, []int)
- 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 (*SetRollbackRequest) ProtoMessage()
- 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
- 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
- func (*StartCommitRequest) Descriptor() ([]byte, []int)
- 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 (*StartCommitRequest) ProtoMessage()
- 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
- 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
- func (*StreamEvent) Descriptor() ([]byte, []int)
- func (m *StreamEvent) GetEventToken() *EventToken
- func (m *StreamEvent) GetStatements() []*StreamEvent_Statement
- func (*StreamEvent) ProtoMessage()
- 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
- func (*StreamEvent_Statement) Descriptor() ([]byte, []int)
- 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 (*StreamEvent_Statement) ProtoMessage()
- 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
- type StreamExecuteRequest
- func (*StreamExecuteRequest) Descriptor() ([]byte, []int)
- 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 (*StreamExecuteRequest) ProtoMessage()
- 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
- func (*StreamExecuteResponse) Descriptor() ([]byte, []int)
- func (m *StreamExecuteResponse) GetResult() *QueryResult
- func (*StreamExecuteResponse) ProtoMessage()
- 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
- 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
- func (*StreamHealthResponse) Descriptor() ([]byte, []int)
- 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 (*StreamHealthResponse) ProtoMessage()
- 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
- func (*Target) Descriptor() ([]byte, []int)
- func (m *Target) GetCell() string
- func (m *Target) GetKeyspace() string
- func (m *Target) GetShard() string
- func (m *Target) GetTabletType() topodata.TabletType
- func (*Target) ProtoMessage()
- 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
- func (*TransactionMetadata) Descriptor() ([]byte, []int)
- func (m *TransactionMetadata) GetDtid() string
- func (m *TransactionMetadata) GetParticipants() []*Target
- func (m *TransactionMetadata) GetState() TransactionState
- func (m *TransactionMetadata) GetTimeCreated() int64
- func (*TransactionMetadata) ProtoMessage()
- 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
- type Type
- type VTGateCallerID
- func (*VTGateCallerID) Descriptor() ([]byte, []int)
- func (m *VTGateCallerID) GetGroups() []string
- func (m *VTGateCallerID) GetUsername() string
- func (*VTGateCallerID) ProtoMessage()
- 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
- func (*Value) Descriptor() ([]byte, []int)
- func (m *Value) GetType() Type
- func (m *Value) GetValue() []byte
- func (*Value) ProtoMessage()
- 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
Constants ¶
This section is empty.
Variables ¶
var ExecuteOptions_IncludedFields_name = map[int32]string{
0: "TYPE_AND_NAME",
1: "TYPE_ONLY",
2: "ALL",
}
var ExecuteOptions_IncludedFields_value = map[string]int32{
"TYPE_AND_NAME": 0,
"TYPE_ONLY": 1,
"ALL": 2,
}
var ExecuteOptions_TransactionIsolation_name = map[int32]string{
0: "DEFAULT",
1: "REPEATABLE_READ",
2: "READ_COMMITTED",
3: "READ_UNCOMMITTED",
4: "SERIALIZABLE",
5: "CONSISTENT_SNAPSHOT_READ_ONLY",
6: "AUTOCOMMIT",
}
var ExecuteOptions_TransactionIsolation_value = map[string]int32{
"DEFAULT": 0,
"REPEATABLE_READ": 1,
"READ_COMMITTED": 2,
"READ_UNCOMMITTED": 3,
"SERIALIZABLE": 4,
"CONSISTENT_SNAPSHOT_READ_ONLY": 5,
"AUTOCOMMIT": 6,
}
var ExecuteOptions_Workload_name = map[int32]string{
0: "UNSPECIFIED",
1: "OLTP",
2: "OLAP",
3: "DBA",
}
var ExecuteOptions_Workload_value = map[string]int32{
"UNSPECIFIED": 0,
"OLTP": 1,
"OLAP": 2,
"DBA": 3,
}
var Flag_name = map[int32]string{
0: "NONE",
256: "ISINTEGRAL",
512: "ISUNSIGNED",
1024: "ISFLOAT",
2048: "ISQUOTED",
4096: "ISTEXT",
8192: "ISBINARY",
}
var Flag_value = map[string]int32{
"NONE": 0,
"ISINTEGRAL": 256,
"ISUNSIGNED": 512,
"ISFLOAT": 1024,
"ISQUOTED": 2048,
"ISTEXT": 4096,
"ISBINARY": 8192,
}
var MySqlFlag_name = map[int32]string{
0: "EMPTY",
1: "NOT_NULL_FLAG",
2: "PRI_KEY_FLAG",
4: "UNIQUE_KEY_FLAG",
8: "MULTIPLE_KEY_FLAG",
16: "BLOB_FLAG",
32: "UNSIGNED_FLAG",
64: "ZEROFILL_FLAG",
128: "BINARY_FLAG",
256: "ENUM_FLAG",
512: "AUTO_INCREMENT_FLAG",
1024: "TIMESTAMP_FLAG",
2048: "SET_FLAG",
4096: "NO_DEFAULT_VALUE_FLAG",
8192: "ON_UPDATE_NOW_FLAG",
32768: "NUM_FLAG",
16384: "PART_KEY_FLAG",
65536: "UNIQUE_FLAG",
131072: "BINCMP_FLAG",
}
var MySqlFlag_value = map[string]int32{
"EMPTY": 0,
"NOT_NULL_FLAG": 1,
"PRI_KEY_FLAG": 2,
"UNIQUE_KEY_FLAG": 4,
"MULTIPLE_KEY_FLAG": 8,
"BLOB_FLAG": 16,
"UNSIGNED_FLAG": 32,
"ZEROFILL_FLAG": 64,
"BINARY_FLAG": 128,
"ENUM_FLAG": 256,
"AUTO_INCREMENT_FLAG": 512,
"TIMESTAMP_FLAG": 1024,
"SET_FLAG": 2048,
"NO_DEFAULT_VALUE_FLAG": 4096,
"ON_UPDATE_NOW_FLAG": 8192,
"NUM_FLAG": 32768,
"PART_KEY_FLAG": 16384,
"GROUP_FLAG": 32768,
"UNIQUE_FLAG": 65536,
"BINCMP_FLAG": 131072,
}
var StreamEvent_Statement_Category_name = map[int32]string{
0: "Error",
1: "DML",
2: "DDL",
}
var StreamEvent_Statement_Category_value = map[string]int32{
"Error": 0,
"DML": 1,
"DDL": 2,
}
var TransactionState_name = map[int32]string{
0: "UNKNOWN",
1: "PREPARE",
2: "COMMIT",
3: "ROLLBACK",
}
var TransactionState_value = map[string]int32{
"UNKNOWN": 0,
"PREPARE": 1,
"COMMIT": 2,
"ROLLBACK": 3,
}
var Type_name = map[int32]string{
0: "NULL_TYPE",
257: "INT8",
770: "UINT8",
259: "INT16",
772: "UINT16",
261: "INT24",
774: "UINT24",
263: "INT32",
776: "UINT32",
265: "INT64",
778: "UINT64",
1035: "FLOAT32",
1036: "FLOAT64",
2061: "TIMESTAMP",
2062: "DATE",
2063: "TIME",
2064: "DATETIME",
785: "YEAR",
18: "DECIMAL",
6163: "TEXT",
10260: "BLOB",
6165: "VARCHAR",
10262: "VARBINARY",
6167: "CHAR",
10264: "BINARY",
2073: "BIT",
2074: "ENUM",
2075: "SET",
28: "TUPLE",
2077: "GEOMETRY",
2078: "JSON",
31: "EXPRESSION",
}
var Type_value = map[string]int32{
"NULL_TYPE": 0,
"INT8": 257,
"UINT8": 770,
"INT16": 259,
"UINT16": 772,
"INT24": 261,
"UINT24": 774,
"INT32": 263,
"UINT32": 776,
"INT64": 265,
"UINT64": 778,
"FLOAT32": 1035,
"FLOAT64": 1036,
"TIMESTAMP": 2061,
"DATE": 2062,
"TIME": 2063,
"DATETIME": 2064,
"YEAR": 785,
"DECIMAL": 18,
"TEXT": 6163,
"BLOB": 10260,
"VARCHAR": 6165,
"VARBINARY": 10262,
"CHAR": 6167,
"BINARY": 10264,
"BIT": 2073,
"ENUM": 2074,
"SET": 2075,
"TUPLE": 28,
"GEOMETRY": 2077,
"JSON": 2078,
"EXPRESSION": 31,
}
Functions ¶
This section is empty.
Types ¶
type AggregateStats ¶
type AggregateStats struct { // healthy_tablet_count is the number of healthy tablets in the group. HealthyTabletCount int32 `protobuf:"varint,1,opt,name=healthy_tablet_count,json=healthyTabletCount,proto3" json:"healthy_tablet_count,omitempty"` // unhealthy_tablet_count is the number of unhealthy tablets in the group. UnhealthyTabletCount int32 `protobuf:"varint,2,opt,name=unhealthy_tablet_count,json=unhealthyTabletCount,proto3" json:"unhealthy_tablet_count,omitempty"` // seconds_behind_master_min is the minimum of the // seconds_behind_master values of the healthy tablets. It is unset // if the tablet type is master. SecondsBehindMasterMin uint32 `` /* 132-byte string literal not displayed */ // seconds_behind_master_max is the maximum of the // seconds_behind_master values of the healthy tablets. It is unset // if the tablet type is master. SecondsBehindMasterMax uint32 `` /* 132-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
AggregateStats contains information about the health of a group of tablets for a Target. It is used to propagate stats from a vtgate to another, or from the Gateway layer of a vtgate to the routing layer.
func (*AggregateStats) Descriptor ¶
func (*AggregateStats) Descriptor() ([]byte, []int)
func (*AggregateStats) GetHealthyTabletCount ¶
func (m *AggregateStats) GetHealthyTabletCount() int32
func (*AggregateStats) GetSecondsBehindMasterMax ¶
func (m *AggregateStats) GetSecondsBehindMasterMax() uint32
func (*AggregateStats) GetSecondsBehindMasterMin ¶
func (m *AggregateStats) GetSecondsBehindMasterMin() uint32
func (*AggregateStats) GetUnhealthyTabletCount ¶
func (m *AggregateStats) GetUnhealthyTabletCount() int32
func (*AggregateStats) ProtoMessage ¶
func (*AggregateStats) ProtoMessage()
func (*AggregateStats) Reset ¶
func (m *AggregateStats) Reset()
func (*AggregateStats) String ¶
func (m *AggregateStats) String() string
func (*AggregateStats) XXX_DiscardUnknown ¶
func (m *AggregateStats) XXX_DiscardUnknown()
func (*AggregateStats) XXX_Marshal ¶
func (m *AggregateStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AggregateStats) XXX_Merge ¶
func (m *AggregateStats) XXX_Merge(src proto.Message)
func (*AggregateStats) XXX_Size ¶
func (m *AggregateStats) XXX_Size() int
func (*AggregateStats) XXX_Unmarshal ¶
func (m *AggregateStats) XXX_Unmarshal(b []byte) error
type BeginExecuteBatchRequest ¶
type BeginExecuteBatchRequest struct { EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"` ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"` Target *Target `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` Queries []*BoundQuery `protobuf:"bytes,4,rep,name=queries,proto3" json:"queries,omitempty"` AsTransaction bool `protobuf:"varint,5,opt,name=as_transaction,json=asTransaction,proto3" json:"as_transaction,omitempty"` Options *ExecuteOptions `protobuf:"bytes,6,opt,name=options,proto3" json:"options,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
BeginExecuteBatchRequest is the payload to BeginExecuteBatch
func (*BeginExecuteBatchRequest) Descriptor ¶
func (*BeginExecuteBatchRequest) Descriptor() ([]byte, []int)
func (*BeginExecuteBatchRequest) GetAsTransaction ¶
func (m *BeginExecuteBatchRequest) GetAsTransaction() bool
func (*BeginExecuteBatchRequest) GetEffectiveCallerId ¶
func (m *BeginExecuteBatchRequest) GetEffectiveCallerId() *vtrpc.CallerID
func (*BeginExecuteBatchRequest) GetImmediateCallerId ¶
func (m *BeginExecuteBatchRequest) GetImmediateCallerId() *VTGateCallerID
func (*BeginExecuteBatchRequest) GetOptions ¶
func (m *BeginExecuteBatchRequest) GetOptions() *ExecuteOptions
func (*BeginExecuteBatchRequest) GetQueries ¶
func (m *BeginExecuteBatchRequest) GetQueries() []*BoundQuery
func (*BeginExecuteBatchRequest) GetTarget ¶
func (m *BeginExecuteBatchRequest) GetTarget() *Target
func (*BeginExecuteBatchRequest) ProtoMessage ¶
func (*BeginExecuteBatchRequest) ProtoMessage()
func (*BeginExecuteBatchRequest) Reset ¶
func (m *BeginExecuteBatchRequest) Reset()
func (*BeginExecuteBatchRequest) String ¶
func (m *BeginExecuteBatchRequest) String() string
func (*BeginExecuteBatchRequest) XXX_DiscardUnknown ¶
func (m *BeginExecuteBatchRequest) XXX_DiscardUnknown()
func (*BeginExecuteBatchRequest) XXX_Marshal ¶
func (m *BeginExecuteBatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BeginExecuteBatchRequest) XXX_Merge ¶
func (m *BeginExecuteBatchRequest) XXX_Merge(src proto.Message)
func (*BeginExecuteBatchRequest) XXX_Size ¶
func (m *BeginExecuteBatchRequest) XXX_Size() int
func (*BeginExecuteBatchRequest) XXX_Unmarshal ¶
func (m *BeginExecuteBatchRequest) XXX_Unmarshal(b []byte) error
type BeginExecuteBatchResponse ¶
type BeginExecuteBatchResponse struct { // error contains an application level error if necessary. Note the // transaction_id may be set, even when an error is returned, if the begin // worked but the execute failed. Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Results []*QueryResult `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"` // transaction_id might be non-zero even if an error is present. TransactionId int64 `protobuf:"varint,3,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"` TabletAlias *topodata.TabletAlias `protobuf:"bytes,4,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
BeginExecuteBatchResponse is the returned value from BeginExecuteBatch
func (*BeginExecuteBatchResponse) Descriptor ¶
func (*BeginExecuteBatchResponse) Descriptor() ([]byte, []int)
func (*BeginExecuteBatchResponse) GetError ¶
func (m *BeginExecuteBatchResponse) GetError() *vtrpc.RPCError
func (*BeginExecuteBatchResponse) GetResults ¶
func (m *BeginExecuteBatchResponse) GetResults() []*QueryResult
func (*BeginExecuteBatchResponse) GetTabletAlias ¶
func (m *BeginExecuteBatchResponse) GetTabletAlias() *topodata.TabletAlias
func (*BeginExecuteBatchResponse) GetTransactionId ¶
func (m *BeginExecuteBatchResponse) GetTransactionId() int64
func (*BeginExecuteBatchResponse) ProtoMessage ¶
func (*BeginExecuteBatchResponse) ProtoMessage()
func (*BeginExecuteBatchResponse) Reset ¶
func (m *BeginExecuteBatchResponse) Reset()
func (*BeginExecuteBatchResponse) String ¶
func (m *BeginExecuteBatchResponse) String() string
func (*BeginExecuteBatchResponse) XXX_DiscardUnknown ¶
func (m *BeginExecuteBatchResponse) XXX_DiscardUnknown()
func (*BeginExecuteBatchResponse) XXX_Marshal ¶
func (m *BeginExecuteBatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BeginExecuteBatchResponse) XXX_Merge ¶
func (m *BeginExecuteBatchResponse) XXX_Merge(src proto.Message)
func (*BeginExecuteBatchResponse) XXX_Size ¶
func (m *BeginExecuteBatchResponse) XXX_Size() int
func (*BeginExecuteBatchResponse) XXX_Unmarshal ¶
func (m *BeginExecuteBatchResponse) XXX_Unmarshal(b []byte) error
type BeginExecuteRequest ¶
type BeginExecuteRequest struct { EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"` ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"` Target *Target `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` Query *BoundQuery `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"` Options *ExecuteOptions `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"` ReservedId int64 `protobuf:"varint,6,opt,name=reserved_id,json=reservedId,proto3" json:"reserved_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
BeginExecuteRequest is the payload to BeginExecute
func (*BeginExecuteRequest) Descriptor ¶
func (*BeginExecuteRequest) Descriptor() ([]byte, []int)
func (*BeginExecuteRequest) GetEffectiveCallerId ¶
func (m *BeginExecuteRequest) GetEffectiveCallerId() *vtrpc.CallerID
func (*BeginExecuteRequest) GetImmediateCallerId ¶
func (m *BeginExecuteRequest) GetImmediateCallerId() *VTGateCallerID
func (*BeginExecuteRequest) GetOptions ¶
func (m *BeginExecuteRequest) GetOptions() *ExecuteOptions
func (*BeginExecuteRequest) GetQuery ¶
func (m *BeginExecuteRequest) GetQuery() *BoundQuery
func (*BeginExecuteRequest) GetReservedId ¶
func (m *BeginExecuteRequest) GetReservedId() int64
func (*BeginExecuteRequest) GetTarget ¶
func (m *BeginExecuteRequest) GetTarget() *Target
func (*BeginExecuteRequest) ProtoMessage ¶
func (*BeginExecuteRequest) ProtoMessage()
func (*BeginExecuteRequest) Reset ¶
func (m *BeginExecuteRequest) Reset()
func (*BeginExecuteRequest) String ¶
func (m *BeginExecuteRequest) String() string
func (*BeginExecuteRequest) XXX_DiscardUnknown ¶
func (m *BeginExecuteRequest) XXX_DiscardUnknown()
func (*BeginExecuteRequest) XXX_Marshal ¶
func (m *BeginExecuteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BeginExecuteRequest) XXX_Merge ¶
func (m *BeginExecuteRequest) XXX_Merge(src proto.Message)
func (*BeginExecuteRequest) XXX_Size ¶
func (m *BeginExecuteRequest) XXX_Size() int
func (*BeginExecuteRequest) XXX_Unmarshal ¶
func (m *BeginExecuteRequest) XXX_Unmarshal(b []byte) error
type BeginExecuteResponse ¶
type BeginExecuteResponse struct { // error contains an application level error if necessary. Note the // transaction_id may be set, even when an error is returned, if the begin // worked but the execute failed. Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Result *QueryResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` // transaction_id might be non-zero even if an error is present. TransactionId int64 `protobuf:"varint,3,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"` TabletAlias *topodata.TabletAlias `protobuf:"bytes,4,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
BeginExecuteResponse is the returned value from BeginExecute
func (*BeginExecuteResponse) Descriptor ¶
func (*BeginExecuteResponse) Descriptor() ([]byte, []int)
func (*BeginExecuteResponse) GetError ¶
func (m *BeginExecuteResponse) GetError() *vtrpc.RPCError
func (*BeginExecuteResponse) GetResult ¶
func (m *BeginExecuteResponse) GetResult() *QueryResult
func (*BeginExecuteResponse) GetTabletAlias ¶
func (m *BeginExecuteResponse) GetTabletAlias() *topodata.TabletAlias
func (*BeginExecuteResponse) GetTransactionId ¶
func (m *BeginExecuteResponse) GetTransactionId() int64
func (*BeginExecuteResponse) ProtoMessage ¶
func (*BeginExecuteResponse) ProtoMessage()
func (*BeginExecuteResponse) Reset ¶
func (m *BeginExecuteResponse) Reset()
func (*BeginExecuteResponse) String ¶
func (m *BeginExecuteResponse) String() string
func (*BeginExecuteResponse) XXX_DiscardUnknown ¶
func (m *BeginExecuteResponse) XXX_DiscardUnknown()
func (*BeginExecuteResponse) XXX_Marshal ¶
func (m *BeginExecuteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BeginExecuteResponse) XXX_Merge ¶
func (m *BeginExecuteResponse) XXX_Merge(src proto.Message)
func (*BeginExecuteResponse) XXX_Size ¶
func (m *BeginExecuteResponse) XXX_Size() int
func (*BeginExecuteResponse) XXX_Unmarshal ¶
func (m *BeginExecuteResponse) XXX_Unmarshal(b []byte) error
type BeginRequest ¶
type BeginRequest struct { EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"` ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"` Target *Target `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` Options *ExecuteOptions `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
BeginRequest is the payload to Begin
func (*BeginRequest) Descriptor ¶
func (*BeginRequest) Descriptor() ([]byte, []int)
func (*BeginRequest) GetEffectiveCallerId ¶
func (m *BeginRequest) GetEffectiveCallerId() *vtrpc.CallerID
func (*BeginRequest) GetImmediateCallerId ¶
func (m *BeginRequest) GetImmediateCallerId() *VTGateCallerID
func (*BeginRequest) GetOptions ¶
func (m *BeginRequest) GetOptions() *ExecuteOptions
func (*BeginRequest) GetTarget ¶
func (m *BeginRequest) GetTarget() *Target
func (*BeginRequest) ProtoMessage ¶
func (*BeginRequest) ProtoMessage()
func (*BeginRequest) Reset ¶
func (m *BeginRequest) Reset()
func (*BeginRequest) String ¶
func (m *BeginRequest) String() string
func (*BeginRequest) XXX_DiscardUnknown ¶
func (m *BeginRequest) XXX_DiscardUnknown()
func (*BeginRequest) XXX_Marshal ¶
func (m *BeginRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BeginRequest) XXX_Merge ¶
func (m *BeginRequest) XXX_Merge(src proto.Message)
func (*BeginRequest) XXX_Size ¶
func (m *BeginRequest) XXX_Size() int
func (*BeginRequest) XXX_Unmarshal ¶
func (m *BeginRequest) XXX_Unmarshal(b []byte) error
type BeginResponse ¶
type BeginResponse struct { TransactionId int64 `protobuf:"varint,1,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"` TabletAlias *topodata.TabletAlias `protobuf:"bytes,2,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
BeginResponse is the returned value from Begin
func (*BeginResponse) Descriptor ¶
func (*BeginResponse) Descriptor() ([]byte, []int)
func (*BeginResponse) GetTabletAlias ¶
func (m *BeginResponse) GetTabletAlias() *topodata.TabletAlias
func (*BeginResponse) GetTransactionId ¶
func (m *BeginResponse) GetTransactionId() int64
func (*BeginResponse) ProtoMessage ¶
func (*BeginResponse) ProtoMessage()
func (*BeginResponse) Reset ¶
func (m *BeginResponse) Reset()
func (*BeginResponse) String ¶
func (m *BeginResponse) String() string
func (*BeginResponse) XXX_DiscardUnknown ¶
func (m *BeginResponse) XXX_DiscardUnknown()
func (*BeginResponse) XXX_Marshal ¶
func (m *BeginResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BeginResponse) XXX_Merge ¶
func (m *BeginResponse) XXX_Merge(src proto.Message)
func (*BeginResponse) XXX_Size ¶
func (m *BeginResponse) XXX_Size() int
func (*BeginResponse) XXX_Unmarshal ¶
func (m *BeginResponse) XXX_Unmarshal(b []byte) error
type BindVariable ¶
type BindVariable struct { Type Type `protobuf:"varint,1,opt,name=type,proto3,enum=query.Type" json:"type,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // values are set if type is TUPLE. Values []*Value `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
BindVariable represents a single bind variable in a Query.
func (*BindVariable) Descriptor ¶
func (*BindVariable) Descriptor() ([]byte, []int)
func (*BindVariable) GetType ¶
func (m *BindVariable) GetType() Type
func (*BindVariable) GetValue ¶
func (m *BindVariable) GetValue() []byte
func (*BindVariable) GetValues ¶
func (m *BindVariable) GetValues() []*Value
func (*BindVariable) ProtoMessage ¶
func (*BindVariable) ProtoMessage()
func (*BindVariable) Reset ¶
func (m *BindVariable) Reset()
func (*BindVariable) String ¶
func (m *BindVariable) String() string
func (*BindVariable) XXX_DiscardUnknown ¶
func (m *BindVariable) XXX_DiscardUnknown()
func (*BindVariable) XXX_Marshal ¶
func (m *BindVariable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BindVariable) XXX_Merge ¶
func (m *BindVariable) XXX_Merge(src proto.Message)
func (*BindVariable) XXX_Size ¶
func (m *BindVariable) XXX_Size() int
func (*BindVariable) XXX_Unmarshal ¶
func (m *BindVariable) XXX_Unmarshal(b []byte) error
type BoundQuery ¶
type BoundQuery struct { // sql is the SQL query to execute Sql string `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"` // bind_variables is a map of all bind variables to expand in the query. // nil values are not allowed. Use NULL_TYPE to express a NULL value. BindVariables map[string]*BindVariable `` /* 188-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
BoundQuery is a query with its bind variables
func (*BoundQuery) Descriptor ¶
func (*BoundQuery) Descriptor() ([]byte, []int)
func (*BoundQuery) GetBindVariables ¶
func (m *BoundQuery) GetBindVariables() map[string]*BindVariable
func (*BoundQuery) GetSql ¶
func (m *BoundQuery) GetSql() string
func (*BoundQuery) ProtoMessage ¶
func (*BoundQuery) ProtoMessage()
func (*BoundQuery) Reset ¶
func (m *BoundQuery) Reset()
func (*BoundQuery) String ¶
func (m *BoundQuery) String() string
func (*BoundQuery) XXX_DiscardUnknown ¶
func (m *BoundQuery) XXX_DiscardUnknown()
func (*BoundQuery) XXX_Marshal ¶
func (m *BoundQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BoundQuery) XXX_Merge ¶
func (m *BoundQuery) XXX_Merge(src proto.Message)
func (*BoundQuery) XXX_Size ¶
func (m *BoundQuery) XXX_Size() int
func (*BoundQuery) XXX_Unmarshal ¶
func (m *BoundQuery) XXX_Unmarshal(b []byte) error
type CommitPreparedRequest ¶
type CommitPreparedRequest struct { EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"` ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"` Target *Target `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` Dtid string `protobuf:"bytes,4,opt,name=dtid,proto3" json:"dtid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
CommitPreparedRequest is the payload to CommitPrepared
func (*CommitPreparedRequest) Descriptor ¶
func (*CommitPreparedRequest) Descriptor() ([]byte, []int)
func (*CommitPreparedRequest) GetDtid ¶
func (m *CommitPreparedRequest) GetDtid() string
func (*CommitPreparedRequest) GetEffectiveCallerId ¶
func (m *CommitPreparedRequest) GetEffectiveCallerId() *vtrpc.CallerID
func (*CommitPreparedRequest) GetImmediateCallerId ¶
func (m *CommitPreparedRequest) GetImmediateCallerId() *VTGateCallerID
func (*CommitPreparedRequest) GetTarget ¶
func (m *CommitPreparedRequest) GetTarget() *Target
func (*CommitPreparedRequest) ProtoMessage ¶
func (*CommitPreparedRequest) ProtoMessage()
func (*CommitPreparedRequest) Reset ¶
func (m *CommitPreparedRequest) Reset()
func (*CommitPreparedRequest) String ¶
func (m *CommitPreparedRequest) String() string
func (*CommitPreparedRequest) XXX_DiscardUnknown ¶
func (m *CommitPreparedRequest) XXX_DiscardUnknown()
func (*CommitPreparedRequest) XXX_Marshal ¶
func (m *CommitPreparedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CommitPreparedRequest) XXX_Merge ¶
func (m *CommitPreparedRequest) XXX_Merge(src proto.Message)
func (*CommitPreparedRequest) XXX_Size ¶
func (m *CommitPreparedRequest) XXX_Size() int
func (*CommitPreparedRequest) XXX_Unmarshal ¶
func (m *CommitPreparedRequest) XXX_Unmarshal(b []byte) error
type CommitPreparedResponse ¶
type CommitPreparedResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
CommitPreparedResponse is the returned value from CommitPrepared
func (*CommitPreparedResponse) Descriptor ¶
func (*CommitPreparedResponse) Descriptor() ([]byte, []int)
func (*CommitPreparedResponse) ProtoMessage ¶
func (*CommitPreparedResponse) ProtoMessage()
func (*CommitPreparedResponse) Reset ¶
func (m *CommitPreparedResponse) Reset()
func (*CommitPreparedResponse) String ¶
func (m *CommitPreparedResponse) String() string
func (*CommitPreparedResponse) XXX_DiscardUnknown ¶
func (m *CommitPreparedResponse) XXX_DiscardUnknown()
func (*CommitPreparedResponse) XXX_Marshal ¶
func (m *CommitPreparedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CommitPreparedResponse) XXX_Merge ¶
func (m *CommitPreparedResponse) XXX_Merge(src proto.Message)
func (*CommitPreparedResponse) XXX_Size ¶
func (m *CommitPreparedResponse) XXX_Size() int
func (*CommitPreparedResponse) XXX_Unmarshal ¶
func (m *CommitPreparedResponse) XXX_Unmarshal(b []byte) error
type CommitRequest ¶
type CommitRequest struct { EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"` ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"` Target *Target `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` TransactionId int64 `protobuf:"varint,4,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
CommitRequest is the payload to Commit
func (*CommitRequest) Descriptor ¶
func (*CommitRequest) Descriptor() ([]byte, []int)
func (*CommitRequest) GetEffectiveCallerId ¶
func (m *CommitRequest) GetEffectiveCallerId() *vtrpc.CallerID
func (*CommitRequest) GetImmediateCallerId ¶
func (m *CommitRequest) GetImmediateCallerId() *VTGateCallerID
func (*CommitRequest) GetTarget ¶
func (m *CommitRequest) GetTarget() *Target
func (*CommitRequest) GetTransactionId ¶
func (m *CommitRequest) GetTransactionId() int64
func (*CommitRequest) ProtoMessage ¶
func (*CommitRequest) ProtoMessage()
func (*CommitRequest) Reset ¶
func (m *CommitRequest) Reset()
func (*CommitRequest) String ¶
func (m *CommitRequest) String() string
func (*CommitRequest) XXX_DiscardUnknown ¶
func (m *CommitRequest) XXX_DiscardUnknown()
func (*CommitRequest) XXX_Marshal ¶
func (m *CommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CommitRequest) XXX_Merge ¶
func (m *CommitRequest) XXX_Merge(src proto.Message)
func (*CommitRequest) XXX_Size ¶
func (m *CommitRequest) XXX_Size() int
func (*CommitRequest) XXX_Unmarshal ¶
func (m *CommitRequest) XXX_Unmarshal(b []byte) error
type CommitResponse ¶
type CommitResponse struct { ReservedId int64 `protobuf:"varint,1,opt,name=reserved_id,json=reservedId,proto3" json:"reserved_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
CommitResponse is the returned value from Commit
func (*CommitResponse) Descriptor ¶
func (*CommitResponse) Descriptor() ([]byte, []int)
func (*CommitResponse) GetReservedId ¶
func (m *CommitResponse) GetReservedId() int64
func (*CommitResponse) ProtoMessage ¶
func (*CommitResponse) ProtoMessage()
func (*CommitResponse) Reset ¶
func (m *CommitResponse) Reset()
func (*CommitResponse) String ¶
func (m *CommitResponse) String() string
func (*CommitResponse) XXX_DiscardUnknown ¶
func (m *CommitResponse) XXX_DiscardUnknown()
func (*CommitResponse) XXX_Marshal ¶
func (m *CommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CommitResponse) XXX_Merge ¶
func (m *CommitResponse) XXX_Merge(src proto.Message)
func (*CommitResponse) XXX_Size ¶
func (m *CommitResponse) XXX_Size() int
func (*CommitResponse) XXX_Unmarshal ¶
func (m *CommitResponse) XXX_Unmarshal(b []byte) error
type ConcludeTransactionRequest ¶
type ConcludeTransactionRequest struct { EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"` ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"` Target *Target `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` Dtid string `protobuf:"bytes,4,opt,name=dtid,proto3" json:"dtid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ConcludeTransactionRequest is the payload to ConcludeTransaction
func (*ConcludeTransactionRequest) Descriptor ¶
func (*ConcludeTransactionRequest) Descriptor() ([]byte, []int)
func (*ConcludeTransactionRequest) GetDtid ¶
func (m *ConcludeTransactionRequest) GetDtid() string
func (*ConcludeTransactionRequest) GetEffectiveCallerId ¶
func (m *ConcludeTransactionRequest) GetEffectiveCallerId() *vtrpc.CallerID
func (*ConcludeTransactionRequest) GetImmediateCallerId ¶
func (m *ConcludeTransactionRequest) GetImmediateCallerId() *VTGateCallerID
func (*ConcludeTransactionRequest) GetTarget ¶
func (m *ConcludeTransactionRequest) GetTarget() *Target
func (*ConcludeTransactionRequest) ProtoMessage ¶
func (*ConcludeTransactionRequest) ProtoMessage()
func (*ConcludeTransactionRequest) Reset ¶
func (m *ConcludeTransactionRequest) Reset()
func (*ConcludeTransactionRequest) String ¶
func (m *ConcludeTransactionRequest) String() string
func (*ConcludeTransactionRequest) XXX_DiscardUnknown ¶
func (m *ConcludeTransactionRequest) XXX_DiscardUnknown()
func (*ConcludeTransactionRequest) XXX_Marshal ¶
func (m *ConcludeTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConcludeTransactionRequest) XXX_Merge ¶
func (m *ConcludeTransactionRequest) XXX_Merge(src proto.Message)
func (*ConcludeTransactionRequest) XXX_Size ¶
func (m *ConcludeTransactionRequest) XXX_Size() int
func (*ConcludeTransactionRequest) XXX_Unmarshal ¶
func (m *ConcludeTransactionRequest) XXX_Unmarshal(b []byte) error
type ConcludeTransactionResponse ¶
type ConcludeTransactionResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ConcludeTransactionResponse is the returned value from ConcludeTransaction
func (*ConcludeTransactionResponse) Descriptor ¶
func (*ConcludeTransactionResponse) Descriptor() ([]byte, []int)
func (*ConcludeTransactionResponse) ProtoMessage ¶
func (*ConcludeTransactionResponse) ProtoMessage()
func (*ConcludeTransactionResponse) Reset ¶
func (m *ConcludeTransactionResponse) Reset()
func (*ConcludeTransactionResponse) String ¶
func (m *ConcludeTransactionResponse) String() string
func (*ConcludeTransactionResponse) XXX_DiscardUnknown ¶
func (m *ConcludeTransactionResponse) XXX_DiscardUnknown()
func (*ConcludeTransactionResponse) XXX_Marshal ¶
func (m *ConcludeTransactionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConcludeTransactionResponse) XXX_Merge ¶
func (m *ConcludeTransactionResponse) XXX_Merge(src proto.Message)
func (*ConcludeTransactionResponse) XXX_Size ¶
func (m *ConcludeTransactionResponse) XXX_Size() int
func (*ConcludeTransactionResponse) XXX_Unmarshal ¶
func (m *ConcludeTransactionResponse) XXX_Unmarshal(b []byte) error
type CreateTransactionRequest ¶
type CreateTransactionRequest struct { EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"` ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"` Target *Target `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` Dtid string `protobuf:"bytes,4,opt,name=dtid,proto3" json:"dtid,omitempty"` Participants []*Target `protobuf:"bytes,5,rep,name=participants,proto3" json:"participants,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
CreateTransactionRequest is the payload to CreateTransaction
func (*CreateTransactionRequest) Descriptor ¶
func (*CreateTransactionRequest) Descriptor() ([]byte, []int)
func (*CreateTransactionRequest) GetDtid ¶
func (m *CreateTransactionRequest) GetDtid() string
func (*CreateTransactionRequest) GetEffectiveCallerId ¶
func (m *CreateTransactionRequest) GetEffectiveCallerId() *vtrpc.CallerID
func (*CreateTransactionRequest) GetImmediateCallerId ¶
func (m *CreateTransactionRequest) GetImmediateCallerId() *VTGateCallerID
func (*CreateTransactionRequest) GetParticipants ¶
func (m *CreateTransactionRequest) GetParticipants() []*Target
func (*CreateTransactionRequest) GetTarget ¶
func (m *CreateTransactionRequest) GetTarget() *Target
func (*CreateTransactionRequest) ProtoMessage ¶
func (*CreateTransactionRequest) ProtoMessage()
func (*CreateTransactionRequest) Reset ¶
func (m *CreateTransactionRequest) Reset()
func (*CreateTransactionRequest) String ¶
func (m *CreateTransactionRequest) String() string
func (*CreateTransactionRequest) XXX_DiscardUnknown ¶
func (m *CreateTransactionRequest) XXX_DiscardUnknown()
func (*CreateTransactionRequest) XXX_Marshal ¶
func (m *CreateTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateTransactionRequest) XXX_Merge ¶
func (m *CreateTransactionRequest) XXX_Merge(src proto.Message)
func (*CreateTransactionRequest) XXX_Size ¶
func (m *CreateTransactionRequest) XXX_Size() int
func (*CreateTransactionRequest) XXX_Unmarshal ¶
func (m *CreateTransactionRequest) XXX_Unmarshal(b []byte) error
type CreateTransactionResponse ¶
type CreateTransactionResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
CreateTransactionResponse is the returned value from CreateTransaction
func (*CreateTransactionResponse) Descriptor ¶
func (*CreateTransactionResponse) Descriptor() ([]byte, []int)
func (*CreateTransactionResponse) ProtoMessage ¶
func (*CreateTransactionResponse) ProtoMessage()
func (*CreateTransactionResponse) Reset ¶
func (m *CreateTransactionResponse) Reset()
func (*CreateTransactionResponse) String ¶
func (m *CreateTransactionResponse) String() string
func (*CreateTransactionResponse) XXX_DiscardUnknown ¶
func (m *CreateTransactionResponse) XXX_DiscardUnknown()
func (*CreateTransactionResponse) XXX_Marshal ¶
func (m *CreateTransactionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateTransactionResponse) XXX_Merge ¶
func (m *CreateTransactionResponse) XXX_Merge(src proto.Message)
func (*CreateTransactionResponse) XXX_Size ¶
func (m *CreateTransactionResponse) XXX_Size() int
func (*CreateTransactionResponse) XXX_Unmarshal ¶
func (m *CreateTransactionResponse) XXX_Unmarshal(b []byte) error
type EventToken ¶
type EventToken struct { // timestamp is the MySQL timestamp of the statements. Seconds since Epoch. Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // The shard name that applied the statements. Note this is not set when // streaming from a vttablet. It is only used on the client -> vtgate link. Shard string `protobuf:"bytes,2,opt,name=shard,proto3" json:"shard,omitempty"` // The position on the replication stream after this statement was applied. // It is not the transaction ID / GTID, but the position / GTIDSet. Position string `protobuf:"bytes,3,opt,name=position,proto3" json:"position,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
EventToken is a structure that describes a point in time in a replication stream on one shard. The most recent known replication position can be retrieved from vttablet when executing a query. It is also sent with the replication streams from the binlog service.
func (*EventToken) Descriptor ¶
func (*EventToken) Descriptor() ([]byte, []int)
func (*EventToken) GetPosition ¶
func (m *EventToken) GetPosition() string
func (*EventToken) GetShard ¶
func (m *EventToken) GetShard() string
func (*EventToken) GetTimestamp ¶
func (m *EventToken) GetTimestamp() int64
func (*EventToken) ProtoMessage ¶
func (*EventToken) ProtoMessage()
func (*EventToken) Reset ¶
func (m *EventToken) Reset()
func (*EventToken) String ¶
func (m *EventToken) String() string
func (*EventToken) XXX_DiscardUnknown ¶
func (m *EventToken) XXX_DiscardUnknown()
func (*EventToken) XXX_Marshal ¶
func (m *EventToken) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventToken) XXX_Merge ¶
func (m *EventToken) XXX_Merge(src proto.Message)
func (*EventToken) XXX_Size ¶
func (m *EventToken) XXX_Size() int
func (*EventToken) XXX_Unmarshal ¶
func (m *EventToken) XXX_Unmarshal(b []byte) error
type ExecuteBatchRequest ¶
type ExecuteBatchRequest struct { EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"` ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"` Target *Target `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` Queries []*BoundQuery `protobuf:"bytes,4,rep,name=queries,proto3" json:"queries,omitempty"` AsTransaction bool `protobuf:"varint,5,opt,name=as_transaction,json=asTransaction,proto3" json:"as_transaction,omitempty"` TransactionId int64 `protobuf:"varint,6,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"` Options *ExecuteOptions `protobuf:"bytes,7,opt,name=options,proto3" json:"options,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ExecuteBatchRequest is the payload to ExecuteBatch
func (*ExecuteBatchRequest) Descriptor ¶
func (*ExecuteBatchRequest) Descriptor() ([]byte, []int)
func (*ExecuteBatchRequest) GetAsTransaction ¶
func (m *ExecuteBatchRequest) GetAsTransaction() bool
func (*ExecuteBatchRequest) GetEffectiveCallerId ¶
func (m *ExecuteBatchRequest) GetEffectiveCallerId() *vtrpc.CallerID
func (*ExecuteBatchRequest) GetImmediateCallerId ¶
func (m *ExecuteBatchRequest) GetImmediateCallerId() *VTGateCallerID
func (*ExecuteBatchRequest) GetOptions ¶
func (m *ExecuteBatchRequest) GetOptions() *ExecuteOptions
func (*ExecuteBatchRequest) GetQueries ¶
func (m *ExecuteBatchRequest) GetQueries() []*BoundQuery
func (*ExecuteBatchRequest) GetTarget ¶
func (m *ExecuteBatchRequest) GetTarget() *Target
func (*ExecuteBatchRequest) GetTransactionId ¶
func (m *ExecuteBatchRequest) GetTransactionId() int64
func (*ExecuteBatchRequest) ProtoMessage ¶
func (*ExecuteBatchRequest) ProtoMessage()
func (*ExecuteBatchRequest) Reset ¶
func (m *ExecuteBatchRequest) Reset()
func (*ExecuteBatchRequest) String ¶
func (m *ExecuteBatchRequest) String() string
func (*ExecuteBatchRequest) XXX_DiscardUnknown ¶
func (m *ExecuteBatchRequest) XXX_DiscardUnknown()
func (*ExecuteBatchRequest) XXX_Marshal ¶
func (m *ExecuteBatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExecuteBatchRequest) XXX_Merge ¶
func (m *ExecuteBatchRequest) XXX_Merge(src proto.Message)
func (*ExecuteBatchRequest) XXX_Size ¶
func (m *ExecuteBatchRequest) XXX_Size() int
func (*ExecuteBatchRequest) XXX_Unmarshal ¶
func (m *ExecuteBatchRequest) XXX_Unmarshal(b []byte) error
type ExecuteBatchResponse ¶
type ExecuteBatchResponse struct { Results []*QueryResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ExecuteBatchResponse is the returned value from ExecuteBatch
func (*ExecuteBatchResponse) Descriptor ¶
func (*ExecuteBatchResponse) Descriptor() ([]byte, []int)
func (*ExecuteBatchResponse) GetResults ¶
func (m *ExecuteBatchResponse) GetResults() []*QueryResult
func (*ExecuteBatchResponse) ProtoMessage ¶
func (*ExecuteBatchResponse) ProtoMessage()
func (*ExecuteBatchResponse) Reset ¶
func (m *ExecuteBatchResponse) Reset()
func (*ExecuteBatchResponse) String ¶
func (m *ExecuteBatchResponse) String() string
func (*ExecuteBatchResponse) XXX_DiscardUnknown ¶
func (m *ExecuteBatchResponse) XXX_DiscardUnknown()
func (*ExecuteBatchResponse) XXX_Marshal ¶
func (m *ExecuteBatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExecuteBatchResponse) XXX_Merge ¶
func (m *ExecuteBatchResponse) XXX_Merge(src proto.Message)
func (*ExecuteBatchResponse) XXX_Size ¶
func (m *ExecuteBatchResponse) XXX_Size() int
func (*ExecuteBatchResponse) XXX_Unmarshal ¶
func (m *ExecuteBatchResponse) XXX_Unmarshal(b []byte) error
type ExecuteOptions ¶
type ExecuteOptions struct { // Controls what fields are returned in Field message responses from mysql, i.e. // field name, table name, etc. This is an optimization for high-QPS queries where // the client knows what it's getting IncludedFields ExecuteOptions_IncludedFields `` /* 145-byte string literal not displayed */ // client_rows_found specifies if rows_affected should return // rows found instead of rows affected. Behavior is defined // by MySQL's CLIENT_FOUND_ROWS flag. ClientFoundRows bool `protobuf:"varint,5,opt,name=client_found_rows,json=clientFoundRows,proto3" json:"client_found_rows,omitempty"` // workload specifies the type of workload: // OLTP: DMLs allowed, results have row count limit, and // query timeouts are shorter. // OLAP: DMLS not allowed, no limit on row count, timeouts // can be as high as desired. // DBA: no limit on rowcount or timeout, all queries allowed // but intended for long DMLs and DDLs. Workload ExecuteOptions_Workload `protobuf:"varint,6,opt,name=workload,proto3,enum=query.ExecuteOptions_Workload" json:"workload,omitempty"` // sql_select_limit sets an implicit limit on all select statements. Since // vitess also sets a rowcount limit on queries, the smallest value wins. SqlSelectLimit int64 `protobuf:"varint,8,opt,name=sql_select_limit,json=sqlSelectLimit,proto3" json:"sql_select_limit,omitempty"` TransactionIsolation ExecuteOptions_TransactionIsolation `` /* 169-byte string literal not displayed */ // skip_query_plan_cache specifies if the query plan should be cached by vitess. // By default all query plans are cached. SkipQueryPlanCache bool `protobuf:"varint,10,opt,name=skip_query_plan_cache,json=skipQueryPlanCache,proto3" json:"skip_query_plan_cache,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ExecuteOptions is passed around for all Execute calls.
func (*ExecuteOptions) Descriptor ¶
func (*ExecuteOptions) Descriptor() ([]byte, []int)
func (*ExecuteOptions) GetClientFoundRows ¶
func (m *ExecuteOptions) GetClientFoundRows() bool
func (*ExecuteOptions) GetIncludedFields ¶
func (m *ExecuteOptions) GetIncludedFields() ExecuteOptions_IncludedFields
func (*ExecuteOptions) GetSkipQueryPlanCache ¶
func (m *ExecuteOptions) GetSkipQueryPlanCache() bool
func (*ExecuteOptions) GetSqlSelectLimit ¶
func (m *ExecuteOptions) GetSqlSelectLimit() int64
func (*ExecuteOptions) GetTransactionIsolation ¶
func (m *ExecuteOptions) GetTransactionIsolation() ExecuteOptions_TransactionIsolation
func (*ExecuteOptions) GetWorkload ¶
func (m *ExecuteOptions) GetWorkload() ExecuteOptions_Workload
func (*ExecuteOptions) ProtoMessage ¶
func (*ExecuteOptions) ProtoMessage()
func (*ExecuteOptions) Reset ¶
func (m *ExecuteOptions) Reset()
func (*ExecuteOptions) String ¶
func (m *ExecuteOptions) String() string
func (*ExecuteOptions) XXX_DiscardUnknown ¶
func (m *ExecuteOptions) XXX_DiscardUnknown()
func (*ExecuteOptions) XXX_Marshal ¶
func (m *ExecuteOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExecuteOptions) XXX_Merge ¶
func (m *ExecuteOptions) XXX_Merge(src proto.Message)
func (*ExecuteOptions) XXX_Size ¶
func (m *ExecuteOptions) XXX_Size() int
func (*ExecuteOptions) XXX_Unmarshal ¶
func (m *ExecuteOptions) XXX_Unmarshal(b []byte) error
type ExecuteOptions_IncludedFields ¶
type ExecuteOptions_IncludedFields int32
const ( ExecuteOptions_TYPE_AND_NAME ExecuteOptions_IncludedFields = 0 ExecuteOptions_TYPE_ONLY ExecuteOptions_IncludedFields = 1 ExecuteOptions_ALL ExecuteOptions_IncludedFields = 2 )
func (ExecuteOptions_IncludedFields) EnumDescriptor ¶
func (ExecuteOptions_IncludedFields) EnumDescriptor() ([]byte, []int)
func (ExecuteOptions_IncludedFields) String ¶
func (x ExecuteOptions_IncludedFields) String() string
type ExecuteOptions_TransactionIsolation ¶
type ExecuteOptions_TransactionIsolation int32
const ( ExecuteOptions_DEFAULT ExecuteOptions_TransactionIsolation = 0 ExecuteOptions_REPEATABLE_READ ExecuteOptions_TransactionIsolation = 1 ExecuteOptions_READ_COMMITTED ExecuteOptions_TransactionIsolation = 2 ExecuteOptions_READ_UNCOMMITTED ExecuteOptions_TransactionIsolation = 3 ExecuteOptions_SERIALIZABLE ExecuteOptions_TransactionIsolation = 4 // This is not an "official" transaction level but it will do a // START TRANSACTION WITH CONSISTENT SNAPSHOT, READ ONLY ExecuteOptions_CONSISTENT_SNAPSHOT_READ_ONLY ExecuteOptions_TransactionIsolation = 5 // This not an "official" transaction level, it will send queries to mysql // without wrapping them in a transaction ExecuteOptions_AUTOCOMMIT ExecuteOptions_TransactionIsolation = 6 )
func (ExecuteOptions_TransactionIsolation) EnumDescriptor ¶
func (ExecuteOptions_TransactionIsolation) EnumDescriptor() ([]byte, []int)
func (ExecuteOptions_TransactionIsolation) String ¶
func (x ExecuteOptions_TransactionIsolation) String() string
type ExecuteOptions_Workload ¶
type ExecuteOptions_Workload int32
const ( ExecuteOptions_UNSPECIFIED ExecuteOptions_Workload = 0 ExecuteOptions_OLTP ExecuteOptions_Workload = 1 ExecuteOptions_OLAP ExecuteOptions_Workload = 2 ExecuteOptions_DBA ExecuteOptions_Workload = 3 )
func (ExecuteOptions_Workload) EnumDescriptor ¶
func (ExecuteOptions_Workload) EnumDescriptor() ([]byte, []int)
func (ExecuteOptions_Workload) String ¶
func (x ExecuteOptions_Workload) String() string
type ExecuteRequest ¶
type ExecuteRequest struct { EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"` ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"` Target *Target `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` Query *BoundQuery `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"` TransactionId int64 `protobuf:"varint,5,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"` Options *ExecuteOptions `protobuf:"bytes,6,opt,name=options,proto3" json:"options,omitempty"` ReservedId int64 `protobuf:"varint,7,opt,name=reserved_id,json=reservedId,proto3" json:"reserved_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ExecuteRequest is the payload to Execute
func (*ExecuteRequest) Descriptor ¶
func (*ExecuteRequest) Descriptor() ([]byte, []int)
func (*ExecuteRequest) GetEffectiveCallerId ¶
func (m *ExecuteRequest) GetEffectiveCallerId() *vtrpc.CallerID
func (*ExecuteRequest) GetImmediateCallerId ¶
func (m *ExecuteRequest) GetImmediateCallerId() *VTGateCallerID
func (*ExecuteRequest) GetOptions ¶
func (m *ExecuteRequest) GetOptions() *ExecuteOptions
func (*ExecuteRequest) GetQuery ¶
func (m *ExecuteRequest) GetQuery() *BoundQuery
func (*ExecuteRequest) GetReservedId ¶
func (m *ExecuteRequest) GetReservedId() int64
func (*ExecuteRequest) GetTarget ¶
func (m *ExecuteRequest) GetTarget() *Target
func (*ExecuteRequest) GetTransactionId ¶
func (m *ExecuteRequest) GetTransactionId() int64
func (*ExecuteRequest) ProtoMessage ¶
func (*ExecuteRequest) ProtoMessage()
func (*ExecuteRequest) Reset ¶
func (m *ExecuteRequest) Reset()
func (*ExecuteRequest) String ¶
func (m *ExecuteRequest) String() string
func (*ExecuteRequest) XXX_DiscardUnknown ¶
func (m *ExecuteRequest) XXX_DiscardUnknown()
func (*ExecuteRequest) XXX_Marshal ¶
func (m *ExecuteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExecuteRequest) XXX_Merge ¶
func (m *ExecuteRequest) XXX_Merge(src proto.Message)
func (*ExecuteRequest) XXX_Size ¶
func (m *ExecuteRequest) XXX_Size() int
func (*ExecuteRequest) XXX_Unmarshal ¶
func (m *ExecuteRequest) XXX_Unmarshal(b []byte) error
type ExecuteResponse ¶
type ExecuteResponse struct { Result *QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ExecuteResponse is the returned value from Execute
func (*ExecuteResponse) Descriptor ¶
func (*ExecuteResponse) Descriptor() ([]byte, []int)
func (*ExecuteResponse) GetResult ¶
func (m *ExecuteResponse) GetResult() *QueryResult
func (*ExecuteResponse) ProtoMessage ¶
func (*ExecuteResponse) ProtoMessage()
func (*ExecuteResponse) Reset ¶
func (m *ExecuteResponse) Reset()
func (*ExecuteResponse) String ¶
func (m *ExecuteResponse) String() string
func (*ExecuteResponse) XXX_DiscardUnknown ¶
func (m *ExecuteResponse) XXX_DiscardUnknown()
func (*ExecuteResponse) XXX_Marshal ¶
func (m *ExecuteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExecuteResponse) XXX_Merge ¶
func (m *ExecuteResponse) XXX_Merge(src proto.Message)
func (*ExecuteResponse) XXX_Size ¶
func (m *ExecuteResponse) XXX_Size() int
func (*ExecuteResponse) XXX_Unmarshal ¶
func (m *ExecuteResponse) XXX_Unmarshal(b []byte) error
type Field ¶
type Field struct { // name of the field as returned by mysql C API Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // vitess-defined type. Conversion function is in sqltypes package. Type Type `protobuf:"varint,2,opt,name=type,proto3,enum=query.Type" json:"type,omitempty"` // Remaining fields from mysql C API. // These fields are only populated when ExecuteOptions.included_fields // is set to IncludedFields.ALL. Table string `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"` OrgTable string `protobuf:"bytes,4,opt,name=org_table,json=orgTable,proto3" json:"org_table,omitempty"` Database string `protobuf:"bytes,5,opt,name=database,proto3" json:"database,omitempty"` OrgName string `protobuf:"bytes,6,opt,name=org_name,json=orgName,proto3" json:"org_name,omitempty"` // column_length is really a uint32. All 32 bits can be used. ColumnLength uint32 `protobuf:"varint,7,opt,name=column_length,json=columnLength,proto3" json:"column_length,omitempty"` // charset is actually a uint16. Only the lower 16 bits are used. Charset uint32 `protobuf:"varint,8,opt,name=charset,proto3" json:"charset,omitempty"` // decimals is actually a uint8. Only the lower 8 bits are used. Decimals uint32 `protobuf:"varint,9,opt,name=decimals,proto3" json:"decimals,omitempty"` // flags is actually a uint16. Only the lower 16 bits are used. Flags uint32 `protobuf:"varint,10,opt,name=flags,proto3" json:"flags,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Field describes a single column returned by a query
func (*Field) Descriptor ¶
func (*Field) GetCharset ¶
func (*Field) GetColumnLength ¶
func (*Field) GetDatabase ¶
func (*Field) GetDecimals ¶
func (*Field) GetOrgName ¶
func (*Field) GetOrgTable ¶
func (*Field) ProtoMessage ¶
func (*Field) ProtoMessage()
func (*Field) XXX_DiscardUnknown ¶
func (m *Field) XXX_DiscardUnknown()
func (*Field) XXX_Marshal ¶
func (*Field) XXX_Unmarshal ¶
type Flag ¶
type Flag int32
Flag allows us to qualify types by their common properties.
func (Flag) EnumDescriptor ¶
type MessageAckRequest ¶
type MessageAckRequest struct { EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"` ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"` Target *Target `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` // name is the message table name. Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` Ids []*Value `protobuf:"bytes,5,rep,name=ids,proto3" json:"ids,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
MessageAckRequest is the request payload for MessageAck.
func (*MessageAckRequest) Descriptor ¶
func (*MessageAckRequest) Descriptor() ([]byte, []int)
func (*MessageAckRequest) GetEffectiveCallerId ¶
func (m *MessageAckRequest) GetEffectiveCallerId() *vtrpc.CallerID
func (*MessageAckRequest) GetIds ¶
func (m *MessageAckRequest) GetIds() []*Value
func (*MessageAckRequest) GetImmediateCallerId ¶
func (m *MessageAckRequest) GetImmediateCallerId() *VTGateCallerID
func (*MessageAckRequest) GetName ¶
func (m *MessageAckRequest) GetName() string
func (*MessageAckRequest) GetTarget ¶
func (m *MessageAckRequest) GetTarget() *Target
func (*MessageAckRequest) ProtoMessage ¶
func (*MessageAckRequest) ProtoMessage()
func (*MessageAckRequest) Reset ¶
func (m *MessageAckRequest) Reset()
func (*MessageAckRequest) String ¶
func (m *MessageAckRequest) String() string
func (*MessageAckRequest) XXX_DiscardUnknown ¶
func (m *MessageAckRequest) XXX_DiscardUnknown()
func (*MessageAckRequest) XXX_Marshal ¶
func (m *MessageAckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MessageAckRequest) XXX_Merge ¶
func (m *MessageAckRequest) XXX_Merge(src proto.Message)
func (*MessageAckRequest) XXX_Size ¶
func (m *MessageAckRequest) XXX_Size() int
func (*MessageAckRequest) XXX_Unmarshal ¶
func (m *MessageAckRequest) XXX_Unmarshal(b []byte) error
type MessageAckResponse ¶
type MessageAckResponse struct { // result contains the result of the ack operation. // Since this acts like a DML, only // RowsAffected is returned in the result. Result *QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
MessageAckResponse is the response for MessageAck.
func (*MessageAckResponse) Descriptor ¶
func (*MessageAckResponse) Descriptor() ([]byte, []int)
func (*MessageAckResponse) GetResult ¶
func (m *MessageAckResponse) GetResult() *QueryResult
func (*MessageAckResponse) ProtoMessage ¶
func (*MessageAckResponse) ProtoMessage()
func (*MessageAckResponse) Reset ¶
func (m *MessageAckResponse) Reset()
func (*MessageAckResponse) String ¶
func (m *MessageAckResponse) String() string
func (*MessageAckResponse) XXX_DiscardUnknown ¶
func (m *MessageAckResponse) XXX_DiscardUnknown()
func (*MessageAckResponse) XXX_Marshal ¶
func (m *MessageAckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MessageAckResponse) XXX_Merge ¶
func (m *MessageAckResponse) XXX_Merge(src proto.Message)
func (*MessageAckResponse) XXX_Size ¶
func (m *MessageAckResponse) XXX_Size() int
func (*MessageAckResponse) XXX_Unmarshal ¶
func (m *MessageAckResponse) XXX_Unmarshal(b []byte) error
type MessageStreamRequest ¶
type MessageStreamRequest struct { EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"` ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"` Target *Target `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` // name is the message table name. Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
MessageStreamRequest is the request payload for MessageStream.
func (*MessageStreamRequest) Descriptor ¶
func (*MessageStreamRequest) Descriptor() ([]byte, []int)
func (*MessageStreamRequest) GetEffectiveCallerId ¶
func (m *MessageStreamRequest) GetEffectiveCallerId() *vtrpc.CallerID
func (*MessageStreamRequest) GetImmediateCallerId ¶
func (m *MessageStreamRequest) GetImmediateCallerId() *VTGateCallerID
func (*MessageStreamRequest) GetName ¶
func (m *MessageStreamRequest) GetName() string
func (*MessageStreamRequest) GetTarget ¶
func (m *MessageStreamRequest) GetTarget() *Target
func (*MessageStreamRequest) ProtoMessage ¶
func (*MessageStreamRequest) ProtoMessage()
func (*MessageStreamRequest) Reset ¶
func (m *MessageStreamRequest) Reset()
func (*MessageStreamRequest) String ¶
func (m *MessageStreamRequest) String() string
func (*MessageStreamRequest) XXX_DiscardUnknown ¶
func (m *MessageStreamRequest) XXX_DiscardUnknown()
func (*MessageStreamRequest) XXX_Marshal ¶
func (m *MessageStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MessageStreamRequest) XXX_Merge ¶
func (m *MessageStreamRequest) XXX_Merge(src proto.Message)
func (*MessageStreamRequest) XXX_Size ¶
func (m *MessageStreamRequest) XXX_Size() int
func (*MessageStreamRequest) XXX_Unmarshal ¶
func (m *MessageStreamRequest) XXX_Unmarshal(b []byte) error
type MessageStreamResponse ¶
type MessageStreamResponse struct { Result *QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
MessageStreamResponse is a response for MessageStream.
func (*MessageStreamResponse) Descriptor ¶
func (*MessageStreamResponse) Descriptor() ([]byte, []int)
func (*MessageStreamResponse) GetResult ¶
func (m *MessageStreamResponse) GetResult() *QueryResult
func (*MessageStreamResponse) ProtoMessage ¶
func (*MessageStreamResponse) ProtoMessage()
func (*MessageStreamResponse) Reset ¶
func (m *MessageStreamResponse) Reset()
func (*MessageStreamResponse) String ¶
func (m *MessageStreamResponse) String() string
func (*MessageStreamResponse) XXX_DiscardUnknown ¶
func (m *MessageStreamResponse) XXX_DiscardUnknown()
func (*MessageStreamResponse) XXX_Marshal ¶
func (m *MessageStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MessageStreamResponse) XXX_Merge ¶
func (m *MessageStreamResponse) XXX_Merge(src proto.Message)
func (*MessageStreamResponse) XXX_Size ¶
func (m *MessageStreamResponse) XXX_Size() int
func (*MessageStreamResponse) XXX_Unmarshal ¶
func (m *MessageStreamResponse) XXX_Unmarshal(b []byte) error
type MySqlFlag ¶
type MySqlFlag int32
Flags sent from the MySQL C API
const ( MySqlFlag_EMPTY MySqlFlag = 0 MySqlFlag_NOT_NULL_FLAG MySqlFlag = 1 MySqlFlag_PRI_KEY_FLAG MySqlFlag = 2 MySqlFlag_UNIQUE_KEY_FLAG MySqlFlag = 4 MySqlFlag_MULTIPLE_KEY_FLAG MySqlFlag = 8 MySqlFlag_BLOB_FLAG MySqlFlag = 16 MySqlFlag_UNSIGNED_FLAG MySqlFlag = 32 MySqlFlag_ZEROFILL_FLAG MySqlFlag = 64 MySqlFlag_BINARY_FLAG MySqlFlag = 128 MySqlFlag_ENUM_FLAG MySqlFlag = 256 MySqlFlag_AUTO_INCREMENT_FLAG MySqlFlag = 512 MySqlFlag_TIMESTAMP_FLAG MySqlFlag = 1024 MySqlFlag_SET_FLAG MySqlFlag = 2048 MySqlFlag_NO_DEFAULT_VALUE_FLAG MySqlFlag = 4096 MySqlFlag_ON_UPDATE_NOW_FLAG MySqlFlag = 8192 MySqlFlag_NUM_FLAG MySqlFlag = 32768 MySqlFlag_PART_KEY_FLAG MySqlFlag = 16384 MySqlFlag_GROUP_FLAG MySqlFlag = 32768 MySqlFlag_UNIQUE_FLAG MySqlFlag = 65536 MySqlFlag_BINCMP_FLAG MySqlFlag = 131072 )
func (MySqlFlag) EnumDescriptor ¶
type PrepareRequest ¶
type PrepareRequest struct { EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"` ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"` Target *Target `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` TransactionId int64 `protobuf:"varint,4,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"` Dtid string `protobuf:"bytes,5,opt,name=dtid,proto3" json:"dtid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
PrepareRequest is the payload to Prepare
func (*PrepareRequest) Descriptor ¶
func (*PrepareRequest) Descriptor() ([]byte, []int)
func (*PrepareRequest) GetDtid ¶
func (m *PrepareRequest) GetDtid() string
func (*PrepareRequest) GetEffectiveCallerId ¶
func (m *PrepareRequest) GetEffectiveCallerId() *vtrpc.CallerID
func (*PrepareRequest) GetImmediateCallerId ¶
func (m *PrepareRequest) GetImmediateCallerId() *VTGateCallerID
func (*PrepareRequest) GetTarget ¶
func (m *PrepareRequest) GetTarget() *Target
func (*PrepareRequest) GetTransactionId ¶
func (m *PrepareRequest) GetTransactionId() int64
func (*PrepareRequest) ProtoMessage ¶
func (*PrepareRequest) ProtoMessage()
func (*PrepareRequest) Reset ¶
func (m *PrepareRequest) Reset()
func (*PrepareRequest) String ¶
func (m *PrepareRequest) String() string
func (*PrepareRequest) XXX_DiscardUnknown ¶
func (m *PrepareRequest) XXX_DiscardUnknown()
func (*PrepareRequest) XXX_Marshal ¶
func (m *PrepareRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PrepareRequest) XXX_Merge ¶
func (m *PrepareRequest) XXX_Merge(src proto.Message)
func (*PrepareRequest) XXX_Size ¶
func (m *PrepareRequest) XXX_Size() int
func (*PrepareRequest) XXX_Unmarshal ¶
func (m *PrepareRequest) XXX_Unmarshal(b []byte) error
type PrepareResponse ¶
type PrepareResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
PrepareResponse is the returned value from Prepare
func (*PrepareResponse) Descriptor ¶
func (*PrepareResponse) Descriptor() ([]byte, []int)
func (*PrepareResponse) ProtoMessage ¶
func (*PrepareResponse) ProtoMessage()
func (*PrepareResponse) Reset ¶
func (m *PrepareResponse) Reset()
func (*PrepareResponse) String ¶
func (m *PrepareResponse) String() string
func (*PrepareResponse) XXX_DiscardUnknown ¶
func (m *PrepareResponse) XXX_DiscardUnknown()
func (*PrepareResponse) XXX_Marshal ¶
func (m *PrepareResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PrepareResponse) XXX_Merge ¶
func (m *PrepareResponse) XXX_Merge(src proto.Message)
func (*PrepareResponse) XXX_Size ¶
func (m *PrepareResponse) XXX_Size() int
func (*PrepareResponse) XXX_Unmarshal ¶
func (m *PrepareResponse) XXX_Unmarshal(b []byte) error
type QueryResult ¶
type QueryResult struct { Fields []*Field `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"` RowsAffected uint64 `protobuf:"varint,2,opt,name=rows_affected,json=rowsAffected,proto3" json:"rows_affected,omitempty"` InsertId uint64 `protobuf:"varint,3,opt,name=insert_id,json=insertId,proto3" json:"insert_id,omitempty"` Rows []*Row `protobuf:"bytes,4,rep,name=rows,proto3" json:"rows,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
QueryResult is returned by Execute and ExecuteStream.
As returned by Execute, len(fields) is always equal to len(row) (for each row in rows).
As returned by StreamExecute, the first QueryResult has the fields set, and subsequent QueryResult have rows set. And as Execute, len(QueryResult[0].fields) is always equal to len(row) (for each row in rows for each QueryResult in QueryResult[1:]).
func (*QueryResult) Descriptor ¶
func (*QueryResult) Descriptor() ([]byte, []int)
func (*QueryResult) GetFields ¶
func (m *QueryResult) GetFields() []*Field
func (*QueryResult) GetInsertId ¶
func (m *QueryResult) GetInsertId() uint64
func (*QueryResult) GetRows ¶
func (m *QueryResult) GetRows() []*Row
func (*QueryResult) GetRowsAffected ¶
func (m *QueryResult) GetRowsAffected() uint64
func (*QueryResult) ProtoMessage ¶
func (*QueryResult) ProtoMessage()
func (*QueryResult) Reset ¶
func (m *QueryResult) Reset()
func (*QueryResult) String ¶
func (m *QueryResult) String() string
func (*QueryResult) XXX_DiscardUnknown ¶
func (m *QueryResult) XXX_DiscardUnknown()
func (*QueryResult) XXX_Marshal ¶
func (m *QueryResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryResult) XXX_Merge ¶
func (m *QueryResult) XXX_Merge(src proto.Message)
func (*QueryResult) XXX_Size ¶
func (m *QueryResult) XXX_Size() int
func (*QueryResult) XXX_Unmarshal ¶
func (m *QueryResult) XXX_Unmarshal(b []byte) error
type QueryWarning ¶
type QueryWarning struct { Code uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
QueryWarning is used to convey out of band query execution warnings by storing in the vtgate.Session
func (*QueryWarning) Descriptor ¶
func (*QueryWarning) Descriptor() ([]byte, []int)
func (*QueryWarning) GetCode ¶
func (m *QueryWarning) GetCode() uint32
func (*QueryWarning) GetMessage ¶
func (m *QueryWarning) GetMessage() string
func (*QueryWarning) ProtoMessage ¶
func (*QueryWarning) ProtoMessage()
func (*QueryWarning) Reset ¶
func (m *QueryWarning) Reset()
func (*QueryWarning) String ¶
func (m *QueryWarning) String() string
func (*QueryWarning) XXX_DiscardUnknown ¶
func (m *QueryWarning) XXX_DiscardUnknown()
func (*QueryWarning) XXX_Marshal ¶
func (m *QueryWarning) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryWarning) XXX_Merge ¶
func (m *QueryWarning) XXX_Merge(src proto.Message)
func (*QueryWarning) XXX_Size ¶
func (m *QueryWarning) XXX_Size() int
func (*QueryWarning) XXX_Unmarshal ¶
func (m *QueryWarning) XXX_Unmarshal(b []byte) error
type ReadTransactionRequest ¶
type ReadTransactionRequest struct { EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"` ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"` Target *Target `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` Dtid string `protobuf:"bytes,4,opt,name=dtid,proto3" json:"dtid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ReadTransactionRequest is the payload to ReadTransaction
func (*ReadTransactionRequest) Descriptor ¶
func (*ReadTransactionRequest) Descriptor() ([]byte, []int)
func (*ReadTransactionRequest) GetDtid ¶
func (m *ReadTransactionRequest) GetDtid() string
func (*ReadTransactionRequest) GetEffectiveCallerId ¶
func (m *ReadTransactionRequest) GetEffectiveCallerId() *vtrpc.CallerID
func (*ReadTransactionRequest) GetImmediateCallerId ¶
func (m *ReadTransactionRequest) GetImmediateCallerId() *VTGateCallerID
func (*ReadTransactionRequest) GetTarget ¶
func (m *ReadTransactionRequest) GetTarget() *Target
func (*ReadTransactionRequest) ProtoMessage ¶
func (*ReadTransactionRequest) ProtoMessage()
func (*ReadTransactionRequest) Reset ¶
func (m *ReadTransactionRequest) Reset()
func (*ReadTransactionRequest) String ¶
func (m *ReadTransactionRequest) String() string
func (*ReadTransactionRequest) XXX_DiscardUnknown ¶
func (m *ReadTransactionRequest) XXX_DiscardUnknown()
func (*ReadTransactionRequest) XXX_Marshal ¶
func (m *ReadTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReadTransactionRequest) XXX_Merge ¶
func (m *ReadTransactionRequest) XXX_Merge(src proto.Message)
func (*ReadTransactionRequest) XXX_Size ¶
func (m *ReadTransactionRequest) XXX_Size() int
func (*ReadTransactionRequest) XXX_Unmarshal ¶
func (m *ReadTransactionRequest) XXX_Unmarshal(b []byte) error
type ReadTransactionResponse ¶
type ReadTransactionResponse struct { Metadata *TransactionMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ReadTransactionResponse is the returned value from ReadTransaction
func (*ReadTransactionResponse) Descriptor ¶
func (*ReadTransactionResponse) Descriptor() ([]byte, []int)
func (*ReadTransactionResponse) GetMetadata ¶
func (m *ReadTransactionResponse) GetMetadata() *TransactionMetadata
func (*ReadTransactionResponse) ProtoMessage ¶
func (*ReadTransactionResponse) ProtoMessage()
func (*ReadTransactionResponse) Reset ¶
func (m *ReadTransactionResponse) Reset()
func (*ReadTransactionResponse) String ¶
func (m *ReadTransactionResponse) String() string
func (*ReadTransactionResponse) XXX_DiscardUnknown ¶
func (m *ReadTransactionResponse) XXX_DiscardUnknown()
func (*ReadTransactionResponse) XXX_Marshal ¶
func (m *ReadTransactionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReadTransactionResponse) XXX_Merge ¶
func (m *ReadTransactionResponse) XXX_Merge(src proto.Message)
func (*ReadTransactionResponse) XXX_Size ¶
func (m *ReadTransactionResponse) XXX_Size() int
func (*ReadTransactionResponse) XXX_Unmarshal ¶
func (m *ReadTransactionResponse) XXX_Unmarshal(b []byte) error
type RealtimeStats ¶
type RealtimeStats struct { // health_error is the last error we got from health check, // or empty is the server is healthy. This is used for subset selection, // we do not send queries to servers that are not healthy. HealthError string `protobuf:"bytes,1,opt,name=health_error,json=healthError,proto3" json:"health_error,omitempty"` // seconds_behind_master is populated for replicas only. It indicates // how far behind on (MySQL) replication a replica currently is. It is used // by clients for subset selection (so we don't try to send traffic // to tablets that are too far behind). // NOTE: This field must not be evaluated if "health_error" is not empty. // TODO(mberlin): Let's switch it to int64 instead? SecondsBehindMaster uint32 `protobuf:"varint,2,opt,name=seconds_behind_master,json=secondsBehindMaster,proto3" json:"seconds_behind_master,omitempty"` // bin_log_players_count is the number of currently running binlog players. // if the value is 0, it means that filtered replication is currently not // running on the tablet. If >0, filtered replication is running. // NOTE: This field must not be evaluated if "health_error" is not empty. BinlogPlayersCount int32 `protobuf:"varint,3,opt,name=binlog_players_count,json=binlogPlayersCount,proto3" json:"binlog_players_count,omitempty"` // seconds_behind_master_filtered_replication is populated for the receiving // master of an ongoing filtered replication only. // It specifies how far the receiving master lags behind the sending master. // NOTE: This field must not be evaluated if "health_error" is not empty. // NOTE: This field must not be evaluated if "bin_log_players_count" is 0. SecondsBehindMasterFilteredReplication int64 `` /* 182-byte string literal not displayed */ // cpu_usage is used for load-based balancing CpuUsage float64 `protobuf:"fixed64,5,opt,name=cpu_usage,json=cpuUsage,proto3" json:"cpu_usage,omitempty"` // qps is the average QPS (queries per second) rate in the last XX seconds // where XX is usually 60 (See query_service_stats.go). Qps float64 `protobuf:"fixed64,6,opt,name=qps,proto3" json:"qps,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
RealtimeStats contains information about the tablet status. It is only valid for a single tablet.
func (*RealtimeStats) Descriptor ¶
func (*RealtimeStats) Descriptor() ([]byte, []int)
func (*RealtimeStats) GetBinlogPlayersCount ¶
func (m *RealtimeStats) GetBinlogPlayersCount() int32
func (*RealtimeStats) GetCpuUsage ¶
func (m *RealtimeStats) GetCpuUsage() float64
func (*RealtimeStats) GetHealthError ¶
func (m *RealtimeStats) GetHealthError() string
func (*RealtimeStats) GetQps ¶
func (m *RealtimeStats) GetQps() float64
func (*RealtimeStats) GetSecondsBehindMaster ¶
func (m *RealtimeStats) GetSecondsBehindMaster() uint32
func (*RealtimeStats) GetSecondsBehindMasterFilteredReplication ¶
func (m *RealtimeStats) GetSecondsBehindMasterFilteredReplication() int64
func (*RealtimeStats) ProtoMessage ¶
func (*RealtimeStats) ProtoMessage()
func (*RealtimeStats) Reset ¶
func (m *RealtimeStats) Reset()
func (*RealtimeStats) String ¶
func (m *RealtimeStats) String() string
func (*RealtimeStats) XXX_DiscardUnknown ¶
func (m *RealtimeStats) XXX_DiscardUnknown()
func (*RealtimeStats) XXX_Marshal ¶
func (m *RealtimeStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RealtimeStats) XXX_Merge ¶
func (m *RealtimeStats) XXX_Merge(src proto.Message)
func (*RealtimeStats) XXX_Size ¶
func (m *RealtimeStats) XXX_Size() int
func (*RealtimeStats) XXX_Unmarshal ¶
func (m *RealtimeStats) XXX_Unmarshal(b []byte) error
type ReleaseRequest ¶
type ReleaseRequest struct { EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"` ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"` Target *Target `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` TransactionId int64 `protobuf:"varint,4,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"` ReservedId int64 `protobuf:"varint,5,opt,name=reserved_id,json=reservedId,proto3" json:"reserved_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ReleaseRequest is the payload to Release
func (*ReleaseRequest) Descriptor ¶
func (*ReleaseRequest) Descriptor() ([]byte, []int)
func (*ReleaseRequest) GetEffectiveCallerId ¶
func (m *ReleaseRequest) GetEffectiveCallerId() *vtrpc.CallerID
func (*ReleaseRequest) GetImmediateCallerId ¶
func (m *ReleaseRequest) GetImmediateCallerId() *VTGateCallerID
func (*ReleaseRequest) GetReservedId ¶
func (m *ReleaseRequest) GetReservedId() int64
func (*ReleaseRequest) GetTarget ¶
func (m *ReleaseRequest) GetTarget() *Target
func (*ReleaseRequest) GetTransactionId ¶
func (m *ReleaseRequest) GetTransactionId() int64
func (*ReleaseRequest) ProtoMessage ¶
func (*ReleaseRequest) ProtoMessage()
func (*ReleaseRequest) Reset ¶
func (m *ReleaseRequest) Reset()
func (*ReleaseRequest) String ¶
func (m *ReleaseRequest) String() string
func (*ReleaseRequest) XXX_DiscardUnknown ¶
func (m *ReleaseRequest) XXX_DiscardUnknown()
func (*ReleaseRequest) XXX_Marshal ¶
func (m *ReleaseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReleaseRequest) XXX_Merge ¶
func (m *ReleaseRequest) XXX_Merge(src proto.Message)
func (*ReleaseRequest) XXX_Size ¶
func (m *ReleaseRequest) XXX_Size() int
func (*ReleaseRequest) XXX_Unmarshal ¶
func (m *ReleaseRequest) XXX_Unmarshal(b []byte) error
type ReleaseResponse ¶
type ReleaseResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ReleaseResponse is the returned value from Release
func (*ReleaseResponse) Descriptor ¶
func (*ReleaseResponse) Descriptor() ([]byte, []int)
func (*ReleaseResponse) ProtoMessage ¶
func (*ReleaseResponse) ProtoMessage()
func (*ReleaseResponse) Reset ¶
func (m *ReleaseResponse) Reset()
func (*ReleaseResponse) String ¶
func (m *ReleaseResponse) String() string
func (*ReleaseResponse) XXX_DiscardUnknown ¶
func (m *ReleaseResponse) XXX_DiscardUnknown()
func (*ReleaseResponse) XXX_Marshal ¶
func (m *ReleaseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReleaseResponse) XXX_Merge ¶
func (m *ReleaseResponse) XXX_Merge(src proto.Message)
func (*ReleaseResponse) XXX_Size ¶
func (m *ReleaseResponse) XXX_Size() int
func (*ReleaseResponse) XXX_Unmarshal ¶
func (m *ReleaseResponse) XXX_Unmarshal(b []byte) error
type ReserveBeginExecuteRequest ¶
type ReserveBeginExecuteRequest struct { EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"` ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"` Target *Target `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` Query *BoundQuery `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"` Options *ExecuteOptions `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"` PreQueries []string `protobuf:"bytes,6,rep,name=pre_queries,json=preQueries,proto3" json:"pre_queries,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ReserveBeginExecuteRequest is the payload to ReserveBeginExecute
func (*ReserveBeginExecuteRequest) Descriptor ¶
func (*ReserveBeginExecuteRequest) Descriptor() ([]byte, []int)
func (*ReserveBeginExecuteRequest) GetEffectiveCallerId ¶
func (m *ReserveBeginExecuteRequest) GetEffectiveCallerId() *vtrpc.CallerID
func (*ReserveBeginExecuteRequest) GetImmediateCallerId ¶
func (m *ReserveBeginExecuteRequest) GetImmediateCallerId() *VTGateCallerID
func (*ReserveBeginExecuteRequest) GetOptions ¶
func (m *ReserveBeginExecuteRequest) GetOptions() *ExecuteOptions
func (*ReserveBeginExecuteRequest) GetPreQueries ¶
func (m *ReserveBeginExecuteRequest) GetPreQueries() []string
func (*ReserveBeginExecuteRequest) GetQuery ¶
func (m *ReserveBeginExecuteRequest) GetQuery() *BoundQuery
func (*ReserveBeginExecuteRequest) GetTarget ¶
func (m *ReserveBeginExecuteRequest) GetTarget() *Target
func (*ReserveBeginExecuteRequest) ProtoMessage ¶
func (*ReserveBeginExecuteRequest) ProtoMessage()
func (*ReserveBeginExecuteRequest) Reset ¶
func (m *ReserveBeginExecuteRequest) Reset()
func (*ReserveBeginExecuteRequest) String ¶
func (m *ReserveBeginExecuteRequest) String() string
func (*ReserveBeginExecuteRequest) XXX_DiscardUnknown ¶
func (m *ReserveBeginExecuteRequest) XXX_DiscardUnknown()
func (*ReserveBeginExecuteRequest) XXX_Marshal ¶
func (m *ReserveBeginExecuteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReserveBeginExecuteRequest) XXX_Merge ¶
func (m *ReserveBeginExecuteRequest) XXX_Merge(src proto.Message)
func (*ReserveBeginExecuteRequest) XXX_Size ¶
func (m *ReserveBeginExecuteRequest) XXX_Size() int
func (*ReserveBeginExecuteRequest) XXX_Unmarshal ¶
func (m *ReserveBeginExecuteRequest) XXX_Unmarshal(b []byte) error
type ReserveBeginExecuteResponse ¶
type ReserveBeginExecuteResponse struct { // error contains an application level error if necessary. Note the // transaction_id may be set, even when an error is returned, if the begin // worked but the execute failed. Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Result *QueryResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` // The following fields might be non-zero even if an error is present. TransactionId int64 `protobuf:"varint,3,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"` ReservedId int64 `protobuf:"varint,4,opt,name=reserved_id,json=reservedId,proto3" json:"reserved_id,omitempty"` TabletAlias *topodata.TabletAlias `protobuf:"bytes,5,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ReserveBeginExecuteResponse is the returned value from ReserveBeginExecute
func (*ReserveBeginExecuteResponse) Descriptor ¶
func (*ReserveBeginExecuteResponse) Descriptor() ([]byte, []int)
func (*ReserveBeginExecuteResponse) GetError ¶
func (m *ReserveBeginExecuteResponse) GetError() *vtrpc.RPCError
func (*ReserveBeginExecuteResponse) GetReservedId ¶
func (m *ReserveBeginExecuteResponse) GetReservedId() int64
func (*ReserveBeginExecuteResponse) GetResult ¶
func (m *ReserveBeginExecuteResponse) GetResult() *QueryResult
func (*ReserveBeginExecuteResponse) GetTabletAlias ¶
func (m *ReserveBeginExecuteResponse) GetTabletAlias() *topodata.TabletAlias
func (*ReserveBeginExecuteResponse) GetTransactionId ¶
func (m *ReserveBeginExecuteResponse) GetTransactionId() int64
func (*ReserveBeginExecuteResponse) ProtoMessage ¶
func (*ReserveBeginExecuteResponse) ProtoMessage()
func (*ReserveBeginExecuteResponse) Reset ¶
func (m *ReserveBeginExecuteResponse) Reset()
func (*ReserveBeginExecuteResponse) String ¶
func (m *ReserveBeginExecuteResponse) String() string
func (*ReserveBeginExecuteResponse) XXX_DiscardUnknown ¶
func (m *ReserveBeginExecuteResponse) XXX_DiscardUnknown()
func (*ReserveBeginExecuteResponse) XXX_Marshal ¶
func (m *ReserveBeginExecuteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReserveBeginExecuteResponse) XXX_Merge ¶
func (m *ReserveBeginExecuteResponse) XXX_Merge(src proto.Message)
func (*ReserveBeginExecuteResponse) XXX_Size ¶
func (m *ReserveBeginExecuteResponse) XXX_Size() int
func (*ReserveBeginExecuteResponse) XXX_Unmarshal ¶
func (m *ReserveBeginExecuteResponse) XXX_Unmarshal(b []byte) error
type ReserveExecuteRequest ¶
type ReserveExecuteRequest struct { EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"` ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"` Target *Target `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` Query *BoundQuery `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"` TransactionId int64 `protobuf:"varint,5,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"` Options *ExecuteOptions `protobuf:"bytes,6,opt,name=options,proto3" json:"options,omitempty"` PreQueries []string `protobuf:"bytes,7,rep,name=pre_queries,json=preQueries,proto3" json:"pre_queries,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ReserveExecuteRequest is the payload to ReserveExecute
func (*ReserveExecuteRequest) Descriptor ¶
func (*ReserveExecuteRequest) Descriptor() ([]byte, []int)
func (*ReserveExecuteRequest) GetEffectiveCallerId ¶
func (m *ReserveExecuteRequest) GetEffectiveCallerId() *vtrpc.CallerID
func (*ReserveExecuteRequest) GetImmediateCallerId ¶
func (m *ReserveExecuteRequest) GetImmediateCallerId() *VTGateCallerID
func (*ReserveExecuteRequest) GetOptions ¶
func (m *ReserveExecuteRequest) GetOptions() *ExecuteOptions
func (*ReserveExecuteRequest) GetPreQueries ¶
func (m *ReserveExecuteRequest) GetPreQueries() []string
func (*ReserveExecuteRequest) GetQuery ¶
func (m *ReserveExecuteRequest) GetQuery() *BoundQuery
func (*ReserveExecuteRequest) GetTarget ¶
func (m *ReserveExecuteRequest) GetTarget() *Target
func (*ReserveExecuteRequest) GetTransactionId ¶
func (m *ReserveExecuteRequest) GetTransactionId() int64
func (*ReserveExecuteRequest) ProtoMessage ¶
func (*ReserveExecuteRequest) ProtoMessage()
func (*ReserveExecuteRequest) Reset ¶
func (m *ReserveExecuteRequest) Reset()
func (*ReserveExecuteRequest) String ¶
func (m *ReserveExecuteRequest) String() string
func (*ReserveExecuteRequest) XXX_DiscardUnknown ¶
func (m *ReserveExecuteRequest) XXX_DiscardUnknown()
func (*ReserveExecuteRequest) XXX_Marshal ¶
func (m *ReserveExecuteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReserveExecuteRequest) XXX_Merge ¶
func (m *ReserveExecuteRequest) XXX_Merge(src proto.Message)
func (*ReserveExecuteRequest) XXX_Size ¶
func (m *ReserveExecuteRequest) XXX_Size() int
func (*ReserveExecuteRequest) XXX_Unmarshal ¶
func (m *ReserveExecuteRequest) XXX_Unmarshal(b []byte) error
type ReserveExecuteResponse ¶
type ReserveExecuteResponse struct { Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Result *QueryResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` // The following fields might be non-zero even if an error is present. ReservedId int64 `protobuf:"varint,3,opt,name=reserved_id,json=reservedId,proto3" json:"reserved_id,omitempty"` TabletAlias *topodata.TabletAlias `protobuf:"bytes,4,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ReserveExecuteResponse is the returned value from ReserveExecute
func (*ReserveExecuteResponse) Descriptor ¶
func (*ReserveExecuteResponse) Descriptor() ([]byte, []int)
func (*ReserveExecuteResponse) GetError ¶
func (m *ReserveExecuteResponse) GetError() *vtrpc.RPCError
func (*ReserveExecuteResponse) GetReservedId ¶
func (m *ReserveExecuteResponse) GetReservedId() int64
func (*ReserveExecuteResponse) GetResult ¶
func (m *ReserveExecuteResponse) GetResult() *QueryResult
func (*ReserveExecuteResponse) GetTabletAlias ¶
func (m *ReserveExecuteResponse) GetTabletAlias() *topodata.TabletAlias
func (*ReserveExecuteResponse) ProtoMessage ¶
func (*ReserveExecuteResponse) ProtoMessage()
func (*ReserveExecuteResponse) Reset ¶
func (m *ReserveExecuteResponse) Reset()
func (*ReserveExecuteResponse) String ¶
func (m *ReserveExecuteResponse) String() string
func (*ReserveExecuteResponse) XXX_DiscardUnknown ¶
func (m *ReserveExecuteResponse) XXX_DiscardUnknown()
func (*ReserveExecuteResponse) XXX_Marshal ¶
func (m *ReserveExecuteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReserveExecuteResponse) XXX_Merge ¶
func (m *ReserveExecuteResponse) XXX_Merge(src proto.Message)
func (*ReserveExecuteResponse) XXX_Size ¶
func (m *ReserveExecuteResponse) XXX_Size() int
func (*ReserveExecuteResponse) XXX_Unmarshal ¶
func (m *ReserveExecuteResponse) XXX_Unmarshal(b []byte) error
type ResultWithError ¶
type ResultWithError struct { // error contains an query level error, only set if result is unset. Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` // result contains the query result, only set if error is unset. Result *QueryResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ResultWithError represents a query response in the form of result or error but not both. TODO: To be used in ExecuteBatchResponse and BeginExecuteBatchResponse.
func (*ResultWithError) Descriptor ¶
func (*ResultWithError) Descriptor() ([]byte, []int)
func (*ResultWithError) GetError ¶
func (m *ResultWithError) GetError() *vtrpc.RPCError
func (*ResultWithError) GetResult ¶
func (m *ResultWithError) GetResult() *QueryResult
func (*ResultWithError) ProtoMessage ¶
func (*ResultWithError) ProtoMessage()
func (*ResultWithError) Reset ¶
func (m *ResultWithError) Reset()
func (*ResultWithError) String ¶
func (m *ResultWithError) String() string
func (*ResultWithError) XXX_DiscardUnknown ¶
func (m *ResultWithError) XXX_DiscardUnknown()
func (*ResultWithError) XXX_Marshal ¶
func (m *ResultWithError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResultWithError) XXX_Merge ¶
func (m *ResultWithError) XXX_Merge(src proto.Message)
func (*ResultWithError) XXX_Size ¶
func (m *ResultWithError) XXX_Size() int
func (*ResultWithError) XXX_Unmarshal ¶
func (m *ResultWithError) XXX_Unmarshal(b []byte) error
type RollbackPreparedRequest ¶
type RollbackPreparedRequest struct { EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"` ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"` Target *Target `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` TransactionId int64 `protobuf:"varint,4,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"` Dtid string `protobuf:"bytes,5,opt,name=dtid,proto3" json:"dtid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
RollbackPreparedRequest is the payload to RollbackPrepared
func (*RollbackPreparedRequest) Descriptor ¶
func (*RollbackPreparedRequest) Descriptor() ([]byte, []int)
func (*RollbackPreparedRequest) GetDtid ¶
func (m *RollbackPreparedRequest) GetDtid() string
func (*RollbackPreparedRequest) GetEffectiveCallerId ¶
func (m *RollbackPreparedRequest) GetEffectiveCallerId() *vtrpc.CallerID
func (*RollbackPreparedRequest) GetImmediateCallerId ¶
func (m *RollbackPreparedRequest) GetImmediateCallerId() *VTGateCallerID
func (*RollbackPreparedRequest) GetTarget ¶
func (m *RollbackPreparedRequest) GetTarget() *Target
func (*RollbackPreparedRequest) GetTransactionId ¶
func (m *RollbackPreparedRequest) GetTransactionId() int64
func (*RollbackPreparedRequest) ProtoMessage ¶
func (*RollbackPreparedRequest) ProtoMessage()
func (*RollbackPreparedRequest) Reset ¶
func (m *RollbackPreparedRequest) Reset()
func (*RollbackPreparedRequest) String ¶
func (m *RollbackPreparedRequest) String() string
func (*RollbackPreparedRequest) XXX_DiscardUnknown ¶
func (m *RollbackPreparedRequest) XXX_DiscardUnknown()
func (*RollbackPreparedRequest) XXX_Marshal ¶
func (m *RollbackPreparedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RollbackPreparedRequest) XXX_Merge ¶
func (m *RollbackPreparedRequest) XXX_Merge(src proto.Message)
func (*RollbackPreparedRequest) XXX_Size ¶
func (m *RollbackPreparedRequest) XXX_Size() int
func (*RollbackPreparedRequest) XXX_Unmarshal ¶
func (m *RollbackPreparedRequest) XXX_Unmarshal(b []byte) error
type RollbackPreparedResponse ¶
type RollbackPreparedResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
RollbackPreparedResponse is the returned value from RollbackPrepared
func (*RollbackPreparedResponse) Descriptor ¶
func (*RollbackPreparedResponse) Descriptor() ([]byte, []int)
func (*RollbackPreparedResponse) ProtoMessage ¶
func (*RollbackPreparedResponse) ProtoMessage()
func (*RollbackPreparedResponse) Reset ¶
func (m *RollbackPreparedResponse) Reset()
func (*RollbackPreparedResponse) String ¶
func (m *RollbackPreparedResponse) String() string
func (*RollbackPreparedResponse) XXX_DiscardUnknown ¶
func (m *RollbackPreparedResponse) XXX_DiscardUnknown()
func (*RollbackPreparedResponse) XXX_Marshal ¶
func (m *RollbackPreparedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RollbackPreparedResponse) XXX_Merge ¶
func (m *RollbackPreparedResponse) XXX_Merge(src proto.Message)
func (*RollbackPreparedResponse) XXX_Size ¶
func (m *RollbackPreparedResponse) XXX_Size() int
func (*RollbackPreparedResponse) XXX_Unmarshal ¶
func (m *RollbackPreparedResponse) XXX_Unmarshal(b []byte) error
type RollbackRequest ¶
type RollbackRequest struct { EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"` ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"` Target *Target `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` TransactionId int64 `protobuf:"varint,4,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
RollbackRequest is the payload to Rollback
func (*RollbackRequest) Descriptor ¶
func (*RollbackRequest) Descriptor() ([]byte, []int)
func (*RollbackRequest) GetEffectiveCallerId ¶
func (m *RollbackRequest) GetEffectiveCallerId() *vtrpc.CallerID
func (*RollbackRequest) GetImmediateCallerId ¶
func (m *RollbackRequest) GetImmediateCallerId() *VTGateCallerID
func (*RollbackRequest) GetTarget ¶
func (m *RollbackRequest) GetTarget() *Target
func (*RollbackRequest) GetTransactionId ¶
func (m *RollbackRequest) GetTransactionId() int64
func (*RollbackRequest) ProtoMessage ¶
func (*RollbackRequest) ProtoMessage()
func (*RollbackRequest) Reset ¶
func (m *RollbackRequest) Reset()
func (*RollbackRequest) String ¶
func (m *RollbackRequest) String() string
func (*RollbackRequest) XXX_DiscardUnknown ¶
func (m *RollbackRequest) XXX_DiscardUnknown()
func (*RollbackRequest) XXX_Marshal ¶
func (m *RollbackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RollbackRequest) XXX_Merge ¶
func (m *RollbackRequest) XXX_Merge(src proto.Message)
func (*RollbackRequest) XXX_Size ¶
func (m *RollbackRequest) XXX_Size() int
func (*RollbackRequest) XXX_Unmarshal ¶
func (m *RollbackRequest) XXX_Unmarshal(b []byte) error
type RollbackResponse ¶
type RollbackResponse struct { ReservedId int64 `protobuf:"varint,1,opt,name=reserved_id,json=reservedId,proto3" json:"reserved_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
RollbackResponse is the returned value from Rollback
func (*RollbackResponse) Descriptor ¶
func (*RollbackResponse) Descriptor() ([]byte, []int)
func (*RollbackResponse) GetReservedId ¶
func (m *RollbackResponse) GetReservedId() int64
func (*RollbackResponse) ProtoMessage ¶
func (*RollbackResponse) ProtoMessage()
func (*RollbackResponse) Reset ¶
func (m *RollbackResponse) Reset()
func (*RollbackResponse) String ¶
func (m *RollbackResponse) String() string
func (*RollbackResponse) XXX_DiscardUnknown ¶
func (m *RollbackResponse) XXX_DiscardUnknown()
func (*RollbackResponse) XXX_Marshal ¶
func (m *RollbackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RollbackResponse) XXX_Merge ¶
func (m *RollbackResponse) XXX_Merge(src proto.Message)
func (*RollbackResponse) XXX_Size ¶
func (m *RollbackResponse) XXX_Size() int
func (*RollbackResponse) XXX_Unmarshal ¶
func (m *RollbackResponse) XXX_Unmarshal(b []byte) error
type Row ¶
type Row struct { // lengths contains the length of each value in values. // A length of -1 means that the field is NULL. While // reading values, you have to accummulate the length // to know the offset where the next value begins in values. Lengths []int64 `protobuf:"zigzag64,1,rep,packed,name=lengths,proto3" json:"lengths,omitempty"` // values contains a concatenation of all values in the row. Values []byte `protobuf:"bytes,2,opt,name=values,proto3" json:"values,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Row is a database row.
func (*Row) Descriptor ¶
func (*Row) GetLengths ¶
func (*Row) ProtoMessage ¶
func (*Row) ProtoMessage()
func (*Row) XXX_DiscardUnknown ¶
func (m *Row) XXX_DiscardUnknown()
func (*Row) XXX_Unmarshal ¶
type SetRollbackRequest ¶
type SetRollbackRequest struct { EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"` ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"` Target *Target `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` TransactionId int64 `protobuf:"varint,4,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"` Dtid string `protobuf:"bytes,5,opt,name=dtid,proto3" json:"dtid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
SetRollbackRequest is the payload to SetRollback
func (*SetRollbackRequest) Descriptor ¶
func (*SetRollbackRequest) Descriptor() ([]byte, []int)
func (*SetRollbackRequest) GetDtid ¶
func (m *SetRollbackRequest) GetDtid() string
func (*SetRollbackRequest) GetEffectiveCallerId ¶
func (m *SetRollbackRequest) GetEffectiveCallerId() *vtrpc.CallerID
func (*SetRollbackRequest) GetImmediateCallerId ¶
func (m *SetRollbackRequest) GetImmediateCallerId() *VTGateCallerID
func (*SetRollbackRequest) GetTarget ¶
func (m *SetRollbackRequest) GetTarget() *Target
func (*SetRollbackRequest) GetTransactionId ¶
func (m *SetRollbackRequest) GetTransactionId() int64
func (*SetRollbackRequest) ProtoMessage ¶
func (*SetRollbackRequest) ProtoMessage()
func (*SetRollbackRequest) Reset ¶
func (m *SetRollbackRequest) Reset()
func (*SetRollbackRequest) String ¶
func (m *SetRollbackRequest) String() string
func (*SetRollbackRequest) XXX_DiscardUnknown ¶
func (m *SetRollbackRequest) XXX_DiscardUnknown()
func (*SetRollbackRequest) XXX_Marshal ¶
func (m *SetRollbackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetRollbackRequest) XXX_Merge ¶
func (m *SetRollbackRequest) XXX_Merge(src proto.Message)
func (*SetRollbackRequest) XXX_Size ¶
func (m *SetRollbackRequest) XXX_Size() int
func (*SetRollbackRequest) XXX_Unmarshal ¶
func (m *SetRollbackRequest) XXX_Unmarshal(b []byte) error
type SetRollbackResponse ¶
type SetRollbackResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
SetRollbackResponse is the returned value from SetRollback
func (*SetRollbackResponse) Descriptor ¶
func (*SetRollbackResponse) Descriptor() ([]byte, []int)
func (*SetRollbackResponse) ProtoMessage ¶
func (*SetRollbackResponse) ProtoMessage()
func (*SetRollbackResponse) Reset ¶
func (m *SetRollbackResponse) Reset()
func (*SetRollbackResponse) String ¶
func (m *SetRollbackResponse) String() string
func (*SetRollbackResponse) XXX_DiscardUnknown ¶
func (m *SetRollbackResponse) XXX_DiscardUnknown()
func (*SetRollbackResponse) XXX_Marshal ¶
func (m *SetRollbackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetRollbackResponse) XXX_Merge ¶
func (m *SetRollbackResponse) XXX_Merge(src proto.Message)
func (*SetRollbackResponse) XXX_Size ¶
func (m *SetRollbackResponse) XXX_Size() int
func (*SetRollbackResponse) XXX_Unmarshal ¶
func (m *SetRollbackResponse) XXX_Unmarshal(b []byte) error
type StartCommitRequest ¶
type StartCommitRequest struct { EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"` ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"` Target *Target `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` TransactionId int64 `protobuf:"varint,4,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"` Dtid string `protobuf:"bytes,5,opt,name=dtid,proto3" json:"dtid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
StartCommitRequest is the payload to StartCommit
func (*StartCommitRequest) Descriptor ¶
func (*StartCommitRequest) Descriptor() ([]byte, []int)
func (*StartCommitRequest) GetDtid ¶
func (m *StartCommitRequest) GetDtid() string
func (*StartCommitRequest) GetEffectiveCallerId ¶
func (m *StartCommitRequest) GetEffectiveCallerId() *vtrpc.CallerID
func (*StartCommitRequest) GetImmediateCallerId ¶
func (m *StartCommitRequest) GetImmediateCallerId() *VTGateCallerID
func (*StartCommitRequest) GetTarget ¶
func (m *StartCommitRequest) GetTarget() *Target
func (*StartCommitRequest) GetTransactionId ¶
func (m *StartCommitRequest) GetTransactionId() int64
func (*StartCommitRequest) ProtoMessage ¶
func (*StartCommitRequest) ProtoMessage()
func (*StartCommitRequest) Reset ¶
func (m *StartCommitRequest) Reset()
func (*StartCommitRequest) String ¶
func (m *StartCommitRequest) String() string
func (*StartCommitRequest) XXX_DiscardUnknown ¶
func (m *StartCommitRequest) XXX_DiscardUnknown()
func (*StartCommitRequest) XXX_Marshal ¶
func (m *StartCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StartCommitRequest) XXX_Merge ¶
func (m *StartCommitRequest) XXX_Merge(src proto.Message)
func (*StartCommitRequest) XXX_Size ¶
func (m *StartCommitRequest) XXX_Size() int
func (*StartCommitRequest) XXX_Unmarshal ¶
func (m *StartCommitRequest) XXX_Unmarshal(b []byte) error
type StartCommitResponse ¶
type StartCommitResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
StartCommitResponse is the returned value from StartCommit
func (*StartCommitResponse) Descriptor ¶
func (*StartCommitResponse) Descriptor() ([]byte, []int)
func (*StartCommitResponse) ProtoMessage ¶
func (*StartCommitResponse) ProtoMessage()
func (*StartCommitResponse) Reset ¶
func (m *StartCommitResponse) Reset()
func (*StartCommitResponse) String ¶
func (m *StartCommitResponse) String() string
func (*StartCommitResponse) XXX_DiscardUnknown ¶
func (m *StartCommitResponse) XXX_DiscardUnknown()
func (*StartCommitResponse) XXX_Marshal ¶
func (m *StartCommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StartCommitResponse) XXX_Merge ¶
func (m *StartCommitResponse) XXX_Merge(src proto.Message)
func (*StartCommitResponse) XXX_Size ¶
func (m *StartCommitResponse) XXX_Size() int
func (*StartCommitResponse) XXX_Unmarshal ¶
func (m *StartCommitResponse) XXX_Unmarshal(b []byte) error
type StreamEvent ¶
type StreamEvent struct { // The statements in this transaction. Statements []*StreamEvent_Statement `protobuf:"bytes,1,rep,name=statements,proto3" json:"statements,omitempty"` // The Event Token for this event. EventToken *EventToken `protobuf:"bytes,2,opt,name=event_token,json=eventToken,proto3" json:"event_token,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
StreamEvent describes a set of transformations that happened as a single transactional unit on a server. It is streamed back by the Update Stream calls.
func (*StreamEvent) Descriptor ¶
func (*StreamEvent) Descriptor() ([]byte, []int)
func (*StreamEvent) GetEventToken ¶
func (m *StreamEvent) GetEventToken() *EventToken
func (*StreamEvent) GetStatements ¶
func (m *StreamEvent) GetStatements() []*StreamEvent_Statement
func (*StreamEvent) ProtoMessage ¶
func (*StreamEvent) ProtoMessage()
func (*StreamEvent) Reset ¶
func (m *StreamEvent) Reset()
func (*StreamEvent) String ¶
func (m *StreamEvent) String() string
func (*StreamEvent) XXX_DiscardUnknown ¶
func (m *StreamEvent) XXX_DiscardUnknown()
func (*StreamEvent) XXX_Marshal ¶
func (m *StreamEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamEvent) XXX_Merge ¶
func (m *StreamEvent) XXX_Merge(src proto.Message)
func (*StreamEvent) XXX_Size ¶
func (m *StreamEvent) XXX_Size() int
func (*StreamEvent) XXX_Unmarshal ¶
func (m *StreamEvent) XXX_Unmarshal(b []byte) error
type StreamEvent_Statement ¶
type StreamEvent_Statement struct { Category StreamEvent_Statement_Category `protobuf:"varint,1,opt,name=category,proto3,enum=query.StreamEvent_Statement_Category" json:"category,omitempty"` // table_name, primary_key_fields and primary_key_values are set for DML. TableName string `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` PrimaryKeyFields []*Field `protobuf:"bytes,3,rep,name=primary_key_fields,json=primaryKeyFields,proto3" json:"primary_key_fields,omitempty"` PrimaryKeyValues []*Row `protobuf:"bytes,4,rep,name=primary_key_values,json=primaryKeyValues,proto3" json:"primary_key_values,omitempty"` // sql is set for all queries. // FIXME(alainjobart) we may not need it for DMLs. Sql []byte `protobuf:"bytes,5,opt,name=sql,proto3" json:"sql,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
One individual Statement in a transaction.
func (*StreamEvent_Statement) Descriptor ¶
func (*StreamEvent_Statement) Descriptor() ([]byte, []int)
func (*StreamEvent_Statement) GetCategory ¶
func (m *StreamEvent_Statement) GetCategory() StreamEvent_Statement_Category
func (*StreamEvent_Statement) GetPrimaryKeyFields ¶
func (m *StreamEvent_Statement) GetPrimaryKeyFields() []*Field
func (*StreamEvent_Statement) GetPrimaryKeyValues ¶
func (m *StreamEvent_Statement) GetPrimaryKeyValues() []*Row
func (*StreamEvent_Statement) GetSql ¶
func (m *StreamEvent_Statement) GetSql() []byte
func (*StreamEvent_Statement) GetTableName ¶
func (m *StreamEvent_Statement) GetTableName() string
func (*StreamEvent_Statement) ProtoMessage ¶
func (*StreamEvent_Statement) ProtoMessage()
func (*StreamEvent_Statement) Reset ¶
func (m *StreamEvent_Statement) Reset()
func (*StreamEvent_Statement) String ¶
func (m *StreamEvent_Statement) String() string
func (*StreamEvent_Statement) XXX_DiscardUnknown ¶
func (m *StreamEvent_Statement) XXX_DiscardUnknown()
func (*StreamEvent_Statement) XXX_Marshal ¶
func (m *StreamEvent_Statement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamEvent_Statement) XXX_Merge ¶
func (m *StreamEvent_Statement) XXX_Merge(src proto.Message)
func (*StreamEvent_Statement) XXX_Size ¶
func (m *StreamEvent_Statement) XXX_Size() int
func (*StreamEvent_Statement) XXX_Unmarshal ¶
func (m *StreamEvent_Statement) XXX_Unmarshal(b []byte) error
type StreamEvent_Statement_Category ¶
type StreamEvent_Statement_Category int32
The category of one statement.
const ( StreamEvent_Statement_Error StreamEvent_Statement_Category = 0 StreamEvent_Statement_DML StreamEvent_Statement_Category = 1 StreamEvent_Statement_DDL StreamEvent_Statement_Category = 2 )
func (StreamEvent_Statement_Category) EnumDescriptor ¶
func (StreamEvent_Statement_Category) EnumDescriptor() ([]byte, []int)
func (StreamEvent_Statement_Category) String ¶
func (x StreamEvent_Statement_Category) String() string
type StreamExecuteRequest ¶
type StreamExecuteRequest struct { EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"` ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"` Target *Target `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"` Query *BoundQuery `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"` Options *ExecuteOptions `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"` TransactionId int64 `protobuf:"varint,6,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
StreamExecuteRequest is the payload to StreamExecute
func (*StreamExecuteRequest) Descriptor ¶
func (*StreamExecuteRequest) Descriptor() ([]byte, []int)
func (*StreamExecuteRequest) GetEffectiveCallerId ¶
func (m *StreamExecuteRequest) GetEffectiveCallerId() *vtrpc.CallerID
func (*StreamExecuteRequest) GetImmediateCallerId ¶
func (m *StreamExecuteRequest) GetImmediateCallerId() *VTGateCallerID
func (*StreamExecuteRequest) GetOptions ¶
func (m *StreamExecuteRequest) GetOptions() *ExecuteOptions
func (*StreamExecuteRequest) GetQuery ¶
func (m *StreamExecuteRequest) GetQuery() *BoundQuery
func (*StreamExecuteRequest) GetTarget ¶
func (m *StreamExecuteRequest) GetTarget() *Target
func (*StreamExecuteRequest) GetTransactionId ¶
func (m *StreamExecuteRequest) GetTransactionId() int64
func (*StreamExecuteRequest) ProtoMessage ¶
func (*StreamExecuteRequest) ProtoMessage()
func (*StreamExecuteRequest) Reset ¶
func (m *StreamExecuteRequest) Reset()
func (*StreamExecuteRequest) String ¶
func (m *StreamExecuteRequest) String() string
func (*StreamExecuteRequest) XXX_DiscardUnknown ¶
func (m *StreamExecuteRequest) XXX_DiscardUnknown()
func (*StreamExecuteRequest) XXX_Marshal ¶
func (m *StreamExecuteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamExecuteRequest) XXX_Merge ¶
func (m *StreamExecuteRequest) XXX_Merge(src proto.Message)
func (*StreamExecuteRequest) XXX_Size ¶
func (m *StreamExecuteRequest) XXX_Size() int
func (*StreamExecuteRequest) XXX_Unmarshal ¶
func (m *StreamExecuteRequest) XXX_Unmarshal(b []byte) error
type StreamExecuteResponse ¶
type StreamExecuteResponse struct { Result *QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
StreamExecuteResponse is the returned value from StreamExecute
func (*StreamExecuteResponse) Descriptor ¶
func (*StreamExecuteResponse) Descriptor() ([]byte, []int)
func (*StreamExecuteResponse) GetResult ¶
func (m *StreamExecuteResponse) GetResult() *QueryResult
func (*StreamExecuteResponse) ProtoMessage ¶
func (*StreamExecuteResponse) ProtoMessage()
func (*StreamExecuteResponse) Reset ¶
func (m *StreamExecuteResponse) Reset()
func (*StreamExecuteResponse) String ¶
func (m *StreamExecuteResponse) String() string
func (*StreamExecuteResponse) XXX_DiscardUnknown ¶
func (m *StreamExecuteResponse) XXX_DiscardUnknown()
func (*StreamExecuteResponse) XXX_Marshal ¶
func (m *StreamExecuteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamExecuteResponse) XXX_Merge ¶
func (m *StreamExecuteResponse) XXX_Merge(src proto.Message)
func (*StreamExecuteResponse) XXX_Size ¶
func (m *StreamExecuteResponse) XXX_Size() int
func (*StreamExecuteResponse) XXX_Unmarshal ¶
func (m *StreamExecuteResponse) XXX_Unmarshal(b []byte) error
type StreamHealthRequest ¶
type StreamHealthRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
StreamHealthRequest is the payload for StreamHealth
func (*StreamHealthRequest) Descriptor ¶
func (*StreamHealthRequest) Descriptor() ([]byte, []int)
func (*StreamHealthRequest) ProtoMessage ¶
func (*StreamHealthRequest) ProtoMessage()
func (*StreamHealthRequest) Reset ¶
func (m *StreamHealthRequest) Reset()
func (*StreamHealthRequest) String ¶
func (m *StreamHealthRequest) String() string
func (*StreamHealthRequest) XXX_DiscardUnknown ¶
func (m *StreamHealthRequest) XXX_DiscardUnknown()
func (*StreamHealthRequest) XXX_Marshal ¶
func (m *StreamHealthRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamHealthRequest) XXX_Merge ¶
func (m *StreamHealthRequest) XXX_Merge(src proto.Message)
func (*StreamHealthRequest) XXX_Size ¶
func (m *StreamHealthRequest) XXX_Size() int
func (*StreamHealthRequest) XXX_Unmarshal ¶
func (m *StreamHealthRequest) XXX_Unmarshal(b []byte) error
type StreamHealthResponse ¶
type StreamHealthResponse struct { // target is the current server type. Only queries with that exact Target // record will be accepted (the cell may not match, however). Target *Target `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"` // serving is true iff the tablet is serving. A tablet may not be serving // if filtered replication is enabled on a master for instance, // or if a replica should not be used because the keyspace is being resharded. Serving bool `protobuf:"varint,2,opt,name=serving,proto3" json:"serving,omitempty"` // tablet_externally_reparented_timestamp can be interpreted as the // last time we knew that this tablet was the MASTER of this shard // (if StreamHealthResponse describes a group of tablets, between // two vtgates, only one master will be present in the group, and // this is this master's value). // // It is used by vtgate when determining the current MASTER of a shard. // If vtgate sees more than one MASTER tablet, this timestamp is used // as tiebreaker where the MASTER with the highest timestamp wins. // Another usage of this timestamp is in go/vt/vtgate/buffer to detect the end // of a reparent (failover) and stop buffering. // // In practice, this field is set to: // a) the last time the RPC tabletmanager.TabletExternallyReparented was // called on this tablet (usually done by an external failover tool e.g. // Orchestrator). The failover tool can call this as long as we are the // master i.e. even ages after the last reparent occurred. // OR // b) the last time an active reparent was executed through a vtctl command // (InitShardMaster, PlannedReparentShard, EmergencyReparentShard) // OR // c) the last time vttablet was started and it initialized its tablet type // as MASTER because it was recorded as the shard's current master in the // topology (see go/vt/vttablet/tabletmanager/init_tablet.go) // OR // d) 0 if the vttablet was never a MASTER. TabletExternallyReparentedTimestamp int64 `` /* 171-byte string literal not displayed */ // realtime_stats contains information about the tablet status. // It is only filled in if the information is about a tablet. RealtimeStats *RealtimeStats `protobuf:"bytes,4,opt,name=realtime_stats,json=realtimeStats,proto3" json:"realtime_stats,omitempty"` // tablet_alias is the alias of the sending tablet. The discovery/healthcheck.go // code uses it to verify that it's talking to the correct tablet and that it // hasn't changed in the meantime e.g. due to tablet restarts where ports or // ips have been reused but assigned differently. TabletAlias *topodata.TabletAlias `protobuf:"bytes,5,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
StreamHealthResponse is streamed by StreamHealth on a regular basis. It is expected to be used between a vtgate and vttablet: - target describes the tablet. - realtime_stats is set. - aggregate_stats is not set (deprecated)
func (*StreamHealthResponse) Descriptor ¶
func (*StreamHealthResponse) Descriptor() ([]byte, []int)
func (*StreamHealthResponse) GetRealtimeStats ¶
func (m *StreamHealthResponse) GetRealtimeStats() *RealtimeStats
func (*StreamHealthResponse) GetServing ¶
func (m *StreamHealthResponse) GetServing() bool
func (*StreamHealthResponse) GetTabletAlias ¶
func (m *StreamHealthResponse) GetTabletAlias() *topodata.TabletAlias
func (*StreamHealthResponse) GetTabletExternallyReparentedTimestamp ¶
func (m *StreamHealthResponse) GetTabletExternallyReparentedTimestamp() int64
func (*StreamHealthResponse) GetTarget ¶
func (m *StreamHealthResponse) GetTarget() *Target
func (*StreamHealthResponse) ProtoMessage ¶
func (*StreamHealthResponse) ProtoMessage()
func (*StreamHealthResponse) Reset ¶
func (m *StreamHealthResponse) Reset()
func (*StreamHealthResponse) String ¶
func (m *StreamHealthResponse) String() string
func (*StreamHealthResponse) XXX_DiscardUnknown ¶
func (m *StreamHealthResponse) XXX_DiscardUnknown()
func (*StreamHealthResponse) XXX_Marshal ¶
func (m *StreamHealthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamHealthResponse) XXX_Merge ¶
func (m *StreamHealthResponse) XXX_Merge(src proto.Message)
func (*StreamHealthResponse) XXX_Size ¶
func (m *StreamHealthResponse) XXX_Size() int
func (*StreamHealthResponse) XXX_Unmarshal ¶
func (m *StreamHealthResponse) XXX_Unmarshal(b []byte) error
type Target ¶
type Target struct { Keyspace string `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"` Shard string `protobuf:"bytes,2,opt,name=shard,proto3" json:"shard,omitempty"` TabletType topodata.TabletType `protobuf:"varint,3,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"` // cell is used for routing queries between vtgate and vttablets. It // is not used when Target is part of the Session sent by the client. Cell string `protobuf:"bytes,4,opt,name=cell,proto3" json:"cell,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Target describes what the client expects the tablet is. If the tablet does not match, an error is returned.
func (*Target) Descriptor ¶
func (*Target) GetKeyspace ¶
func (*Target) GetTabletType ¶
func (m *Target) GetTabletType() topodata.TabletType
func (*Target) ProtoMessage ¶
func (*Target) ProtoMessage()
func (*Target) XXX_DiscardUnknown ¶
func (m *Target) XXX_DiscardUnknown()
func (*Target) XXX_Marshal ¶
func (*Target) XXX_Unmarshal ¶
type TransactionMetadata ¶
type TransactionMetadata struct { Dtid string `protobuf:"bytes,1,opt,name=dtid,proto3" json:"dtid,omitempty"` State TransactionState `protobuf:"varint,2,opt,name=state,proto3,enum=query.TransactionState" json:"state,omitempty"` TimeCreated int64 `protobuf:"varint,3,opt,name=time_created,json=timeCreated,proto3" json:"time_created,omitempty"` Participants []*Target `protobuf:"bytes,4,rep,name=participants,proto3" json:"participants,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
TransactionMetadata contains the metadata for a distributed transaction.
func (*TransactionMetadata) Descriptor ¶
func (*TransactionMetadata) Descriptor() ([]byte, []int)
func (*TransactionMetadata) GetDtid ¶
func (m *TransactionMetadata) GetDtid() string
func (*TransactionMetadata) GetParticipants ¶
func (m *TransactionMetadata) GetParticipants() []*Target
func (*TransactionMetadata) GetState ¶
func (m *TransactionMetadata) GetState() TransactionState
func (*TransactionMetadata) GetTimeCreated ¶
func (m *TransactionMetadata) GetTimeCreated() int64
func (*TransactionMetadata) ProtoMessage ¶
func (*TransactionMetadata) ProtoMessage()
func (*TransactionMetadata) Reset ¶
func (m *TransactionMetadata) Reset()
func (*TransactionMetadata) String ¶
func (m *TransactionMetadata) String() string
func (*TransactionMetadata) XXX_DiscardUnknown ¶
func (m *TransactionMetadata) XXX_DiscardUnknown()
func (*TransactionMetadata) XXX_Marshal ¶
func (m *TransactionMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TransactionMetadata) XXX_Merge ¶
func (m *TransactionMetadata) XXX_Merge(src proto.Message)
func (*TransactionMetadata) XXX_Size ¶
func (m *TransactionMetadata) XXX_Size() int
func (*TransactionMetadata) XXX_Unmarshal ¶
func (m *TransactionMetadata) XXX_Unmarshal(b []byte) error
type TransactionState ¶
type TransactionState int32
TransactionState represents the state of a distributed transaction.
const ( TransactionState_UNKNOWN TransactionState = 0 TransactionState_PREPARE TransactionState = 1 TransactionState_COMMIT TransactionState = 2 TransactionState_ROLLBACK TransactionState = 3 )
func (TransactionState) EnumDescriptor ¶
func (TransactionState) EnumDescriptor() ([]byte, []int)
func (TransactionState) String ¶
func (x TransactionState) String() string
type Type ¶
type Type int32
Type defines the various supported data types in bind vars and query results.
const ( // NULL_TYPE specifies a NULL type. Type_NULL_TYPE Type = 0 // INT8 specifies a TINYINT type. // Properties: 1, IsNumber. Type_INT8 Type = 257 // UINT8 specifies a TINYINT UNSIGNED type. // Properties: 2, IsNumber, IsUnsigned. Type_UINT8 Type = 770 // INT16 specifies a SMALLINT type. // Properties: 3, IsNumber. Type_INT16 Type = 259 // UINT16 specifies a SMALLINT UNSIGNED type. // Properties: 4, IsNumber, IsUnsigned. Type_UINT16 Type = 772 // INT24 specifies a MEDIUMINT type. // Properties: 5, IsNumber. Type_INT24 Type = 261 // UINT24 specifies a MEDIUMINT UNSIGNED type. // Properties: 6, IsNumber, IsUnsigned. Type_UINT24 Type = 774 // INT32 specifies a INTEGER type. // Properties: 7, IsNumber. Type_INT32 Type = 263 // UINT32 specifies a INTEGER UNSIGNED type. // Properties: 8, IsNumber, IsUnsigned. Type_UINT32 Type = 776 // INT64 specifies a BIGINT type. // Properties: 9, IsNumber. Type_INT64 Type = 265 // UINT64 specifies a BIGINT UNSIGNED type. // Properties: 10, IsNumber, IsUnsigned. Type_UINT64 Type = 778 // FLOAT32 specifies a FLOAT type. // Properties: 11, IsFloat. Type_FLOAT32 Type = 1035 // FLOAT64 specifies a DOUBLE or REAL type. // Properties: 12, IsFloat. Type_FLOAT64 Type = 1036 // TIMESTAMP specifies a TIMESTAMP type. // Properties: 13, IsQuoted. Type_TIMESTAMP Type = 2061 // DATE specifies a DATE type. // Properties: 14, IsQuoted. Type_DATE Type = 2062 // TIME specifies a TIME type. // Properties: 15, IsQuoted. Type_TIME Type = 2063 // DATETIME specifies a DATETIME type. // Properties: 16, IsQuoted. Type_DATETIME Type = 2064 // YEAR specifies a YEAR type. // Properties: 17, IsNumber, IsUnsigned. Type_YEAR Type = 785 // DECIMAL specifies a DECIMAL or NUMERIC type. // Properties: 18, None. Type_DECIMAL Type = 18 // TEXT specifies a TEXT type. // Properties: 19, IsQuoted, IsText. Type_TEXT Type = 6163 // BLOB specifies a BLOB type. // Properties: 20, IsQuoted, IsBinary. Type_BLOB Type = 10260 // VARCHAR specifies a VARCHAR type. // Properties: 21, IsQuoted, IsText. Type_VARCHAR Type = 6165 // VARBINARY specifies a VARBINARY type. // Properties: 22, IsQuoted, IsBinary. Type_VARBINARY Type = 10262 // CHAR specifies a CHAR type. // Properties: 23, IsQuoted, IsText. Type_CHAR Type = 6167 // BINARY specifies a BINARY type. // Properties: 24, IsQuoted, IsBinary. Type_BINARY Type = 10264 // BIT specifies a BIT type. // Properties: 25, IsQuoted. Type_BIT Type = 2073 // ENUM specifies an ENUM type. // Properties: 26, IsQuoted. Type_ENUM Type = 2074 // SET specifies a SET type. // Properties: 27, IsQuoted. Type_SET Type = 2075 // TUPLE specifies a tuple. This cannot // be returned in a QueryResult, but it can // be sent as a bind var. // Properties: 28, None. Type_TUPLE Type = 28 // GEOMETRY specifies a GEOMETRY type. // Properties: 29, IsQuoted. Type_GEOMETRY Type = 2077 // JSON specifies a JSON type. // Properties: 30, IsQuoted. Type_JSON Type = 2078 // EXPRESSION specifies a SQL expression. // This type is for internal use only. // Properties: 31, None. Type_EXPRESSION Type = 31 )
func (Type) EnumDescriptor ¶
type VTGateCallerID ¶
type VTGateCallerID struct { Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"` Groups []string `protobuf:"bytes,2,rep,name=groups,proto3" json:"groups,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
VTGateCallerID is sent by VTGate to VTTablet to describe the caller. If possible, this information is secure. For instance, if using unique certificates that guarantee that VTGate->VTTablet traffic cannot be spoofed, then VTTablet can trust this information, and VTTablet will use it for tablet ACLs, for instance. Because of this security guarantee, this is different than the CallerID structure, which is not secure at all, because it is provided by the Vitess client.
func (*VTGateCallerID) Descriptor ¶
func (*VTGateCallerID) Descriptor() ([]byte, []int)
func (*VTGateCallerID) GetGroups ¶
func (m *VTGateCallerID) GetGroups() []string
func (*VTGateCallerID) GetUsername ¶
func (m *VTGateCallerID) GetUsername() string
func (*VTGateCallerID) ProtoMessage ¶
func (*VTGateCallerID) ProtoMessage()
func (*VTGateCallerID) Reset ¶
func (m *VTGateCallerID) Reset()
func (*VTGateCallerID) String ¶
func (m *VTGateCallerID) String() string
func (*VTGateCallerID) XXX_DiscardUnknown ¶
func (m *VTGateCallerID) XXX_DiscardUnknown()
func (*VTGateCallerID) XXX_Marshal ¶
func (m *VTGateCallerID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*VTGateCallerID) XXX_Merge ¶
func (m *VTGateCallerID) XXX_Merge(src proto.Message)
func (*VTGateCallerID) XXX_Size ¶
func (m *VTGateCallerID) XXX_Size() int
func (*VTGateCallerID) XXX_Unmarshal ¶
func (m *VTGateCallerID) XXX_Unmarshal(b []byte) error
type Value ¶
type Value struct { Type Type `protobuf:"varint,1,opt,name=type,proto3,enum=query.Type" json:"type,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Value represents a typed value.
func (*Value) Descriptor ¶
func (*Value) ProtoMessage ¶
func (*Value) ProtoMessage()
func (*Value) XXX_DiscardUnknown ¶
func (m *Value) XXX_DiscardUnknown()