vtgate

package
v0.21.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 29, 2024 License: Apache-2.0 Imports: 14 Imported by: 31

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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.

View Source 
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.

View Source 
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) CloneMessageVT added in v0.18.0 

func (m *CloseSessionRequest) CloneMessageVT() proto.Message

func (*CloseSessionRequest) CloneVT added in v0.18.0 

func (m *CloseSessionRequest) CloneVT() *CloseSessionRequest

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) CloneMessageVT added in v0.18.0 

func (m *CloseSessionResponse) CloneMessageVT() proto.Message

func (*CloseSessionResponse) CloneVT added in v0.18.0 

func (m *CloseSessionResponse) CloneVT() *CloseSessionResponse

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) CloneMessageVT added in v0.18.0 

func (m *ExecuteBatchRequest) CloneMessageVT() proto.Message

func (*ExecuteBatchRequest) CloneVT added in v0.18.0 

func (m *ExecuteBatchRequest) CloneVT() *ExecuteBatchRequest

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) CloneMessageVT added in v0.18.0 

func (m *ExecuteBatchResponse) CloneMessageVT() proto.Message

func (*ExecuteBatchResponse) CloneVT added in v0.18.0 

func (m *ExecuteBatchResponse) CloneVT() *ExecuteBatchResponse

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) CloneMessageVT added in v0.18.0 

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

func (*ExecuteRequest) CloneVT added in v0.18.0 

func (m *ExecuteRequest) CloneVT() *ExecuteRequest

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) CloneMessageVT added in v0.18.0 

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

func (*ExecuteResponse) CloneVT added in v0.18.0 

func (m *ExecuteResponse) CloneVT() *ExecuteResponse

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 PrepareData added in v0.17.0 

type PrepareData struct {
	PrepareStatement string `protobuf:"bytes,1,opt,name=prepare_statement,json=prepareStatement,proto3" json:"prepare_statement,omitempty"`
	ParamsCount      int32  `protobuf:"varint,2,opt,name=params_count,json=paramsCount,proto3" json:"params_count,omitempty"`
	// contains filtered or unexported fields
}

PrepareData keeps the prepared statement and other information related for execution of it.

func (*PrepareData) CloneMessageVT added in v0.18.0 

func (m *PrepareData) CloneMessageVT() proto.Message

func (*PrepareData) CloneVT added in v0.18.0 

func (m *PrepareData) CloneVT() *PrepareData

func (*PrepareData) Descriptor deprecated added in v0.17.0 

func (*PrepareData) Descriptor() ([]byte, []int)

Deprecated: Use PrepareData.ProtoReflect.Descriptor instead.

func (*PrepareData) GetParamsCount added in v0.17.0 

func (x *PrepareData) GetParamsCount() int32

func (*PrepareData) GetPrepareStatement added in v0.17.0 

func (x *PrepareData) GetPrepareStatement() string

func (*PrepareData) MarshalToSizedBufferVT added in v0.17.0 

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

func (*PrepareData) MarshalToVT added in v0.17.0 

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

func (*PrepareData) MarshalVT added in v0.17.0 

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

func (*PrepareData) ProtoMessage added in v0.17.0 

func (*PrepareData) ProtoMessage()

func (*PrepareData) ProtoReflect added in v0.17.0 

func (x *PrepareData) ProtoReflect() protoreflect.Message

func (*PrepareData) Reset added in v0.17.0 

func (x *PrepareData) Reset()

func (*PrepareData) SizeVT added in v0.17.0 

func (m *PrepareData) SizeVT() (n int)

func (*PrepareData) String added in v0.17.0 

func (x *PrepareData) String() string

func (*PrepareData) UnmarshalVT added in v0.17.0 

func (m *PrepareData) 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) CloneMessageVT added in v0.18.0 

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

func (*PrepareRequest) CloneVT added in v0.18.0 

func (m *PrepareRequest) CloneVT() *PrepareRequest

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) CloneMessageVT added in v0.18.0 

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

func (*PrepareResponse) CloneVT added in v0.18.0 

func (m *PrepareResponse) CloneVT() *PrepareResponse

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) CloneMessageVT added in v0.18.0 

func (m *ReadAfterWrite) CloneMessageVT() proto.Message

func (*ReadAfterWrite) CloneVT added in v0.18.0 

func (m *ReadAfterWrite) CloneVT() *ReadAfterWrite

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) CloneMessageVT added in v0.18.0 

func (m *ResolveTransactionRequest) CloneMessageVT() proto.Message

func (*ResolveTransactionRequest) CloneVT added in v0.18.0 

func (m *ResolveTransactionRequest) CloneVT() *ResolveTransactionRequest

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) CloneMessageVT added in v0.18.0 

func (m *ResolveTransactionResponse) CloneMessageVT() proto.Message

func (*ResolveTransactionResponse) CloneVT added in v0.18.0 

func (m *ResolveTransactionResponse) CloneVT() *ResolveTransactionResponse

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 */
	// query_timeout is the maximum amount of time a query is permitted to run
	QueryTimeout     int64                   `protobuf:"varint,25,opt,name=query_timeout,json=queryTimeout,proto3" json:"query_timeout,omitempty"`
	PrepareStatement map[string]*PrepareData `` /* 198-byte string literal not displayed */
	// MigrationContext
	MigrationContext string `protobuf:"bytes,27,opt,name=migration_context,json=migrationContext,proto3" json:"migration_context,omitempty"`
	// 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) CloneMessageVT added in v0.18.0 

func (m *Session) CloneMessageVT() proto.Message

func (*Session) CloneVT added in v0.18.0 

func (m *Session) CloneVT() *Session

func (*Session) Descriptor deprecated 

func (*Session) Descriptor() ([]byte, []int)

Deprecated: Use Session.ProtoReflect.Descriptor instead.

func (*Session) GetAdvisoryLock added in v0.14.0 

func (x *Session) GetAdvisoryLock() map[string]int64

func (*Session) GetAutocommit 

func (x *Session) GetAutocommit() bool

func (*Session) GetDDLStrategy added in v0.9.0 

func (x *Session) GetDDLStrategy() string

func (*Session) GetEnableSystemSettings added in v0.10.0 

func (x *Session) GetEnableSystemSettings() bool

func (*Session) GetFoundRows 

func (x *Session) GetFoundRows() uint64

func (*Session) GetInReservedConn 

func (x *Session) GetInReservedConn() bool

func (*Session) GetInTransaction 

func (x *Session) GetInTransaction() bool

func (*Session) GetLastInsertId 

func (x *Session) GetLastInsertId() uint64

func (*Session) GetLastLockHeartbeat added in v0.8.0 

func (x *Session) GetLastLockHeartbeat() int64

func (*Session) GetLockSession added in v0.8.0 

func (x *Session) GetLockSession() *Session_ShardSession

func (*Session) GetMigrationContext added in v0.18.0 

func (x *Session) GetMigrationContext() string

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) GetPrepareStatement added in v0.17.0 

func (x *Session) GetPrepareStatement() map[string]*PrepareData

func (*Session) GetQueryTimeout added in v0.16.0 

func (x *Session) GetQueryTimeout() int64

func (*Session) GetReadAfterWrite added in v0.9.0 

func (x *Session) GetReadAfterWrite() *ReadAfterWrite

func (*Session) GetRowCount 

func (x *Session) GetRowCount() int64

func (*Session) GetSavepoints 

func (x *Session) GetSavepoints() []string

func (*Session) GetSessionUUID added in v0.9.0 

func (x *Session) GetSessionUUID() string

func (*Session) GetShardSessions 

func (x *Session) GetShardSessions() []*Session_ShardSession

func (*Session) GetSystemVariables 

func (x *Session) GetSystemVariables() map[string]string

func (*Session) GetTargetString 

func (x *Session) GetTargetString() string

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 (m *Session) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Session) MarshalToVT added in v0.11.0 

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

func (*Session) MarshalVT added in v0.11.0 

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

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) ProtoReflect added in v0.11.0 

func (x *Session) ProtoReflect() protoreflect.Message

func (*Session) Reset 

func (x *Session) Reset()

func (*Session) SizeVT added in v0.11.0 

func (m *Session) SizeVT() (n int)

func (*Session) String 

func (x *Session) String() string

func (*Session) UnmarshalVT added in v0.11.0 

func (m *Session) UnmarshalVT(dAtA []byte) error

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) CloneMessageVT added in v0.18.0 

func (m *Session_ShardSession) CloneMessageVT() proto.Message

func (*Session_ShardSession) CloneVT added in v0.18.0 

func (m *Session_ShardSession) CloneVT() *Session_ShardSession

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) CloneMessageVT added in v0.18.0 

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

func (*StreamExecuteRequest) CloneVT added in v0.18.0 

func (m *StreamExecuteRequest) CloneVT() *StreamExecuteRequest

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"`
	// session is the updated session information.
	Session *Session `protobuf:"bytes,2,opt,name=session,proto3" json:"session,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) CloneMessageVT added in v0.18.0 

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

func (*StreamExecuteResponse) CloneVT added in v0.18.0 

func (m *StreamExecuteResponse) CloneVT() *StreamExecuteResponse

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) GetSession added in v0.17.0 

func (x *StreamExecuteResponse) GetSession() *Session

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"`
	CellPreference string `protobuf:"bytes,5,opt,name=cell_preference,json=cellPreference,proto3" json:"cell_preference,omitempty"`
	TabletOrder    string `protobuf:"bytes,6,opt,name=tablet_order,json=tabletOrder,proto3" json:"tablet_order,omitempty"`
	// When set, all new row events from the `heartbeat` table, for all shards, in the sidecardb will be streamed.
	StreamKeyspaceHeartbeats bool `` /* 136-byte string literal not displayed */
	// Include reshard journal events in the stream.
	IncludeReshardJournalEvents bool `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*VStreamFlags) CloneMessageVT added in v0.18.0 

func (m *VStreamFlags) CloneMessageVT() proto.Message

func (*VStreamFlags) CloneVT added in v0.18.0 

func (m *VStreamFlags) CloneVT() *VStreamFlags

func (*VStreamFlags) Descriptor deprecated added in v0.10.0 

func (*VStreamFlags) Descriptor() ([]byte, []int)

Deprecated: Use VStreamFlags.ProtoReflect.Descriptor instead.

func (*VStreamFlags) GetCellPreference added in v0.17.0 

func (x *VStreamFlags) GetCellPreference() string

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) GetIncludeReshardJournalEvents added in v0.21.0 

func (x *VStreamFlags) GetIncludeReshardJournalEvents() bool

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) GetStreamKeyspaceHeartbeats added in v0.21.0 

func (x *VStreamFlags) GetStreamKeyspaceHeartbeats() bool

func (*VStreamFlags) GetTabletOrder added in v0.17.0 

func (x *VStreamFlags) GetTabletOrder() string

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) CloneMessageVT added in v0.18.0 

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

func (*VStreamRequest) CloneVT added in v0.18.0 

func (m *VStreamRequest) CloneVT() *VStreamRequest

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) CloneMessageVT added in v0.18.0 

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

func (*VStreamResponse) CloneVT added in v0.18.0 

func (m *VStreamResponse) CloneVT() *VStreamResponse

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.