query

package
Version: v0.11.1 Latest Latest
Warning

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

Go to latest
Published: Sep 9, 2021 License: Apache-2.0 Imports: 11 Imported by: 88

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	MySqlFlag_name = map[int32]string{
		0:     "EMPTY",
		1:     "NOT_NULL_FLAG",
		2:     "PRI_KEY_FLAG",
		4:     "UNIQUE_KEY_FLAG",
		8:     "MULTIPLE_KEY_FLAG",
		16:    "BLOB_FLAG",
		32:    "UNSIGNED_FLAG",
		64:    "ZEROFILL_FLAG",
		128:   "BINARY_FLAG",
		256:   "ENUM_FLAG",
		512:   "AUTO_INCREMENT_FLAG",
		1024:  "TIMESTAMP_FLAG",
		2048:  "SET_FLAG",
		4096:  "NO_DEFAULT_VALUE_FLAG",
		8192:  "ON_UPDATE_NOW_FLAG",
		32768: "NUM_FLAG",
		16384: "PART_KEY_FLAG",

		65536:  "UNIQUE_FLAG",
		131072: "BINCMP_FLAG",
	}
	MySqlFlag_value = map[string]int32{
		"EMPTY":                 0,
		"NOT_NULL_FLAG":         1,
		"PRI_KEY_FLAG":          2,
		"UNIQUE_KEY_FLAG":       4,
		"MULTIPLE_KEY_FLAG":     8,
		"BLOB_FLAG":             16,
		"UNSIGNED_FLAG":         32,
		"ZEROFILL_FLAG":         64,
		"BINARY_FLAG":           128,
		"ENUM_FLAG":             256,
		"AUTO_INCREMENT_FLAG":   512,
		"TIMESTAMP_FLAG":        1024,
		"SET_FLAG":              2048,
		"NO_DEFAULT_VALUE_FLAG": 4096,
		"ON_UPDATE_NOW_FLAG":    8192,
		"NUM_FLAG":              32768,
		"PART_KEY_FLAG":         16384,
		"GROUP_FLAG":            32768,
		"UNIQUE_FLAG":           65536,
		"BINCMP_FLAG":           131072,
	}
)

Enum value maps for MySqlFlag.

View Source
var (
	Flag_name = map[int32]string{
		0:    "NONE",
		256:  "ISINTEGRAL",
		512:  "ISUNSIGNED",
		1024: "ISFLOAT",
		2048: "ISQUOTED",
		4096: "ISTEXT",
		8192: "ISBINARY",
	}
	Flag_value = map[string]int32{
		"NONE":       0,
		"ISINTEGRAL": 256,
		"ISUNSIGNED": 512,
		"ISFLOAT":    1024,
		"ISQUOTED":   2048,
		"ISTEXT":     4096,
		"ISBINARY":   8192,
	}
)

Enum value maps for Flag.

View Source
var (
	Type_name = map[int32]string{
		0:     "NULL_TYPE",
		257:   "INT8",
		770:   "UINT8",
		259:   "INT16",
		772:   "UINT16",
		261:   "INT24",
		774:   "UINT24",
		263:   "INT32",
		776:   "UINT32",
		265:   "INT64",
		778:   "UINT64",
		1035:  "FLOAT32",
		1036:  "FLOAT64",
		2061:  "TIMESTAMP",
		2062:  "DATE",
		2063:  "TIME",
		2064:  "DATETIME",
		785:   "YEAR",
		18:    "DECIMAL",
		6163:  "TEXT",
		10260: "BLOB",
		6165:  "VARCHAR",
		10262: "VARBINARY",
		6167:  "CHAR",
		10264: "BINARY",
		2073:  "BIT",
		2074:  "ENUM",
		2075:  "SET",
		28:    "TUPLE",
		2077:  "GEOMETRY",
		2078:  "JSON",
		31:    "EXPRESSION",
	}
	Type_value = map[string]int32{
		"NULL_TYPE":  0,
		"INT8":       257,
		"UINT8":      770,
		"INT16":      259,
		"UINT16":     772,
		"INT24":      261,
		"UINT24":     774,
		"INT32":      263,
		"UINT32":     776,
		"INT64":      265,
		"UINT64":     778,
		"FLOAT32":    1035,
		"FLOAT64":    1036,
		"TIMESTAMP":  2061,
		"DATE":       2062,
		"TIME":       2063,
		"DATETIME":   2064,
		"YEAR":       785,
		"DECIMAL":    18,
		"TEXT":       6163,
		"BLOB":       10260,
		"VARCHAR":    6165,
		"VARBINARY":  10262,
		"CHAR":       6167,
		"BINARY":     10264,
		"BIT":        2073,
		"ENUM":       2074,
		"SET":        2075,
		"TUPLE":      28,
		"GEOMETRY":   2077,
		"JSON":       2078,
		"EXPRESSION": 31,
	}
)

Enum value maps for Type.

View Source
var (
	TransactionState_name = map[int32]string{
		0: "UNKNOWN",
		1: "PREPARE",
		2: "COMMIT",
		3: "ROLLBACK",
	}
	TransactionState_value = map[string]int32{
		"UNKNOWN":  0,
		"PREPARE":  1,
		"COMMIT":   2,
		"ROLLBACK": 3,
	}
)

Enum value maps for TransactionState.

View Source
var (
	ExecuteOptions_IncludedFields_name = map[int32]string{
		0: "TYPE_AND_NAME",
		1: "TYPE_ONLY",
		2: "ALL",
	}
	ExecuteOptions_IncludedFields_value = map[string]int32{
		"TYPE_AND_NAME": 0,
		"TYPE_ONLY":     1,
		"ALL":           2,
	}
)

Enum value maps for ExecuteOptions_IncludedFields.

View Source
var (
	ExecuteOptions_Workload_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "OLTP",
		2: "OLAP",
		3: "DBA",
	}
	ExecuteOptions_Workload_value = map[string]int32{
		"UNSPECIFIED": 0,
		"OLTP":        1,
		"OLAP":        2,
		"DBA":         3,
	}
)

Enum value maps for ExecuteOptions_Workload.

View Source
var (
	ExecuteOptions_TransactionIsolation_name = map[int32]string{
		0: "DEFAULT",
		1: "REPEATABLE_READ",
		2: "READ_COMMITTED",
		3: "READ_UNCOMMITTED",
		4: "SERIALIZABLE",
		5: "CONSISTENT_SNAPSHOT_READ_ONLY",
		6: "AUTOCOMMIT",
	}
	ExecuteOptions_TransactionIsolation_value = map[string]int32{
		"DEFAULT":                       0,
		"REPEATABLE_READ":               1,
		"READ_COMMITTED":                2,
		"READ_UNCOMMITTED":              3,
		"SERIALIZABLE":                  4,
		"CONSISTENT_SNAPSHOT_READ_ONLY": 5,
		"AUTOCOMMIT":                    6,
	}
)

Enum value maps for ExecuteOptions_TransactionIsolation.

View Source
var (
	ExecuteOptions_PlannerVersion_name = map[int32]string{
		0: "DEFAULT_PLANNER",
		1: "V3",
		2: "Gen4",
		3: "Gen4Greedy",
		4: "Gen4Left2Right",
		5: "Gen4WithFallback",
	}
	ExecuteOptions_PlannerVersion_value = map[string]int32{
		"DEFAULT_PLANNER":  0,
		"V3":               1,
		"Gen4":             2,
		"Gen4Greedy":       3,
		"Gen4Left2Right":   4,
		"Gen4WithFallback": 5,
	}
)

Enum value maps for ExecuteOptions_PlannerVersion.

View Source
var (
	StreamEvent_Statement_Category_name = map[int32]string{
		0: "Error",
		1: "DML",
		2: "DDL",
	}
	StreamEvent_Statement_Category_value = map[string]int32{
		"Error": 0,
		"DML":   1,
		"DDL":   2,
	}
)

Enum value maps for StreamEvent_Statement_Category.

View Source
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source
var File_query_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AggregateStats

type AggregateStats struct {

	// healthy_tablet_count is the number of healthy tablets in the group.
	HealthyTabletCount int32 `protobuf:"varint,1,opt,name=healthy_tablet_count,json=healthyTabletCount,proto3" json:"healthy_tablet_count,omitempty"`
	// unhealthy_tablet_count is the number of unhealthy tablets in the group.
	UnhealthyTabletCount int32 `protobuf:"varint,2,opt,name=unhealthy_tablet_count,json=unhealthyTabletCount,proto3" json:"unhealthy_tablet_count,omitempty"`
	// seconds_behind_master_min is the minimum of the
	// seconds_behind_master values of the healthy tablets. It is unset
	// if the tablet type is master.
	SecondsBehindMasterMin uint32 `` /* 132-byte string literal not displayed */
	// seconds_behind_master_max is the maximum of the
	// seconds_behind_master values of the healthy tablets. It is unset
	// if the tablet type is master.
	SecondsBehindMasterMax uint32 `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

AggregateStats contains information about the health of a group of tablets for a Target. It is used to propagate stats from a vtgate to another, or from the Gateway layer of a vtgate to the routing layer.

func (*AggregateStats) Descriptor deprecated

This method has been deprecated.
func (*AggregateStats) Descriptor() ([]byte, []int)

Deprecated: Use AggregateStats.ProtoReflect.Descriptor instead.

func (*AggregateStats) GetHealthyTabletCount

func (x *AggregateStats) GetHealthyTabletCount() int32

func (*AggregateStats) GetSecondsBehindMasterMax

func (x *AggregateStats) GetSecondsBehindMasterMax() uint32

func (*AggregateStats) GetSecondsBehindMasterMin

func (x *AggregateStats) GetSecondsBehindMasterMin() uint32

func (*AggregateStats) GetUnhealthyTabletCount

func (x *AggregateStats) GetUnhealthyTabletCount() int32

func (*AggregateStats) MarshalToSizedBufferVT added in v0.11.0

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

func (*AggregateStats) MarshalToVT added in v0.11.0

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

func (*AggregateStats) MarshalVT added in v0.11.0

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

func (*AggregateStats) ProtoMessage

func (*AggregateStats) ProtoMessage()

func (*AggregateStats) ProtoReflect added in v0.11.0

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

func (*AggregateStats) Reset

func (x *AggregateStats) Reset()

func (*AggregateStats) SizeVT added in v0.11.0

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

func (*AggregateStats) String

func (x *AggregateStats) String() string

func (*AggregateStats) UnmarshalVT added in v0.11.0

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

type BeginExecuteBatchRequest

type BeginExecuteBatchRequest struct {
	EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
	ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
	Target            *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	Queries           []*BoundQuery   `protobuf:"bytes,4,rep,name=queries,proto3" json:"queries,omitempty"`
	AsTransaction     bool            `protobuf:"varint,5,opt,name=as_transaction,json=asTransaction,proto3" json:"as_transaction,omitempty"`
	Options           *ExecuteOptions `protobuf:"bytes,6,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

BeginExecuteBatchRequest is the payload to BeginExecuteBatch

func (*BeginExecuteBatchRequest) Descriptor deprecated

This method has been deprecated.
func (*BeginExecuteBatchRequest) Descriptor() ([]byte, []int)

Deprecated: Use BeginExecuteBatchRequest.ProtoReflect.Descriptor instead.

func (*BeginExecuteBatchRequest) GetAsTransaction

func (x *BeginExecuteBatchRequest) GetAsTransaction() bool

func (*BeginExecuteBatchRequest) GetEffectiveCallerId

func (x *BeginExecuteBatchRequest) GetEffectiveCallerId() *vtrpc.CallerID

func (*BeginExecuteBatchRequest) GetImmediateCallerId

func (x *BeginExecuteBatchRequest) GetImmediateCallerId() *VTGateCallerID

func (*BeginExecuteBatchRequest) GetOptions

func (x *BeginExecuteBatchRequest) GetOptions() *ExecuteOptions

func (*BeginExecuteBatchRequest) GetQueries

func (x *BeginExecuteBatchRequest) GetQueries() []*BoundQuery

func (*BeginExecuteBatchRequest) GetTarget

func (x *BeginExecuteBatchRequest) GetTarget() *Target

func (*BeginExecuteBatchRequest) MarshalToSizedBufferVT added in v0.11.0

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

func (*BeginExecuteBatchRequest) MarshalToVT added in v0.11.0

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

func (*BeginExecuteBatchRequest) MarshalVT added in v0.11.0

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

func (*BeginExecuteBatchRequest) ProtoMessage

func (*BeginExecuteBatchRequest) ProtoMessage()

func (*BeginExecuteBatchRequest) ProtoReflect added in v0.11.0

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

func (*BeginExecuteBatchRequest) Reset

func (x *BeginExecuteBatchRequest) Reset()

func (*BeginExecuteBatchRequest) SizeVT added in v0.11.0

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

func (*BeginExecuteBatchRequest) String

func (x *BeginExecuteBatchRequest) String() string

func (*BeginExecuteBatchRequest) UnmarshalVT added in v0.11.0

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

type BeginExecuteBatchResponse

type BeginExecuteBatchResponse struct {

	// error contains an application level error if necessary. Note the
	// transaction_id may be set, even when an error is returned, if the begin
	// worked but the execute failed.
	Error   *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Results []*QueryResult  `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"`
	// transaction_id might be non-zero even if an error is present.
	TransactionId int64                 `protobuf:"varint,3,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	TabletAlias   *topodata.TabletAlias `protobuf:"bytes,4,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	// contains filtered or unexported fields
}

BeginExecuteBatchResponse is the returned value from BeginExecuteBatch

func (*BeginExecuteBatchResponse) Descriptor deprecated

This method has been deprecated.
func (*BeginExecuteBatchResponse) Descriptor() ([]byte, []int)

Deprecated: Use BeginExecuteBatchResponse.ProtoReflect.Descriptor instead.

func (*BeginExecuteBatchResponse) GetError

func (x *BeginExecuteBatchResponse) GetError() *vtrpc.RPCError

func (*BeginExecuteBatchResponse) GetResults

func (x *BeginExecuteBatchResponse) GetResults() []*QueryResult

func (*BeginExecuteBatchResponse) GetTabletAlias

func (x *BeginExecuteBatchResponse) GetTabletAlias() *topodata.TabletAlias

func (*BeginExecuteBatchResponse) GetTransactionId

func (x *BeginExecuteBatchResponse) GetTransactionId() int64

func (*BeginExecuteBatchResponse) MarshalToSizedBufferVT added in v0.11.0

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

func (*BeginExecuteBatchResponse) MarshalToVT added in v0.11.0

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

func (*BeginExecuteBatchResponse) MarshalVT added in v0.11.0

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

func (*BeginExecuteBatchResponse) ProtoMessage

func (*BeginExecuteBatchResponse) ProtoMessage()

func (*BeginExecuteBatchResponse) ProtoReflect added in v0.11.0

func (*BeginExecuteBatchResponse) Reset

func (x *BeginExecuteBatchResponse) Reset()

func (*BeginExecuteBatchResponse) SizeVT added in v0.11.0

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

func (*BeginExecuteBatchResponse) String

func (x *BeginExecuteBatchResponse) String() string

func (*BeginExecuteBatchResponse) UnmarshalVT added in v0.11.0

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

type BeginExecuteRequest

type BeginExecuteRequest struct {
	EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
	ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
	Target            *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	Query             *BoundQuery     `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
	Options           *ExecuteOptions `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"`
	ReservedId        int64           `protobuf:"varint,6,opt,name=reserved_id,json=reservedId,proto3" json:"reserved_id,omitempty"`
	PreQueries        []string        `protobuf:"bytes,7,rep,name=pre_queries,json=preQueries,proto3" json:"pre_queries,omitempty"`
	// contains filtered or unexported fields
}

BeginExecuteRequest is the payload to BeginExecute

func (*BeginExecuteRequest) Descriptor deprecated

This method has been deprecated.
func (*BeginExecuteRequest) Descriptor() ([]byte, []int)

Deprecated: Use BeginExecuteRequest.ProtoReflect.Descriptor instead.

func (*BeginExecuteRequest) GetEffectiveCallerId

func (x *BeginExecuteRequest) GetEffectiveCallerId() *vtrpc.CallerID

func (*BeginExecuteRequest) GetImmediateCallerId

func (x *BeginExecuteRequest) GetImmediateCallerId() *VTGateCallerID

func (*BeginExecuteRequest) GetOptions

func (x *BeginExecuteRequest) GetOptions() *ExecuteOptions

func (*BeginExecuteRequest) GetPreQueries

func (x *BeginExecuteRequest) GetPreQueries() []string

func (*BeginExecuteRequest) GetQuery

func (x *BeginExecuteRequest) GetQuery() *BoundQuery

func (*BeginExecuteRequest) GetReservedId

func (x *BeginExecuteRequest) GetReservedId() int64

func (*BeginExecuteRequest) GetTarget

func (x *BeginExecuteRequest) GetTarget() *Target

func (*BeginExecuteRequest) MarshalToSizedBufferVT added in v0.11.0

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

func (*BeginExecuteRequest) MarshalToVT added in v0.11.0

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

func (*BeginExecuteRequest) MarshalVT added in v0.11.0

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

func (*BeginExecuteRequest) ProtoMessage

func (*BeginExecuteRequest) ProtoMessage()

func (*BeginExecuteRequest) ProtoReflect added in v0.11.0

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

func (*BeginExecuteRequest) Reset

func (x *BeginExecuteRequest) Reset()

func (*BeginExecuteRequest) SizeVT added in v0.11.0

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

func (*BeginExecuteRequest) String

func (x *BeginExecuteRequest) String() string

func (*BeginExecuteRequest) UnmarshalVT added in v0.11.0

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

type BeginExecuteResponse

type BeginExecuteResponse struct {

	// error contains an application level error if necessary. Note the
	// transaction_id may be set, even when an error is returned, if the begin
	// worked but the execute failed.
	Error  *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Result *QueryResult    `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// transaction_id might be non-zero even if an error is present.
	TransactionId int64                 `protobuf:"varint,3,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	TabletAlias   *topodata.TabletAlias `protobuf:"bytes,4,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	// contains filtered or unexported fields
}

BeginExecuteResponse is the returned value from BeginExecute

func (*BeginExecuteResponse) Descriptor deprecated

This method has been deprecated.
func (*BeginExecuteResponse) Descriptor() ([]byte, []int)

Deprecated: Use BeginExecuteResponse.ProtoReflect.Descriptor instead.

func (*BeginExecuteResponse) GetError

func (x *BeginExecuteResponse) GetError() *vtrpc.RPCError

func (*BeginExecuteResponse) GetResult

func (x *BeginExecuteResponse) GetResult() *QueryResult

func (*BeginExecuteResponse) GetTabletAlias

func (x *BeginExecuteResponse) GetTabletAlias() *topodata.TabletAlias

func (*BeginExecuteResponse) GetTransactionId

func (x *BeginExecuteResponse) GetTransactionId() int64

func (*BeginExecuteResponse) MarshalToSizedBufferVT added in v0.11.0

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

func (*BeginExecuteResponse) MarshalToVT added in v0.11.0

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

func (*BeginExecuteResponse) MarshalVT added in v0.11.0

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

func (*BeginExecuteResponse) ProtoMessage

func (*BeginExecuteResponse) ProtoMessage()

func (*BeginExecuteResponse) ProtoReflect added in v0.11.0

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

func (*BeginExecuteResponse) Reset

func (x *BeginExecuteResponse) Reset()

func (*BeginExecuteResponse) SizeVT added in v0.11.0

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

func (*BeginExecuteResponse) String

func (x *BeginExecuteResponse) String() string

func (*BeginExecuteResponse) UnmarshalVT added in v0.11.0

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

type BeginRequest

type BeginRequest struct {
	EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
	ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
	Target            *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	Options           *ExecuteOptions `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

BeginRequest is the payload to Begin

func (*BeginRequest) Descriptor deprecated

This method has been deprecated.
func (*BeginRequest) Descriptor() ([]byte, []int)

Deprecated: Use BeginRequest.ProtoReflect.Descriptor instead.

func (*BeginRequest) GetEffectiveCallerId

func (x *BeginRequest) GetEffectiveCallerId() *vtrpc.CallerID

func (*BeginRequest) GetImmediateCallerId

func (x *BeginRequest) GetImmediateCallerId() *VTGateCallerID

func (*BeginRequest) GetOptions

func (x *BeginRequest) GetOptions() *ExecuteOptions

func (*BeginRequest) GetTarget

func (x *BeginRequest) GetTarget() *Target

func (*BeginRequest) MarshalToSizedBufferVT added in v0.11.0

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

func (*BeginRequest) MarshalToVT added in v0.11.0

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

func (*BeginRequest) MarshalVT added in v0.11.0

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

func (*BeginRequest) ProtoMessage

func (*BeginRequest) ProtoMessage()

func (*BeginRequest) ProtoReflect added in v0.11.0

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

func (*BeginRequest) Reset

func (x *BeginRequest) Reset()

func (*BeginRequest) SizeVT added in v0.11.0

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

func (*BeginRequest) String

func (x *BeginRequest) String() string

func (*BeginRequest) UnmarshalVT added in v0.11.0

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

type BeginResponse

type BeginResponse struct {
	TransactionId int64                 `protobuf:"varint,1,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	TabletAlias   *topodata.TabletAlias `protobuf:"bytes,2,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	// contains filtered or unexported fields
}

BeginResponse is the returned value from Begin

func (*BeginResponse) Descriptor deprecated

This method has been deprecated.
func (*BeginResponse) Descriptor() ([]byte, []int)

Deprecated: Use BeginResponse.ProtoReflect.Descriptor instead.

func (*BeginResponse) GetTabletAlias

func (x *BeginResponse) GetTabletAlias() *topodata.TabletAlias

func (*BeginResponse) GetTransactionId

func (x *BeginResponse) GetTransactionId() int64

func (*BeginResponse) MarshalToSizedBufferVT added in v0.11.0

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

func (*BeginResponse) MarshalToVT added in v0.11.0

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

func (*BeginResponse) MarshalVT added in v0.11.0

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

func (*BeginResponse) ProtoMessage

func (*BeginResponse) ProtoMessage()

func (*BeginResponse) ProtoReflect added in v0.11.0

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

func (*BeginResponse) Reset

func (x *BeginResponse) Reset()

func (*BeginResponse) SizeVT added in v0.11.0

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

func (*BeginResponse) String

func (x *BeginResponse) String() string

func (*BeginResponse) UnmarshalVT added in v0.11.0

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

type BindVariable

type BindVariable struct {
	Type  Type   `protobuf:"varint,1,opt,name=type,proto3,enum=query.Type" json:"type,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// values are set if type is TUPLE.
	Values []*Value `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

BindVariable represents a single bind variable in a Query.

func (*BindVariable) CachedSize added in v0.10.0

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

func (*BindVariable) Descriptor deprecated

This method has been deprecated.
func (*BindVariable) Descriptor() ([]byte, []int)

Deprecated: Use BindVariable.ProtoReflect.Descriptor instead.

func (*BindVariable) GetType

func (x *BindVariable) GetType() Type

func (*BindVariable) GetValue

func (x *BindVariable) GetValue() []byte

func (*BindVariable) GetValues

func (x *BindVariable) GetValues() []*Value

func (*BindVariable) MarshalToSizedBufferVT added in v0.11.0

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

func (*BindVariable) MarshalToVT added in v0.11.0

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

func (*BindVariable) MarshalVT added in v0.11.0

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

func (*BindVariable) ProtoMessage

func (*BindVariable) ProtoMessage()

func (*BindVariable) ProtoReflect added in v0.11.0

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

func (*BindVariable) Reset

func (x *BindVariable) Reset()

func (*BindVariable) SizeVT added in v0.11.0

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

func (*BindVariable) String

func (x *BindVariable) String() string

func (*BindVariable) UnmarshalVT added in v0.11.0

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

type BoundQuery

type BoundQuery struct {

	// sql is the SQL query to execute
	Sql string `protobuf:"bytes,1,opt,name=sql,proto3" json:"sql,omitempty"`
	// bind_variables is a map of all bind variables to expand in the query.
	// nil values are not allowed. Use NULL_TYPE to express a NULL value.
	BindVariables map[string]*BindVariable `` /* 188-byte string literal not displayed */
	// contains filtered or unexported fields
}

BoundQuery is a query with its bind variables

func (*BoundQuery) Descriptor deprecated

This method has been deprecated.
func (*BoundQuery) Descriptor() ([]byte, []int)

Deprecated: Use BoundQuery.ProtoReflect.Descriptor instead.

func (*BoundQuery) GetBindVariables

func (x *BoundQuery) GetBindVariables() map[string]*BindVariable

func (*BoundQuery) GetSql

func (x *BoundQuery) GetSql() string

func (*BoundQuery) MarshalToSizedBufferVT added in v0.11.0

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

func (*BoundQuery) MarshalToVT added in v0.11.0

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

func (*BoundQuery) MarshalVT added in v0.11.0

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

func (*BoundQuery) ProtoMessage

func (*BoundQuery) ProtoMessage()

func (*BoundQuery) ProtoReflect added in v0.11.0

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

func (*BoundQuery) Reset

func (x *BoundQuery) Reset()

func (*BoundQuery) SizeVT added in v0.11.0

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

func (*BoundQuery) String

func (x *BoundQuery) String() string

func (*BoundQuery) UnmarshalVT added in v0.11.0

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

type CommitPreparedRequest

type CommitPreparedRequest struct {
	EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
	ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
	Target            *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	Dtid              string          `protobuf:"bytes,4,opt,name=dtid,proto3" json:"dtid,omitempty"`
	// contains filtered or unexported fields
}

CommitPreparedRequest is the payload to CommitPrepared

func (*CommitPreparedRequest) Descriptor deprecated

This method has been deprecated.
func (*CommitPreparedRequest) Descriptor() ([]byte, []int)

Deprecated: Use CommitPreparedRequest.ProtoReflect.Descriptor instead.

func (*CommitPreparedRequest) GetDtid

func (x *CommitPreparedRequest) GetDtid() string

func (*CommitPreparedRequest) GetEffectiveCallerId

func (x *CommitPreparedRequest) GetEffectiveCallerId() *vtrpc.CallerID

func (*CommitPreparedRequest) GetImmediateCallerId

func (x *CommitPreparedRequest) GetImmediateCallerId() *VTGateCallerID

func (*CommitPreparedRequest) GetTarget

func (x *CommitPreparedRequest) GetTarget() *Target

func (*CommitPreparedRequest) MarshalToSizedBufferVT added in v0.11.0

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

func (*CommitPreparedRequest) MarshalToVT added in v0.11.0

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

func (*CommitPreparedRequest) MarshalVT added in v0.11.0

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

func (*CommitPreparedRequest) ProtoMessage

func (*CommitPreparedRequest) ProtoMessage()

func (*CommitPreparedRequest) ProtoReflect added in v0.11.0

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

func (*CommitPreparedRequest) Reset

func (x *CommitPreparedRequest) Reset()

func (*CommitPreparedRequest) SizeVT added in v0.11.0

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

func (*CommitPreparedRequest) String

func (x *CommitPreparedRequest) String() string

func (*CommitPreparedRequest) UnmarshalVT added in v0.11.0

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

type CommitPreparedResponse

type CommitPreparedResponse struct {
	// contains filtered or unexported fields
}

CommitPreparedResponse is the returned value from CommitPrepared

func (*CommitPreparedResponse) Descriptor deprecated

This method has been deprecated.
func (*CommitPreparedResponse) Descriptor() ([]byte, []int)

Deprecated: Use CommitPreparedResponse.ProtoReflect.Descriptor instead.

func (*CommitPreparedResponse) MarshalToSizedBufferVT added in v0.11.0

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

func (*CommitPreparedResponse) MarshalToVT added in v0.11.0

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

func (*CommitPreparedResponse) MarshalVT added in v0.11.0

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

func (*CommitPreparedResponse) ProtoMessage

func (*CommitPreparedResponse) ProtoMessage()

func (*CommitPreparedResponse) ProtoReflect added in v0.11.0

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

func (*CommitPreparedResponse) Reset

func (x *CommitPreparedResponse) Reset()

func (*CommitPreparedResponse) SizeVT added in v0.11.0

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

func (*CommitPreparedResponse) String

func (x *CommitPreparedResponse) String() string

func (*CommitPreparedResponse) UnmarshalVT added in v0.11.0

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

type CommitRequest

type CommitRequest struct {
	EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
	ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
	Target            *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	TransactionId     int64           `protobuf:"varint,4,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	// contains filtered or unexported fields
}

CommitRequest is the payload to Commit

func (*CommitRequest) Descriptor deprecated

This method has been deprecated.
func (*CommitRequest) Descriptor() ([]byte, []int)

Deprecated: Use CommitRequest.ProtoReflect.Descriptor instead.

func (*CommitRequest) GetEffectiveCallerId

func (x *CommitRequest) GetEffectiveCallerId() *vtrpc.CallerID

func (*CommitRequest) GetImmediateCallerId

func (x *CommitRequest) GetImmediateCallerId() *VTGateCallerID

func (*CommitRequest) GetTarget

func (x *CommitRequest) GetTarget() *Target

func (*CommitRequest) GetTransactionId

func (x *CommitRequest) GetTransactionId() int64

func (*CommitRequest) MarshalToSizedBufferVT added in v0.11.0

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

func (*CommitRequest) MarshalToVT added in v0.11.0

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

func (*CommitRequest) MarshalVT added in v0.11.0

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

func (*CommitRequest) ProtoMessage

func (*CommitRequest) ProtoMessage()

func (*CommitRequest) ProtoReflect added in v0.11.0

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

func (*CommitRequest) Reset

func (x *CommitRequest) Reset()

func (*CommitRequest) SizeVT added in v0.11.0

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

func (*CommitRequest) String

func (x *CommitRequest) String() string

func (*CommitRequest) UnmarshalVT added in v0.11.0

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

type CommitResponse

type CommitResponse struct {
	ReservedId int64 `protobuf:"varint,1,opt,name=reserved_id,json=reservedId,proto3" json:"reserved_id,omitempty"`
	// contains filtered or unexported fields
}

CommitResponse is the returned value from Commit

func (*CommitResponse) Descriptor deprecated

This method has been deprecated.
func (*CommitResponse) Descriptor() ([]byte, []int)

Deprecated: Use CommitResponse.ProtoReflect.Descriptor instead.

func (*CommitResponse) GetReservedId

func (x *CommitResponse) GetReservedId() int64

func (*CommitResponse) MarshalToSizedBufferVT added in v0.11.0

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

func (*CommitResponse) MarshalToVT added in v0.11.0

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

func (*CommitResponse) MarshalVT added in v0.11.0

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

func (*CommitResponse) ProtoMessage

func (*CommitResponse) ProtoMessage()

func (*CommitResponse) ProtoReflect added in v0.11.0

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

func (*CommitResponse) Reset

func (x *CommitResponse) Reset()

func (*CommitResponse) SizeVT added in v0.11.0

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

func (*CommitResponse) String

func (x *CommitResponse) String() string

func (*CommitResponse) UnmarshalVT added in v0.11.0

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

type ConcludeTransactionRequest

type ConcludeTransactionRequest struct {
	EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
	ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
	Target            *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	Dtid              string          `protobuf:"bytes,4,opt,name=dtid,proto3" json:"dtid,omitempty"`
	// contains filtered or unexported fields
}

ConcludeTransactionRequest is the payload to ConcludeTransaction

func (*ConcludeTransactionRequest) Descriptor deprecated

This method has been deprecated.
func (*ConcludeTransactionRequest) Descriptor() ([]byte, []int)

Deprecated: Use ConcludeTransactionRequest.ProtoReflect.Descriptor instead.

func (*ConcludeTransactionRequest) GetDtid

func (x *ConcludeTransactionRequest) GetDtid() string

func (*ConcludeTransactionRequest) GetEffectiveCallerId

func (x *ConcludeTransactionRequest) GetEffectiveCallerId() *vtrpc.CallerID

func (*ConcludeTransactionRequest) GetImmediateCallerId

func (x *ConcludeTransactionRequest) GetImmediateCallerId() *VTGateCallerID

func (*ConcludeTransactionRequest) GetTarget

func (x *ConcludeTransactionRequest) GetTarget() *Target

func (*ConcludeTransactionRequest) MarshalToSizedBufferVT added in v0.11.0

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

func (*ConcludeTransactionRequest) MarshalToVT added in v0.11.0

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

func (*ConcludeTransactionRequest) MarshalVT added in v0.11.0

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

func (*ConcludeTransactionRequest) ProtoMessage

func (*ConcludeTransactionRequest) ProtoMessage()

func (*ConcludeTransactionRequest) ProtoReflect added in v0.11.0

func (*ConcludeTransactionRequest) Reset

func (x *ConcludeTransactionRequest) Reset()

func (*ConcludeTransactionRequest) SizeVT added in v0.11.0

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

func (*ConcludeTransactionRequest) String

func (x *ConcludeTransactionRequest) String() string

func (*ConcludeTransactionRequest) UnmarshalVT added in v0.11.0

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

type ConcludeTransactionResponse

type ConcludeTransactionResponse struct {
	// contains filtered or unexported fields
}

ConcludeTransactionResponse is the returned value from ConcludeTransaction

func (*ConcludeTransactionResponse) Descriptor deprecated

This method has been deprecated.
func (*ConcludeTransactionResponse) Descriptor() ([]byte, []int)

Deprecated: Use ConcludeTransactionResponse.ProtoReflect.Descriptor instead.

func (*ConcludeTransactionResponse) MarshalToSizedBufferVT added in v0.11.0

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

func (*ConcludeTransactionResponse) MarshalToVT added in v0.11.0

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

func (*ConcludeTransactionResponse) MarshalVT added in v0.11.0

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

func (*ConcludeTransactionResponse) ProtoMessage

func (*ConcludeTransactionResponse) ProtoMessage()

func (*ConcludeTransactionResponse) ProtoReflect added in v0.11.0

func (*ConcludeTransactionResponse) Reset

func (x *ConcludeTransactionResponse) Reset()

func (*ConcludeTransactionResponse) SizeVT added in v0.11.0

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

func (*ConcludeTransactionResponse) String

func (x *ConcludeTransactionResponse) String() string

func (*ConcludeTransactionResponse) UnmarshalVT added in v0.11.0

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

type CreateTransactionRequest

type CreateTransactionRequest struct {
	EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
	ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
	Target            *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	Dtid              string          `protobuf:"bytes,4,opt,name=dtid,proto3" json:"dtid,omitempty"`
	Participants      []*Target       `protobuf:"bytes,5,rep,name=participants,proto3" json:"participants,omitempty"`
	// contains filtered or unexported fields
}

CreateTransactionRequest is the payload to CreateTransaction

func (*CreateTransactionRequest) Descriptor deprecated

This method has been deprecated.
func (*CreateTransactionRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateTransactionRequest.ProtoReflect.Descriptor instead.

func (*CreateTransactionRequest) GetDtid

func (x *CreateTransactionRequest) GetDtid() string

func (*CreateTransactionRequest) GetEffectiveCallerId

func (x *CreateTransactionRequest) GetEffectiveCallerId() *vtrpc.CallerID

func (*CreateTransactionRequest) GetImmediateCallerId

func (x *CreateTransactionRequest) GetImmediateCallerId() *VTGateCallerID

func (*CreateTransactionRequest) GetParticipants

func (x *CreateTransactionRequest) GetParticipants() []*Target

func (*CreateTransactionRequest) GetTarget

func (x *CreateTransactionRequest) GetTarget() *Target

func (*CreateTransactionRequest) MarshalToSizedBufferVT added in v0.11.0

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

func (*CreateTransactionRequest) MarshalToVT added in v0.11.0

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

func (*CreateTransactionRequest) MarshalVT added in v0.11.0

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

func (*CreateTransactionRequest) ProtoMessage

func (*CreateTransactionRequest) ProtoMessage()

func (*CreateTransactionRequest) ProtoReflect added in v0.11.0

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

func (*CreateTransactionRequest) Reset

func (x *CreateTransactionRequest) Reset()

func (*CreateTransactionRequest) SizeVT added in v0.11.0

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

func (*CreateTransactionRequest) String

func (x *CreateTransactionRequest) String() string

func (*CreateTransactionRequest) UnmarshalVT added in v0.11.0

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

type CreateTransactionResponse

type CreateTransactionResponse struct {
	// contains filtered or unexported fields
}

CreateTransactionResponse is the returned value from CreateTransaction

func (*CreateTransactionResponse) Descriptor deprecated

This method has been deprecated.
func (*CreateTransactionResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateTransactionResponse.ProtoReflect.Descriptor instead.

func (*CreateTransactionResponse) MarshalToSizedBufferVT added in v0.11.0

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

func (*CreateTransactionResponse) MarshalToVT added in v0.11.0

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

func (*CreateTransactionResponse) MarshalVT added in v0.11.0

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

func (*CreateTransactionResponse) ProtoMessage

func (*CreateTransactionResponse) ProtoMessage()

func (*CreateTransactionResponse) ProtoReflect added in v0.11.0

func (*CreateTransactionResponse) Reset

func (x *CreateTransactionResponse) Reset()

func (*CreateTransactionResponse) SizeVT added in v0.11.0

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

func (*CreateTransactionResponse) String

func (x *CreateTransactionResponse) String() string

func (*CreateTransactionResponse) UnmarshalVT added in v0.11.0

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

type EventToken

type EventToken struct {

	// timestamp is the MySQL timestamp of the statements. Seconds since Epoch.
	Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// The shard name that applied the statements. Note this is not set when
	// streaming from a vttablet. It is only used on the client -> vtgate link.
	Shard string `protobuf:"bytes,2,opt,name=shard,proto3" json:"shard,omitempty"`
	// The position on the replication stream after this statement was applied.
	// It is not the transaction ID / GTID, but the position / GTIDSet.
	Position string `protobuf:"bytes,3,opt,name=position,proto3" json:"position,omitempty"`
	// contains filtered or unexported fields
}

EventToken is a structure that describes a point in time in a replication stream on one shard. The most recent known replication position can be retrieved from vttablet when executing a query. It is also sent with the replication streams from the binlog service.

func (*EventToken) Descriptor deprecated

This method has been deprecated.
func (*EventToken) Descriptor() ([]byte, []int)

Deprecated: Use EventToken.ProtoReflect.Descriptor instead.

func (*EventToken) GetPosition

func (x *EventToken) GetPosition() string

func (*EventToken) GetShard

func (x *EventToken) GetShard() string

func (*EventToken) GetTimestamp

func (x *EventToken) GetTimestamp() int64

func (*EventToken) MarshalToSizedBufferVT added in v0.11.0

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

func (*EventToken) MarshalToVT added in v0.11.0

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

func (*EventToken) MarshalVT added in v0.11.0

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

func (*EventToken) ProtoMessage

func (*EventToken) ProtoMessage()

func (*EventToken) ProtoReflect added in v0.11.0

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

func (*EventToken) Reset

func (x *EventToken) Reset()

func (*EventToken) SizeVT added in v0.11.0

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

func (*EventToken) String

func (x *EventToken) String() string

func (*EventToken) UnmarshalVT added in v0.11.0

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

type ExecuteBatchRequest

type ExecuteBatchRequest struct {
	EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
	ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
	Target            *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	Queries           []*BoundQuery   `protobuf:"bytes,4,rep,name=queries,proto3" json:"queries,omitempty"`
	AsTransaction     bool            `protobuf:"varint,5,opt,name=as_transaction,json=asTransaction,proto3" json:"as_transaction,omitempty"`
	TransactionId     int64           `protobuf:"varint,6,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	Options           *ExecuteOptions `protobuf:"bytes,7,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

ExecuteBatchRequest is the payload to ExecuteBatch

func (*ExecuteBatchRequest) Descriptor deprecated

This method has been deprecated.
func (*ExecuteBatchRequest) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteBatchRequest.ProtoReflect.Descriptor instead.

func (*ExecuteBatchRequest) GetAsTransaction

func (x *ExecuteBatchRequest) GetAsTransaction() bool

func (*ExecuteBatchRequest) GetEffectiveCallerId

func (x *ExecuteBatchRequest) GetEffectiveCallerId() *vtrpc.CallerID

func (*ExecuteBatchRequest) GetImmediateCallerId

func (x *ExecuteBatchRequest) GetImmediateCallerId() *VTGateCallerID

func (*ExecuteBatchRequest) GetOptions

func (x *ExecuteBatchRequest) GetOptions() *ExecuteOptions

func (*ExecuteBatchRequest) GetQueries

func (x *ExecuteBatchRequest) GetQueries() []*BoundQuery

func (*ExecuteBatchRequest) GetTarget

func (x *ExecuteBatchRequest) GetTarget() *Target

func (*ExecuteBatchRequest) GetTransactionId

func (x *ExecuteBatchRequest) GetTransactionId() int64

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 {
	Results []*QueryResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

ExecuteBatchResponse is the returned value from ExecuteBatch

func (*ExecuteBatchResponse) Descriptor deprecated

This method has been deprecated.
func (*ExecuteBatchResponse) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteBatchResponse.ProtoReflect.Descriptor instead.

func (*ExecuteBatchResponse) GetResults

func (x *ExecuteBatchResponse) GetResults() []*QueryResult

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 ExecuteOptions

type ExecuteOptions struct {

	// Controls what fields are returned in Field message responses from mysql, i.e.
	// field name, table name, etc. This is an optimization for high-QPS queries where
	// the client knows what it's getting
	IncludedFields ExecuteOptions_IncludedFields `` /* 145-byte string literal not displayed */
	// client_rows_found specifies if rows_affected should return
	// rows found instead of rows affected. Behavior is defined
	// by MySQL's CLIENT_FOUND_ROWS flag.
	ClientFoundRows bool `protobuf:"varint,5,opt,name=client_found_rows,json=clientFoundRows,proto3" json:"client_found_rows,omitempty"`
	// workload specifies the type of workload:
	// OLTP: DMLs allowed, results have row count limit, and
	// query timeouts are shorter.
	// OLAP: DMLS not allowed, no limit on row count, timeouts
	// can be as high as desired.
	// DBA: no limit on rowcount or timeout, all queries allowed
	// but intended for long DMLs and DDLs.
	Workload ExecuteOptions_Workload `protobuf:"varint,6,opt,name=workload,proto3,enum=query.ExecuteOptions_Workload" json:"workload,omitempty"`
	// sql_select_limit sets an implicit limit on all select statements. Since
	// vitess also sets a rowcount limit on queries, the smallest value wins.
	SqlSelectLimit       int64                               `protobuf:"varint,8,opt,name=sql_select_limit,json=sqlSelectLimit,proto3" json:"sql_select_limit,omitempty"`
	TransactionIsolation ExecuteOptions_TransactionIsolation `` /* 169-byte string literal not displayed */
	// skip_query_plan_cache specifies if the query plan should be cached by vitess.
	// By default all query plans are cached.
	SkipQueryPlanCache bool `protobuf:"varint,10,opt,name=skip_query_plan_cache,json=skipQueryPlanCache,proto3" json:"skip_query_plan_cache,omitempty"`
	// PlannerVersion specifies which planner to use.
	// If DEFAULT is chosen, whatever vtgate was started with will be used
	PlannerVersion ExecuteOptions_PlannerVersion `` /* 146-byte string literal not displayed */
	// has_created_temp_tables signals whether plans created in this session should be cached or not
	// if the user has created temp tables, Vitess will not reuse plans created for this session in other sessions.
	// The current session can still use other sessions cached plans.
	HasCreatedTempTables bool `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

ExecuteOptions is passed around for all Execute calls.

func (*ExecuteOptions) Descriptor deprecated

This method has been deprecated.
func (*ExecuteOptions) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteOptions.ProtoReflect.Descriptor instead.

func (*ExecuteOptions) GetClientFoundRows

func (x *ExecuteOptions) GetClientFoundRows() bool

func (*ExecuteOptions) GetHasCreatedTempTables added in v0.10.0

func (x *ExecuteOptions) GetHasCreatedTempTables() bool

func (*ExecuteOptions) GetIncludedFields

func (x *ExecuteOptions) GetIncludedFields() ExecuteOptions_IncludedFields

func (*ExecuteOptions) GetPlannerVersion added in v0.10.0

func (x *ExecuteOptions) GetPlannerVersion() ExecuteOptions_PlannerVersion

func (*ExecuteOptions) GetSkipQueryPlanCache

func (x *ExecuteOptions) GetSkipQueryPlanCache() bool

func (*ExecuteOptions) GetSqlSelectLimit

func (x *ExecuteOptions) GetSqlSelectLimit() int64

func (*ExecuteOptions) GetTransactionIsolation

func (x *ExecuteOptions) GetTransactionIsolation() ExecuteOptions_TransactionIsolation

func (*ExecuteOptions) GetWorkload

func (x *ExecuteOptions) GetWorkload() ExecuteOptions_Workload

func (*ExecuteOptions) MarshalToSizedBufferVT added in v0.11.0

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

func (*ExecuteOptions) MarshalToVT added in v0.11.0

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

func (*ExecuteOptions) MarshalVT added in v0.11.0

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

func (*ExecuteOptions) ProtoMessage

func (*ExecuteOptions) ProtoMessage()

func (*ExecuteOptions) ProtoReflect added in v0.11.0

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

func (*ExecuteOptions) Reset

func (x *ExecuteOptions) Reset()

func (*ExecuteOptions) SizeVT added in v0.11.0

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

func (*ExecuteOptions) String

func (x *ExecuteOptions) String() string

func (*ExecuteOptions) UnmarshalVT added in v0.11.0

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

type ExecuteOptions_IncludedFields

type ExecuteOptions_IncludedFields int32
const (
	ExecuteOptions_TYPE_AND_NAME ExecuteOptions_IncludedFields = 0
	ExecuteOptions_TYPE_ONLY     ExecuteOptions_IncludedFields = 1
	ExecuteOptions_ALL           ExecuteOptions_IncludedFields = 2
)

func (ExecuteOptions_IncludedFields) Descriptor added in v0.11.0

func (ExecuteOptions_IncludedFields) Enum added in v0.11.0

func (ExecuteOptions_IncludedFields) EnumDescriptor deprecated

This method has been deprecated.
func (ExecuteOptions_IncludedFields) EnumDescriptor() ([]byte, []int)

Deprecated: Use ExecuteOptions_IncludedFields.Descriptor instead.

func (ExecuteOptions_IncludedFields) Number added in v0.11.0

func (ExecuteOptions_IncludedFields) String

func (ExecuteOptions_IncludedFields) Type added in v0.11.0

type ExecuteOptions_PlannerVersion added in v0.10.0

type ExecuteOptions_PlannerVersion int32
const (
	ExecuteOptions_DEFAULT_PLANNER  ExecuteOptions_PlannerVersion = 0
	ExecuteOptions_V3               ExecuteOptions_PlannerVersion = 1
	ExecuteOptions_Gen4             ExecuteOptions_PlannerVersion = 2
	ExecuteOptions_Gen4Greedy       ExecuteOptions_PlannerVersion = 3
	ExecuteOptions_Gen4Left2Right   ExecuteOptions_PlannerVersion = 4
	ExecuteOptions_Gen4WithFallback ExecuteOptions_PlannerVersion = 5
)

func (ExecuteOptions_PlannerVersion) Descriptor added in v0.11.0

func (ExecuteOptions_PlannerVersion) Enum added in v0.11.0

func (ExecuteOptions_PlannerVersion) EnumDescriptor deprecated added in v0.10.0

This method has been deprecated.
func (ExecuteOptions_PlannerVersion) EnumDescriptor() ([]byte, []int)

Deprecated: Use ExecuteOptions_PlannerVersion.Descriptor instead.

func (ExecuteOptions_PlannerVersion) Number added in v0.11.0

func (ExecuteOptions_PlannerVersion) String added in v0.10.0

func (ExecuteOptions_PlannerVersion) Type added in v0.11.0

type ExecuteOptions_TransactionIsolation

type ExecuteOptions_TransactionIsolation int32
const (
	ExecuteOptions_DEFAULT          ExecuteOptions_TransactionIsolation = 0
	ExecuteOptions_REPEATABLE_READ  ExecuteOptions_TransactionIsolation = 1
	ExecuteOptions_READ_COMMITTED   ExecuteOptions_TransactionIsolation = 2
	ExecuteOptions_READ_UNCOMMITTED ExecuteOptions_TransactionIsolation = 3
	ExecuteOptions_SERIALIZABLE     ExecuteOptions_TransactionIsolation = 4
	// This is not an "official" transaction level but it will do a
	// START TRANSACTION WITH CONSISTENT SNAPSHOT, READ ONLY
	ExecuteOptions_CONSISTENT_SNAPSHOT_READ_ONLY ExecuteOptions_TransactionIsolation = 5
	// This not an "official" transaction level, it will send queries to mysql
	// without wrapping them in a transaction
	ExecuteOptions_AUTOCOMMIT ExecuteOptions_TransactionIsolation = 6
)

func (ExecuteOptions_TransactionIsolation) Descriptor added in v0.11.0

func (ExecuteOptions_TransactionIsolation) Enum added in v0.11.0

func (ExecuteOptions_TransactionIsolation) EnumDescriptor deprecated

This method has been deprecated.
func (ExecuteOptions_TransactionIsolation) EnumDescriptor() ([]byte, []int)

Deprecated: Use ExecuteOptions_TransactionIsolation.Descriptor instead.

func (ExecuteOptions_TransactionIsolation) Number added in v0.11.0

func (ExecuteOptions_TransactionIsolation) String

func (ExecuteOptions_TransactionIsolation) Type added in v0.11.0

type ExecuteOptions_Workload

type ExecuteOptions_Workload int32
const (
	ExecuteOptions_UNSPECIFIED ExecuteOptions_Workload = 0
	ExecuteOptions_OLTP        ExecuteOptions_Workload = 1
	ExecuteOptions_OLAP        ExecuteOptions_Workload = 2
	ExecuteOptions_DBA         ExecuteOptions_Workload = 3
)

func (ExecuteOptions_Workload) Descriptor added in v0.11.0

func (ExecuteOptions_Workload) Enum added in v0.11.0

func (ExecuteOptions_Workload) EnumDescriptor deprecated

This method has been deprecated.
func (ExecuteOptions_Workload) EnumDescriptor() ([]byte, []int)

Deprecated: Use ExecuteOptions_Workload.Descriptor instead.

func (ExecuteOptions_Workload) Number added in v0.11.0

func (ExecuteOptions_Workload) String

func (x ExecuteOptions_Workload) String() string

func (ExecuteOptions_Workload) Type added in v0.11.0

type ExecuteRequest

type ExecuteRequest struct {
	EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
	ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
	Target            *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	Query             *BoundQuery     `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
	TransactionId     int64           `protobuf:"varint,5,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	Options           *ExecuteOptions `protobuf:"bytes,6,opt,name=options,proto3" json:"options,omitempty"`
	ReservedId        int64           `protobuf:"varint,7,opt,name=reserved_id,json=reservedId,proto3" json:"reserved_id,omitempty"`
	// contains filtered or unexported fields
}

ExecuteRequest is the payload to Execute

func (*ExecuteRequest) Descriptor deprecated

This method has been deprecated.
func (*ExecuteRequest) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteRequest.ProtoReflect.Descriptor instead.

func (*ExecuteRequest) GetEffectiveCallerId

func (x *ExecuteRequest) GetEffectiveCallerId() *vtrpc.CallerID

func (*ExecuteRequest) GetImmediateCallerId

func (x *ExecuteRequest) GetImmediateCallerId() *VTGateCallerID

func (*ExecuteRequest) GetOptions

func (x *ExecuteRequest) GetOptions() *ExecuteOptions

func (*ExecuteRequest) GetQuery

func (x *ExecuteRequest) GetQuery() *BoundQuery

func (*ExecuteRequest) GetReservedId

func (x *ExecuteRequest) GetReservedId() int64

func (*ExecuteRequest) GetTarget

func (x *ExecuteRequest) GetTarget() *Target

func (*ExecuteRequest) GetTransactionId

func (x *ExecuteRequest) GetTransactionId() int64

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 {
	Result *QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

ExecuteResponse is the returned value from Execute

func (*ExecuteResponse) Descriptor deprecated

This method has been deprecated.
func (*ExecuteResponse) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteResponse.ProtoReflect.Descriptor instead.

func (*ExecuteResponse) GetResult

func (x *ExecuteResponse) GetResult() *QueryResult

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 Field

type Field struct {

	// name of the field as returned by mysql C API
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// vitess-defined type. Conversion function is in sqltypes package.
	Type Type `protobuf:"varint,2,opt,name=type,proto3,enum=query.Type" json:"type,omitempty"`
	// Remaining fields from mysql C API.
	// These fields are only populated when ExecuteOptions.included_fields
	// is set to IncludedFields.ALL.
	Table    string `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	OrgTable string `protobuf:"bytes,4,opt,name=org_table,json=orgTable,proto3" json:"org_table,omitempty"`
	Database string `protobuf:"bytes,5,opt,name=database,proto3" json:"database,omitempty"`
	OrgName  string `protobuf:"bytes,6,opt,name=org_name,json=orgName,proto3" json:"org_name,omitempty"`
	// column_length is really a uint32. All 32 bits can be used.
	ColumnLength uint32 `protobuf:"varint,7,opt,name=column_length,json=columnLength,proto3" json:"column_length,omitempty"`
	// charset is actually a uint16. Only the lower 16 bits are used.
	Charset uint32 `protobuf:"varint,8,opt,name=charset,proto3" json:"charset,omitempty"`
	// decimals is actually a uint8. Only the lower 8 bits are used.
	Decimals uint32 `protobuf:"varint,9,opt,name=decimals,proto3" json:"decimals,omitempty"`
	// flags is actually a uint16. Only the lower 16 bits are used.
	Flags uint32 `protobuf:"varint,10,opt,name=flags,proto3" json:"flags,omitempty"`
	// column_type is optionally populated from information_schema.columns
	ColumnType string `protobuf:"bytes,11,opt,name=column_type,json=columnType,proto3" json:"column_type,omitempty"`
	// contains filtered or unexported fields
}

Field describes a single column returned by a query

func (*Field) CachedSize added in v0.10.0

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

func (*Field) Descriptor deprecated

This method has been deprecated.
func (*Field) Descriptor() ([]byte, []int)

Deprecated: Use Field.ProtoReflect.Descriptor instead.

func (*Field) GetCharset

func (x *Field) GetCharset() uint32

func (*Field) GetColumnLength

func (x *Field) GetColumnLength() uint32

func (*Field) GetColumnType added in v0.9.0

func (x *Field) GetColumnType() string

func (*Field) GetDatabase

func (x *Field) GetDatabase() string

func (*Field) GetDecimals

func (x *Field) GetDecimals() uint32

func (*Field) GetFlags

func (x *Field) GetFlags() uint32

func (*Field) GetName

func (x *Field) GetName() string

func (*Field) GetOrgName

func (x *Field) GetOrgName() string

func (*Field) GetOrgTable

func (x *Field) GetOrgTable() string

func (*Field) GetTable

func (x *Field) GetTable() string

func (*Field) GetType

func (x *Field) GetType() Type

func (*Field) MarshalToSizedBufferVT added in v0.11.0

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

func (*Field) MarshalToVT added in v0.11.0

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

func (*Field) MarshalVT added in v0.11.0

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

func (*Field) ProtoMessage

func (*Field) ProtoMessage()

func (*Field) ProtoReflect added in v0.11.0

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

func (*Field) Reset

func (x *Field) Reset()

func (*Field) SizeVT added in v0.11.0

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

func (*Field) String

func (x *Field) String() string

func (*Field) UnmarshalVT added in v0.11.0

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

type Flag

type Flag int32

Flag allows us to qualify types by their common properties.

const (
	Flag_NONE       Flag = 0
	Flag_ISINTEGRAL Flag = 256
	Flag_ISUNSIGNED Flag = 512
	Flag_ISFLOAT    Flag = 1024
	Flag_ISQUOTED   Flag = 2048
	Flag_ISTEXT     Flag = 4096
	Flag_ISBINARY   Flag = 8192
)

func (Flag) Descriptor added in v0.11.0

func (Flag) Descriptor() protoreflect.EnumDescriptor

func (Flag) Enum added in v0.11.0

func (x Flag) Enum() *Flag

func (Flag) EnumDescriptor deprecated

This method has been deprecated.
func (Flag) EnumDescriptor() ([]byte, []int)

Deprecated: Use Flag.Descriptor instead.

func (Flag) Number added in v0.11.0

func (x Flag) Number() protoreflect.EnumNumber

func (Flag) String

func (x Flag) String() string

func (Flag) Type added in v0.11.0

func (Flag) Type() protoreflect.EnumType

type MessageAckRequest

type MessageAckRequest struct {
	EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
	ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
	Target            *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	// name is the message table name.
	Name string   `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Ids  []*Value `protobuf:"bytes,5,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

MessageAckRequest is the request payload for MessageAck.

func (*MessageAckRequest) Descriptor deprecated

This method has been deprecated.
func (*MessageAckRequest) Descriptor() ([]byte, []int)

Deprecated: Use MessageAckRequest.ProtoReflect.Descriptor instead.

func (*MessageAckRequest) GetEffectiveCallerId

func (x *MessageAckRequest) GetEffectiveCallerId() *vtrpc.CallerID

func (*MessageAckRequest) GetIds

func (x *MessageAckRequest) GetIds() []*Value

func (*MessageAckRequest) GetImmediateCallerId

func (x *MessageAckRequest) GetImmediateCallerId() *VTGateCallerID

func (*MessageAckRequest) GetName

func (x *MessageAckRequest) GetName() string

func (*MessageAckRequest) GetTarget

func (x *MessageAckRequest) GetTarget() *Target

func (*MessageAckRequest) MarshalToSizedBufferVT added in v0.11.0

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

func (*MessageAckRequest) MarshalToVT added in v0.11.0

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

func (*MessageAckRequest) MarshalVT added in v0.11.0

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

func (*MessageAckRequest) ProtoMessage

func (*MessageAckRequest) ProtoMessage()

func (*MessageAckRequest) ProtoReflect added in v0.11.0

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

func (*MessageAckRequest) Reset

func (x *MessageAckRequest) Reset()

func (*MessageAckRequest) SizeVT added in v0.11.0

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

func (*MessageAckRequest) String

func (x *MessageAckRequest) String() string

func (*MessageAckRequest) UnmarshalVT added in v0.11.0

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

type MessageAckResponse

type MessageAckResponse struct {

	// result contains the result of the ack operation.
	// Since this acts like a DML, only
	// RowsAffected is returned in the result.
	Result *QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

MessageAckResponse is the response for MessageAck.

func (*MessageAckResponse) Descriptor deprecated

This method has been deprecated.
func (*MessageAckResponse) Descriptor() ([]byte, []int)

Deprecated: Use MessageAckResponse.ProtoReflect.Descriptor instead.

func (*MessageAckResponse) GetResult

func (x *MessageAckResponse) GetResult() *QueryResult

func (*MessageAckResponse) MarshalToSizedBufferVT added in v0.11.0

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

func (*MessageAckResponse) MarshalToVT added in v0.11.0

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

func (*MessageAckResponse) MarshalVT added in v0.11.0

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

func (*MessageAckResponse) ProtoMessage

func (*MessageAckResponse) ProtoMessage()

func (*MessageAckResponse) ProtoReflect added in v0.11.0

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

func (*MessageAckResponse) Reset

func (x *MessageAckResponse) Reset()

func (*MessageAckResponse) SizeVT added in v0.11.0

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

func (*MessageAckResponse) String

func (x *MessageAckResponse) String() string

func (*MessageAckResponse) UnmarshalVT added in v0.11.0

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

type MessageStreamRequest

type MessageStreamRequest struct {
	EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
	ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
	Target            *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	// name is the message table name.
	Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

MessageStreamRequest is the request payload for MessageStream.

func (*MessageStreamRequest) Descriptor deprecated

This method has been deprecated.
func (*MessageStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use MessageStreamRequest.ProtoReflect.Descriptor instead.

func (*MessageStreamRequest) GetEffectiveCallerId

func (x *MessageStreamRequest) GetEffectiveCallerId() *vtrpc.CallerID

func (*MessageStreamRequest) GetImmediateCallerId

func (x *MessageStreamRequest) GetImmediateCallerId() *VTGateCallerID

func (*MessageStreamRequest) GetName

func (x *MessageStreamRequest) GetName() string

func (*MessageStreamRequest) GetTarget

func (x *MessageStreamRequest) GetTarget() *Target

func (*MessageStreamRequest) MarshalToSizedBufferVT added in v0.11.0

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

func (*MessageStreamRequest) MarshalToVT added in v0.11.0

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

func (*MessageStreamRequest) MarshalVT added in v0.11.0

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

func (*MessageStreamRequest) ProtoMessage

func (*MessageStreamRequest) ProtoMessage()

func (*MessageStreamRequest) ProtoReflect added in v0.11.0

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

func (*MessageStreamRequest) Reset

func (x *MessageStreamRequest) Reset()

func (*MessageStreamRequest) SizeVT added in v0.11.0

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

func (*MessageStreamRequest) String

func (x *MessageStreamRequest) String() string

func (*MessageStreamRequest) UnmarshalVT added in v0.11.0

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

type MessageStreamResponse

type MessageStreamResponse struct {
	Result *QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

MessageStreamResponse is a response for MessageStream.

func (*MessageStreamResponse) Descriptor deprecated

This method has been deprecated.
func (*MessageStreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use MessageStreamResponse.ProtoReflect.Descriptor instead.

func (*MessageStreamResponse) GetResult

func (x *MessageStreamResponse) GetResult() *QueryResult

func (*MessageStreamResponse) MarshalToSizedBufferVT added in v0.11.0

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

func (*MessageStreamResponse) MarshalToVT added in v0.11.0

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

func (*MessageStreamResponse) MarshalVT added in v0.11.0

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

func (*MessageStreamResponse) ProtoMessage

func (*MessageStreamResponse) ProtoMessage()

func (*MessageStreamResponse) ProtoReflect added in v0.11.0

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

func (*MessageStreamResponse) Reset

func (x *MessageStreamResponse) Reset()

func (*MessageStreamResponse) SizeVT added in v0.11.0

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

func (*MessageStreamResponse) String

func (x *MessageStreamResponse) String() string

func (*MessageStreamResponse) UnmarshalVT added in v0.11.0

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

type MySqlFlag

type MySqlFlag int32

Flags sent from the MySQL C API

const (
	MySqlFlag_EMPTY                 MySqlFlag = 0
	MySqlFlag_NOT_NULL_FLAG         MySqlFlag = 1
	MySqlFlag_PRI_KEY_FLAG          MySqlFlag = 2
	MySqlFlag_UNIQUE_KEY_FLAG       MySqlFlag = 4
	MySqlFlag_MULTIPLE_KEY_FLAG     MySqlFlag = 8
	MySqlFlag_BLOB_FLAG             MySqlFlag = 16
	MySqlFlag_UNSIGNED_FLAG         MySqlFlag = 32
	MySqlFlag_ZEROFILL_FLAG         MySqlFlag = 64
	MySqlFlag_BINARY_FLAG           MySqlFlag = 128
	MySqlFlag_ENUM_FLAG             MySqlFlag = 256
	MySqlFlag_AUTO_INCREMENT_FLAG   MySqlFlag = 512
	MySqlFlag_TIMESTAMP_FLAG        MySqlFlag = 1024
	MySqlFlag_SET_FLAG              MySqlFlag = 2048
	MySqlFlag_NO_DEFAULT_VALUE_FLAG MySqlFlag = 4096
	MySqlFlag_ON_UPDATE_NOW_FLAG    MySqlFlag = 8192
	MySqlFlag_NUM_FLAG              MySqlFlag = 32768
	MySqlFlag_PART_KEY_FLAG         MySqlFlag = 16384
	MySqlFlag_GROUP_FLAG            MySqlFlag = 32768
	MySqlFlag_UNIQUE_FLAG           MySqlFlag = 65536
	MySqlFlag_BINCMP_FLAG           MySqlFlag = 131072
)

func (MySqlFlag) Descriptor added in v0.11.0

func (MySqlFlag) Descriptor() protoreflect.EnumDescriptor

func (MySqlFlag) Enum added in v0.11.0

func (x MySqlFlag) Enum() *MySqlFlag

func (MySqlFlag) EnumDescriptor deprecated

This method has been deprecated.
func (MySqlFlag) EnumDescriptor() ([]byte, []int)

Deprecated: Use MySqlFlag.Descriptor instead.

func (MySqlFlag) Number added in v0.11.0

func (x MySqlFlag) Number() protoreflect.EnumNumber

func (MySqlFlag) String

func (x MySqlFlag) String() string

func (MySqlFlag) Type added in v0.11.0

type PrepareRequest

type PrepareRequest struct {
	EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
	ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
	Target            *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	TransactionId     int64           `protobuf:"varint,4,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	Dtid              string          `protobuf:"bytes,5,opt,name=dtid,proto3" json:"dtid,omitempty"`
	// contains filtered or unexported fields
}

PrepareRequest is the payload to Prepare

func (*PrepareRequest) Descriptor deprecated

This method has been deprecated.
func (*PrepareRequest) Descriptor() ([]byte, []int)

Deprecated: Use PrepareRequest.ProtoReflect.Descriptor instead.

func (*PrepareRequest) GetDtid

func (x *PrepareRequest) GetDtid() string

func (*PrepareRequest) GetEffectiveCallerId

func (x *PrepareRequest) GetEffectiveCallerId() *vtrpc.CallerID

func (*PrepareRequest) GetImmediateCallerId

func (x *PrepareRequest) GetImmediateCallerId() *VTGateCallerID

func (*PrepareRequest) GetTarget

func (x *PrepareRequest) GetTarget() *Target

func (*PrepareRequest) GetTransactionId

func (x *PrepareRequest) GetTransactionId() int64

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

func (*PrepareRequest) ProtoMessage()

func (*PrepareRequest) ProtoReflect added in v0.11.0

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

func (*PrepareRequest) Reset

func (x *PrepareRequest) Reset()

func (*PrepareRequest) SizeVT added in v0.11.0

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

func (*PrepareRequest) String

func (x *PrepareRequest) String() string

func (*PrepareRequest) UnmarshalVT added in v0.11.0

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

type PrepareResponse

type PrepareResponse struct {
	// contains filtered or unexported fields
}

PrepareResponse is the returned value from Prepare

func (*PrepareResponse) Descriptor deprecated

This method has been deprecated.
func (*PrepareResponse) Descriptor() ([]byte, []int)

Deprecated: Use PrepareResponse.ProtoReflect.Descriptor instead.

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

func (*PrepareResponse) ProtoMessage()

func (*PrepareResponse) ProtoReflect added in v0.11.0

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

func (*PrepareResponse) Reset

func (x *PrepareResponse) Reset()

func (*PrepareResponse) SizeVT added in v0.11.0

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

func (*PrepareResponse) String

func (x *PrepareResponse) String() string

func (*PrepareResponse) UnmarshalVT added in v0.11.0

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

type QueryResult

type QueryResult struct {
	Fields       []*Field `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	RowsAffected uint64   `protobuf:"varint,2,opt,name=rows_affected,json=rowsAffected,proto3" json:"rows_affected,omitempty"`
	InsertId     uint64   `protobuf:"varint,3,opt,name=insert_id,json=insertId,proto3" json:"insert_id,omitempty"`
	Rows         []*Row   `protobuf:"bytes,4,rep,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

QueryResult is returned by Execute and ExecuteStream.

As returned by Execute, len(fields) is always equal to len(row) (for each row in rows).

As returned by StreamExecute, the first QueryResult has the fields set, and subsequent QueryResult have rows set. And as Execute, len(QueryResult[0].fields) is always equal to len(row) (for each row in rows for each QueryResult in QueryResult[1:]).

func (*QueryResult) Descriptor deprecated

This method has been deprecated.
func (*QueryResult) Descriptor() ([]byte, []int)

Deprecated: Use QueryResult.ProtoReflect.Descriptor instead.

func (*QueryResult) GetFields

func (x *QueryResult) GetFields() []*Field

func (*QueryResult) GetInsertId

func (x *QueryResult) GetInsertId() uint64

func (*QueryResult) GetRows

func (x *QueryResult) GetRows() []*Row

func (*QueryResult) GetRowsAffected

func (x *QueryResult) GetRowsAffected() uint64

func (*QueryResult) MarshalToSizedBufferVT added in v0.11.0

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

func (*QueryResult) MarshalToVT added in v0.11.0

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

func (*QueryResult) MarshalVT added in v0.11.0

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

func (*QueryResult) ProtoMessage

func (*QueryResult) ProtoMessage()

func (*QueryResult) ProtoReflect added in v0.11.0

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

func (*QueryResult) Reset

func (x *QueryResult) Reset()

func (*QueryResult) SizeVT added in v0.11.0

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

func (*QueryResult) String

func (x *QueryResult) String() string

func (*QueryResult) UnmarshalVT added in v0.11.0

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

type QueryWarning

type QueryWarning struct {
	Code    uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

QueryWarning is used to convey out of band query execution warnings by storing in the vtgate.Session

func (*QueryWarning) CachedSize added in v0.10.0

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

func (*QueryWarning) Descriptor deprecated

This method has been deprecated.
func (*QueryWarning) Descriptor() ([]byte, []int)

Deprecated: Use QueryWarning.ProtoReflect.Descriptor instead.

func (*QueryWarning) GetCode

func (x *QueryWarning) GetCode() uint32

func (*QueryWarning) GetMessage

func (x *QueryWarning) GetMessage() string

func (*QueryWarning) MarshalToSizedBufferVT added in v0.11.0

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

func (*QueryWarning) MarshalToVT added in v0.11.0

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

func (*QueryWarning) MarshalVT added in v0.11.0

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

func (*QueryWarning) ProtoMessage

func (*QueryWarning) ProtoMessage()

func (*QueryWarning) ProtoReflect added in v0.11.0

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

func (*QueryWarning) Reset

func (x *QueryWarning) Reset()

func (*QueryWarning) SizeVT added in v0.11.0

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

func (*QueryWarning) String

func (x *QueryWarning) String() string

func (*QueryWarning) UnmarshalVT added in v0.11.0

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

type ReadTransactionRequest

type ReadTransactionRequest struct {
	EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
	ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
	Target            *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	Dtid              string          `protobuf:"bytes,4,opt,name=dtid,proto3" json:"dtid,omitempty"`
	// contains filtered or unexported fields
}

ReadTransactionRequest is the payload to ReadTransaction

func (*ReadTransactionRequest) Descriptor deprecated

This method has been deprecated.
func (*ReadTransactionRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReadTransactionRequest.ProtoReflect.Descriptor instead.

func (*ReadTransactionRequest) GetDtid

func (x *ReadTransactionRequest) GetDtid() string

func (*ReadTransactionRequest) GetEffectiveCallerId

func (x *ReadTransactionRequest) GetEffectiveCallerId() *vtrpc.CallerID

func (*ReadTransactionRequest) GetImmediateCallerId

func (x *ReadTransactionRequest) GetImmediateCallerId() *VTGateCallerID

func (*ReadTransactionRequest) GetTarget

func (x *ReadTransactionRequest) GetTarget() *Target

func (*ReadTransactionRequest) MarshalToSizedBufferVT added in v0.11.0

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

func (*ReadTransactionRequest) MarshalToVT added in v0.11.0

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

func (*ReadTransactionRequest) MarshalVT added in v0.11.0

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

func (*ReadTransactionRequest) ProtoMessage

func (*ReadTransactionRequest) ProtoMessage()

func (*ReadTransactionRequest) ProtoReflect added in v0.11.0

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

func (*ReadTransactionRequest) Reset

func (x *ReadTransactionRequest) Reset()

func (*ReadTransactionRequest) SizeVT added in v0.11.0

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

func (*ReadTransactionRequest) String

func (x *ReadTransactionRequest) String() string

func (*ReadTransactionRequest) UnmarshalVT added in v0.11.0

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

type ReadTransactionResponse

type ReadTransactionResponse struct {
	Metadata *TransactionMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

ReadTransactionResponse is the returned value from ReadTransaction

func (*ReadTransactionResponse) Descriptor deprecated

This method has been deprecated.
func (*ReadTransactionResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReadTransactionResponse.ProtoReflect.Descriptor instead.

func (*ReadTransactionResponse) GetMetadata

func (x *ReadTransactionResponse) GetMetadata() *TransactionMetadata

func (*ReadTransactionResponse) MarshalToSizedBufferVT added in v0.11.0

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

func (*ReadTransactionResponse) MarshalToVT added in v0.11.0

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

func (*ReadTransactionResponse) MarshalVT added in v0.11.0

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

func (*ReadTransactionResponse) ProtoMessage

func (*ReadTransactionResponse) ProtoMessage()

func (*ReadTransactionResponse) ProtoReflect added in v0.11.0

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

func (*ReadTransactionResponse) Reset

func (x *ReadTransactionResponse) Reset()

func (*ReadTransactionResponse) SizeVT added in v0.11.0

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

func (*ReadTransactionResponse) String

func (x *ReadTransactionResponse) String() string

func (*ReadTransactionResponse) UnmarshalVT added in v0.11.0

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

type RealtimeStats

type RealtimeStats struct {

	// health_error is the last error we got from health check,
	// or empty is the server is healthy. This is used for subset selection,
	// we do not send queries to servers that are not healthy.
	HealthError string `protobuf:"bytes,1,opt,name=health_error,json=healthError,proto3" json:"health_error,omitempty"`
	// seconds_behind_master is populated for replicas only. It indicates
	// how far behind on (MySQL) replication a replica currently is.  It is used
	// by clients for subset selection (so we don't try to send traffic
	// to tablets that are too far behind).
	// NOTE: This field must not be evaluated if "health_error" is not empty.
	// TODO(mberlin): Let's switch it to int64 instead?
	SecondsBehindMaster uint32 `protobuf:"varint,2,opt,name=seconds_behind_master,json=secondsBehindMaster,proto3" json:"seconds_behind_master,omitempty"`
	// bin_log_players_count is the number of currently running binlog players.
	// if the value is 0, it means that filtered replication is currently not
	// running on the tablet. If >0, filtered replication is running.
	// NOTE: This field must not be evaluated if "health_error" is not empty.
	BinlogPlayersCount int32 `protobuf:"varint,3,opt,name=binlog_players_count,json=binlogPlayersCount,proto3" json:"binlog_players_count,omitempty"`
	// seconds_behind_master_filtered_replication is populated for the receiving
	// master of an ongoing filtered replication only.
	// It specifies how far the receiving master lags behind the sending master.
	// NOTE: This field must not be evaluated if "health_error" is not empty.
	// NOTE: This field must not be evaluated if "bin_log_players_count" is 0.
	SecondsBehindMasterFilteredReplication int64 `` /* 182-byte string literal not displayed */
	// cpu_usage is used for load-based balancing
	CpuUsage float64 `protobuf:"fixed64,5,opt,name=cpu_usage,json=cpuUsage,proto3" json:"cpu_usage,omitempty"`
	// qps is the average QPS (queries per second) rate in the last XX seconds
	// where XX is usually 60 (See query_service_stats.go).
	Qps float64 `protobuf:"fixed64,6,opt,name=qps,proto3" json:"qps,omitempty"`
	// table_schema_changed is to provide list of tables that have schema changes detected by the tablet.
	TableSchemaChanged []string `protobuf:"bytes,7,rep,name=table_schema_changed,json=tableSchemaChanged,proto3" json:"table_schema_changed,omitempty"`
	// contains filtered or unexported fields
}

RealtimeStats contains information about the tablet status. It is only valid for a single tablet.

func (*RealtimeStats) Descriptor deprecated

This method has been deprecated.
func (*RealtimeStats) Descriptor() ([]byte, []int)

Deprecated: Use RealtimeStats.ProtoReflect.Descriptor instead.

func (*RealtimeStats) GetBinlogPlayersCount

func (x *RealtimeStats) GetBinlogPlayersCount() int32

func (*RealtimeStats) GetCpuUsage

func (x *RealtimeStats) GetCpuUsage() float64

func (*RealtimeStats) GetHealthError

func (x *RealtimeStats) GetHealthError() string

func (*RealtimeStats) GetQps

func (x *RealtimeStats) GetQps() float64

func (*RealtimeStats) GetSecondsBehindMaster

func (x *RealtimeStats) GetSecondsBehindMaster() uint32

func (*RealtimeStats) GetSecondsBehindMasterFilteredReplication

func (x *RealtimeStats) GetSecondsBehindMasterFilteredReplication() int64

func (*RealtimeStats) GetTableSchemaChanged added in v0.11.0

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

func (*RealtimeStats) MarshalToSizedBufferVT added in v0.11.0

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

func (*RealtimeStats) MarshalToVT added in v0.11.0

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

func (*RealtimeStats) MarshalVT added in v0.11.0

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

func (*RealtimeStats) ProtoMessage

func (*RealtimeStats) ProtoMessage()

func (*RealtimeStats) ProtoReflect added in v0.11.0

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

func (*RealtimeStats) Reset

func (x *RealtimeStats) Reset()

func (*RealtimeStats) SizeVT added in v0.11.0

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

func (*RealtimeStats) String

func (x *RealtimeStats) String() string

func (*RealtimeStats) UnmarshalVT added in v0.11.0

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

type ReleaseRequest

type ReleaseRequest struct {
	EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
	ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
	Target            *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	TransactionId     int64           `protobuf:"varint,4,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	ReservedId        int64           `protobuf:"varint,5,opt,name=reserved_id,json=reservedId,proto3" json:"reserved_id,omitempty"`
	// contains filtered or unexported fields
}

ReleaseRequest is the payload to Release

func (*ReleaseRequest) Descriptor deprecated

This method has been deprecated.
func (*ReleaseRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReleaseRequest.ProtoReflect.Descriptor instead.

func (*ReleaseRequest) GetEffectiveCallerId

func (x *ReleaseRequest) GetEffectiveCallerId() *vtrpc.CallerID

func (*ReleaseRequest) GetImmediateCallerId

func (x *ReleaseRequest) GetImmediateCallerId() *VTGateCallerID

func (*ReleaseRequest) GetReservedId

func (x *ReleaseRequest) GetReservedId() int64

func (*ReleaseRequest) GetTarget

func (x *ReleaseRequest) GetTarget() *Target

func (*ReleaseRequest) GetTransactionId

func (x *ReleaseRequest) GetTransactionId() int64

func (*ReleaseRequest) MarshalToSizedBufferVT added in v0.11.0

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

func (*ReleaseRequest) MarshalToVT added in v0.11.0

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

func (*ReleaseRequest) MarshalVT added in v0.11.0

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

func (*ReleaseRequest) ProtoMessage

func (*ReleaseRequest) ProtoMessage()

func (*ReleaseRequest) ProtoReflect added in v0.11.0

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

func (*ReleaseRequest) Reset

func (x *ReleaseRequest) Reset()

func (*ReleaseRequest) SizeVT added in v0.11.0

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

func (*ReleaseRequest) String

func (x *ReleaseRequest) String() string

func (*ReleaseRequest) UnmarshalVT added in v0.11.0

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

type ReleaseResponse

type ReleaseResponse struct {
	// contains filtered or unexported fields
}

ReleaseResponse is the returned value from Release

func (*ReleaseResponse) Descriptor deprecated

This method has been deprecated.
func (*ReleaseResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReleaseResponse.ProtoReflect.Descriptor instead.

func (*ReleaseResponse) MarshalToSizedBufferVT added in v0.11.0

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

func (*ReleaseResponse) MarshalToVT added in v0.11.0

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

func (*ReleaseResponse) MarshalVT added in v0.11.0

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

func (*ReleaseResponse) ProtoMessage

func (*ReleaseResponse) ProtoMessage()

func (*ReleaseResponse) ProtoReflect added in v0.11.0

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

func (*ReleaseResponse) Reset

func (x *ReleaseResponse) Reset()

func (*ReleaseResponse) SizeVT added in v0.11.0

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

func (*ReleaseResponse) String

func (x *ReleaseResponse) String() string

func (*ReleaseResponse) UnmarshalVT added in v0.11.0

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

type ReserveBeginExecuteRequest

type ReserveBeginExecuteRequest struct {
	EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
	ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
	Target            *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	Query             *BoundQuery     `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
	Options           *ExecuteOptions `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"`
	PreQueries        []string        `protobuf:"bytes,6,rep,name=pre_queries,json=preQueries,proto3" json:"pre_queries,omitempty"`
	// contains filtered or unexported fields
}

ReserveBeginExecuteRequest is the payload to ReserveBeginExecute

func (*ReserveBeginExecuteRequest) Descriptor deprecated

This method has been deprecated.
func (*ReserveBeginExecuteRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReserveBeginExecuteRequest.ProtoReflect.Descriptor instead.

func (*ReserveBeginExecuteRequest) GetEffectiveCallerId

func (x *ReserveBeginExecuteRequest) GetEffectiveCallerId() *vtrpc.CallerID

func (*ReserveBeginExecuteRequest) GetImmediateCallerId

func (x *ReserveBeginExecuteRequest) GetImmediateCallerId() *VTGateCallerID

func (*ReserveBeginExecuteRequest) GetOptions

func (x *ReserveBeginExecuteRequest) GetOptions() *ExecuteOptions

func (*ReserveBeginExecuteRequest) GetPreQueries

func (x *ReserveBeginExecuteRequest) GetPreQueries() []string

func (*ReserveBeginExecuteRequest) GetQuery

func (x *ReserveBeginExecuteRequest) GetQuery() *BoundQuery

func (*ReserveBeginExecuteRequest) GetTarget

func (x *ReserveBeginExecuteRequest) GetTarget() *Target

func (*ReserveBeginExecuteRequest) MarshalToSizedBufferVT added in v0.11.0

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

func (*ReserveBeginExecuteRequest) MarshalToVT added in v0.11.0

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

func (*ReserveBeginExecuteRequest) MarshalVT added in v0.11.0

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

func (*ReserveBeginExecuteRequest) ProtoMessage

func (*ReserveBeginExecuteRequest) ProtoMessage()

func (*ReserveBeginExecuteRequest) ProtoReflect added in v0.11.0

func (*ReserveBeginExecuteRequest) Reset

func (x *ReserveBeginExecuteRequest) Reset()

func (*ReserveBeginExecuteRequest) SizeVT added in v0.11.0

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

func (*ReserveBeginExecuteRequest) String

func (x *ReserveBeginExecuteRequest) String() string

func (*ReserveBeginExecuteRequest) UnmarshalVT added in v0.11.0

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

type ReserveBeginExecuteResponse

type ReserveBeginExecuteResponse struct {

	// error contains an application level error if necessary. Note the
	// transaction_id may be set, even when an error is returned, if the begin
	// worked but the execute failed.
	Error  *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Result *QueryResult    `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// The following fields might be non-zero even if an error is present.
	TransactionId int64                 `protobuf:"varint,3,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	ReservedId    int64                 `protobuf:"varint,4,opt,name=reserved_id,json=reservedId,proto3" json:"reserved_id,omitempty"`
	TabletAlias   *topodata.TabletAlias `protobuf:"bytes,5,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	// contains filtered or unexported fields
}

ReserveBeginExecuteResponse is the returned value from ReserveBeginExecute

func (*ReserveBeginExecuteResponse) Descriptor deprecated

This method has been deprecated.
func (*ReserveBeginExecuteResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReserveBeginExecuteResponse.ProtoReflect.Descriptor instead.

func (*ReserveBeginExecuteResponse) GetError

func (*ReserveBeginExecuteResponse) GetReservedId

func (x *ReserveBeginExecuteResponse) GetReservedId() int64

func (*ReserveBeginExecuteResponse) GetResult

func (x *ReserveBeginExecuteResponse) GetResult() *QueryResult

func (*ReserveBeginExecuteResponse) GetTabletAlias

func (x *ReserveBeginExecuteResponse) GetTabletAlias() *topodata.TabletAlias

func (*ReserveBeginExecuteResponse) GetTransactionId

func (x *ReserveBeginExecuteResponse) GetTransactionId() int64

func (*ReserveBeginExecuteResponse) MarshalToSizedBufferVT added in v0.11.0