Documentation ¶
Index ¶
- Variables
- type CloseSessionRequest
- func (*CloseSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CloseSessionRequest) GetCallerId() *vtrpc.CallerID
- func (x *CloseSessionRequest) GetSession() *Session
- func (m *CloseSessionRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *CloseSessionRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *CloseSessionRequest) MarshalVT() (dAtA []byte, err error)
- func (*CloseSessionRequest) ProtoMessage()
- func (x *CloseSessionRequest) ProtoReflect() protoreflect.Message
- func (x *CloseSessionRequest) Reset()
- func (m *CloseSessionRequest) SizeVT() (n int)
- func (x *CloseSessionRequest) String() string
- func (m *CloseSessionRequest) UnmarshalVT(dAtA []byte) error
- type CloseSessionResponse
- func (*CloseSessionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CloseSessionResponse) GetError() *vtrpc.RPCError
- func (m *CloseSessionResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *CloseSessionResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *CloseSessionResponse) MarshalVT() (dAtA []byte, err error)
- func (*CloseSessionResponse) ProtoMessage()
- func (x *CloseSessionResponse) ProtoReflect() protoreflect.Message
- func (x *CloseSessionResponse) Reset()
- func (m *CloseSessionResponse) SizeVT() (n int)
- func (x *CloseSessionResponse) String() string
- func (m *CloseSessionResponse) UnmarshalVT(dAtA []byte) error
- type CommitOrder
- func (CommitOrder) Descriptor() protoreflect.EnumDescriptor
- func (x CommitOrder) Enum() *CommitOrder
- func (CommitOrder) EnumDescriptor() ([]byte, []int)deprecated
- func (x CommitOrder) Number() protoreflect.EnumNumber
- func (x CommitOrder) String() string
- func (CommitOrder) Type() protoreflect.EnumType
- type ExecuteBatchRequest
- func (*ExecuteBatchRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteBatchRequest) GetCallerId() *vtrpc.CallerID
- func (x *ExecuteBatchRequest) GetQueries() []*query.BoundQuery
- func (x *ExecuteBatchRequest) GetSession() *Session
- func (m *ExecuteBatchRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ExecuteBatchRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *ExecuteBatchRequest) MarshalVT() (dAtA []byte, err error)
- func (*ExecuteBatchRequest) ProtoMessage()
- func (x *ExecuteBatchRequest) ProtoReflect() protoreflect.Message
- func (x *ExecuteBatchRequest) Reset()
- func (m *ExecuteBatchRequest) SizeVT() (n int)
- func (x *ExecuteBatchRequest) String() string
- func (m *ExecuteBatchRequest) UnmarshalVT(dAtA []byte) error
- type ExecuteBatchResponse
- func (*ExecuteBatchResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteBatchResponse) GetError() *vtrpc.RPCError
- func (x *ExecuteBatchResponse) GetResults() []*query.ResultWithError
- func (x *ExecuteBatchResponse) GetSession() *Session
- func (m *ExecuteBatchResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ExecuteBatchResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *ExecuteBatchResponse) MarshalVT() (dAtA []byte, err error)
- func (*ExecuteBatchResponse) ProtoMessage()
- func (x *ExecuteBatchResponse) ProtoReflect() protoreflect.Message
- func (x *ExecuteBatchResponse) Reset()
- func (m *ExecuteBatchResponse) SizeVT() (n int)
- func (x *ExecuteBatchResponse) String() string
- func (m *ExecuteBatchResponse) UnmarshalVT(dAtA []byte) error
- type ExecuteRequest
- func (*ExecuteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteRequest) GetCallerId() *vtrpc.CallerID
- func (x *ExecuteRequest) GetQuery() *query.BoundQuery
- func (x *ExecuteRequest) GetSession() *Session
- func (m *ExecuteRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ExecuteRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *ExecuteRequest) MarshalVT() (dAtA []byte, err error)
- func (*ExecuteRequest) ProtoMessage()
- func (x *ExecuteRequest) ProtoReflect() protoreflect.Message
- func (x *ExecuteRequest) Reset()
- func (m *ExecuteRequest) SizeVT() (n int)
- func (x *ExecuteRequest) String() string
- func (m *ExecuteRequest) UnmarshalVT(dAtA []byte) error
- type ExecuteResponse
- func (*ExecuteResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ExecuteResponse) GetError() *vtrpc.RPCError
- func (x *ExecuteResponse) GetResult() *query.QueryResult
- func (x *ExecuteResponse) GetSession() *Session
- func (m *ExecuteResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ExecuteResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *ExecuteResponse) MarshalVT() (dAtA []byte, err error)
- func (*ExecuteResponse) ProtoMessage()
- func (x *ExecuteResponse) ProtoReflect() protoreflect.Message
- func (x *ExecuteResponse) Reset()
- func (m *ExecuteResponse) SizeVT() (n int)
- func (x *ExecuteResponse) String() string
- func (m *ExecuteResponse) UnmarshalVT(dAtA []byte) error
- type PrepareRequest
- func (*PrepareRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PrepareRequest) GetCallerId() *vtrpc.CallerID
- func (x *PrepareRequest) GetQuery() *query.BoundQuery
- func (x *PrepareRequest) GetSession() *Session
- func (m *PrepareRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *PrepareRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *PrepareRequest) MarshalVT() (dAtA []byte, err error)
- func (*PrepareRequest) ProtoMessage()
- func (x *PrepareRequest) ProtoReflect() protoreflect.Message
- func (x *PrepareRequest) Reset()
- func (m *PrepareRequest) SizeVT() (n int)
- func (x *PrepareRequest) String() string
- func (m *PrepareRequest) UnmarshalVT(dAtA []byte) error
- type PrepareResponse
- func (*PrepareResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PrepareResponse) GetError() *vtrpc.RPCError
- func (x *PrepareResponse) GetFields() []*query.Field
- func (x *PrepareResponse) GetSession() *Session
- func (m *PrepareResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *PrepareResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *PrepareResponse) MarshalVT() (dAtA []byte, err error)
- func (*PrepareResponse) ProtoMessage()
- func (x *PrepareResponse) ProtoReflect() protoreflect.Message
- func (x *PrepareResponse) Reset()
- func (m *PrepareResponse) SizeVT() (n int)
- func (x *PrepareResponse) String() string
- func (m *PrepareResponse) UnmarshalVT(dAtA []byte) error
- type ReadAfterWrite
- func (*ReadAfterWrite) Descriptor() ([]byte, []int)deprecated
- func (x *ReadAfterWrite) GetReadAfterWriteGtid() string
- func (x *ReadAfterWrite) GetReadAfterWriteTimeout() float64
- func (x *ReadAfterWrite) GetSessionTrackGtids() bool
- func (m *ReadAfterWrite) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ReadAfterWrite) MarshalToVT(dAtA []byte) (int, error)
- func (m *ReadAfterWrite) MarshalVT() (dAtA []byte, err error)
- func (*ReadAfterWrite) ProtoMessage()
- func (x *ReadAfterWrite) ProtoReflect() protoreflect.Message
- func (x *ReadAfterWrite) Reset()
- func (m *ReadAfterWrite) SizeVT() (n int)
- func (x *ReadAfterWrite) String() string
- func (m *ReadAfterWrite) UnmarshalVT(dAtA []byte) error
- type ResolveTransactionRequest
- func (*ResolveTransactionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ResolveTransactionRequest) GetCallerId() *vtrpc.CallerID
- func (x *ResolveTransactionRequest) GetDtid() string
- func (m *ResolveTransactionRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ResolveTransactionRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *ResolveTransactionRequest) MarshalVT() (dAtA []byte, err error)
- func (*ResolveTransactionRequest) ProtoMessage()
- func (x *ResolveTransactionRequest) ProtoReflect() protoreflect.Message
- func (x *ResolveTransactionRequest) Reset()
- func (m *ResolveTransactionRequest) SizeVT() (n int)
- func (x *ResolveTransactionRequest) String() string
- func (m *ResolveTransactionRequest) UnmarshalVT(dAtA []byte) error
- type ResolveTransactionResponse
- func (*ResolveTransactionResponse) Descriptor() ([]byte, []int)deprecated
- func (m *ResolveTransactionResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ResolveTransactionResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *ResolveTransactionResponse) MarshalVT() (dAtA []byte, err error)
- func (*ResolveTransactionResponse) ProtoMessage()
- func (x *ResolveTransactionResponse) ProtoReflect() protoreflect.Message
- func (x *ResolveTransactionResponse) Reset()
- func (m *ResolveTransactionResponse) SizeVT() (n int)
- func (x *ResolveTransactionResponse) String() string
- func (m *ResolveTransactionResponse) UnmarshalVT(dAtA []byte) error
- type Session
- func (*Session) Descriptor() ([]byte, []int)deprecated
- func (x *Session) GetAdvisoryLock() map[string]int64
- func (x *Session) GetAutocommit() bool
- func (x *Session) GetDDLStrategy() string
- func (x *Session) GetEnableSystemSettings() bool
- func (x *Session) GetFoundRows() uint64
- func (x *Session) GetInReservedConn() bool
- func (x *Session) GetInTransaction() bool
- func (x *Session) GetLastInsertId() uint64
- func (x *Session) GetLastLockHeartbeat() int64
- func (x *Session) GetLockSession() *Session_ShardSession
- func (x *Session) GetOptions() *query.ExecuteOptions
- func (x *Session) GetPostSessions() []*Session_ShardSession
- func (x *Session) GetPreSessions() []*Session_ShardSession
- func (x *Session) GetReadAfterWrite() *ReadAfterWrite
- func (x *Session) GetRowCount() int64
- func (x *Session) GetSavepoints() []string
- func (x *Session) GetSessionUUID() string
- func (x *Session) GetShardSessions() []*Session_ShardSession
- func (x *Session) GetSystemVariables() map[string]string
- func (x *Session) GetTargetString() string
- func (x *Session) GetTransactionMode() TransactionMode
- func (x *Session) GetUserDefinedVariables() map[string]*query.BindVariable
- func (x *Session) GetWarnings() []*query.QueryWarning
- func (m *Session) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *Session) MarshalToVT(dAtA []byte) (int, error)
- func (m *Session) MarshalVT() (dAtA []byte, err error)
- func (*Session) ProtoMessage()
- func (x *Session) ProtoReflect() protoreflect.Message
- func (x *Session) Reset()
- func (m *Session) SizeVT() (n int)
- func (x *Session) String() string
- func (m *Session) UnmarshalVT(dAtA []byte) error
- type Session_ShardSession
- func (*Session_ShardSession) Descriptor() ([]byte, []int)deprecated
- func (x *Session_ShardSession) GetReservedId() int64
- func (x *Session_ShardSession) GetTabletAlias() *topodata.TabletAlias
- func (x *Session_ShardSession) GetTarget() *query.Target
- func (x *Session_ShardSession) GetTransactionId() int64
- func (x *Session_ShardSession) GetVindexOnly() bool
- func (m *Session_ShardSession) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *Session_ShardSession) MarshalToVT(dAtA []byte) (int, error)
- func (m *Session_ShardSession) MarshalVT() (dAtA []byte, err error)
- func (*Session_ShardSession) ProtoMessage()
- func (x *Session_ShardSession) ProtoReflect() protoreflect.Message
- func (x *Session_ShardSession) Reset()
- func (m *Session_ShardSession) SizeVT() (n int)
- func (x *Session_ShardSession) String() string
- func (m *Session_ShardSession) UnmarshalVT(dAtA []byte) error
- type StreamExecuteRequest
- func (*StreamExecuteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamExecuteRequest) GetCallerId() *vtrpc.CallerID
- func (x *StreamExecuteRequest) GetQuery() *query.BoundQuery
- func (x *StreamExecuteRequest) GetSession() *Session
- func (m *StreamExecuteRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *StreamExecuteRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *StreamExecuteRequest) MarshalVT() (dAtA []byte, err error)
- func (*StreamExecuteRequest) ProtoMessage()
- func (x *StreamExecuteRequest) ProtoReflect() protoreflect.Message
- func (x *StreamExecuteRequest) Reset()
- func (m *StreamExecuteRequest) SizeVT() (n int)
- func (x *StreamExecuteRequest) String() string
- func (m *StreamExecuteRequest) UnmarshalVT(dAtA []byte) error
- type StreamExecuteResponse
- func (*StreamExecuteResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StreamExecuteResponse) GetResult() *query.QueryResult
- func (m *StreamExecuteResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *StreamExecuteResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *StreamExecuteResponse) MarshalVT() (dAtA []byte, err error)
- func (*StreamExecuteResponse) ProtoMessage()
- func (x *StreamExecuteResponse) ProtoReflect() protoreflect.Message
- func (x *StreamExecuteResponse) Reset()
- func (m *StreamExecuteResponse) SizeVT() (n int)
- func (x *StreamExecuteResponse) String() string
- func (m *StreamExecuteResponse) UnmarshalVT(dAtA []byte) error
- type TransactionMode
- func (TransactionMode) Descriptor() protoreflect.EnumDescriptor
- func (x TransactionMode) Enum() *TransactionMode
- func (TransactionMode) EnumDescriptor() ([]byte, []int)deprecated
- func (x TransactionMode) Number() protoreflect.EnumNumber
- func (x TransactionMode) String() string
- func (TransactionMode) Type() protoreflect.EnumType
- type VStreamFlags
- func (*VStreamFlags) Descriptor() ([]byte, []int)deprecated
- func (x *VStreamFlags) GetCells() string
- func (x *VStreamFlags) GetHeartbeatInterval() uint32
- func (x *VStreamFlags) GetMinimizeSkew() bool
- func (x *VStreamFlags) GetStopOnReshard() bool
- func (m *VStreamFlags) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *VStreamFlags) MarshalToVT(dAtA []byte) (int, error)
- func (m *VStreamFlags) MarshalVT() (dAtA []byte, err error)
- func (*VStreamFlags) ProtoMessage()
- func (x *VStreamFlags) ProtoReflect() protoreflect.Message
- func (x *VStreamFlags) Reset()
- func (m *VStreamFlags) SizeVT() (n int)
- func (x *VStreamFlags) String() string
- func (m *VStreamFlags) UnmarshalVT(dAtA []byte) error
- type VStreamRequest
- func (*VStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *VStreamRequest) GetCallerId() *vtrpc.CallerID
- func (x *VStreamRequest) GetFilter() *binlogdata.Filter
- func (x *VStreamRequest) GetFlags() *VStreamFlags
- func (x *VStreamRequest) GetTabletType() topodata.TabletType
- func (x *VStreamRequest) GetVgtid() *binlogdata.VGtid
- func (m *VStreamRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *VStreamRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *VStreamRequest) MarshalVT() (dAtA []byte, err error)
- func (*VStreamRequest) ProtoMessage()
- func (x *VStreamRequest) ProtoReflect() protoreflect.Message
- func (x *VStreamRequest) Reset()
- func (m *VStreamRequest) SizeVT() (n int)
- func (x *VStreamRequest) String() string
- func (m *VStreamRequest) UnmarshalVT(dAtA []byte) error
- type VStreamResponse
- func (*VStreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *VStreamResponse) GetEvents() []*binlogdata.VEvent
- func (m *VStreamResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *VStreamResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *VStreamResponse) MarshalVT() (dAtA []byte, err error)
- func (*VStreamResponse) ProtoMessage()
- func (x *VStreamResponse) ProtoReflect() protoreflect.Message
- func (x *VStreamResponse) Reset()
- func (m *VStreamResponse) SizeVT() (n int)
- func (x *VStreamResponse) String() string
- func (m *VStreamResponse) UnmarshalVT(dAtA []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( TransactionMode_name = map[int32]string{ 0: "UNSPECIFIED", 1: "SINGLE", 2: "MULTI", 3: "TWOPC", } TransactionMode_value = map[string]int32{ "UNSPECIFIED": 0, "SINGLE": 1, "MULTI": 2, "TWOPC": 3, } )
Enum value maps for TransactionMode.
var ( CommitOrder_name = map[int32]string{ 0: "NORMAL", 1: "PRE", 2: "POST", 3: "AUTOCOMMIT", } CommitOrder_value = map[string]int32{ "NORMAL": 0, "PRE": 1, "POST": 2, "AUTOCOMMIT": 3, } )
Enum value maps for CommitOrder.
var ( ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflow = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group") )
var File_vtgate_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type CloseSessionRequest ¶ added in v0.11.0
type CloseSessionRequest struct { // caller_id identifies the caller. This is the effective caller ID, // set by the application to further identify the caller. CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"` // session carries the session state. Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"` // contains filtered or unexported fields }
CloseSessionRequest is the payload to CloseSession.
func (*CloseSessionRequest) Descriptor
deprecated
added in
v0.11.0
func (*CloseSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use CloseSessionRequest.ProtoReflect.Descriptor instead.
func (*CloseSessionRequest) GetCallerId ¶ added in v0.11.0
func (x *CloseSessionRequest) GetCallerId() *vtrpc.CallerID
func (*CloseSessionRequest) GetSession ¶ added in v0.11.0
func (x *CloseSessionRequest) GetSession() *Session
func (*CloseSessionRequest) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *CloseSessionRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*CloseSessionRequest) MarshalToVT ¶ added in v0.11.0
func (m *CloseSessionRequest) MarshalToVT(dAtA []byte) (int, error)
func (*CloseSessionRequest) MarshalVT ¶ added in v0.11.0
func (m *CloseSessionRequest) MarshalVT() (dAtA []byte, err error)
func (*CloseSessionRequest) ProtoMessage ¶ added in v0.11.0
func (*CloseSessionRequest) ProtoMessage()
func (*CloseSessionRequest) ProtoReflect ¶ added in v0.11.0
func (x *CloseSessionRequest) ProtoReflect() protoreflect.Message
func (*CloseSessionRequest) Reset ¶ added in v0.11.0
func (x *CloseSessionRequest) Reset()
func (*CloseSessionRequest) SizeVT ¶ added in v0.11.0
func (m *CloseSessionRequest) SizeVT() (n int)
func (*CloseSessionRequest) String ¶ added in v0.11.0
func (x *CloseSessionRequest) String() string
func (*CloseSessionRequest) UnmarshalVT ¶ added in v0.11.0
func (m *CloseSessionRequest) UnmarshalVT(dAtA []byte) error
type CloseSessionResponse ¶ added in v0.11.0
type CloseSessionResponse struct { // error contains an application level error if necessary. Note the // session may have changed, even when an error is returned (for // instance if a database integrity error happened). Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
CloseSessionResponse is the returned value from CloseSession.
func (*CloseSessionResponse) Descriptor
deprecated
added in
v0.11.0
func (*CloseSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use CloseSessionResponse.ProtoReflect.Descriptor instead.
func (*CloseSessionResponse) GetError ¶ added in v0.11.0
func (x *CloseSessionResponse) GetError() *vtrpc.RPCError
func (*CloseSessionResponse) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *CloseSessionResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*CloseSessionResponse) MarshalToVT ¶ added in v0.11.0
func (m *CloseSessionResponse) MarshalToVT(dAtA []byte) (int, error)
func (*CloseSessionResponse) MarshalVT ¶ added in v0.11.0
func (m *CloseSessionResponse) MarshalVT() (dAtA []byte, err error)
func (*CloseSessionResponse) ProtoMessage ¶ added in v0.11.0
func (*CloseSessionResponse) ProtoMessage()
func (*CloseSessionResponse) ProtoReflect ¶ added in v0.11.0
func (x *CloseSessionResponse) ProtoReflect() protoreflect.Message
func (*CloseSessionResponse) Reset ¶ added in v0.11.0
func (x *CloseSessionResponse) Reset()
func (*CloseSessionResponse) SizeVT ¶ added in v0.11.0
func (m *CloseSessionResponse) SizeVT() (n int)
func (*CloseSessionResponse) String ¶ added in v0.11.0
func (x *CloseSessionResponse) String() string
func (*CloseSessionResponse) UnmarshalVT ¶ added in v0.11.0
func (m *CloseSessionResponse) UnmarshalVT(dAtA []byte) error
type CommitOrder ¶
type CommitOrder int32
CommitOrder is used to designate which of the ShardSessions get used for transactions.
const ( // NORMAL is the default commit order. CommitOrder_NORMAL CommitOrder = 0 // PRE is used to designate pre_sessions. CommitOrder_PRE CommitOrder = 1 // POST is used to designate post_sessions. CommitOrder_POST CommitOrder = 2 // AUTOCOMMIT is used to run the statement as autocommitted transaction. CommitOrder_AUTOCOMMIT CommitOrder = 3 )
func (CommitOrder) Descriptor ¶ added in v0.11.0
func (CommitOrder) Descriptor() protoreflect.EnumDescriptor
func (CommitOrder) Enum ¶ added in v0.11.0
func (x CommitOrder) Enum() *CommitOrder
func (CommitOrder) EnumDescriptor
deprecated
func (CommitOrder) EnumDescriptor() ([]byte, []int)
Deprecated: Use CommitOrder.Descriptor instead.
func (CommitOrder) Number ¶ added in v0.11.0
func (x CommitOrder) Number() protoreflect.EnumNumber
func (CommitOrder) String ¶
func (x CommitOrder) String() string
func (CommitOrder) Type ¶ added in v0.11.0
func (CommitOrder) Type() protoreflect.EnumType
type ExecuteBatchRequest ¶
type ExecuteBatchRequest struct { // caller_id identifies the caller. This is the effective caller ID, // set by the application to further identify the caller. CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"` // session carries the session state. Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"` // queries is a list of query and bind variables to execute. Queries []*query.BoundQuery `protobuf:"bytes,3,rep,name=queries,proto3" json:"queries,omitempty"` // contains filtered or unexported fields }
ExecuteBatchRequest is the payload to ExecuteBatch.
func (*ExecuteBatchRequest) Descriptor
deprecated
func (*ExecuteBatchRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteBatchRequest.ProtoReflect.Descriptor instead.
func (*ExecuteBatchRequest) GetCallerId ¶
func (x *ExecuteBatchRequest) GetCallerId() *vtrpc.CallerID
func (*ExecuteBatchRequest) GetQueries ¶
func (x *ExecuteBatchRequest) GetQueries() []*query.BoundQuery
func (*ExecuteBatchRequest) GetSession ¶
func (x *ExecuteBatchRequest) GetSession() *Session
func (*ExecuteBatchRequest) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *ExecuteBatchRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ExecuteBatchRequest) MarshalToVT ¶ added in v0.11.0
func (m *ExecuteBatchRequest) MarshalToVT(dAtA []byte) (int, error)
func (*ExecuteBatchRequest) MarshalVT ¶ added in v0.11.0
func (m *ExecuteBatchRequest) MarshalVT() (dAtA []byte, err error)
func (*ExecuteBatchRequest) ProtoMessage ¶
func (*ExecuteBatchRequest) ProtoMessage()
func (*ExecuteBatchRequest) ProtoReflect ¶ added in v0.11.0
func (x *ExecuteBatchRequest) ProtoReflect() protoreflect.Message
func (*ExecuteBatchRequest) Reset ¶
func (x *ExecuteBatchRequest) Reset()
func (*ExecuteBatchRequest) SizeVT ¶ added in v0.11.0
func (m *ExecuteBatchRequest) SizeVT() (n int)
func (*ExecuteBatchRequest) String ¶
func (x *ExecuteBatchRequest) String() string
func (*ExecuteBatchRequest) UnmarshalVT ¶ added in v0.11.0
func (m *ExecuteBatchRequest) UnmarshalVT(dAtA []byte) error
type ExecuteBatchResponse ¶
type ExecuteBatchResponse struct { // error contains an application level error if necessary. Note the // session may have changed, even when an error is returned (for // instance if a database integrity error happened). Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` // session is the updated session information. Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"` // results contains the query results, only set if application level error is unset. Results []*query.ResultWithError `protobuf:"bytes,3,rep,name=results,proto3" json:"results,omitempty"` // contains filtered or unexported fields }
ExecuteBatchResponse is the returned value from ExecuteBatch.
func (*ExecuteBatchResponse) Descriptor
deprecated
func (*ExecuteBatchResponse) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteBatchResponse.ProtoReflect.Descriptor instead.
func (*ExecuteBatchResponse) GetError ¶
func (x *ExecuteBatchResponse) GetError() *vtrpc.RPCError
func (*ExecuteBatchResponse) GetResults ¶
func (x *ExecuteBatchResponse) GetResults() []*query.ResultWithError
func (*ExecuteBatchResponse) GetSession ¶
func (x *ExecuteBatchResponse) GetSession() *Session
func (*ExecuteBatchResponse) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *ExecuteBatchResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ExecuteBatchResponse) MarshalToVT ¶ added in v0.11.0
func (m *ExecuteBatchResponse) MarshalToVT(dAtA []byte) (int, error)
func (*ExecuteBatchResponse) MarshalVT ¶ added in v0.11.0
func (m *ExecuteBatchResponse) MarshalVT() (dAtA []byte, err error)
func (*ExecuteBatchResponse) ProtoMessage ¶
func (*ExecuteBatchResponse) ProtoMessage()
func (*ExecuteBatchResponse) ProtoReflect ¶ added in v0.11.0
func (x *ExecuteBatchResponse) ProtoReflect() protoreflect.Message
func (*ExecuteBatchResponse) Reset ¶
func (x *ExecuteBatchResponse) Reset()
func (*ExecuteBatchResponse) SizeVT ¶ added in v0.11.0
func (m *ExecuteBatchResponse) SizeVT() (n int)
func (*ExecuteBatchResponse) String ¶
func (x *ExecuteBatchResponse) String() string
func (*ExecuteBatchResponse) UnmarshalVT ¶ added in v0.11.0
func (m *ExecuteBatchResponse) UnmarshalVT(dAtA []byte) error
type ExecuteRequest ¶
type ExecuteRequest struct { // caller_id identifies the caller. This is the effective caller ID, // set by the application to further identify the caller. CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"` // session carries the session state. Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"` // query is the query and bind variables to execute. Query *query.BoundQuery `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"` // contains filtered or unexported fields }
ExecuteRequest is the payload to Execute.
func (*ExecuteRequest) Descriptor
deprecated
func (*ExecuteRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteRequest.ProtoReflect.Descriptor instead.
func (*ExecuteRequest) GetCallerId ¶
func (x *ExecuteRequest) GetCallerId() *vtrpc.CallerID
func (*ExecuteRequest) GetQuery ¶
func (x *ExecuteRequest) GetQuery() *query.BoundQuery
func (*ExecuteRequest) GetSession ¶
func (x *ExecuteRequest) GetSession() *Session
func (*ExecuteRequest) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *ExecuteRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ExecuteRequest) MarshalToVT ¶ added in v0.11.0
func (m *ExecuteRequest) MarshalToVT(dAtA []byte) (int, error)
func (*ExecuteRequest) MarshalVT ¶ added in v0.11.0
func (m *ExecuteRequest) MarshalVT() (dAtA []byte, err error)
func (*ExecuteRequest) ProtoMessage ¶
func (*ExecuteRequest) ProtoMessage()
func (*ExecuteRequest) ProtoReflect ¶ added in v0.11.0
func (x *ExecuteRequest) ProtoReflect() protoreflect.Message
func (*ExecuteRequest) Reset ¶
func (x *ExecuteRequest) Reset()
func (*ExecuteRequest) SizeVT ¶ added in v0.11.0
func (m *ExecuteRequest) SizeVT() (n int)
func (*ExecuteRequest) String ¶
func (x *ExecuteRequest) String() string
func (*ExecuteRequest) UnmarshalVT ¶ added in v0.11.0
func (m *ExecuteRequest) UnmarshalVT(dAtA []byte) error
type ExecuteResponse ¶
type ExecuteResponse struct { // error contains an application level error if necessary. Note the // session may have changed, even when an error is returned (for // instance if a database integrity error happened). Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` // session is the updated session information. Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"` // result contains the query result, only set if error is unset. Result *query.QueryResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
ExecuteResponse is the returned value from Execute.
func (*ExecuteResponse) Descriptor
deprecated
func (*ExecuteResponse) Descriptor() ([]byte, []int)
Deprecated: Use ExecuteResponse.ProtoReflect.Descriptor instead.
func (*ExecuteResponse) GetError ¶
func (x *ExecuteResponse) GetError() *vtrpc.RPCError
func (*ExecuteResponse) GetResult ¶
func (x *ExecuteResponse) GetResult() *query.QueryResult
func (*ExecuteResponse) GetSession ¶
func (x *ExecuteResponse) GetSession() *Session
func (*ExecuteResponse) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *ExecuteResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ExecuteResponse) MarshalToVT ¶ added in v0.11.0
func (m *ExecuteResponse) MarshalToVT(dAtA []byte) (int, error)
func (*ExecuteResponse) MarshalVT ¶ added in v0.11.0
func (m *ExecuteResponse) MarshalVT() (dAtA []byte, err error)
func (*ExecuteResponse) ProtoMessage ¶
func (*ExecuteResponse) ProtoMessage()
func (*ExecuteResponse) ProtoReflect ¶ added in v0.11.0
func (x *ExecuteResponse) ProtoReflect() protoreflect.Message
func (*ExecuteResponse) Reset ¶
func (x *ExecuteResponse) Reset()
func (*ExecuteResponse) SizeVT ¶ added in v0.11.0
func (m *ExecuteResponse) SizeVT() (n int)
func (*ExecuteResponse) String ¶
func (x *ExecuteResponse) String() string
func (*ExecuteResponse) UnmarshalVT ¶ added in v0.11.0
func (m *ExecuteResponse) UnmarshalVT(dAtA []byte) error
type PrepareRequest ¶ added in v0.11.0
type PrepareRequest struct { // caller_id identifies the caller. This is the effective caller ID, // set by the application to further identify the caller. CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"` // session carries the session state. Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"` // query is the query and bind variables to execute. Query *query.BoundQuery `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"` // contains filtered or unexported fields }
PrepareRequest is the payload to Prepare.
func (*PrepareRequest) Descriptor
deprecated
added in
v0.11.0
func (*PrepareRequest) Descriptor() ([]byte, []int)
Deprecated: Use PrepareRequest.ProtoReflect.Descriptor instead.
func (*PrepareRequest) GetCallerId ¶ added in v0.11.0
func (x *PrepareRequest) GetCallerId() *vtrpc.CallerID
func (*PrepareRequest) GetQuery ¶ added in v0.11.0
func (x *PrepareRequest) GetQuery() *query.BoundQuery
func (*PrepareRequest) GetSession ¶ added in v0.11.0
func (x *PrepareRequest) GetSession() *Session
func (*PrepareRequest) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *PrepareRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*PrepareRequest) MarshalToVT ¶ added in v0.11.0
func (m *PrepareRequest) MarshalToVT(dAtA []byte) (int, error)
func (*PrepareRequest) MarshalVT ¶ added in v0.11.0
func (m *PrepareRequest) MarshalVT() (dAtA []byte, err error)
func (*PrepareRequest) ProtoMessage ¶ added in v0.11.0
func (*PrepareRequest) ProtoMessage()
func (*PrepareRequest) ProtoReflect ¶ added in v0.11.0
func (x *PrepareRequest) ProtoReflect() protoreflect.Message
func (*PrepareRequest) Reset ¶ added in v0.11.0
func (x *PrepareRequest) Reset()
func (*PrepareRequest) SizeVT ¶ added in v0.11.0
func (m *PrepareRequest) SizeVT() (n int)
func (*PrepareRequest) String ¶ added in v0.11.0
func (x *PrepareRequest) String() string
func (*PrepareRequest) UnmarshalVT ¶ added in v0.11.0
func (m *PrepareRequest) UnmarshalVT(dAtA []byte) error
type PrepareResponse ¶ added in v0.11.0
type PrepareResponse struct { // error contains an application level error if necessary. Note the // session may have changed, even when an error is returned (for // instance if a database integrity error happened). Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` // session is the updated session information. Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,omitempty"` // fields contains the fields, only set if error is unset. Fields []*query.Field `protobuf:"bytes,3,rep,name=fields,proto3" json:"fields,omitempty"` // contains filtered or unexported fields }
PrepareResponse is the returned value from Prepare.
func (*PrepareResponse) Descriptor
deprecated
added in
v0.11.0
func (*PrepareResponse) Descriptor() ([]byte, []int)
Deprecated: Use PrepareResponse.ProtoReflect.Descriptor instead.
func (*PrepareResponse) GetError ¶ added in v0.11.0
func (x *PrepareResponse) GetError() *vtrpc.RPCError
func (*PrepareResponse) GetFields ¶ added in v0.11.0
func (x *PrepareResponse) GetFields() []*query.Field
func (*PrepareResponse) GetSession ¶ added in v0.11.0
func (x *PrepareResponse) GetSession() *Session
func (*PrepareResponse) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *PrepareResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*PrepareResponse) MarshalToVT ¶ added in v0.11.0
func (m *PrepareResponse) MarshalToVT(dAtA []byte) (int, error)
func (*PrepareResponse) MarshalVT ¶ added in v0.11.0
func (m *PrepareResponse) MarshalVT() (dAtA []byte, err error)
func (*PrepareResponse) ProtoMessage ¶ added in v0.11.0
func (*PrepareResponse) ProtoMessage()
func (*PrepareResponse) ProtoReflect ¶ added in v0.11.0
func (x *PrepareResponse) ProtoReflect() protoreflect.Message
func (*PrepareResponse) Reset ¶ added in v0.11.0
func (x *PrepareResponse) Reset()
func (*PrepareResponse) SizeVT ¶ added in v0.11.0
func (m *PrepareResponse) SizeVT() (n int)
func (*PrepareResponse) String ¶ added in v0.11.0
func (x *PrepareResponse) String() string
func (*PrepareResponse) UnmarshalVT ¶ added in v0.11.0
func (m *PrepareResponse) UnmarshalVT(dAtA []byte) error
type ReadAfterWrite ¶ added in v0.9.0
type ReadAfterWrite struct { ReadAfterWriteGtid string `protobuf:"bytes,1,opt,name=read_after_write_gtid,json=readAfterWriteGtid,proto3" json:"read_after_write_gtid,omitempty"` ReadAfterWriteTimeout float64 `` /* 130-byte string literal not displayed */ SessionTrackGtids bool `protobuf:"varint,3,opt,name=session_track_gtids,json=sessionTrackGtids,proto3" json:"session_track_gtids,omitempty"` // contains filtered or unexported fields }
ReadAfterWrite contains information regarding gtid set and timeout Also if the gtid information needs to be passed to client.
func (*ReadAfterWrite) Descriptor
deprecated
added in
v0.9.0
func (*ReadAfterWrite) Descriptor() ([]byte, []int)
Deprecated: Use ReadAfterWrite.ProtoReflect.Descriptor instead.
func (*ReadAfterWrite) GetReadAfterWriteGtid ¶ added in v0.9.0
func (x *ReadAfterWrite) GetReadAfterWriteGtid() string
func (*ReadAfterWrite) GetReadAfterWriteTimeout ¶ added in v0.9.0
func (x *ReadAfterWrite) GetReadAfterWriteTimeout() float64
func (*ReadAfterWrite) GetSessionTrackGtids ¶ added in v0.9.0
func (x *ReadAfterWrite) GetSessionTrackGtids() bool
func (*ReadAfterWrite) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *ReadAfterWrite) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ReadAfterWrite) MarshalToVT ¶ added in v0.11.0
func (m *ReadAfterWrite) MarshalToVT(dAtA []byte) (int, error)
func (*ReadAfterWrite) MarshalVT ¶ added in v0.11.0
func (m *ReadAfterWrite) MarshalVT() (dAtA []byte, err error)
func (*ReadAfterWrite) ProtoMessage ¶ added in v0.9.0
func (*ReadAfterWrite) ProtoMessage()
func (*ReadAfterWrite) ProtoReflect ¶ added in v0.11.0
func (x *ReadAfterWrite) ProtoReflect() protoreflect.Message
func (*ReadAfterWrite) Reset ¶ added in v0.9.0
func (x *ReadAfterWrite) Reset()
func (*ReadAfterWrite) SizeVT ¶ added in v0.11.0
func (m *ReadAfterWrite) SizeVT() (n int)
func (*ReadAfterWrite) String ¶ added in v0.9.0
func (x *ReadAfterWrite) String() string
func (*ReadAfterWrite) UnmarshalVT ¶ added in v0.11.0
func (m *ReadAfterWrite) UnmarshalVT(dAtA []byte) error
type ResolveTransactionRequest ¶
type ResolveTransactionRequest struct { // caller_id identifies the caller. This is the effective caller ID, // set by the application to further identify the caller. CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"` // dtid is the dtid of the transaction to be resolved. Dtid string `protobuf:"bytes,2,opt,name=dtid,proto3" json:"dtid,omitempty"` // contains filtered or unexported fields }
ResolveTransactionRequest is the payload to ResolveTransaction.
func (*ResolveTransactionRequest) Descriptor
deprecated
func (*ResolveTransactionRequest) Descriptor() ([]byte, []int)
Deprecated: Use ResolveTransactionRequest.ProtoReflect.Descriptor instead.
func (*ResolveTransactionRequest) GetCallerId ¶
func (x *ResolveTransactionRequest) GetCallerId() *vtrpc.CallerID
func (*ResolveTransactionRequest) GetDtid ¶
func (x *ResolveTransactionRequest) GetDtid() string
func (*ResolveTransactionRequest) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *ResolveTransactionRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ResolveTransactionRequest) MarshalToVT ¶ added in v0.11.0
func (m *ResolveTransactionRequest) MarshalToVT(dAtA []byte) (int, error)
func (*ResolveTransactionRequest) MarshalVT ¶ added in v0.11.0
func (m *ResolveTransactionRequest) MarshalVT() (dAtA []byte, err error)
func (*ResolveTransactionRequest) ProtoMessage ¶
func (*ResolveTransactionRequest) ProtoMessage()
func (*ResolveTransactionRequest) ProtoReflect ¶ added in v0.11.0
func (x *ResolveTransactionRequest) ProtoReflect() protoreflect.Message
func (*ResolveTransactionRequest) Reset ¶
func (x *ResolveTransactionRequest) Reset()
func (*ResolveTransactionRequest) SizeVT ¶ added in v0.11.0
func (m *ResolveTransactionRequest) SizeVT() (n int)
func (*ResolveTransactionRequest) String ¶
func (x *ResolveTransactionRequest) String() string
func (*ResolveTransactionRequest) UnmarshalVT ¶ added in v0.11.0
func (m *ResolveTransactionRequest) UnmarshalVT(dAtA []byte) error
type ResolveTransactionResponse ¶
type ResolveTransactionResponse struct {
// contains filtered or unexported fields
}
ResolveTransactionResponse is the returned value from Rollback.
func (*ResolveTransactionResponse) Descriptor
deprecated
func (*ResolveTransactionResponse) Descriptor() ([]byte, []int)
Deprecated: Use ResolveTransactionResponse.ProtoReflect.Descriptor instead.
func (*ResolveTransactionResponse) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *ResolveTransactionResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*ResolveTransactionResponse) MarshalToVT ¶ added in v0.11.0
func (m *ResolveTransactionResponse) MarshalToVT(dAtA []byte) (int, error)
func (*ResolveTransactionResponse) MarshalVT ¶ added in v0.11.0
func (m *ResolveTransactionResponse) MarshalVT() (dAtA []byte, err error)
func (*ResolveTransactionResponse) ProtoMessage ¶
func (*ResolveTransactionResponse) ProtoMessage()
func (*ResolveTransactionResponse) ProtoReflect ¶ added in v0.11.0
func (x *ResolveTransactionResponse) ProtoReflect() protoreflect.Message
func (*ResolveTransactionResponse) Reset ¶
func (x *ResolveTransactionResponse) Reset()
func (*ResolveTransactionResponse) SizeVT ¶ added in v0.11.0
func (m *ResolveTransactionResponse) SizeVT() (n int)
func (*ResolveTransactionResponse) String ¶
func (x *ResolveTransactionResponse) String() string
func (*ResolveTransactionResponse) UnmarshalVT ¶ added in v0.11.0
func (m *ResolveTransactionResponse) UnmarshalVT(dAtA []byte) error
type Session ¶
type Session struct { // in_transaction is set to true if the session is in a transaction. InTransaction bool `protobuf:"varint,1,opt,name=in_transaction,json=inTransaction,proto3" json:"in_transaction,omitempty"` // shard_sessions keep track of per-shard transaction info. ShardSessions []*Session_ShardSession `protobuf:"bytes,2,rep,name=shard_sessions,json=shardSessions,proto3" json:"shard_sessions,omitempty"` // autocommit specifies if the session is in autocommit mode. // This is used only for V3. Autocommit bool `protobuf:"varint,4,opt,name=autocommit,proto3" json:"autocommit,omitempty"` // target_string is the target expressed as a string. Valid // names are: keyspace:shard@target, keyspace@target or @target. // This is used only for V3. TargetString string `protobuf:"bytes,5,opt,name=target_string,json=targetString,proto3" json:"target_string,omitempty"` // options is used only for V3. Options *query.ExecuteOptions `protobuf:"bytes,6,opt,name=options,proto3" json:"options,omitempty"` // transaction_mode specifies the current transaction mode. TransactionMode TransactionMode `` /* 135-byte string literal not displayed */ // warnings contains non-fatal warnings from the previous query Warnings []*query.QueryWarning `protobuf:"bytes,8,rep,name=warnings,proto3" json:"warnings,omitempty"` // pre_sessions contains sessions that have to be committed first. PreSessions []*Session_ShardSession `protobuf:"bytes,9,rep,name=pre_sessions,json=preSessions,proto3" json:"pre_sessions,omitempty"` // post_sessions contains sessions that have to be committed last. PostSessions []*Session_ShardSession `protobuf:"bytes,10,rep,name=post_sessions,json=postSessions,proto3" json:"post_sessions,omitempty"` // last_insert_id keeps track of the last seen insert_id for this session LastInsertId uint64 `protobuf:"varint,11,opt,name=last_insert_id,json=lastInsertId,proto3" json:"last_insert_id,omitempty"` // found_rows keeps track of how many rows the last query returned FoundRows uint64 `protobuf:"varint,12,opt,name=found_rows,json=foundRows,proto3" json:"found_rows,omitempty"` // user_defined_variables contains all the @variables defined for this session UserDefinedVariables map[string]*query.BindVariable `` /* 212-byte string literal not displayed */ // system_variables keeps track of all session variables set for this connection // TODO: systay should we keep this so we can apply it ordered? SystemVariables map[string]string `` /* 195-byte string literal not displayed */ // row_count keeps track of the last seen rows affected for this session RowCount int64 `protobuf:"varint,15,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"` // Stores savepoint and release savepoint calls inside a transaction // and is reset once transaction is committed or rolled back. Savepoints []string `protobuf:"bytes,16,rep,name=savepoints,proto3" json:"savepoints,omitempty"` // in_reserved_conn is set to true if the session should be using reserved connections. InReservedConn bool `protobuf:"varint,17,opt,name=in_reserved_conn,json=inReservedConn,proto3" json:"in_reserved_conn,omitempty"` // lock_session keep tracks of shard on which the lock query is sent. LockSession *Session_ShardSession `protobuf:"bytes,18,opt,name=lock_session,json=lockSession,proto3" json:"lock_session,omitempty"` // last_lock_heartbeat keep tracks of when last lock heartbeat was sent. LastLockHeartbeat int64 `protobuf:"varint,19,opt,name=last_lock_heartbeat,json=lastLockHeartbeat,proto3" json:"last_lock_heartbeat,omitempty"` // read_after_write tracks the ReadAfterWrite settings for this session. ReadAfterWrite *ReadAfterWrite `protobuf:"bytes,20,opt,name=read_after_write,json=readAfterWrite,proto3" json:"read_after_write,omitempty"` // DDL strategy DDLStrategy string `protobuf:"bytes,21,opt,name=DDLStrategy,proto3" json:"DDLStrategy,omitempty"` // Session UUID SessionUUID string `protobuf:"bytes,22,opt,name=SessionUUID,proto3" json:"SessionUUID,omitempty"` // enable_system_settings defines if we can use reserved connections. EnableSystemSettings bool `protobuf:"varint,23,opt,name=enable_system_settings,json=enableSystemSettings,proto3" json:"enable_system_settings,omitempty"` AdvisoryLock map[string]int64 `` /* 187-byte string literal not displayed */ // contains filtered or unexported fields }
Session objects are exchanged like cookies through various calls to VTGate. The behavior differs between V2 & V3 APIs. V3 APIs are Execute, ExecuteBatch and StreamExecute. All other APIs are V2. For the V3 APIs, the session must be sent with every call to Execute or ExecuteBatch. For the V2 APIs, Begin does not accept a session. It instead returns a brand new one with in_transaction set to true. After a call to Commit or Rollback, the session can be discarded. If you're not in a transaction, Session is an optional parameter for the V2 APIs.
func (*Session) Descriptor
deprecated
func (*Session) GetAdvisoryLock ¶ added in v0.14.0
func (*Session) GetAutocommit ¶
func (*Session) GetDDLStrategy ¶ added in v0.9.0
func (*Session) GetEnableSystemSettings ¶ added in v0.10.0
func (*Session) GetFoundRows ¶
func (*Session) GetInReservedConn ¶
func (*Session) GetInTransaction ¶
func (*Session) GetLastInsertId ¶
func (*Session) GetLastLockHeartbeat ¶ added in v0.8.0
func (*Session) GetLockSession ¶ added in v0.8.0
func (x *Session) GetLockSession() *Session_ShardSession
func (*Session) GetOptions ¶
func (x *Session) GetOptions() *query.ExecuteOptions
func (*Session) GetPostSessions ¶
func (x *Session) GetPostSessions() []*Session_ShardSession
func (*Session) GetPreSessions ¶
func (x *Session) GetPreSessions() []*Session_ShardSession
func (*Session) GetReadAfterWrite ¶ added in v0.9.0
func (x *Session) GetReadAfterWrite() *ReadAfterWrite
func (*Session) GetRowCount ¶
func (*Session) GetSavepoints ¶
func (*Session) GetSessionUUID ¶ added in v0.9.0
func (*Session) GetShardSessions ¶
func (x *Session) GetShardSessions() []*Session_ShardSession
func (*Session) GetSystemVariables ¶
func (*Session) GetTargetString ¶
func (*Session) GetTransactionMode ¶
func (x *Session) GetTransactionMode() TransactionMode
func (*Session) GetUserDefinedVariables ¶
func (x *Session) GetUserDefinedVariables() map[string]*query.BindVariable
func (*Session) GetWarnings ¶
func (x *Session) GetWarnings() []*query.QueryWarning
func (*Session) MarshalToSizedBufferVT ¶ added in v0.11.0
func (*Session) MarshalToVT ¶ added in v0.11.0
func (*Session) ProtoMessage ¶
func (*Session) ProtoMessage()
func (*Session) ProtoReflect ¶ added in v0.11.0
func (x *Session) ProtoReflect() protoreflect.Message
func (*Session) UnmarshalVT ¶ added in v0.11.0
type Session_ShardSession ¶
type Session_ShardSession struct { Target *query.Target `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"` TransactionId int64 `protobuf:"varint,2,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"` TabletAlias *topodata.TabletAlias `protobuf:"bytes,3,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"` // reserved connection if a dedicated connection is needed ReservedId int64 `protobuf:"varint,4,opt,name=reserved_id,json=reservedId,proto3" json:"reserved_id,omitempty"` VindexOnly bool `protobuf:"varint,5,opt,name=vindex_only,json=vindexOnly,proto3" json:"vindex_only,omitempty"` // contains filtered or unexported fields }
func (*Session_ShardSession) Descriptor
deprecated
func (*Session_ShardSession) Descriptor() ([]byte, []int)
Deprecated: Use Session_ShardSession.ProtoReflect.Descriptor instead.
func (*Session_ShardSession) GetReservedId ¶
func (x *Session_ShardSession) GetReservedId() int64
func (*Session_ShardSession) GetTabletAlias ¶
func (x *Session_ShardSession) GetTabletAlias() *topodata.TabletAlias
func (*Session_ShardSession) GetTarget ¶
func (x *Session_ShardSession) GetTarget() *query.Target
func (*Session_ShardSession) GetTransactionId ¶
func (x *Session_ShardSession) GetTransactionId() int64
func (*Session_ShardSession) GetVindexOnly ¶ added in v0.15.0
func (x *Session_ShardSession) GetVindexOnly() bool
func (*Session_ShardSession) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *Session_ShardSession) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*Session_ShardSession) MarshalToVT ¶ added in v0.11.0
func (m *Session_ShardSession) MarshalToVT(dAtA []byte) (int, error)
func (*Session_ShardSession) MarshalVT ¶ added in v0.11.0
func (m *Session_ShardSession) MarshalVT() (dAtA []byte, err error)
func (*Session_ShardSession) ProtoMessage ¶
func (*Session_ShardSession) ProtoMessage()
func (*Session_ShardSession) ProtoReflect ¶ added in v0.11.0
func (x *Session_ShardSession) ProtoReflect() protoreflect.Message
func (*Session_ShardSession) Reset ¶
func (x *Session_ShardSession) Reset()
func (*Session_ShardSession) SizeVT ¶ added in v0.11.0
func (m *Session_ShardSession) SizeVT() (n int)
func (*Session_ShardSession) String ¶
func (x *Session_ShardSession) String() string
func (*Session_ShardSession) UnmarshalVT ¶ added in v0.11.0
func (m *Session_ShardSession) UnmarshalVT(dAtA []byte) error
type StreamExecuteRequest ¶
type StreamExecuteRequest struct { // caller_id identifies the caller. This is the effective caller ID, // set by the application to further identify the caller. CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"` // query is the query and bind variables to execute. Query *query.BoundQuery `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"` // session carries the session state. Session *Session `protobuf:"bytes,6,opt,name=session,proto3" json:"session,omitempty"` // contains filtered or unexported fields }
StreamExecuteRequest is the payload to StreamExecute.
func (*StreamExecuteRequest) Descriptor
deprecated
func (*StreamExecuteRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamExecuteRequest.ProtoReflect.Descriptor instead.
func (*StreamExecuteRequest) GetCallerId ¶
func (x *StreamExecuteRequest) GetCallerId() *vtrpc.CallerID
func (*StreamExecuteRequest) GetQuery ¶
func (x *StreamExecuteRequest) GetQuery() *query.BoundQuery
func (*StreamExecuteRequest) GetSession ¶
func (x *StreamExecuteRequest) GetSession() *Session
func (*StreamExecuteRequest) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *StreamExecuteRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StreamExecuteRequest) MarshalToVT ¶ added in v0.11.0
func (m *StreamExecuteRequest) MarshalToVT(dAtA []byte) (int, error)
func (*StreamExecuteRequest) MarshalVT ¶ added in v0.11.0
func (m *StreamExecuteRequest) MarshalVT() (dAtA []byte, err error)
func (*StreamExecuteRequest) ProtoMessage ¶
func (*StreamExecuteRequest) ProtoMessage()
func (*StreamExecuteRequest) ProtoReflect ¶ added in v0.11.0
func (x *StreamExecuteRequest) ProtoReflect() protoreflect.Message
func (*StreamExecuteRequest) Reset ¶
func (x *StreamExecuteRequest) Reset()
func (*StreamExecuteRequest) SizeVT ¶ added in v0.11.0
func (m *StreamExecuteRequest) SizeVT() (n int)
func (*StreamExecuteRequest) String ¶
func (x *StreamExecuteRequest) String() string
func (*StreamExecuteRequest) UnmarshalVT ¶ added in v0.11.0
func (m *StreamExecuteRequest) UnmarshalVT(dAtA []byte) error
type StreamExecuteResponse ¶
type StreamExecuteResponse struct { // result contains the result data. // The first value contains only Fields information. // The next values contain the actual rows, a few values per result. Result *query.QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
StreamExecuteResponse is the returned value from StreamExecute. The session is currently not returned because StreamExecute is not expected to modify it.
func (*StreamExecuteResponse) Descriptor
deprecated
func (*StreamExecuteResponse) Descriptor() ([]byte, []int)
Deprecated: Use StreamExecuteResponse.ProtoReflect.Descriptor instead.
func (*StreamExecuteResponse) GetResult ¶
func (x *StreamExecuteResponse) GetResult() *query.QueryResult
func (*StreamExecuteResponse) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *StreamExecuteResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*StreamExecuteResponse) MarshalToVT ¶ added in v0.11.0
func (m *StreamExecuteResponse) MarshalToVT(dAtA []byte) (int, error)
func (*StreamExecuteResponse) MarshalVT ¶ added in v0.11.0
func (m *StreamExecuteResponse) MarshalVT() (dAtA []byte, err error)
func (*StreamExecuteResponse) ProtoMessage ¶
func (*StreamExecuteResponse) ProtoMessage()
func (*StreamExecuteResponse) ProtoReflect ¶ added in v0.11.0
func (x *StreamExecuteResponse) ProtoReflect() protoreflect.Message
func (*StreamExecuteResponse) Reset ¶
func (x *StreamExecuteResponse) Reset()
func (*StreamExecuteResponse) SizeVT ¶ added in v0.11.0
func (m *StreamExecuteResponse) SizeVT() (n int)
func (*StreamExecuteResponse) String ¶
func (x *StreamExecuteResponse) String() string
func (*StreamExecuteResponse) UnmarshalVT ¶ added in v0.11.0
func (m *StreamExecuteResponse) UnmarshalVT(dAtA []byte) error
type TransactionMode ¶
type TransactionMode int32
TransactionMode controls the execution of distributed transaction across multiple shards.
const ( // UNSPECIFIED uses the transaction mode set by the VTGate flag 'transaction_mode'. TransactionMode_UNSPECIFIED TransactionMode = 0 // SINGLE disallows distributed transactions. TransactionMode_SINGLE TransactionMode = 1 // MULTI allows distributed transactions with best effort commit. TransactionMode_MULTI TransactionMode = 2 // TWOPC is for distributed transactions with atomic commits. TransactionMode_TWOPC TransactionMode = 3 )
func (TransactionMode) Descriptor ¶ added in v0.11.0
func (TransactionMode) Descriptor() protoreflect.EnumDescriptor
func (TransactionMode) Enum ¶ added in v0.11.0
func (x TransactionMode) Enum() *TransactionMode
func (TransactionMode) EnumDescriptor
deprecated
func (TransactionMode) EnumDescriptor() ([]byte, []int)
Deprecated: Use TransactionMode.Descriptor instead.
func (TransactionMode) Number ¶ added in v0.11.0
func (x TransactionMode) Number() protoreflect.EnumNumber
func (TransactionMode) String ¶
func (x TransactionMode) String() string
func (TransactionMode) Type ¶ added in v0.11.0
func (TransactionMode) Type() protoreflect.EnumType
type VStreamFlags ¶ added in v0.10.0
type VStreamFlags struct { // align streams MinimizeSkew bool `protobuf:"varint,1,opt,name=minimize_skew,json=minimizeSkew,proto3" json:"minimize_skew,omitempty"` // how often heartbeats must be sent when idle (seconds) HeartbeatInterval uint32 `protobuf:"varint,2,opt,name=heartbeat_interval,json=heartbeatInterval,proto3" json:"heartbeat_interval,omitempty"` // stop streams on a reshard (journal event) StopOnReshard bool `protobuf:"varint,3,opt,name=stop_on_reshard,json=stopOnReshard,proto3" json:"stop_on_reshard,omitempty"` // if specified, these cells (comma-separated) are used to pick source tablets from. // defaults to the cell of the vtgate serving the VStream API. Cells string `protobuf:"bytes,4,opt,name=cells,proto3" json:"cells,omitempty"` // contains filtered or unexported fields }
func (*VStreamFlags) Descriptor
deprecated
added in
v0.10.0
func (*VStreamFlags) Descriptor() ([]byte, []int)
Deprecated: Use VStreamFlags.ProtoReflect.Descriptor instead.
func (*VStreamFlags) GetCells ¶ added in v0.14.0
func (x *VStreamFlags) GetCells() string
func (*VStreamFlags) GetHeartbeatInterval ¶ added in v0.11.0
func (x *VStreamFlags) GetHeartbeatInterval() uint32
func (*VStreamFlags) GetMinimizeSkew ¶ added in v0.10.0
func (x *VStreamFlags) GetMinimizeSkew() bool
func (*VStreamFlags) GetStopOnReshard ¶ added in v0.12.0
func (x *VStreamFlags) GetStopOnReshard() bool
func (*VStreamFlags) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *VStreamFlags) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*VStreamFlags) MarshalToVT ¶ added in v0.11.0
func (m *VStreamFlags) MarshalToVT(dAtA []byte) (int, error)
func (*VStreamFlags) MarshalVT ¶ added in v0.11.0
func (m *VStreamFlags) MarshalVT() (dAtA []byte, err error)
func (*VStreamFlags) ProtoMessage ¶ added in v0.10.0
func (*VStreamFlags) ProtoMessage()
func (*VStreamFlags) ProtoReflect ¶ added in v0.11.0
func (x *VStreamFlags) ProtoReflect() protoreflect.Message
func (*VStreamFlags) Reset ¶ added in v0.10.0
func (x *VStreamFlags) Reset()
func (*VStreamFlags) SizeVT ¶ added in v0.11.0
func (m *VStreamFlags) SizeVT() (n int)
func (*VStreamFlags) String ¶ added in v0.10.0
func (x *VStreamFlags) String() string
func (*VStreamFlags) UnmarshalVT ¶ added in v0.11.0
func (m *VStreamFlags) UnmarshalVT(dAtA []byte) error
type VStreamRequest ¶
type VStreamRequest struct { CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"` TabletType topodata.TabletType `protobuf:"varint,2,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"` // position specifies the starting point of the bin log positions // as well as the keyspace-shards to pull events from. // position is of the form 'ks1:0@MySQL56/<mysql_pos>|ks2:-80@MySQL56/<mysql_pos>'. Vgtid *binlogdata.VGtid `protobuf:"bytes,3,opt,name=vgtid,proto3" json:"vgtid,omitempty"` Filter *binlogdata.Filter `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"` Flags *VStreamFlags `protobuf:"bytes,5,opt,name=flags,proto3" json:"flags,omitempty"` // contains filtered or unexported fields }
VStreamRequest is the payload for VStream.
func (*VStreamRequest) Descriptor
deprecated
func (*VStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use VStreamRequest.ProtoReflect.Descriptor instead.
func (*VStreamRequest) GetCallerId ¶
func (x *VStreamRequest) GetCallerId() *vtrpc.CallerID
func (*VStreamRequest) GetFilter ¶
func (x *VStreamRequest) GetFilter() *binlogdata.Filter
func (*VStreamRequest) GetFlags ¶ added in v0.10.0
func (x *VStreamRequest) GetFlags() *VStreamFlags
func (*VStreamRequest) GetTabletType ¶
func (x *VStreamRequest) GetTabletType() topodata.TabletType
func (*VStreamRequest) GetVgtid ¶
func (x *VStreamRequest) GetVgtid() *binlogdata.VGtid
func (*VStreamRequest) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *VStreamRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*VStreamRequest) MarshalToVT ¶ added in v0.11.0
func (m *VStreamRequest) MarshalToVT(dAtA []byte) (int, error)
func (*VStreamRequest) MarshalVT ¶ added in v0.11.0
func (m *VStreamRequest) MarshalVT() (dAtA []byte, err error)
func (*VStreamRequest) ProtoMessage ¶
func (*VStreamRequest) ProtoMessage()
func (*VStreamRequest) ProtoReflect ¶ added in v0.11.0
func (x *VStreamRequest) ProtoReflect() protoreflect.Message
func (*VStreamRequest) Reset ¶
func (x *VStreamRequest) Reset()
func (*VStreamRequest) SizeVT ¶ added in v0.11.0
func (m *VStreamRequest) SizeVT() (n int)
func (*VStreamRequest) String ¶
func (x *VStreamRequest) String() string
func (*VStreamRequest) UnmarshalVT ¶ added in v0.11.0
func (m *VStreamRequest) UnmarshalVT(dAtA []byte) error
type VStreamResponse ¶
type VStreamResponse struct { Events []*binlogdata.VEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"` // contains filtered or unexported fields }
VStreamResponse is streamed by VStream.
func (*VStreamResponse) Descriptor
deprecated
func (*VStreamResponse) Descriptor() ([]byte, []int)
Deprecated: Use VStreamResponse.ProtoReflect.Descriptor instead.
func (*VStreamResponse) GetEvents ¶
func (x *VStreamResponse) GetEvents() []*binlogdata.VEvent
func (*VStreamResponse) MarshalToSizedBufferVT ¶ added in v0.11.0
func (m *VStreamResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
func (*VStreamResponse) MarshalToVT ¶ added in v0.11.0
func (m *VStreamResponse) MarshalToVT(dAtA []byte) (int, error)
func (*VStreamResponse) MarshalVT ¶ added in v0.11.0
func (m *VStreamResponse) MarshalVT() (dAtA []byte, err error)
func (*VStreamResponse) ProtoMessage ¶
func (*VStreamResponse) ProtoMessage()
func (*VStreamResponse) ProtoReflect ¶ added in v0.11.0
func (x *VStreamResponse) ProtoReflect() protoreflect.Message
func (*VStreamResponse) Reset ¶
func (x *VStreamResponse) Reset()
func (*VStreamResponse) SizeVT ¶ added in v0.11.0
func (m *VStreamResponse) SizeVT() (n int)
func (*VStreamResponse) String ¶
func (x *VStreamResponse) String() string
func (*VStreamResponse) UnmarshalVT ¶ added in v0.11.0
func (m *VStreamResponse) UnmarshalVT(dAtA []byte) error