dev

package
v1.36.10-2025072813344... Latest Latest
Warning

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

 Go to latest Published: unknown License: Apache-2.0 Imports: 6 Imported by: 2

Documentation

Index

Constants

View Source 
const ExecuteOptions_AuthoritativeTimeout_case case_ExecuteOptions_Timeout = 17
View Source 
const ExecuteOptions_Timeout_not_set_case case_ExecuteOptions_Timeout = 0

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",
		4128:  "HEXNUM",
		4129:  "HEXVAL",
		4130:  "BITNUM",
		2083:  "VECTOR",
		2084:  "RAW",
		2085:  "ROW_TUPLE",
	}
	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,
		"HEXNUM":     4128,
		"HEXVAL":     4129,
		"BITNUM":     4130,
		"VECTOR":     2083,
		"RAW":        2084,
		"ROW_TUPLE":  2085,
	}
)

Enum value maps for Type.

View Source 
var (
	StartCommitState_name = map[int32]string{
		0: "Unknown",
		1: "Fail",
		2: "Success",
	}
	StartCommitState_value = map[string]int32{
		"Unknown": 0,
		"Fail":    1,
		"Success": 2,
	}
)

Enum value maps for StartCommitState.

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

Enum value maps for TransactionState.

View Source 
var (
	SchemaTableType_name = map[int32]string{
		0: "VIEWS",
		1: "TABLES",
		2: "ALL",
		3: "UDFS",
	}
	SchemaTableType_value = map[string]int32{
		"VIEWS":  0,
		"TABLES": 1,
		"ALL":    2,
		"UDFS":   3,
	}
)

Enum value maps for SchemaTableType.

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",
		6: "Gen4CompareV3",
		7: "V3Insert",
	}
	ExecuteOptions_PlannerVersion_value = map[string]int32{
		"DEFAULT_PLANNER":  0,
		"V3":               1,
		"Gen4":             2,
		"Gen4Greedy":       3,
		"Gen4Left2Right":   4,
		"Gen4WithFallback": 5,
		"Gen4CompareV3":    6,
		"V3Insert":         7,
	}
)

Enum value maps for ExecuteOptions_PlannerVersion.

View Source 
var (
	ExecuteOptions_Consolidator_name = map[int32]string{
		0: "CONSOLIDATOR_UNSPECIFIED",
		1: "CONSOLIDATOR_DISABLED",
		2: "CONSOLIDATOR_ENABLED",
		3: "CONSOLIDATOR_ENABLED_REPLICAS",
	}
	ExecuteOptions_Consolidator_value = map[string]int32{
		"CONSOLIDATOR_UNSPECIFIED":      0,
		"CONSOLIDATOR_DISABLED":         1,
		"CONSOLIDATOR_ENABLED":          2,
		"CONSOLIDATOR_ENABLED_REPLICAS": 3,
	}
)

Enum value maps for ExecuteOptions_Consolidator.

View Source 
var (
	ExecuteOptions_TransactionAccessMode_name = map[int32]string{
		0: "CONSISTENT_SNAPSHOT",
		1: "READ_WRITE",
		2: "READ_ONLY",
	}
	ExecuteOptions_TransactionAccessMode_value = map[string]int32{
		"CONSISTENT_SNAPSHOT": 0,
		"READ_WRITE":          1,
		"READ_ONLY":           2,
	}
)

Enum value maps for ExecuteOptions_TransactionAccessMode.

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 File_vitess_query_dev_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"`
	// replication_lag_seconds_min is the minimum of the
	// replication_lag_seconds values of the healthy tablets. It is unset
	// if the tablet type is primary.
	ReplicationLagSecondsMin uint32 `` /* 138-byte string literal not displayed */
	// replication_lag_seconds_max is the maximum of the
	// replication_lag_seconds values of the healthy tablets. It is unset
	// if the tablet type is primary.
	ReplicationLagSecondsMax uint32 `` /* 138-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) GetHealthyTabletCount 

func (x *AggregateStats) GetHealthyTabletCount() int32

func (*AggregateStats) GetReplicationLagSecondsMax 

func (x *AggregateStats) GetReplicationLagSecondsMax() uint32

func (*AggregateStats) GetReplicationLagSecondsMin 

func (x *AggregateStats) GetReplicationLagSecondsMin() uint32

func (*AggregateStats) GetUnhealthyTabletCount 

func (x *AggregateStats) GetUnhealthyTabletCount() int32

func (*AggregateStats) ProtoMessage 

func (*AggregateStats) ProtoMessage()

func (*AggregateStats) ProtoReflect 

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

func (*AggregateStats) Reset 

func (x *AggregateStats) Reset()

func (*AggregateStats) SetHealthyTabletCount 

func (x *AggregateStats) SetHealthyTabletCount(v int32)

func (*AggregateStats) SetReplicationLagSecondsMax 

func (x *AggregateStats) SetReplicationLagSecondsMax(v uint32)

func (*AggregateStats) SetReplicationLagSecondsMin 

func (x *AggregateStats) SetReplicationLagSecondsMin(v uint32)

func (*AggregateStats) SetUnhealthyTabletCount 

func (x *AggregateStats) SetUnhealthyTabletCount(v int32)

func (*AggregateStats) String 

func (x *AggregateStats) String() string

type AggregateStats_builder 

type AggregateStats_builder struct {

	// healthy_tablet_count is the number of healthy tablets in the group.
	HealthyTabletCount int32
	// unhealthy_tablet_count is the number of unhealthy tablets in the group.
	UnhealthyTabletCount int32
	// replication_lag_seconds_min is the minimum of the
	// replication_lag_seconds values of the healthy tablets. It is unset
	// if the tablet type is primary.
	ReplicationLagSecondsMin uint32
	// replication_lag_seconds_max is the maximum of the
	// replication_lag_seconds values of the healthy tablets. It is unset
	// if the tablet type is primary.
	ReplicationLagSecondsMax uint32
	// contains filtered or unexported fields
}

func (AggregateStats_builder) Build 

func (b0 AggregateStats_builder) Build() *AggregateStats

type BeginExecuteRequest 

type BeginExecuteRequest struct {
	EffectiveCallerId *dev1.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) ClearEffectiveCallerId 

func (x *BeginExecuteRequest) ClearEffectiveCallerId()

func (*BeginExecuteRequest) ClearImmediateCallerId 

func (x *BeginExecuteRequest) ClearImmediateCallerId()

func (*BeginExecuteRequest) ClearOptions 

func (x *BeginExecuteRequest) ClearOptions()

func (*BeginExecuteRequest) ClearQuery 

func (x *BeginExecuteRequest) ClearQuery()

func (*BeginExecuteRequest) ClearTarget 

func (x *BeginExecuteRequest) ClearTarget()

func (*BeginExecuteRequest) GetEffectiveCallerId 

func (x *BeginExecuteRequest) GetEffectiveCallerId() *dev1.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) HasEffectiveCallerId 

func (x *BeginExecuteRequest) HasEffectiveCallerId() bool

func (*BeginExecuteRequest) HasImmediateCallerId 

func (x *BeginExecuteRequest) HasImmediateCallerId() bool

func (*BeginExecuteRequest) HasOptions 

func (x *BeginExecuteRequest) HasOptions() bool

func (*BeginExecuteRequest) HasQuery 

func (x *BeginExecuteRequest) HasQuery() bool

func (*BeginExecuteRequest) HasTarget 

func (x *BeginExecuteRequest) HasTarget() bool

func (*BeginExecuteRequest) ProtoMessage 

func (*BeginExecuteRequest) ProtoMessage()

func (*BeginExecuteRequest) ProtoReflect 

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

func (*BeginExecuteRequest) Reset 

func (x *BeginExecuteRequest) Reset()

func (*BeginExecuteRequest) SetEffectiveCallerId 

func (x *BeginExecuteRequest) SetEffectiveCallerId(v *dev1.CallerID)

func (*BeginExecuteRequest) SetImmediateCallerId 

func (x *BeginExecuteRequest) SetImmediateCallerId(v *VTGateCallerID)

func (*BeginExecuteRequest) SetOptions 

func (x *BeginExecuteRequest) SetOptions(v *ExecuteOptions)

func (*BeginExecuteRequest) SetPreQueries 

func (x *BeginExecuteRequest) SetPreQueries(v []string)

func (*BeginExecuteRequest) SetQuery 

func (x *BeginExecuteRequest) SetQuery(v *BoundQuery)

func (*BeginExecuteRequest) SetReservedId 

func (x *BeginExecuteRequest) SetReservedId(v int64)

func (*BeginExecuteRequest) SetTarget 

func (x *BeginExecuteRequest) SetTarget(v *Target)

func (*BeginExecuteRequest) String 

func (x *BeginExecuteRequest) String() string

type BeginExecuteRequest_builder 

type BeginExecuteRequest_builder struct {
	EffectiveCallerId *dev1.CallerID
	ImmediateCallerId *VTGateCallerID
	Target            *Target
	Query             *BoundQuery
	Options           *ExecuteOptions
	ReservedId        int64
	PreQueries        []string
	// contains filtered or unexported fields
}

func (BeginExecuteRequest_builder) Build 

func (b0 BeginExecuteRequest_builder) Build() *BeginExecuteRequest

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  *dev1.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   *dev.TabletAlias `protobuf:"bytes,4,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	// The session_state_changes might be set if the transaction is a snapshot transaction
	// and the MySQL implementation supports getting a start gtid on snapshot
	SessionStateChanges string `protobuf:"bytes,5,opt,name=session_state_changes,json=sessionStateChanges,proto3" json:"session_state_changes,omitempty"`
	// contains filtered or unexported fields
}

BeginExecuteResponse is the returned value from BeginExecute

func (*BeginExecuteResponse) ClearError 

func (x *BeginExecuteResponse) ClearError()

func (*BeginExecuteResponse) ClearResult 

func (x *BeginExecuteResponse) ClearResult()

func (*BeginExecuteResponse) ClearTabletAlias 

func (x *BeginExecuteResponse) ClearTabletAlias()

func (*BeginExecuteResponse) GetError 

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

func (*BeginExecuteResponse) GetResult 

func (x *BeginExecuteResponse) GetResult() *QueryResult

func (*BeginExecuteResponse) GetSessionStateChanges 

func (x *BeginExecuteResponse) GetSessionStateChanges() string

func (*BeginExecuteResponse) GetTabletAlias 

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

func (*BeginExecuteResponse) GetTransactionId 

func (x *BeginExecuteResponse) GetTransactionId() int64

func (*BeginExecuteResponse) HasError 

func (x *BeginExecuteResponse) HasError() bool

func (*BeginExecuteResponse) HasResult 

func (x *BeginExecuteResponse) HasResult() bool

func (*BeginExecuteResponse) HasTabletAlias 

func (x *BeginExecuteResponse) HasTabletAlias() bool

func (*BeginExecuteResponse) ProtoMessage 

func (*BeginExecuteResponse) ProtoMessage()

func (*BeginExecuteResponse) ProtoReflect 

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

func (*BeginExecuteResponse) Reset 

func (x *BeginExecuteResponse) Reset()

func (*BeginExecuteResponse) SetError 

func (x *BeginExecuteResponse) SetError(v *dev1.RPCError)

func (*BeginExecuteResponse) SetResult 

func (x *BeginExecuteResponse) SetResult(v *QueryResult)

func (*BeginExecuteResponse) SetSessionStateChanges 

func (x *BeginExecuteResponse) SetSessionStateChanges(v string)

func (*BeginExecuteResponse) SetTabletAlias 

func (x *BeginExecuteResponse) SetTabletAlias(v *dev.TabletAlias)

func (*BeginExecuteResponse) SetTransactionId 

func (x *BeginExecuteResponse) SetTransactionId(v int64)

func (*BeginExecuteResponse) String 

func (x *BeginExecuteResponse) String() string

type BeginExecuteResponse_builder 

type BeginExecuteResponse_builder 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  *dev1.RPCError
	Result *QueryResult
	// transaction_id might be non-zero even if an error is present.
	TransactionId int64
	TabletAlias   *dev.TabletAlias
	// The session_state_changes might be set if the transaction is a snapshot transaction
	// and the MySQL implementation supports getting a start gtid on snapshot
	SessionStateChanges string
	// contains filtered or unexported fields
}

func (BeginExecuteResponse_builder) Build 

func (b0 BeginExecuteResponse_builder) Build() *BeginExecuteResponse

type BeginRequest 

type BeginRequest struct {
	EffectiveCallerId *dev1.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) ClearEffectiveCallerId 

func (x *BeginRequest) ClearEffectiveCallerId()

func (*BeginRequest) ClearImmediateCallerId 

func (x *BeginRequest) ClearImmediateCallerId()

func (*BeginRequest) ClearOptions 

func (x *BeginRequest) ClearOptions()

func (*BeginRequest) ClearTarget 

func (x *BeginRequest) ClearTarget()

func (*BeginRequest) GetEffectiveCallerId 

func (x *BeginRequest) GetEffectiveCallerId() *dev1.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) HasEffectiveCallerId 

func (x *BeginRequest) HasEffectiveCallerId() bool

func (*BeginRequest) HasImmediateCallerId 

func (x *BeginRequest) HasImmediateCallerId() bool

func (*BeginRequest) HasOptions 

func (x *BeginRequest) HasOptions() bool

func (*BeginRequest) HasTarget 

func (x *BeginRequest) HasTarget() bool

func (*BeginRequest) ProtoMessage 

func (*BeginRequest) ProtoMessage()

func (*BeginRequest) ProtoReflect 

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

func (*BeginRequest) Reset 

func (x *BeginRequest) Reset()

func (*BeginRequest) SetEffectiveCallerId 

func (x *BeginRequest) SetEffectiveCallerId(v *dev1.CallerID)

func (*BeginRequest) SetImmediateCallerId 

func (x *BeginRequest) SetImmediateCallerId(v *VTGateCallerID)

func (*BeginRequest) SetOptions 

func (x *BeginRequest) SetOptions(v *ExecuteOptions)

func (*BeginRequest) SetTarget 

func (x *BeginRequest) SetTarget(v *Target)

func (*BeginRequest) String 

func (x *BeginRequest) String() string

type BeginRequest_builder 

type BeginRequest_builder struct {
	EffectiveCallerId *dev1.CallerID
	ImmediateCallerId *VTGateCallerID
	Target            *Target
	Options           *ExecuteOptions
	// contains filtered or unexported fields
}

func (BeginRequest_builder) Build 

func (b0 BeginRequest_builder) Build() *BeginRequest

type BeginResponse 

type BeginResponse struct {
	TransactionId int64            `protobuf:"varint,1,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	TabletAlias   *dev.TabletAlias `protobuf:"bytes,2,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	// The session_state_changes might be set if the transaction is a snapshot transaction
	// and the MySQL implementation supports getting a start gtid on snapshot
	SessionStateChanges string `protobuf:"bytes,3,opt,name=session_state_changes,json=sessionStateChanges,proto3" json:"session_state_changes,omitempty"`
	// contains filtered or unexported fields
}

BeginResponse is the returned value from Begin

func (*BeginResponse) ClearTabletAlias 

func (x *BeginResponse) ClearTabletAlias()

func (*BeginResponse) GetSessionStateChanges 

func (x *BeginResponse) GetSessionStateChanges() string

func (*BeginResponse) GetTabletAlias 

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

func (*BeginResponse) GetTransactionId 

func (x *BeginResponse) GetTransactionId() int64

func (*BeginResponse) HasTabletAlias 

func (x *BeginResponse) HasTabletAlias() bool

func (*BeginResponse) ProtoMessage 

func (*BeginResponse) ProtoMessage()

func (*BeginResponse) ProtoReflect 

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

func (*BeginResponse) Reset 

func (x *BeginResponse) Reset()

func (*BeginResponse) SetSessionStateChanges 

func (x *BeginResponse) SetSessionStateChanges(v string)

func (*BeginResponse) SetTabletAlias 

func (x *BeginResponse) SetTabletAlias(v *dev.TabletAlias)

func (*BeginResponse) SetTransactionId 

func (x *BeginResponse) SetTransactionId(v int64)

func (*BeginResponse) String 

func (x *BeginResponse) String() string

type BeginResponse_builder 

type BeginResponse_builder struct {
	TransactionId int64
	TabletAlias   *dev.TabletAlias
	// The session_state_changes might be set if the transaction is a snapshot transaction
	// and the MySQL implementation supports getting a start gtid on snapshot
	SessionStateChanges string
	// contains filtered or unexported fields
}

func (BeginResponse_builder) Build 

func (b0 BeginResponse_builder) Build() *BeginResponse

type BeginStreamExecuteRequest 

type BeginStreamExecuteRequest struct {
	EffectiveCallerId *dev1.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"`
	ReservedId        int64           `protobuf:"varint,7,opt,name=reserved_id,json=reservedId,proto3" json:"reserved_id,omitempty"`
	// contains filtered or unexported fields
}

BeginStreamExecuteRequest is the payload to BeginStreamExecute

func (*BeginStreamExecuteRequest) ClearEffectiveCallerId 

func (x *BeginStreamExecuteRequest) ClearEffectiveCallerId()

func (*BeginStreamExecuteRequest) ClearImmediateCallerId 

func (x *BeginStreamExecuteRequest) ClearImmediateCallerId()

func (*BeginStreamExecuteRequest) ClearOptions 

func (x *BeginStreamExecuteRequest) ClearOptions()

func (*BeginStreamExecuteRequest) ClearQuery 

func (x *BeginStreamExecuteRequest) ClearQuery()

func (*BeginStreamExecuteRequest) ClearTarget 

func (x *BeginStreamExecuteRequest) ClearTarget()

func (*BeginStreamExecuteRequest) GetEffectiveCallerId 

func (x *BeginStreamExecuteRequest) GetEffectiveCallerId() *dev1.CallerID

func (*BeginStreamExecuteRequest) GetImmediateCallerId 

func (x *BeginStreamExecuteRequest) GetImmediateCallerId() *VTGateCallerID

func (*BeginStreamExecuteRequest) GetOptions 

func (x *BeginStreamExecuteRequest) GetOptions() *ExecuteOptions

func (*BeginStreamExecuteRequest) GetPreQueries 

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

func (*BeginStreamExecuteRequest) GetQuery 

func (x *BeginStreamExecuteRequest) GetQuery() *BoundQuery

func (*BeginStreamExecuteRequest) GetReservedId 

func (x *BeginStreamExecuteRequest) GetReservedId() int64

func (*BeginStreamExecuteRequest) GetTarget 

func (x *BeginStreamExecuteRequest) GetTarget() *Target

func (*BeginStreamExecuteRequest) HasEffectiveCallerId 

func (x *BeginStreamExecuteRequest) HasEffectiveCallerId() bool

func (*BeginStreamExecuteRequest) HasImmediateCallerId 

func (x *BeginStreamExecuteRequest) HasImmediateCallerId() bool

func (*BeginStreamExecuteRequest) HasOptions 

func (x *BeginStreamExecuteRequest) HasOptions() bool

func (*BeginStreamExecuteRequest) HasQuery 

func (x *BeginStreamExecuteRequest) HasQuery() bool

func (*BeginStreamExecuteRequest) HasTarget 

func (x *BeginStreamExecuteRequest) HasTarget() bool

func (*BeginStreamExecuteRequest) ProtoMessage 

func (*BeginStreamExecuteRequest) ProtoMessage()

func (*BeginStreamExecuteRequest) ProtoReflect 

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

func (*BeginStreamExecuteRequest) Reset 

func (x *BeginStreamExecuteRequest) Reset()

func (*BeginStreamExecuteRequest) SetEffectiveCallerId 

func (x *BeginStreamExecuteRequest) SetEffectiveCallerId(v *dev1.CallerID)

func (*BeginStreamExecuteRequest) SetImmediateCallerId 

func (x *BeginStreamExecuteRequest) SetImmediateCallerId(v *VTGateCallerID)

func (*BeginStreamExecuteRequest) SetOptions 

func (x *BeginStreamExecuteRequest) SetOptions(v *ExecuteOptions)

func (*BeginStreamExecuteRequest) SetPreQueries 

func (x *BeginStreamExecuteRequest) SetPreQueries(v []string)

func (*BeginStreamExecuteRequest) SetQuery 

func (x *BeginStreamExecuteRequest) SetQuery(v *BoundQuery)

func (*BeginStreamExecuteRequest) SetReservedId 

func (x *BeginStreamExecuteRequest) SetReservedId(v int64)

func (*BeginStreamExecuteRequest) SetTarget 

func (x *BeginStreamExecuteRequest) SetTarget(v *Target)

func (*BeginStreamExecuteRequest) String 

func (x *BeginStreamExecuteRequest) String() string

type BeginStreamExecuteRequest_builder 

type BeginStreamExecuteRequest_builder struct {
	EffectiveCallerId *dev1.CallerID
	ImmediateCallerId *VTGateCallerID
	Target            *Target
	Query             *BoundQuery
	Options           *ExecuteOptions
	PreQueries        []string
	ReservedId        int64
	// contains filtered or unexported fields
}

func (BeginStreamExecuteRequest_builder) Build 

func (b0 BeginStreamExecuteRequest_builder) Build() *BeginStreamExecuteRequest

type BeginStreamExecuteResponse 

type BeginStreamExecuteResponse 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 stream execute failed.
	Error  *dev1.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   *dev.TabletAlias `protobuf:"bytes,4,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	// The session_state_changes might be set if the transaction is a snapshot transaction
	// and the MySQL implementation supports getting a start gtid on snapshot
	SessionStateChanges string `protobuf:"bytes,5,opt,name=session_state_changes,json=sessionStateChanges,proto3" json:"session_state_changes,omitempty"`
	// contains filtered or unexported fields
}

BeginStreamExecuteResponse is the returned value from BeginStreamExecute

func (*BeginStreamExecuteResponse) ClearError 

func (x *BeginStreamExecuteResponse) ClearError()

func (*BeginStreamExecuteResponse) ClearResult 

func (x *BeginStreamExecuteResponse) ClearResult()

func (*BeginStreamExecuteResponse) ClearTabletAlias 

func (x *BeginStreamExecuteResponse) ClearTabletAlias()

func (*BeginStreamExecuteResponse) GetError 

func (x *BeginStreamExecuteResponse) GetError() *dev1.RPCError

func (*BeginStreamExecuteResponse) GetResult 

func (x *BeginStreamExecuteResponse) GetResult() *QueryResult

func (*BeginStreamExecuteResponse) GetSessionStateChanges 

func (x *BeginStreamExecuteResponse) GetSessionStateChanges() string

func (*BeginStreamExecuteResponse) GetTabletAlias 

func (x *BeginStreamExecuteResponse) GetTabletAlias() *dev.TabletAlias

func (*BeginStreamExecuteResponse) GetTransactionId 

func (x *BeginStreamExecuteResponse) GetTransactionId() int64

func (*BeginStreamExecuteResponse) HasError 

func (x *BeginStreamExecuteResponse) HasError() bool

func (*BeginStreamExecuteResponse) HasResult 

func (x *BeginStreamExecuteResponse) HasResult() bool

func (*BeginStreamExecuteResponse) HasTabletAlias 

func (x *BeginStreamExecuteResponse) HasTabletAlias() bool

func (*BeginStreamExecuteResponse) ProtoMessage 

func (*BeginStreamExecuteResponse) ProtoMessage()

func (*BeginStreamExecuteResponse) ProtoReflect 

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

func (*BeginStreamExecuteResponse) Reset 

func (x *BeginStreamExecuteResponse) Reset()

func (*BeginStreamExecuteResponse) SetError 

func (x *BeginStreamExecuteResponse) SetError(v *dev1.RPCError)

func (*BeginStreamExecuteResponse) SetResult 

func (x *BeginStreamExecuteResponse) SetResult(v *QueryResult)

func (*BeginStreamExecuteResponse) SetSessionStateChanges 

func (x *BeginStreamExecuteResponse) SetSessionStateChanges(v string)

func (*BeginStreamExecuteResponse) SetTabletAlias 

func (x *BeginStreamExecuteResponse) SetTabletAlias(v *dev.TabletAlias)

func (*BeginStreamExecuteResponse) SetTransactionId 

func (x *BeginStreamExecuteResponse) SetTransactionId(v int64)

func (*BeginStreamExecuteResponse) String 

func (x *BeginStreamExecuteResponse) String() string

type BeginStreamExecuteResponse_builder 

type BeginStreamExecuteResponse_builder 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 stream execute failed.
	Error  *dev1.RPCError
	Result *QueryResult
	// transaction_id might be non-zero even if an error is present.
	TransactionId int64
	TabletAlias   *dev.TabletAlias
	// The session_state_changes might be set if the transaction is a snapshot transaction
	// and the MySQL implementation supports getting a start gtid on snapshot
	SessionStateChanges string
	// contains filtered or unexported fields
}

func (BeginStreamExecuteResponse_builder) Build 

func (b0 BeginStreamExecuteResponse_builder) Build() *BeginStreamExecuteResponse

type BindVariable 

type BindVariable struct {
	Type  Type   `protobuf:"varint,1,opt,name=type,proto3,enum=vitess.query.dev.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) GetType 

func (x *BindVariable) GetType() Type

func (*BindVariable) GetValue 

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

func (*BindVariable) GetValues 

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

func (*BindVariable) ProtoMessage 

func (*BindVariable) ProtoMessage()

func (*BindVariable) ProtoReflect 

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

func (*BindVariable) Reset 

func (x *BindVariable) Reset()

func (*BindVariable) SetType 

func (x *BindVariable) SetType(v Type)

func (*BindVariable) SetValue 

func (x *BindVariable) SetValue(v []byte)

func (*BindVariable) SetValues 

func (x *BindVariable) SetValues(v []*Value)

func (*BindVariable) String 

func (x *BindVariable) String() string

type BindVariable_builder 

type BindVariable_builder struct {
	Type  Type
	Value []byte
	// values are set if type is TUPLE.
	Values []*Value
	// contains filtered or unexported fields
}

func (BindVariable_builder) Build 

func (b0 BindVariable_builder) Build() *BindVariable

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 `` /* 174-byte string literal not displayed */
	// contains filtered or unexported fields
}

BoundQuery is a query with its bind variables

func (*BoundQuery) GetBindVariables 

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

func (*BoundQuery) GetSql 

func (x *BoundQuery) GetSql() string

func (*BoundQuery) ProtoMessage 

func (*BoundQuery) ProtoMessage()

func (*BoundQuery) ProtoReflect 

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

func (*BoundQuery) Reset 

func (x *BoundQuery) Reset()

func (*BoundQuery) SetBindVariables 

func (x *BoundQuery) SetBindVariables(v map[string]*BindVariable)

func (*BoundQuery) SetSql 

func (x *BoundQuery) SetSql(v string)

func (*BoundQuery) String 

func (x *BoundQuery) String() string

type BoundQuery_builder 

type BoundQuery_builder struct {

	// sql is the SQL query to execute
	Sql string
	// 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
	// contains filtered or unexported fields
}

func (BoundQuery_builder) Build 

func (b0 BoundQuery_builder) Build() *BoundQuery

type CommitPreparedRequest 

type CommitPreparedRequest struct {
	EffectiveCallerId *dev1.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) ClearEffectiveCallerId 

func (x *CommitPreparedRequest) ClearEffectiveCallerId()

func (*CommitPreparedRequest) ClearImmediateCallerId 

func (x *CommitPreparedRequest) ClearImmediateCallerId()

func (*CommitPreparedRequest) ClearTarget 

func (x *CommitPreparedRequest) ClearTarget()

func (*CommitPreparedRequest) GetDtid 

func (x *CommitPreparedRequest) GetDtid() string

func (*CommitPreparedRequest) GetEffectiveCallerId 

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

func (*CommitPreparedRequest) GetImmediateCallerId 

func (x *CommitPreparedRequest) GetImmediateCallerId() *VTGateCallerID

func (*CommitPreparedRequest) GetTarget 

func (x *CommitPreparedRequest) GetTarget() *Target

func (*CommitPreparedRequest) HasEffectiveCallerId 

func (x *CommitPreparedRequest) HasEffectiveCallerId() bool

func (*CommitPreparedRequest) HasImmediateCallerId 

func (x *CommitPreparedRequest) HasImmediateCallerId() bool

func (*CommitPreparedRequest) HasTarget 

func (x *CommitPreparedRequest) HasTarget() bool

func (*CommitPreparedRequest) ProtoMessage 

func (*CommitPreparedRequest) ProtoMessage()

func (*CommitPreparedRequest) ProtoReflect 

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

func (*CommitPreparedRequest) Reset 

func (x *CommitPreparedRequest) Reset()

func (*CommitPreparedRequest) SetDtid 

func (x *CommitPreparedRequest) SetDtid(v string)

func (*CommitPreparedRequest) SetEffectiveCallerId 

func (x *CommitPreparedRequest) SetEffectiveCallerId(v *dev1.CallerID)

func (*CommitPreparedRequest) SetImmediateCallerId 

func (x *CommitPreparedRequest) SetImmediateCallerId(v *VTGateCallerID)

func (*CommitPreparedRequest) SetTarget 

func (x *CommitPreparedRequest) SetTarget(v *Target)

func (*CommitPreparedRequest) String 

func (x *CommitPreparedRequest) String() string

type CommitPreparedRequest_builder 

type CommitPreparedRequest_builder struct {
	EffectiveCallerId *dev1.CallerID
	ImmediateCallerId *VTGateCallerID
	Target            *Target
	Dtid              string
	// contains filtered or unexported fields
}

func (CommitPreparedRequest_builder) Build 

func (b0 CommitPreparedRequest_builder) Build() *CommitPreparedRequest

type CommitPreparedResponse 

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

CommitPreparedResponse is the returned value from CommitPrepared

func (*CommitPreparedResponse) ProtoMessage 

func (*CommitPreparedResponse) ProtoMessage()

func (*CommitPreparedResponse) ProtoReflect 

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

func (*CommitPreparedResponse) Reset 

func (x *CommitPreparedResponse) Reset()

func (*CommitPreparedResponse) String 

func (x *CommitPreparedResponse) String() string

type CommitPreparedResponse_builder 

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

func (CommitPreparedResponse_builder) Build 

func (b0 CommitPreparedResponse_builder) Build() *CommitPreparedResponse

type CommitRequest 

type CommitRequest struct {
	EffectiveCallerId *dev1.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) ClearEffectiveCallerId 

func (x *CommitRequest) ClearEffectiveCallerId()

func (*CommitRequest) ClearImmediateCallerId 

func (x *CommitRequest) ClearImmediateCallerId()

func (*CommitRequest) ClearTarget 

func (x *CommitRequest) ClearTarget()

func (*CommitRequest) GetEffectiveCallerId 

func (x *CommitRequest) GetEffectiveCallerId() *dev1.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) HasEffectiveCallerId 

func (x *CommitRequest) HasEffectiveCallerId() bool

func (*CommitRequest) HasImmediateCallerId 

func (x *CommitRequest) HasImmediateCallerId() bool

func (*CommitRequest) HasTarget 

func (x *CommitRequest) HasTarget() bool

func (*CommitRequest) ProtoMessage 

func (*CommitRequest) ProtoMessage()

func (*CommitRequest) ProtoReflect 

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

func (*CommitRequest) Reset 

func (x *CommitRequest) Reset()

func (*CommitRequest) SetEffectiveCallerId 

func (x *CommitRequest) SetEffectiveCallerId(v *dev1.CallerID)

func (*CommitRequest) SetImmediateCallerId 

func (x *CommitRequest) SetImmediateCallerId(v *VTGateCallerID)

func (*CommitRequest) SetTarget 

func (x *CommitRequest) SetTarget(v *Target)

func (*CommitRequest) SetTransactionId 

func (x *CommitRequest) SetTransactionId(v int64)

func (*CommitRequest) String 

func (x *CommitRequest) String() string

type CommitRequest_builder 

type CommitRequest_builder struct {
	EffectiveCallerId *dev1.CallerID
	ImmediateCallerId *VTGateCallerID
	Target            *Target
	TransactionId     int64
	// contains filtered or unexported fields
}

func (CommitRequest_builder) Build 

func (b0 CommitRequest_builder) Build() *CommitRequest

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) GetReservedId 

func (x *CommitResponse) GetReservedId() int64

func (*CommitResponse) ProtoMessage 

func (*CommitResponse) ProtoMessage()

func (*CommitResponse) ProtoReflect 

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

func (*CommitResponse) Reset 

func (x *CommitResponse) Reset()

func (*CommitResponse) SetReservedId 

func (x *CommitResponse) SetReservedId(v int64)

func (*CommitResponse) String 

func (x *CommitResponse) String() string

type CommitResponse_builder 

type CommitResponse_builder struct {
	ReservedId int64
	// contains filtered or unexported fields
}

func (CommitResponse_builder) Build 

func (b0 CommitResponse_builder) Build() *CommitResponse

type ConcludeTransactionRequest 

type ConcludeTransactionRequest struct {
	EffectiveCallerId *dev1.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) ClearEffectiveCallerId 

func (x *ConcludeTransactionRequest) ClearEffectiveCallerId()

func (*ConcludeTransactionRequest) ClearImmediateCallerId 

func (x *ConcludeTransactionRequest) ClearImmediateCallerId()

func (*ConcludeTransactionRequest) ClearTarget 

func (x *ConcludeTransactionRequest) ClearTarget()

func (*ConcludeTransactionRequest) GetDtid 

func (x *ConcludeTransactionRequest) GetDtid() string

func (*ConcludeTransactionRequest) GetEffectiveCallerId 

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

func (*ConcludeTransactionRequest) GetImmediateCallerId 

func (x *ConcludeTransactionRequest) GetImmediateCallerId() *VTGateCallerID

func (*ConcludeTransactionRequest) GetTarget 

func (x *ConcludeTransactionRequest) GetTarget() *Target

func (*ConcludeTransactionRequest) HasEffectiveCallerId 

func (x *ConcludeTransactionRequest) HasEffectiveCallerId() bool

func (*ConcludeTransactionRequest) HasImmediateCallerId 

func (x *ConcludeTransactionRequest) HasImmediateCallerId() bool

func (*ConcludeTransactionRequest) HasTarget 

func (x *ConcludeTransactionRequest) HasTarget() bool

func (*ConcludeTransactionRequest) ProtoMessage 

func (*ConcludeTransactionRequest) ProtoMessage()

func (*ConcludeTransactionRequest) ProtoReflect 

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

func (*ConcludeTransactionRequest) Reset 

func (x *ConcludeTransactionRequest) Reset()

func (*ConcludeTransactionRequest) SetDtid 

func (x *ConcludeTransactionRequest) SetDtid(v string)

func (*ConcludeTransactionRequest) SetEffectiveCallerId 

func (x *ConcludeTransactionRequest) SetEffectiveCallerId(v *dev1.CallerID)

func (*ConcludeTransactionRequest) SetImmediateCallerId 

func (x *ConcludeTransactionRequest) SetImmediateCallerId(v *VTGateCallerID)

func (*ConcludeTransactionRequest) SetTarget 

func (x *ConcludeTransactionRequest) SetTarget(v *Target)

func (*ConcludeTransactionRequest) String 

func (x *ConcludeTransactionRequest) String() string

type ConcludeTransactionRequest_builder 

type ConcludeTransactionRequest_builder struct {
	EffectiveCallerId *dev1.CallerID
	ImmediateCallerId *VTGateCallerID
	Target            *Target
	Dtid              string
	// contains filtered or unexported fields
}

func (ConcludeTransactionRequest_builder) Build 

func (b0 ConcludeTransactionRequest_builder) Build() *ConcludeTransactionRequest

type ConcludeTransactionResponse 

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

ConcludeTransactionResponse is the returned value from ConcludeTransaction

func (*ConcludeTransactionResponse) ProtoMessage 

func (*ConcludeTransactionResponse) ProtoMessage()

func (*ConcludeTransactionResponse) ProtoReflect 

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

func (*ConcludeTransactionResponse) Reset 

func (x *ConcludeTransactionResponse) Reset()

func (*ConcludeTransactionResponse) String 

func (x *ConcludeTransactionResponse) String() string

type ConcludeTransactionResponse_builder 

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

func (ConcludeTransactionResponse_builder) Build 

func (b0 ConcludeTransactionResponse_builder) Build() *ConcludeTransactionResponse

type CreateTransactionRequest 

type CreateTransactionRequest struct {
	EffectiveCallerId *dev1.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) ClearEffectiveCallerId 

func (x *CreateTransactionRequest) ClearEffectiveCallerId()

func (*CreateTransactionRequest) ClearImmediateCallerId 

func (x *CreateTransactionRequest) ClearImmediateCallerId()

func (*CreateTransactionRequest) ClearTarget 

func (x *CreateTransactionRequest) ClearTarget()

func (*CreateTransactionRequest) GetDtid 

func (x *CreateTransactionRequest) GetDtid() string

func (*CreateTransactionRequest) GetEffectiveCallerId 

func (x *CreateTransactionRequest) GetEffectiveCallerId() *dev1.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) HasEffectiveCallerId 

func (x *CreateTransactionRequest) HasEffectiveCallerId() bool

func (*CreateTransactionRequest) HasImmediateCallerId 

func (x *CreateTransactionRequest) HasImmediateCallerId() bool

func (*CreateTransactionRequest) HasTarget 

func (x *CreateTransactionRequest) HasTarget() bool

func (*CreateTransactionRequest) ProtoMessage 

func (*CreateTransactionRequest) ProtoMessage()

func (*CreateTransactionRequest) ProtoReflect 

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

func (*CreateTransactionRequest) Reset 

func (x *CreateTransactionRequest) Reset()

func (*CreateTransactionRequest) SetDtid 

func (x *CreateTransactionRequest) SetDtid(v string)

func (*CreateTransactionRequest) SetEffectiveCallerId 

func (x *CreateTransactionRequest) SetEffectiveCallerId(v *dev1.CallerID)

func (*CreateTransactionRequest) SetImmediateCallerId 

func (x *CreateTransactionRequest) SetImmediateCallerId(v *VTGateCallerID)

func (*CreateTransactionRequest) SetParticipants 

func (x *CreateTransactionRequest) SetParticipants(v []*Target)

func (*CreateTransactionRequest) SetTarget 

func (x *CreateTransactionRequest) SetTarget(v *Target)

func (*CreateTransactionRequest) String 

func (x *CreateTransactionRequest) String() string

type CreateTransactionRequest_builder 

type CreateTransactionRequest_builder struct {
	EffectiveCallerId *dev1.CallerID
	ImmediateCallerId *VTGateCallerID
	Target            *Target
	Dtid              string
	Participants      []*Target
	// contains filtered or unexported fields
}

func (CreateTransactionRequest_builder) Build 

func (b0 CreateTransactionRequest_builder) Build() *CreateTransactionRequest

type CreateTransactionResponse 

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

CreateTransactionResponse is the returned value from CreateTransaction

func (*CreateTransactionResponse) ProtoMessage 

func (*CreateTransactionResponse) ProtoMessage()

func (*CreateTransactionResponse) ProtoReflect 

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

func (*CreateTransactionResponse) Reset 

func (x *CreateTransactionResponse) Reset()

func (*CreateTransactionResponse) String 

func (x *CreateTransactionResponse) String() string

type CreateTransactionResponse_builder 

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

func (CreateTransactionResponse_builder) Build 

func (b0 CreateTransactionResponse_builder) Build() *CreateTransactionResponse

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) GetPosition 

func (x *EventToken) GetPosition() string

func (*EventToken) GetShard 

func (x *EventToken) GetShard() string

func (*EventToken) GetTimestamp 

func (x *EventToken) GetTimestamp() int64

func (*EventToken) ProtoMessage 

func (*EventToken) ProtoMessage()

func (*EventToken) ProtoReflect 

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

func (*EventToken) Reset 

func (x *EventToken) Reset()

func (*EventToken) SetPosition 

func (x *EventToken) SetPosition(v string)

func (*EventToken) SetShard 

func (x *EventToken) SetShard(v string)

func (*EventToken) SetTimestamp 

func (x *EventToken) SetTimestamp(v int64)

func (*EventToken) String 

func (x *EventToken) String() string

type EventToken_builder 

type EventToken_builder struct {

	// timestamp is the MySQL timestamp of the statements. Seconds since Epoch.
	Timestamp int64
	// 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
	// The position on the replication stream after this statement was applied.
	// It is not the transaction ID / GTID, but the position / GTIDSet.
	Position string
	// contains filtered or unexported fields
}

func (EventToken_builder) Build 

func (b0 EventToken_builder) Build() *EventToken

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 `` /* 156-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=vitess.query.dev.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 `` /* 180-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 `` /* 157-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 */
	Consolidator         ExecuteOptions_Consolidator `` /* 129-byte string literal not displayed */
	// TransactionAccessMode specifies the access modes to be used while starting the transaction i.e. READ WRITE/READ ONLY/WITH CONSISTENT SNAPSHOT
	// If not specified, the transaction will be started with the default access mode on the connection.
	TransactionAccessMode []ExecuteOptions_TransactionAccessMode `` /* 194-byte string literal not displayed */
	// WorkloadName specifies the name of the workload as indicated in query directives. This is used for instrumentation
	// in metrics and tracing spans.
	WorkloadName string `protobuf:"bytes,15,opt,name=WorkloadName,proto3" json:"WorkloadName,omitempty"`
	// priority specifies the priority of the query, between 0 and 100. This is leveraged by the transaction
	// throttler to determine whether, under resource contention, a query should or should not be throttled.
	Priority string `protobuf:"bytes,16,opt,name=priority,proto3" json:"priority,omitempty"`
	// timeout specifies the query timeout in milliseconds. If not set, the default timeout is used.
	//
	// Types that are valid to be assigned to Timeout:
	//
	//	*ExecuteOptions_AuthoritativeTimeout
	Timeout isExecuteOptions_Timeout `protobuf_oneof:"timeout"`
	// fetch_last_insert_id indicates that after executing a DML involving last_insert_id(x),
	// a subsequent "SELECT last_insert_id()" should be performed to retrieve the updated value.
	// This is to circumvent a bug where setting last_insert_id(x) to zero is not signaled by mysql
	// https://bugs.mysql.com/bug.php?id=116939
	FetchLastInsertId bool `protobuf:"varint,18,opt,name=fetch_last_insert_id,json=fetchLastInsertId,proto3" json:"fetch_last_insert_id,omitempty"`
	// in_dml_execution indicates that the query is being executed as part of a DML execution.
	InDmlExecution bool `protobuf:"varint,19,opt,name=in_dml_execution,json=inDmlExecution,proto3" json:"in_dml_execution,omitempty"`
	// contains filtered or unexported fields
}

ExecuteOptions is passed around for all Execute calls.

func (*ExecuteOptions) ClearAuthoritativeTimeout 

func (x *ExecuteOptions) ClearAuthoritativeTimeout()

func (*ExecuteOptions) ClearTimeout 

func (x *ExecuteOptions) ClearTimeout()

func (*ExecuteOptions) GetAuthoritativeTimeout 

func (x *ExecuteOptions) GetAuthoritativeTimeout() int64

func (*ExecuteOptions) GetClientFoundRows 

func (x *ExecuteOptions) GetClientFoundRows() bool

func (*ExecuteOptions) GetConsolidator 

func (x *ExecuteOptions) GetConsolidator() ExecuteOptions_Consolidator

func (*ExecuteOptions) GetFetchLastInsertId 

func (x *ExecuteOptions) GetFetchLastInsertId() bool

func (*ExecuteOptions) GetHasCreatedTempTables 

func (x *ExecuteOptions) GetHasCreatedTempTables() bool

func (*ExecuteOptions) GetInDmlExecution 

func (x *ExecuteOptions) GetInDmlExecution() bool

func (*ExecuteOptions) GetIncludedFields 

func (x *ExecuteOptions) GetIncludedFields() ExecuteOptions_IncludedFields

func (*ExecuteOptions) GetPlannerVersion 

func (x *ExecuteOptions) GetPlannerVersion() ExecuteOptions_PlannerVersion

func (*ExecuteOptions) GetPriority 

func (x *ExecuteOptions) GetPriority() string

func (*ExecuteOptions) GetSkipQueryPlanCache 

func (x *ExecuteOptions) GetSkipQueryPlanCache() bool

func (*ExecuteOptions) GetSqlSelectLimit 

func (x *ExecuteOptions) GetSqlSelectLimit() int64

func (*ExecuteOptions) GetTimeout 

func (x *ExecuteOptions) GetTimeout() isExecuteOptions_Timeout

func (*ExecuteOptions) GetTransactionAccessMode 

func (x *ExecuteOptions) GetTransactionAccessMode() []ExecuteOptions_TransactionAccessMode

func (*ExecuteOptions) GetTransactionIsolation 

func (x *ExecuteOptions) GetTransactionIsolation() ExecuteOptions_TransactionIsolation

func (*ExecuteOptions) GetWorkload 

func (x *ExecuteOptions) GetWorkload() ExecuteOptions_Workload

func (*ExecuteOptions) GetWorkloadName 

func (x *ExecuteOptions) GetWorkloadName() string

func (*ExecuteOptions) HasAuthoritativeTimeout 

func (x *ExecuteOptions) HasAuthoritativeTimeout() bool

func (*ExecuteOptions) HasTimeout 

func (x *ExecuteOptions) HasTimeout() bool

func (*ExecuteOptions) ProtoMessage 

func (*ExecuteOptions) ProtoMessage()

func (*ExecuteOptions) ProtoReflect 

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

func (*ExecuteOptions) Reset 

func (x *ExecuteOptions) Reset()

func (*ExecuteOptions) SetAuthoritativeTimeout 

func (x *ExecuteOptions) SetAuthoritativeTimeout(v int64)

func (*ExecuteOptions) SetClientFoundRows 

func (x *ExecuteOptions) SetClientFoundRows(v bool)

func (*ExecuteOptions) SetConsolidator 

func (x *ExecuteOptions) SetConsolidator(v ExecuteOptions_Consolidator)

func (*ExecuteOptions) SetFetchLastInsertId 

func (x *ExecuteOptions) SetFetchLastInsertId(v bool)

func (*ExecuteOptions) SetHasCreatedTempTables 

func (x *ExecuteOptions) SetHasCreatedTempTables(v bool)

func (*ExecuteOptions) SetInDmlExecution 

func (x *ExecuteOptions) SetInDmlExecution(v bool)

func (*ExecuteOptions) SetIncludedFields 

func (x *ExecuteOptions) SetIncludedFields(v ExecuteOptions_IncludedFields)

func (*ExecuteOptions) SetPlannerVersion 

func (x *ExecuteOptions) SetPlannerVersion(v ExecuteOptions_PlannerVersion)

func (*ExecuteOptions) SetPriority 

func (x *ExecuteOptions) SetPriority(v string)

func (*ExecuteOptions) SetSkipQueryPlanCache 

func (x *ExecuteOptions) SetSkipQueryPlanCache(v bool)

func (*ExecuteOptions) SetSqlSelectLimit 

func (x *ExecuteOptions) SetSqlSelectLimit(v int64)

func (*ExecuteOptions) SetTransactionAccessMode 

func (x *ExecuteOptions) SetTransactionAccessMode(v []ExecuteOptions_TransactionAccessMode)

func (*ExecuteOptions) SetTransactionIsolation 

func (x *ExecuteOptions) SetTransactionIsolation(v ExecuteOptions_TransactionIsolation)

func (*ExecuteOptions) SetWorkload 

func (x *ExecuteOptions) SetWorkload(v ExecuteOptions_Workload)

func (*ExecuteOptions) SetWorkloadName 

func (x *ExecuteOptions) SetWorkloadName(v string)

func (*ExecuteOptions) String 

func (x *ExecuteOptions) String() string

func (*ExecuteOptions) WhichTimeout 

func (x *ExecuteOptions) WhichTimeout() case_ExecuteOptions_Timeout

type ExecuteOptions_AuthoritativeTimeout 

type ExecuteOptions_AuthoritativeTimeout struct {
	AuthoritativeTimeout int64 `protobuf:"varint,17,opt,name=authoritative_timeout,json=authoritativeTimeout,proto3,oneof"`
}

type ExecuteOptions_Consolidator 

type ExecuteOptions_Consolidator int32
const (
	ExecuteOptions_CONSOLIDATOR_UNSPECIFIED      ExecuteOptions_Consolidator = 0
	ExecuteOptions_CONSOLIDATOR_DISABLED         ExecuteOptions_Consolidator = 1
	ExecuteOptions_CONSOLIDATOR_ENABLED          ExecuteOptions_Consolidator = 2
	ExecuteOptions_CONSOLIDATOR_ENABLED_REPLICAS ExecuteOptions_Consolidator = 3
)

func (ExecuteOptions_Consolidator) Descriptor 

func (ExecuteOptions_Consolidator) Descriptor() protoreflect.EnumDescriptor

func (ExecuteOptions_Consolidator) Enum 

func (x ExecuteOptions_Consolidator) Enum() *ExecuteOptions_Consolidator

func (ExecuteOptions_Consolidator) Number 

func (x ExecuteOptions_Consolidator) Number() protoreflect.EnumNumber

func (ExecuteOptions_Consolidator) String 

func (x ExecuteOptions_Consolidator) String() string

func (ExecuteOptions_Consolidator) Type 

func (ExecuteOptions_Consolidator) Type() protoreflect.EnumType

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 

func (ExecuteOptions_IncludedFields) Descriptor() protoreflect.EnumDescriptor

func (ExecuteOptions_IncludedFields) Enum 

func (x ExecuteOptions_IncludedFields) Enum() *ExecuteOptions_IncludedFields

func (ExecuteOptions_IncludedFields) Number 

func (x ExecuteOptions_IncludedFields) Number() protoreflect.EnumNumber

func (ExecuteOptions_IncludedFields) String 

func (x ExecuteOptions_IncludedFields) String() string

func (ExecuteOptions_IncludedFields) Type 

func (ExecuteOptions_IncludedFields) Type() protoreflect.EnumType

type ExecuteOptions_PlannerVersion 

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
	ExecuteOptions_Gen4CompareV3    ExecuteOptions_PlannerVersion = 6
	ExecuteOptions_V3Insert         ExecuteOptions_PlannerVersion = 7
)

func (ExecuteOptions_PlannerVersion) Descriptor 

func (ExecuteOptions_PlannerVersion) Descriptor() protoreflect.EnumDescriptor

func (ExecuteOptions_PlannerVersion) Enum 

func (x ExecuteOptions_PlannerVersion) Enum() *ExecuteOptions_PlannerVersion

func (ExecuteOptions_PlannerVersion) Number 

func (x ExecuteOptions_PlannerVersion) Number() protoreflect.EnumNumber

func (ExecuteOptions_PlannerVersion) String 

func (x ExecuteOptions_PlannerVersion) String() string

func (ExecuteOptions_PlannerVersion) Type 

func (ExecuteOptions_PlannerVersion) Type() protoreflect.EnumType

type ExecuteOptions_TransactionAccessMode 

type ExecuteOptions_TransactionAccessMode int32
const (
	ExecuteOptions_CONSISTENT_SNAPSHOT ExecuteOptions_TransactionAccessMode = 0
	ExecuteOptions_READ_WRITE          ExecuteOptions_TransactionAccessMode = 1
	ExecuteOptions_READ_ONLY           ExecuteOptions_TransactionAccessMode = 2
)

func (ExecuteOptions_TransactionAccessMode) Descriptor 

func (ExecuteOptions_TransactionAccessMode) Descriptor() protoreflect.EnumDescriptor

func (ExecuteOptions_TransactionAccessMode) Enum 

func (x ExecuteOptions_TransactionAccessMode) Enum() *ExecuteOptions_TransactionAccessMode

func (ExecuteOptions_TransactionAccessMode) Number 

func (x ExecuteOptions_TransactionAccessMode) Number() protoreflect.EnumNumber

func (ExecuteOptions_TransactionAccessMode) String 

func (x ExecuteOptions_TransactionAccessMode) String() string

func (ExecuteOptions_TransactionAccessMode) Type 

func (ExecuteOptions_TransactionAccessMode) Type() protoreflect.EnumType

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 

func (ExecuteOptions_TransactionIsolation) Descriptor() protoreflect.EnumDescriptor

func (ExecuteOptions_TransactionIsolation) Enum 

func (x ExecuteOptions_TransactionIsolation) Enum() *ExecuteOptions_TransactionIsolation

func (ExecuteOptions_TransactionIsolation) Number 

func (x ExecuteOptions_TransactionIsolation) Number() protoreflect.EnumNumber

func (ExecuteOptions_TransactionIsolation) String 

func (x ExecuteOptions_TransactionIsolation) String() string

func (ExecuteOptions_TransactionIsolation) Type 

func (ExecuteOptions_TransactionIsolation) Type() protoreflect.EnumType

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 

func (ExecuteOptions_Workload) Descriptor() protoreflect.EnumDescriptor

func (ExecuteOptions_Workload) Enum 

func (x ExecuteOptions_Workload) Enum() *ExecuteOptions_Workload

func (ExecuteOptions_Workload) Number 

func (x ExecuteOptions_Workload) Number() protoreflect.EnumNumber

func (ExecuteOptions_Workload) String 

func (x ExecuteOptions_Workload) String() string

func (ExecuteOptions_Workload) Type 

func (ExecuteOptions_Workload) Type() protoreflect.EnumType

type ExecuteOptions_builder 

type ExecuteOptions_builder 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
	// 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
	// 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
	// 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
	TransactionIsolation ExecuteOptions_TransactionIsolation
	// skip_query_plan_cache specifies if the query plan should be cached by vitess.
	// By default all query plans are cached.
	SkipQueryPlanCache bool
	// PlannerVersion specifies which planner to use.
	// If DEFAULT is chosen, whatever vtgate was started with will be used
	PlannerVersion ExecuteOptions_PlannerVersion
	// 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
	Consolidator         ExecuteOptions_Consolidator
	// TransactionAccessMode specifies the access modes to be used while starting the transaction i.e. READ WRITE/READ ONLY/WITH CONSISTENT SNAPSHOT
	// If not specified, the transaction will be started with the default access mode on the connection.
	TransactionAccessMode []ExecuteOptions_TransactionAccessMode
	// WorkloadName specifies the name of the workload as indicated in query directives. This is used for instrumentation
	// in metrics and tracing spans.
	WorkloadName string
	// priority specifies the priority of the query, between 0 and 100. This is leveraged by the transaction
	// throttler to determine whether, under resource contention, a query should or should not be throttled.
	Priority string

	// Fields of oneof Timeout:
	AuthoritativeTimeout *int64
	// -- end of Timeout
	// fetch_last_insert_id indicates that after executing a DML involving last_insert_id(x),
	// a subsequent "SELECT last_insert_id()" should be performed to retrieve the updated value.
	// This is to circumvent a bug where setting last_insert_id(x) to zero is not signaled by mysql
	// https://bugs.mysql.com/bug.php?id=116939
	FetchLastInsertId bool
	// in_dml_execution indicates that the query is being executed as part of a DML execution.
	InDmlExecution bool
	// contains filtered or unexported fields
}

func (ExecuteOptions_builder) Build 

func (b0 ExecuteOptions_builder) Build() *ExecuteOptions

type ExecuteRequest 

type ExecuteRequest struct {
	EffectiveCallerId *dev1.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) ClearEffectiveCallerId 

func (x *ExecuteRequest) ClearEffectiveCallerId()

func (*ExecuteRequest) ClearImmediateCallerId 

func (x *ExecuteRequest) ClearImmediateCallerId()

func (*ExecuteRequest) ClearOptions 

func (x *ExecuteRequest) ClearOptions()

func (*ExecuteRequest) ClearQuery 

func (x *ExecuteRequest) ClearQuery()

func (*ExecuteRequest) ClearTarget 

func (x *ExecuteRequest) ClearTarget()

func (*ExecuteRequest) GetEffectiveCallerId 

func (x *ExecuteRequest) GetEffectiveCallerId() *dev1.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) HasEffectiveCallerId 

func (x *ExecuteRequest) HasEffectiveCallerId() bool

func (*ExecuteRequest) HasImmediateCallerId 

func (x *ExecuteRequest) HasImmediateCallerId() bool

func (*ExecuteRequest) HasOptions 

func (x *ExecuteRequest) HasOptions() bool

func (*ExecuteRequest) HasQuery 

func (x *ExecuteRequest) HasQuery() bool

func (*ExecuteRequest) HasTarget 

func (x *ExecuteRequest) HasTarget() bool

func (*ExecuteRequest) ProtoMessage 

func (*ExecuteRequest) ProtoMessage()

func (*ExecuteRequest) ProtoReflect 

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

func (*ExecuteRequest) Reset 

func (x *ExecuteRequest) Reset()

func (*ExecuteRequest) SetEffectiveCallerId 

func (x *ExecuteRequest) SetEffectiveCallerId(v *dev1.CallerID)

func (*ExecuteRequest) SetImmediateCallerId 

func (x *ExecuteRequest) SetImmediateCallerId(v *VTGateCallerID)

func (*ExecuteRequest) SetOptions 

func (x *ExecuteRequest) SetOptions(v *ExecuteOptions)

func (*ExecuteRequest) SetQuery 

func (x *ExecuteRequest) SetQuery(v *BoundQuery)

func (*ExecuteRequest) SetReservedId 

func (x *ExecuteRequest) SetReservedId(v int64)

func (*ExecuteRequest) SetTarget 

func (x *ExecuteRequest) SetTarget(v *Target)

func (*ExecuteRequest) SetTransactionId 

func (x *ExecuteRequest) SetTransactionId(v int64)

func (*ExecuteRequest) String 

func (x *ExecuteRequest) String() string

type ExecuteRequest_builder 

type ExecuteRequest_builder struct {
	EffectiveCallerId *dev1.CallerID
	ImmediateCallerId *VTGateCallerID
	Target            *Target
	Query             *BoundQuery
	TransactionId     int64
	Options           *ExecuteOptions
	ReservedId        int64
	// contains filtered or unexported fields
}

func (ExecuteRequest_builder) Build 

func (b0 ExecuteRequest_builder) Build() *ExecuteRequest

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) ClearResult 

func (x *ExecuteResponse) ClearResult()

func (*ExecuteResponse) GetResult 

func (x *ExecuteResponse) GetResult() *QueryResult

func (*ExecuteResponse) HasResult 

func (x *ExecuteResponse) HasResult() bool

func (*ExecuteResponse) ProtoMessage 

func (*ExecuteResponse) ProtoMessage()

func (*ExecuteResponse) ProtoReflect 

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

func (*ExecuteResponse) Reset 

func (x *ExecuteResponse) Reset()

func (*ExecuteResponse) SetResult 

func (x *ExecuteResponse) SetResult(v *QueryResult)

func (*ExecuteResponse) String 

func (x *ExecuteResponse) String() string

type ExecuteResponse_builder 

type ExecuteResponse_builder struct {
	Result *QueryResult
	// contains filtered or unexported fields
}

func (ExecuteResponse_builder) Build 

func (b0 ExecuteResponse_builder) Build() *ExecuteResponse

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=vitess.query.dev.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) GetCharset 

func (x *Field) GetCharset() uint32

func (*Field) GetColumnLength 

func (x *Field) GetColumnLength() uint32

func (*Field) GetColumnType 

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) ProtoMessage 

func (*Field) ProtoMessage()

func (*Field) ProtoReflect 

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

func (*Field) Reset 

func (x *Field) Reset()

func (*Field) SetCharset 

func (x *Field) SetCharset(v uint32)

func (*Field) SetColumnLength 

func (x *Field) SetColumnLength(v uint32)

func (*Field) SetColumnType 

func (x *Field) SetColumnType(v string)

func (*Field) SetDatabase 

func (x *Field) SetDatabase(v string)

func (*Field) SetDecimals 

func (x *Field) SetDecimals(v uint32)

func (*Field) SetFlags 

func (x *Field) SetFlags(v uint32)

func (*Field) SetName 

func (x *Field) SetName(v string)

func (*Field) SetOrgName 

func (x *Field) SetOrgName(v string)

func (*Field) SetOrgTable 

func (x *Field) SetOrgTable(v string)

func (*Field) SetTable 

func (x *Field) SetTable(v string)

func (*Field) SetType 

func (x *Field) SetType(v Type)

func (*Field) String 

func (x *Field) String() string

type Field_builder 

type Field_builder struct {

	// name of the field as returned by mysql C API
	Name string
	// vitess-defined type. Conversion function is in sqltypes package.
	Type Type
	// Remaining fields from mysql C API.
	// These fields are only populated when ExecuteOptions.included_fields
	// is set to IncludedFields.ALL.
	Table    string
	OrgTable string
	Database string
	OrgName  string
	// column_length is really a uint32. All 32 bits can be used.
	ColumnLength uint32
	// charset is actually a uint16. Only the lower 16 bits are used.
	Charset uint32
	// decimals is actually a uint8. Only the lower 8 bits are used.
	Decimals uint32
	// flags is actually a uint16. Only the lower 16 bits are used.
	Flags uint32
	// column_type is optionally populated from information_schema.columns
	ColumnType string
	// contains filtered or unexported fields
}

func (Field_builder) Build 

func (b0 Field_builder) Build() *Field

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 

func (Flag) Descriptor() protoreflect.EnumDescriptor

func (Flag) Enum 

func (x Flag) Enum() *Flag

func (Flag) Number 

func (x Flag) Number() protoreflect.EnumNumber

func (Flag) String 

func (x Flag) String() string

func (Flag) Type 

func (Flag) Type() protoreflect.EnumType

type GetSchemaRequest 

type GetSchemaRequest struct {
	Target     *Target         `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	TableType  SchemaTableType `` /* 127-byte string literal not displayed */
	TableNames []string        `protobuf:"bytes,3,rep,name=table_names,json=tableNames,proto3" json:"table_names,omitempty"`
	// contains filtered or unexported fields
}

GetSchemaRequest is the payload to GetSchema

func (*GetSchemaRequest) ClearTarget 

func (x *GetSchemaRequest) ClearTarget()

func (*GetSchemaRequest) GetTableNames 

func (x *GetSchemaRequest) GetTableNames() []string

func (*GetSchemaRequest) GetTableType 

func (x *GetSchemaRequest) GetTableType() SchemaTableType

func (*GetSchemaRequest) GetTarget 

func (x *GetSchemaRequest) GetTarget() *Target

func (*GetSchemaRequest) HasTarget 

func (x *GetSchemaRequest) HasTarget() bool

func (*GetSchemaRequest) ProtoMessage 

func (*GetSchemaRequest) ProtoMessage()

func (*GetSchemaRequest) ProtoReflect 

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

func (*GetSchemaRequest) Reset 

func (x *GetSchemaRequest) Reset()

func (*GetSchemaRequest) SetTableNames 

func (x *GetSchemaRequest) SetTableNames(v []string)

func (*GetSchemaRequest) SetTableType 

func (x *GetSchemaRequest) SetTableType(v SchemaTableType)

func (*GetSchemaRequest) SetTarget 

func (x *GetSchemaRequest) SetTarget(v *Target)

func (*GetSchemaRequest) String 

func (x *GetSchemaRequest) String() string

type GetSchemaRequest_builder 

type GetSchemaRequest_builder struct {
	Target     *Target
	TableType  SchemaTableType
	TableNames []string
	// contains filtered or unexported fields
}

func (GetSchemaRequest_builder) Build 

func (b0 GetSchemaRequest_builder) Build() *GetSchemaRequest

type GetSchemaResponse 

type GetSchemaResponse struct {
	Udfs []*UDFInfo `protobuf:"bytes,1,rep,name=udfs,proto3" json:"udfs,omitempty"`
	// this is for the schema definition for the requested tables and views.
	TableDefinition map[string]string `` /* 180-byte string literal not displayed */
	// contains filtered or unexported fields
}

GetSchemaResponse is the returned value from GetSchema

func (*GetSchemaResponse) GetTableDefinition 

func (x *GetSchemaResponse) GetTableDefinition() map[string]string

func (*GetSchemaResponse) GetUdfs 

func (x *GetSchemaResponse) GetUdfs() []*UDFInfo

func (*GetSchemaResponse) ProtoMessage 

func (*GetSchemaResponse) ProtoMessage()

func (*GetSchemaResponse) ProtoReflect 

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

func (*GetSchemaResponse) Reset 

func (x *GetSchemaResponse) Reset()

func (*GetSchemaResponse) SetTableDefinition 

func (x *GetSchemaResponse) SetTableDefinition(v map[string]string)

func (*GetSchemaResponse) SetUdfs 

func (x *GetSchemaResponse) SetUdfs(v []*UDFInfo)

func (*GetSchemaResponse) String 

func (x *GetSchemaResponse) String() string

type GetSchemaResponse_builder 

type GetSchemaResponse_builder struct {
	Udfs []*UDFInfo
	// this is for the schema definition for the requested tables and views.
	TableDefinition map[string]string
	// contains filtered or unexported fields
}

func (GetSchemaResponse_builder) Build 

func (b0 GetSchemaResponse_builder) Build() *GetSchemaResponse

type MessageAckRequest 

type MessageAckRequest struct {
	EffectiveCallerId *dev1.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) ClearEffectiveCallerId 

func (x *MessageAckRequest) ClearEffectiveCallerId()

func (*MessageAckRequest) ClearImmediateCallerId 

func (x *MessageAckRequest) ClearImmediateCallerId()

func (*MessageAckRequest) ClearTarget 

func (x *MessageAckRequest) ClearTarget()

func (*MessageAckRequest) GetEffectiveCallerId 

func (x *MessageAckRequest) GetEffectiveCallerId() *dev1.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) HasEffectiveCallerId 

func (x *MessageAckRequest) HasEffectiveCallerId() bool

func (*MessageAckRequest) HasImmediateCallerId 

func (x *MessageAckRequest) HasImmediateCallerId() bool

func (*MessageAckRequest) HasTarget 

func (x *MessageAckRequest) HasTarget() bool

func (*MessageAckRequest) ProtoMessage 

func (*MessageAckRequest) ProtoMessage()

func (*MessageAckRequest) ProtoReflect 

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

func (*MessageAckRequest) Reset 

func (x *MessageAckRequest) Reset()

func (*MessageAckRequest) SetEffectiveCallerId 

func (x *MessageAckRequest) SetEffectiveCallerId(v *dev1.CallerID)

func (*MessageAckRequest) SetIds 

func (x *MessageAckRequest) SetIds(v []*Value)

func (*MessageAckRequest) SetImmediateCallerId 

func (x *MessageAckRequest) SetImmediateCallerId(v *VTGateCallerID)

func (*MessageAckRequest) SetName 

func (x *MessageAckRequest) SetName(v string)

func (*MessageAckRequest) SetTarget 

func (x *MessageAckRequest) SetTarget(v *Target)

func (*MessageAckRequest) String 

func (x *MessageAckRequest) String() string

type MessageAckRequest_builder 

type MessageAckRequest_builder struct {
	EffectiveCallerId *dev1.CallerID
	ImmediateCallerId *VTGateCallerID
	Target            *Target
	// name is the message table name.
	Name string
	Ids  []*Value
	// contains filtered or unexported fields
}

func (MessageAckRequest_builder) Build 

func (b0 MessageAckRequest_builder) Build() *MessageAckRequest

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) ClearResult 

func (x *MessageAckResponse) ClearResult()

func (*MessageAckResponse) GetResult 

func (x *MessageAckResponse) GetResult() *QueryResult

func (*MessageAckResponse) HasResult 

func (x *MessageAckResponse) HasResult() bool

func (*MessageAckResponse) ProtoMessage 

func (*MessageAckResponse) ProtoMessage()

func (*MessageAckResponse) ProtoReflect 

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

func (*MessageAckResponse) Reset 

func (x *MessageAckResponse) Reset()

func (*MessageAckResponse) SetResult 

func (x *MessageAckResponse) SetResult(v *QueryResult)

func (*MessageAckResponse) String 

func (x *MessageAckResponse) String() string

type MessageAckResponse_builder 

type MessageAckResponse_builder struct {

	// result contains the result of the ack operation.
	// Since this acts like a DML, only
	// RowsAffected is returned in the result.
	Result *QueryResult
	// contains filtered or unexported fields
}

func (MessageAckResponse_builder) Build 

func (b0 MessageAckResponse_builder) Build() *MessageAckResponse

type MessageStreamRequest 

type MessageStreamRequest struct {
	EffectiveCallerId *dev1.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) ClearEffectiveCallerId 

func (x *MessageStreamRequest) ClearEffectiveCallerId()

func (*MessageStreamRequest) ClearImmediateCallerId 

func (x *MessageStreamRequest) ClearImmediateCallerId()

func (*MessageStreamRequest) ClearTarget 

func (x *MessageStreamRequest) ClearTarget()

func (*MessageStreamRequest) GetEffectiveCallerId 

func (x *MessageStreamRequest) GetEffectiveCallerId() *dev1.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) HasEffectiveCallerId 

func (x *MessageStreamRequest) HasEffectiveCallerId() bool

func (*MessageStreamRequest) HasImmediateCallerId 

func (x *MessageStreamRequest) HasImmediateCallerId() bool

func (*MessageStreamRequest) HasTarget 

func (x *MessageStreamRequest) HasTarget() bool

func (*MessageStreamRequest) ProtoMessage 

func (*MessageStreamRequest) ProtoMessage()

func (*MessageStreamRequest) ProtoReflect 

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

func (*MessageStreamRequest) Reset 

func (x *MessageStreamRequest) Reset()

func (*MessageStreamRequest) SetEffectiveCallerId 

func (x *MessageStreamRequest) SetEffectiveCallerId(v *dev1.CallerID)

func (*MessageStreamRequest) SetImmediateCallerId 

func (x *MessageStreamRequest) SetImmediateCallerId(v *VTGateCallerID)

func (*MessageStreamRequest) SetName 

func (x *MessageStreamRequest) SetName(v string)

func (*MessageStreamRequest) SetTarget 

func (x *MessageStreamRequest) SetTarget(v *Target)

func (*MessageStreamRequest) String 

func (x *MessageStreamRequest) String() string

type MessageStreamRequest_builder 

type MessageStreamRequest_builder struct {
	EffectiveCallerId *dev1.CallerID
	ImmediateCallerId *VTGateCallerID
	Target            *Target
	// name is the message table name.
	Name string
	// contains filtered or unexported fields
}

func (MessageStreamRequest_builder) Build 

func (b0 MessageStreamRequest_builder) Build() *MessageStreamRequest

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) ClearResult 

func (x *MessageStreamResponse) ClearResult()

func (*MessageStreamResponse) GetResult 

func (x *MessageStreamResponse) GetResult() *QueryResult

func (*MessageStreamResponse) HasResult 

func (x *MessageStreamResponse) HasResult() bool

func (*MessageStreamResponse) ProtoMessage 

func (*MessageStreamResponse) ProtoMessage()

func (*MessageStreamResponse) ProtoReflect 

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

func (*MessageStreamResponse) Reset 

func (x *MessageStreamResponse) Reset()

func (*MessageStreamResponse) SetResult 

func (x *MessageStreamResponse) SetResult(v *QueryResult)

func (*MessageStreamResponse) String 

func (x *MessageStreamResponse) String() string

type MessageStreamResponse_builder 

type MessageStreamResponse_builder struct {
	Result *QueryResult
	// contains filtered or unexported fields
}

func (MessageStreamResponse_builder) Build 

func (b0 MessageStreamResponse_builder) Build() *MessageStreamResponse

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 

func (MySqlFlag) Descriptor() protoreflect.EnumDescriptor

func (MySqlFlag) Enum 

func (x MySqlFlag) Enum() *MySqlFlag

func (MySqlFlag) Number 

func (x MySqlFlag) Number() protoreflect.EnumNumber

func (MySqlFlag) String 

func (x MySqlFlag) String() string

func (MySqlFlag) Type 

func (MySqlFlag) Type() protoreflect.EnumType

type PrepareRequest 

type PrepareRequest struct {
	EffectiveCallerId *dev1.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) ClearEffectiveCallerId 

func (x *PrepareRequest) ClearEffectiveCallerId()

func (*PrepareRequest) ClearImmediateCallerId 

func (x *PrepareRequest) ClearImmediateCallerId()

func (*PrepareRequest) ClearTarget 

func (x *PrepareRequest) ClearTarget()

func (*PrepareRequest) GetDtid 

func (x *PrepareRequest) GetDtid() string

func (*PrepareRequest) GetEffectiveCallerId 

func (x *PrepareRequest) GetEffectiveCallerId() *dev1.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) HasEffectiveCallerId 

func (x *PrepareRequest) HasEffectiveCallerId() bool

func (*PrepareRequest) HasImmediateCallerId 

func (x *PrepareRequest) HasImmediateCallerId() bool

func (*PrepareRequest) HasTarget 

func (x *PrepareRequest) HasTarget() bool

func (*PrepareRequest) ProtoMessage 

func (*PrepareRequest) ProtoMessage()

func (*PrepareRequest) ProtoReflect 

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

func (*PrepareRequest) Reset 

func (x *PrepareRequest) Reset()

func (*PrepareRequest) SetDtid 

func (x *PrepareRequest) SetDtid(v string)

func (*PrepareRequest) SetEffectiveCallerId 

func (x *PrepareRequest) SetEffectiveCallerId(v *dev1.CallerID)

func (*PrepareRequest) SetImmediateCallerId 

func (x *PrepareRequest) SetImmediateCallerId(v *VTGateCallerID)

func (*PrepareRequest) SetTarget 

func (x *PrepareRequest) SetTarget(v *Target)

func (*PrepareRequest) SetTransactionId 

func (x *PrepareRequest) SetTransactionId(v int64)

func (*PrepareRequest) String 

func (x *PrepareRequest) String() string

type PrepareRequest_builder 

type PrepareRequest_builder struct {
	EffectiveCallerId *dev1.CallerID
	ImmediateCallerId *VTGateCallerID
	Target            *Target
	TransactionId     int64
	Dtid              string
	// contains filtered or unexported fields
}

func (PrepareRequest_builder) Build 

func (b0 PrepareRequest_builder) Build() *PrepareRequest

type PrepareResponse 

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

PrepareResponse is the returned value from Prepare

func (*PrepareResponse) ProtoMessage 

func (*PrepareResponse) ProtoMessage()

func (*PrepareResponse) ProtoReflect 

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

func (*PrepareResponse) Reset 

func (x *PrepareResponse) Reset()

func (*PrepareResponse) String 

func (x *PrepareResponse) String() string

type PrepareResponse_builder 

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

func (PrepareResponse_builder) Build 

func (b0 PrepareResponse_builder) Build() *PrepareResponse

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"`
	Info                string   `protobuf:"bytes,6,opt,name=info,proto3" json:"info,omitempty"`
	SessionStateChanges string   `protobuf:"bytes,7,opt,name=session_state_changes,json=sessionStateChanges,proto3" json:"session_state_changes,omitempty"`
	InsertIdChanged     bool     `protobuf:"varint,8,opt,name=insert_id_changed,json=insertIdChanged,proto3" json:"insert_id_changed,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) GetFields 

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

func (*QueryResult) GetInfo 

func (x *QueryResult) GetInfo() string

func (*QueryResult) GetInsertId 

func (x *QueryResult) GetInsertId() uint64

func (*QueryResult) GetInsertIdChanged 

func (x *QueryResult) GetInsertIdChanged() bool

func (*QueryResult) GetRows 

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

func (*QueryResult) GetRowsAffected 

func (x *QueryResult) GetRowsAffected() uint64

func (*QueryResult) GetSessionStateChanges 

func (x *QueryResult) GetSessionStateChanges() string

func (*QueryResult) ProtoMessage 

func (*QueryResult) ProtoMessage()

func (*QueryResult) ProtoReflect 

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

func (*QueryResult) Reset 

func (x *QueryResult) Reset()

func (*QueryResult) SetFields 

func (x *QueryResult) SetFields(v []*Field)

func (*QueryResult) SetInfo 

func (x *QueryResult) SetInfo(v string)

func (*QueryResult) SetInsertId 

func (x *QueryResult) SetInsertId(v uint64)

func (*QueryResult) SetInsertIdChanged 

func (x *QueryResult) SetInsertIdChanged(v bool)

func (*QueryResult) SetRows 

func (x *QueryResult) SetRows(v []*Row)

func (*QueryResult) SetRowsAffected 

func (x *QueryResult) SetRowsAffected(v uint64)

func (*QueryResult) SetSessionStateChanges 

func (x *QueryResult) SetSessionStateChanges(v string)

func (*QueryResult) String 

func (x *QueryResult) String() string

type QueryResult_builder 

type QueryResult_builder struct {
	Fields              []*Field
	RowsAffected        uint64
	InsertId            uint64
	Rows                []*Row
	Info                string
	SessionStateChanges string
	InsertIdChanged     bool
	// contains filtered or unexported fields
}

func (QueryResult_builder) Build 

func (b0 QueryResult_builder) Build() *QueryResult

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) GetCode 

func (x *QueryWarning) GetCode() uint32

func (*QueryWarning) GetMessage 

func (x *QueryWarning) GetMessage() string

func (*QueryWarning) ProtoMessage 

func (*QueryWarning) ProtoMessage()

func (*QueryWarning) ProtoReflect 

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

func (*QueryWarning) Reset 

func (x *QueryWarning) Reset()

func (*QueryWarning) SetCode 

func (x *QueryWarning) SetCode(v uint32)

func (*QueryWarning) SetMessage 

func (x *QueryWarning) SetMessage(v string)

func (*QueryWarning) String 

func (x *QueryWarning) String() string

type QueryWarning_builder 

type QueryWarning_builder struct {
	Code    uint32
	Message string
	// contains filtered or unexported fields
}

func (QueryWarning_builder) Build 

func (b0 QueryWarning_builder) Build() *QueryWarning

type ReadTransactionRequest 

type ReadTransactionRequest struct {
	EffectiveCallerId *dev1.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) ClearEffectiveCallerId 

func (x *ReadTransactionRequest) ClearEffectiveCallerId()

func (*ReadTransactionRequest) ClearImmediateCallerId 

func (x *ReadTransactionRequest) ClearImmediateCallerId()

func (*ReadTransactionRequest) ClearTarget 

func (x *ReadTransactionRequest) ClearTarget()

func (*ReadTransactionRequest) GetDtid 

func (x *ReadTransactionRequest) GetDtid() string

func (*ReadTransactionRequest) GetEffectiveCallerId 

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

func (*ReadTransactionRequest) GetImmediateCallerId 

func (x *ReadTransactionRequest) GetImmediateCallerId() *VTGateCallerID

func (*ReadTransactionRequest) GetTarget 

func (x *ReadTransactionRequest) GetTarget() *Target

func (*ReadTransactionRequest) HasEffectiveCallerId 

func (x *ReadTransactionRequest) HasEffectiveCallerId() bool

func (*ReadTransactionRequest) HasImmediateCallerId 

func (x *ReadTransactionRequest) HasImmediateCallerId() bool

func (*ReadTransactionRequest) HasTarget 

func (x *ReadTransactionRequest) HasTarget() bool

func (*ReadTransactionRequest) ProtoMessage 

func (*ReadTransactionRequest) ProtoMessage()

func (*ReadTransactionRequest) ProtoReflect 

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

func (*ReadTransactionRequest) Reset 

func (x *ReadTransactionRequest) Reset()

func (*ReadTransactionRequest) SetDtid 

func (x *ReadTransactionRequest) SetDtid(v string)

func (*ReadTransactionRequest) SetEffectiveCallerId 

func (x *ReadTransactionRequest) SetEffectiveCallerId(v *dev1.CallerID)

func (*ReadTransactionRequest) SetImmediateCallerId 

func (x *ReadTransactionRequest) SetImmediateCallerId(v *VTGateCallerID)

func (*ReadTransactionRequest) SetTarget 

func (x *ReadTransactionRequest) SetTarget(v *Target)

func (*ReadTransactionRequest) String 

func (x *ReadTransactionRequest) String() string

type ReadTransactionRequest_builder 

type ReadTransactionRequest_builder struct {
	EffectiveCallerId *dev1.CallerID
	ImmediateCallerId *VTGateCallerID
	Target            *Target
	Dtid              string
	// contains filtered or unexported fields
}

func (ReadTransactionRequest_builder) Build 

func (b0 ReadTransactionRequest_builder) Build() *ReadTransactionRequest

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) ClearMetadata 

func (x *ReadTransactionResponse) ClearMetadata()

func (*ReadTransactionResponse) GetMetadata 

func (x *ReadTransactionResponse) GetMetadata() *TransactionMetadata

func (*ReadTransactionResponse) HasMetadata 

func (x *ReadTransactionResponse) HasMetadata() bool

func (*ReadTransactionResponse) ProtoMessage 

func (*ReadTransactionResponse) ProtoMessage()

func (*ReadTransactionResponse) ProtoReflect 

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

func (*ReadTransactionResponse) Reset 

func (x *ReadTransactionResponse) Reset()

func (*ReadTransactionResponse) SetMetadata 

func (x *ReadTransactionResponse) SetMetadata(v *TransactionMetadata)

func (*ReadTransactionResponse) String 

func (x *ReadTransactionResponse) String() string

type ReadTransactionResponse_builder 

type ReadTransactionResponse_builder struct {
	Metadata *TransactionMetadata
	// contains filtered or unexported fields
}

func (ReadTransactionResponse_builder) Build 

func (b0 ReadTransactionResponse_builder) Build() *ReadTransactionResponse

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"`
	// replication_lag_seconds 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?
	ReplicationLagSeconds uint32 `` /* 127-byte string literal not displayed */
	// 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"`
	// filtered_replication_lag_seconds is populated for the receiving
	// primary of an ongoing filtered replication only.
	// It specifies how far the receiving primary lags behind the sending primary.
	// 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.
	FilteredReplicationLagSeconds int64 `` /* 153-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"`
	// view_schema_changed is to provide list of views that have schema changes detected by the tablet.
	ViewSchemaChanged []string `protobuf:"bytes,8,rep,name=view_schema_changed,json=viewSchemaChanged,proto3" json:"view_schema_changed,omitempty"`
	// udfs_changed is used to signal that the UDFs have changed on the tablet.
	UdfsChanged  bool `protobuf:"varint,9,opt,name=udfs_changed,json=udfsChanged,proto3" json:"udfs_changed,omitempty"`
	TxUnresolved bool `protobuf:"varint,10,opt,name=tx_unresolved,json=txUnresolved,proto3" json:"tx_unresolved,omitempty"`
	// contains filtered or unexported fields
}

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

func (*RealtimeStats) GetBinlogPlayersCount 

func (x *RealtimeStats) GetBinlogPlayersCount() int32

func (*RealtimeStats) GetCpuUsage 

func (x *RealtimeStats) GetCpuUsage() float64

func (*RealtimeStats) GetFilteredReplicationLagSeconds 

func (x *RealtimeStats) GetFilteredReplicationLagSeconds() int64

func (*RealtimeStats) GetHealthError 

func (x *RealtimeStats) GetHealthError() string

func (*RealtimeStats) GetQps 

func (x *RealtimeStats) GetQps() float64

func (*RealtimeStats) GetReplicationLagSeconds 

func (x *RealtimeStats) GetReplicationLagSeconds() uint32

func (*RealtimeStats) GetTableSchemaChanged 

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

func (*RealtimeStats) GetTxUnresolved 

func (x *RealtimeStats) GetTxUnresolved() bool

func (*RealtimeStats) GetUdfsChanged 

func (x *RealtimeStats) GetUdfsChanged() bool

func (*RealtimeStats) GetViewSchemaChanged 

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

func (*RealtimeStats) ProtoMessage 

func (*RealtimeStats) ProtoMessage()

func (*RealtimeStats) ProtoReflect 

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

func (*RealtimeStats) Reset 

func (x *RealtimeStats) Reset()

func (*RealtimeStats) SetBinlogPlayersCount 

func (x *RealtimeStats) SetBinlogPlayersCount(v int32)

func (*RealtimeStats) SetCpuUsage 

func (x *RealtimeStats) SetCpuUsage(v float64)

func (*RealtimeStats) SetFilteredReplicationLagSeconds 

func (x *RealtimeStats) SetFilteredReplicationLagSeconds(v int64)

func (*RealtimeStats) SetHealthError 

func (x *RealtimeStats) SetHealthError(v string)

func (*RealtimeStats) SetQps 

func (x *RealtimeStats) SetQps(v float64)

func (*RealtimeStats) SetReplicationLagSeconds 

func (x *RealtimeStats) SetReplicationLagSeconds(v uint32)

func (*RealtimeStats) SetTableSchemaChanged 

func (x *RealtimeStats) SetTableSchemaChanged(v []string)

func (*RealtimeStats) SetTxUnresolved 

func (x *RealtimeStats) SetTxUnresolved(v bool)

func (*RealtimeStats) SetUdfsChanged 

func (x *RealtimeStats) SetUdfsChanged(v bool)

func (*RealtimeStats) SetViewSchemaChanged 

func (x *RealtimeStats) SetViewSchemaChanged(v []string)

func (*RealtimeStats) String 

func (x *RealtimeStats) String() string

type RealtimeStats_builder 

type RealtimeStats_builder 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
	// replication_lag_seconds 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?
	ReplicationLagSeconds uint32
	// 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
	// filtered_replication_lag_seconds is populated for the receiving
	// primary of an ongoing filtered replication only.
	// It specifies how far the receiving primary lags behind the sending primary.
	// 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.
	FilteredReplicationLagSeconds int64
	// cpu_usage is used for load-based balancing
	CpuUsage float64
	// 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
	// table_schema_changed is to provide list of tables that have schema changes detected by the tablet.
	TableSchemaChanged []string
	// view_schema_changed is to provide list of views that have schema changes detected by the tablet.
	ViewSchemaChanged []string
	// udfs_changed is used to signal that the UDFs have changed on the tablet.
	UdfsChanged  bool
	TxUnresolved bool
	// contains filtered or unexported fields
}

func (RealtimeStats_builder) Build 

func (b0 RealtimeStats_builder) Build() *RealtimeStats

type ReleaseRequest 

type ReleaseRequest struct {
	EffectiveCallerId *dev1.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) ClearEffectiveCallerId 

func (x *ReleaseRequest) ClearEffectiveCallerId()

func (*ReleaseRequest) ClearImmediateCallerId 

func (x *ReleaseRequest) ClearImmediateCallerId()

func (*ReleaseRequest) ClearTarget 

func (x *ReleaseRequest) ClearTarget()

func (*ReleaseRequest) GetEffectiveCallerId 

func (x *ReleaseRequest) GetEffectiveCallerId() *dev1.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) HasEffectiveCallerId 

func (x *ReleaseRequest) HasEffectiveCallerId() bool

func (*ReleaseRequest) HasImmediateCallerId 

func (x *ReleaseRequest) HasImmediateCallerId() bool

func (*ReleaseRequest) HasTarget 

func (x *ReleaseRequest) HasTarget() bool

func (*ReleaseRequest) ProtoMessage 

func (*ReleaseRequest) ProtoMessage()

func (*ReleaseRequest) ProtoReflect 

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

func (*ReleaseRequest) Reset 

func (x *ReleaseRequest) Reset()

func (*ReleaseRequest) SetEffectiveCallerId 

func (x *ReleaseRequest) SetEffectiveCallerId(v *dev1.CallerID)

func (*ReleaseRequest) SetImmediateCallerId 

func (x *ReleaseRequest) SetImmediateCallerId(v *VTGateCallerID)

func (*ReleaseRequest) SetReservedId 

func (x *ReleaseRequest) SetReservedId(v int64)

func (*ReleaseRequest) SetTarget 

func (x *ReleaseRequest) SetTarget(v *Target)

func (*ReleaseRequest) SetTransactionId 

func (x *ReleaseRequest) SetTransactionId(v int64)

func (*ReleaseRequest) String 

func (x *ReleaseRequest) String() string

type ReleaseRequest_builder 

type ReleaseRequest_builder struct {
	EffectiveCallerId *dev1.CallerID
	ImmediateCallerId *VTGateCallerID
	Target            *Target
	TransactionId     int64
	ReservedId        int64
	// contains filtered or unexported fields
}

func (ReleaseRequest_builder) Build 

func (b0 ReleaseRequest_builder) Build() *ReleaseRequest

type ReleaseResponse 

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

ReleaseResponse is the returned value from Release

func (*ReleaseResponse) ProtoMessage 

func (*ReleaseResponse) ProtoMessage()

func (*ReleaseResponse) ProtoReflect 

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

func (*ReleaseResponse) Reset 

func (x *ReleaseResponse) Reset()

func (*ReleaseResponse) String 

func (x *ReleaseResponse) String() string

type ReleaseResponse_builder 

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

func (ReleaseResponse_builder) Build 

func (b0 ReleaseResponse_builder) Build() *ReleaseResponse

type ReserveBeginExecuteRequest 

type ReserveBeginExecuteRequest struct {
	EffectiveCallerId *dev1.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"`
	PostBeginQueries  []string        `protobuf:"bytes,7,rep,name=post_begin_queries,json=postBeginQueries,proto3" json:"post_begin_queries,omitempty"`
	// contains filtered or unexported fields
}

ReserveBeginExecuteRequest is the payload to ReserveBeginExecute

func (*ReserveBeginExecuteRequest) ClearEffectiveCallerId 

func (x *ReserveBeginExecuteRequest) ClearEffectiveCallerId()

func (*ReserveBeginExecuteRequest) ClearImmediateCallerId 

func (x *ReserveBeginExecuteRequest) ClearImmediateCallerId()

func (*ReserveBeginExecuteRequest) ClearOptions 

func (x *ReserveBeginExecuteRequest) ClearOptions()

func (*ReserveBeginExecuteRequest) ClearQuery 

func (x *ReserveBeginExecuteRequest) ClearQuery()

func (*ReserveBeginExecuteRequest) ClearTarget 

func (x *ReserveBeginExecuteRequest) ClearTarget()

func (*ReserveBeginExecuteRequest) GetEffectiveCallerId 

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

func (*ReserveBeginExecuteRequest) GetImmediateCallerId 

func (x *ReserveBeginExecuteRequest) GetImmediateCallerId() *VTGateCallerID

func (*ReserveBeginExecuteRequest) GetOptions 

func (x *ReserveBeginExecuteRequest) GetOptions() *ExecuteOptions

func (*ReserveBeginExecuteRequest) GetPostBeginQueries 

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

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) HasEffectiveCallerId 

func (x *ReserveBeginExecuteRequest) HasEffectiveCallerId() bool

func (*ReserveBeginExecuteRequest) HasImmediateCallerId 

func (x *ReserveBeginExecuteRequest) HasImmediateCallerId() bool

func (*ReserveBeginExecuteRequest) HasOptions 

func (x *ReserveBeginExecuteRequest) HasOptions() bool

func (*ReserveBeginExecuteRequest) HasQuery 

func (x *ReserveBeginExecuteRequest) HasQuery() bool

func (*ReserveBeginExecuteRequest) HasTarget 

func (x *ReserveBeginExecuteRequest) HasTarget() bool

func (*ReserveBeginExecuteRequest) ProtoMessage 

func (*ReserveBeginExecuteRequest) ProtoMessage()

func (*ReserveBeginExecuteRequest) ProtoReflect 

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

func (*ReserveBeginExecuteRequest) Reset 

func (x *ReserveBeginExecuteRequest) Reset()

func (*ReserveBeginExecuteRequest) SetEffectiveCallerId 

func (x *ReserveBeginExecuteRequest) SetEffectiveCallerId(v *dev1.CallerID)

func (*ReserveBeginExecuteRequest) SetImmediateCallerId 

func (x *ReserveBeginExecuteRequest) SetImmediateCallerId(v *VTGateCallerID)

func (*ReserveBeginExecuteRequest) SetOptions 

func (x *ReserveBeginExecuteRequest) SetOptions(v *ExecuteOptions)

func (*ReserveBeginExecuteRequest) SetPostBeginQueries 

func (x *ReserveBeginExecuteRequest) SetPostBeginQueries(v []string)

func (*ReserveBeginExecuteRequest) SetPreQueries 

func (x *ReserveBeginExecuteRequest) SetPreQueries(v []string)

func (*ReserveBeginExecuteRequest) SetQuery 

func (x *ReserveBeginExecuteRequest) SetQuery(v *BoundQuery)

func (*ReserveBeginExecuteRequest) SetTarget 

func (x *ReserveBeginExecuteRequest) SetTarget(v *Target)

func (*ReserveBeginExecuteRequest) String 

func (x *ReserveBeginExecuteRequest) String() string

type ReserveBeginExecuteRequest_builder 

type ReserveBeginExecuteRequest_builder struct {
	EffectiveCallerId *dev1.CallerID
	ImmediateCallerId *VTGateCallerID
	Target            *Target
	Query             *BoundQuery
	Options           *ExecuteOptions
	PreQueries        []string
	PostBeginQueries  []string
	// contains filtered or unexported fields
}

func (ReserveBeginExecuteRequest_builder) Build 

func (b0 ReserveBeginExecuteRequest_builder) Build() *ReserveBeginExecuteRequest

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  *dev1.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   *dev.TabletAlias `protobuf:"bytes,5,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	// The session_state_changes might be set if the transaction is a snapshot transaction
	// and the MySQL implementation supports getting a start gtid on snapshot
	SessionStateChanges string `protobuf:"bytes,6,opt,name=session_state_changes,json=sessionStateChanges,proto3" json:"session_state_changes,omitempty"`
	// contains filtered or unexported fields
}

ReserveBeginExecuteResponse is the returned value from ReserveBeginExecute

func (*ReserveBeginExecuteResponse) ClearError 

func (x *ReserveBeginExecuteResponse) ClearError()

func (*ReserveBeginExecuteResponse) ClearResult 

func (x *ReserveBeginExecuteResponse) ClearResult()

func (*ReserveBeginExecuteResponse) ClearTabletAlias 

func (x *ReserveBeginExecuteResponse) ClearTabletAlias()

func (*ReserveBeginExecuteResponse) GetError 

func (x *ReserveBeginExecuteResponse) GetError() *dev1.RPCError

func (*ReserveBeginExecuteResponse) GetReservedId 

func (x *ReserveBeginExecuteResponse) GetReservedId() int64

func (*ReserveBeginExecuteResponse) GetResult 

func (x *ReserveBeginExecuteResponse) GetResult() *QueryResult

func (*ReserveBeginExecuteResponse) GetSessionStateChanges 

func (x *ReserveBeginExecuteResponse) GetSessionStateChanges() string

func (*ReserveBeginExecuteResponse) GetTabletAlias 

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

func (*ReserveBeginExecuteResponse) GetTransactionId 

func (x *ReserveBeginExecuteResponse) GetTransactionId() int64

func (*ReserveBeginExecuteResponse) HasError 

func (x *ReserveBeginExecuteResponse) HasError() bool

func (*ReserveBeginExecuteResponse) HasResult 

func (x *ReserveBeginExecuteResponse) HasResult() bool

func (*ReserveBeginExecuteResponse) HasTabletAlias 

func (x *ReserveBeginExecuteResponse) HasTabletAlias() bool

func (*ReserveBeginExecuteResponse) ProtoMessage 

func (*ReserveBeginExecuteResponse) ProtoMessage()

func (*ReserveBeginExecuteResponse) ProtoReflect 

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

func (*ReserveBeginExecuteResponse) Reset 

func (x *ReserveBeginExecuteResponse) Reset()

func (*ReserveBeginExecuteResponse) SetError 

func (x *ReserveBeginExecuteResponse) SetError(v *dev1.RPCError)

func (*ReserveBeginExecuteResponse) SetReservedId 

func (x *ReserveBeginExecuteResponse) SetReservedId(v int64)

func (*ReserveBeginExecuteResponse) SetResult 

func (x *ReserveBeginExecuteResponse) SetResult(v *QueryResult)

func (*ReserveBeginExecuteResponse) SetSessionStateChanges 

func (x *ReserveBeginExecuteResponse) SetSessionStateChanges(v string)

func (*ReserveBeginExecuteResponse) SetTabletAlias 

func (x *ReserveBeginExecuteResponse) SetTabletAlias(v *dev.TabletAlias)

func (*ReserveBeginExecuteResponse) SetTransactionId 

func (x *ReserveBeginExecuteResponse) SetTransactionId(v int64)

func (*ReserveBeginExecuteResponse) String 

func (x *ReserveBeginExecuteResponse) String() string

type ReserveBeginExecuteResponse_builder 

type ReserveBeginExecuteResponse_builder 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  *dev1.RPCError
	Result *QueryResult
	// The following fields might be non-zero even if an error is present.
	TransactionId int64
	ReservedId    int64
	TabletAlias   *dev.TabletAlias
	// The session_state_changes might be set if the transaction is a snapshot transaction
	// and the MySQL implementation supports getting a start gtid on snapshot
	SessionStateChanges string
	// contains filtered or unexported fields
}

func (ReserveBeginExecuteResponse_builder) Build 

func (b0 ReserveBeginExecuteResponse_builder) Build() *ReserveBeginExecuteResponse

type ReserveBeginStreamExecuteRequest 

type ReserveBeginStreamExecuteRequest struct {
	EffectiveCallerId *dev1.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"`
	PostBeginQueries  []string        `protobuf:"bytes,7,rep,name=post_begin_queries,json=postBeginQueries,proto3" json:"post_begin_queries,omitempty"`
	// contains filtered or unexported fields
}

ReserveBeginStreamExecuteRequest is the payload to ReserveBeginStreamExecute

func (*ReserveBeginStreamExecuteRequest) ClearEffectiveCallerId 

func (x *ReserveBeginStreamExecuteRequest) ClearEffectiveCallerId()

func (*ReserveBeginStreamExecuteRequest) ClearImmediateCallerId 

func (x *ReserveBeginStreamExecuteRequest) ClearImmediateCallerId()

func (*ReserveBeginStreamExecuteRequest) ClearOptions 

func (x *ReserveBeginStreamExecuteRequest) ClearOptions()

func (*ReserveBeginStreamExecuteRequest) ClearQuery 

func (x *ReserveBeginStreamExecuteRequest) ClearQuery()

func (*ReserveBeginStreamExecuteRequest) ClearTarget 

func (x *ReserveBeginStreamExecuteRequest) ClearTarget()

func (*ReserveBeginStreamExecuteRequest) GetEffectiveCallerId 

func (x *ReserveBeginStreamExecuteRequest) GetEffectiveCallerId() *dev1.CallerID

func (*ReserveBeginStreamExecuteRequest) GetImmediateCallerId 

func (x *ReserveBeginStreamExecuteRequest) GetImmediateCallerId() *VTGateCallerID

func (*ReserveBeginStreamExecuteRequest) GetOptions 

func (x *ReserveBeginStreamExecuteRequest) GetOptions() *ExecuteOptions

func (*ReserveBeginStreamExecuteRequest) GetPostBeginQueries 

func (x *ReserveBeginStreamExecuteRequest) GetPostBeginQueries() []string

func (*ReserveBeginStreamExecuteRequest) GetPreQueries 

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

func (*ReserveBeginStreamExecuteRequest) GetQuery 

func (x *ReserveBeginStreamExecuteRequest) GetQuery() *BoundQuery

func (*ReserveBeginStreamExecuteRequest) GetTarget 

func (x *ReserveBeginStreamExecuteRequest) GetTarget() *Target

func (*ReserveBeginStreamExecuteRequest) HasEffectiveCallerId 

func (x *ReserveBeginStreamExecuteRequest) HasEffectiveCallerId() bool

func (*ReserveBeginStreamExecuteRequest) HasImmediateCallerId 

func (x *ReserveBeginStreamExecuteRequest) HasImmediateCallerId() bool

func (*ReserveBeginStreamExecuteRequest) HasOptions 

func (x *ReserveBeginStreamExecuteRequest) HasOptions() bool

func (*ReserveBeginStreamExecuteRequest) HasQuery 

func (x *ReserveBeginStreamExecuteRequest) HasQuery() bool

func (*ReserveBeginStreamExecuteRequest) HasTarget 

func (x *ReserveBeginStreamExecuteRequest) HasTarget() bool

func (*ReserveBeginStreamExecuteRequest) ProtoMessage 

func (*ReserveBeginStreamExecuteRequest) ProtoMessage()

func (*ReserveBeginStreamExecuteRequest) ProtoReflect 

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

func (*ReserveBeginStreamExecuteRequest) Reset 

func (x *ReserveBeginStreamExecuteRequest) Reset()

func (*ReserveBeginStreamExecuteRequest) SetEffectiveCallerId 

func (x *ReserveBeginStreamExecuteRequest) SetEffectiveCallerId(v *dev1.CallerID)

func (*ReserveBeginStreamExecuteRequest) SetImmediateCallerId 

func (x *ReserveBeginStreamExecuteRequest) SetImmediateCallerId(v *VTGateCallerID)

func (*ReserveBeginStreamExecuteRequest) SetOptions 

func (x *ReserveBeginStreamExecuteRequest) SetOptions(v *ExecuteOptions)

func (*ReserveBeginStreamExecuteRequest) SetPostBeginQueries 

func (x *ReserveBeginStreamExecuteRequest) SetPostBeginQueries(v []string)

func (*ReserveBeginStreamExecuteRequest) SetPreQueries 

func (x *ReserveBeginStreamExecuteRequest) SetPreQueries(v []string)

func (*ReserveBeginStreamExecuteRequest) SetQuery 

func (x *ReserveBeginStreamExecuteRequest) SetQuery(v *BoundQuery)

func (*ReserveBeginStreamExecuteRequest) SetTarget 

func (x *ReserveBeginStreamExecuteRequest) SetTarget(v *Target)

func (*ReserveBeginStreamExecuteRequest) String 

func (x *ReserveBeginStreamExecuteRequest) String() string

type ReserveBeginStreamExecuteRequest_builder 

type ReserveBeginStreamExecuteRequest_builder struct {
	EffectiveCallerId *dev1.CallerID
	ImmediateCallerId *VTGateCallerID
	Target            *Target
	Query             *BoundQuery
	Options           *ExecuteOptions
	PreQueries        []string
	PostBeginQueries  []string
	// contains filtered or unexported fields
}

func (ReserveBeginStreamExecuteRequest_builder) Build 

func (b0 ReserveBeginStreamExecuteRequest_builder) Build() *ReserveBeginStreamExecuteRequest

type ReserveBeginStreamExecuteResponse 

type ReserveBeginStreamExecuteResponse 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 stream execute failed.
	Error  *dev1.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   *dev.TabletAlias `protobuf:"bytes,5,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	// The session_state_changes might be set if the transaction is a snapshot transaction
	// and the MySQL implementation supports getting a start gtid on snapshot
	SessionStateChanges string `protobuf:"bytes,6,opt,name=session_state_changes,json=sessionStateChanges,proto3" json:"session_state_changes,omitempty"`
	// contains filtered or unexported fields
}

ReserveBeginStreamExecuteResponse is the returned value from ReserveBeginStreamExecute

func (*ReserveBeginStreamExecuteResponse) ClearError 

func (x *ReserveBeginStreamExecuteResponse) ClearError()

func (*ReserveBeginStreamExecuteResponse) ClearResult 

func (x *ReserveBeginStreamExecuteResponse) ClearResult()

func (*ReserveBeginStreamExecuteResponse) ClearTabletAlias 

func (x *ReserveBeginStreamExecuteResponse) ClearTabletAlias()

func (*ReserveBeginStreamExecuteResponse) GetError 

func (x *ReserveBeginStreamExecuteResponse) GetError() *dev1.RPCError

func (*ReserveBeginStreamExecuteResponse) GetReservedId 

func (x *ReserveBeginStreamExecuteResponse) GetReservedId() int64

func (*ReserveBeginStreamExecuteResponse) GetResult 

func (x *ReserveBeginStreamExecuteResponse) GetResult() *QueryResult

func (*ReserveBeginStreamExecuteResponse) GetSessionStateChanges 

func (x *ReserveBeginStreamExecuteResponse) GetSessionStateChanges() string

func (*ReserveBeginStreamExecuteResponse) GetTabletAlias 

func (x *ReserveBeginStreamExecuteResponse) GetTabletAlias() *dev.TabletAlias

func (*ReserveBeginStreamExecuteResponse) GetTransactionId 

func (x *ReserveBeginStreamExecuteResponse) GetTransactionId() int64

func (*ReserveBeginStreamExecuteResponse) HasError 

func (x *ReserveBeginStreamExecuteResponse) HasError() bool

func (*ReserveBeginStreamExecuteResponse) HasResult 

func (x *ReserveBeginStreamExecuteResponse) HasResult() bool

func (*ReserveBeginStreamExecuteResponse) HasTabletAlias 

func (x *ReserveBeginStreamExecuteResponse) HasTabletAlias() bool

func (*ReserveBeginStreamExecuteResponse) ProtoMessage 

func (*ReserveBeginStreamExecuteResponse) ProtoMessage()

func (*ReserveBeginStreamExecuteResponse) ProtoReflect 

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

func (*ReserveBeginStreamExecuteResponse) Reset 

func (x *ReserveBeginStreamExecuteResponse) Reset()

func (*ReserveBeginStreamExecuteResponse) SetError 

func (x *ReserveBeginStreamExecuteResponse) SetError(v *dev1.RPCError)

func (*ReserveBeginStreamExecuteResponse) SetReservedId 

func (x *ReserveBeginStreamExecuteResponse) SetReservedId(v int64)

func (*ReserveBeginStreamExecuteResponse) SetResult 

func (x *ReserveBeginStreamExecuteResponse) SetResult(v *QueryResult)

func (*ReserveBeginStreamExecuteResponse) SetSessionStateChanges 

func (x *ReserveBeginStreamExecuteResponse) SetSessionStateChanges(v string)

func (*ReserveBeginStreamExecuteResponse) SetTabletAlias 

func (x *ReserveBeginStreamExecuteResponse) SetTabletAlias(v *dev.TabletAlias)

func (*ReserveBeginStreamExecuteResponse) SetTransactionId 

func (x *ReserveBeginStreamExecuteResponse) SetTransactionId(v int64)

func (*ReserveBeginStreamExecuteResponse) String 

func (x *ReserveBeginStreamExecuteResponse) String() string

type ReserveBeginStreamExecuteResponse_builder 

type ReserveBeginStreamExecuteResponse_builder 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 stream execute failed.
	Error  *dev1.RPCError
	Result *QueryResult
	// The following fields might be non-zero even if an error is present.
	TransactionId int64
	ReservedId    int64
	TabletAlias   *dev.TabletAlias
	// The session_state_changes might be set if the transaction is a snapshot transaction
	// and the MySQL implementation supports getting a start gtid on snapshot
	SessionStateChanges string
	// contains filtered or unexported fields
}

func (ReserveBeginStreamExecuteResponse_builder) Build 

func (b0 ReserveBeginStreamExecuteResponse_builder) Build() *ReserveBeginStreamExecuteResponse

type ReserveExecuteRequest 

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

ReserveExecuteRequest is the payload to ReserveExecute

func (*ReserveExecuteRequest) ClearEffectiveCallerId 

func (x *ReserveExecuteRequest) ClearEffectiveCallerId()

func (*ReserveExecuteRequest) ClearImmediateCallerId 

func (x *ReserveExecuteRequest) ClearImmediateCallerId()

func (*ReserveExecuteRequest) ClearOptions 

func (x *ReserveExecuteRequest) ClearOptions()

func (*ReserveExecuteRequest) ClearQuery 

func (x *ReserveExecuteRequest) ClearQuery()

func (*ReserveExecuteRequest) ClearTarget 

func (x *ReserveExecuteRequest) ClearTarget()

func (*ReserveExecuteRequest) GetEffectiveCallerId 

func (x *ReserveExecuteRequest) GetEffectiveCallerId() *dev1.CallerID

func (*ReserveExecuteRequest) GetImmediateCallerId 

func (x *ReserveExecuteRequest) GetImmediateCallerId() *VTGateCallerID

func (*ReserveExecuteRequest) GetOptions 

func (x *ReserveExecuteRequest) GetOptions() *ExecuteOptions

func (*ReserveExecuteRequest) GetPreQueries 

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

func (*ReserveExecuteRequest) GetQuery 

func (x *ReserveExecuteRequest) GetQuery() *BoundQuery

func (*ReserveExecuteRequest) GetTarget 

func (x *ReserveExecuteRequest) GetTarget() *Target

func (*ReserveExecuteRequest) GetTransactionId 

func (x *ReserveExecuteRequest) GetTransactionId() int64

func (*ReserveExecuteRequest) HasEffectiveCallerId 

func (x *ReserveExecuteRequest) HasEffectiveCallerId() bool

func (*ReserveExecuteRequest) HasImmediateCallerId 

func (x *ReserveExecuteRequest) HasImmediateCallerId() bool

func (*ReserveExecuteRequest) HasOptions 

func (x *ReserveExecuteRequest) HasOptions() bool

func (*ReserveExecuteRequest) HasQuery 

func (x *ReserveExecuteRequest) HasQuery() bool

func (*ReserveExecuteRequest) HasTarget 

func (x *ReserveExecuteRequest) HasTarget() bool

func (*ReserveExecuteRequest) ProtoMessage 

func (*ReserveExecuteRequest) ProtoMessage()

func (*ReserveExecuteRequest) ProtoReflect 

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

func (*ReserveExecuteRequest) Reset 

func (x *ReserveExecuteRequest) Reset()

func (*ReserveExecuteRequest) SetEffectiveCallerId 

func (x *ReserveExecuteRequest) SetEffectiveCallerId(v *dev1.CallerID)

func (*ReserveExecuteRequest) SetImmediateCallerId 

func (x *ReserveExecuteRequest) SetImmediateCallerId(v *VTGateCallerID)

func (*ReserveExecuteRequest) SetOptions 

func (x *ReserveExecuteRequest) SetOptions(v *ExecuteOptions)

func (*ReserveExecuteRequest) SetPreQueries 

func (x *ReserveExecuteRequest) SetPreQueries(v []string)

func (*ReserveExecuteRequest) SetQuery 

func (x *ReserveExecuteRequest) SetQuery(v *BoundQuery)

func (*ReserveExecuteRequest) SetTarget 

func (x *ReserveExecuteRequest) SetTarget(v *Target)

func (*ReserveExecuteRequest) SetTransactionId 

func (x *ReserveExecuteRequest) SetTransactionId(v int64)

func (*ReserveExecuteRequest) String 

func (x *ReserveExecuteRequest) String() string

type ReserveExecuteRequest_builder 

type ReserveExecuteRequest_builder struct {
	EffectiveCallerId *dev1.CallerID
	ImmediateCallerId *VTGateCallerID
	Target            *Target
	Query             *BoundQuery
	TransactionId     int64
	Options           *ExecuteOptions
	PreQueries        []string
	// contains filtered or unexported fields
}

func (ReserveExecuteRequest_builder) Build 

func (b0 ReserveExecuteRequest_builder) Build() *ReserveExecuteRequest

type ReserveExecuteResponse 

type ReserveExecuteResponse struct {
	Error  *dev1.RPCError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Result *QueryResult   `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// The following fields might be non-zero even if an error is present.
	ReservedId  int64            `protobuf:"varint,3,opt,name=reserved_id,json=reservedId,proto3" json:"reserved_id,omitempty"`
	TabletAlias *dev.TabletAlias `protobuf:"bytes,4,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	// contains filtered or unexported fields
}

ReserveExecuteResponse is the returned value from ReserveExecute

func (*ReserveExecuteResponse) ClearError 

func (x *ReserveExecuteResponse) ClearError()

func (*ReserveExecuteResponse) ClearResult 

func (x *ReserveExecuteResponse) ClearResult()

func (*ReserveExecuteResponse) ClearTabletAlias 

func (x *ReserveExecuteResponse) ClearTabletAlias()

func (*ReserveExecuteResponse) GetError 

func (x *ReserveExecuteResponse) GetError() *dev1.RPCError

func (*ReserveExecuteResponse) GetReservedId 

func (x *ReserveExecuteResponse) GetReservedId() int64

func (*ReserveExecuteResponse) GetResult 

func (x *ReserveExecuteResponse) GetResult() *QueryResult

func (*ReserveExecuteResponse) GetTabletAlias 

func (x *ReserveExecuteResponse) GetTabletAlias() *dev.TabletAlias

func (*ReserveExecuteResponse) HasError 

func (x *ReserveExecuteResponse) HasError() bool

func (*ReserveExecuteResponse) HasResult 

func (x *ReserveExecuteResponse) HasResult() bool

func (*ReserveExecuteResponse) HasTabletAlias 

func (x *ReserveExecuteResponse) HasTabletAlias() bool

func (*ReserveExecuteResponse) ProtoMessage 

func (*ReserveExecuteResponse) ProtoMessage()

func (*ReserveExecuteResponse) ProtoReflect 

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

func (*ReserveExecuteResponse) Reset 

func (x *ReserveExecuteResponse) Reset()

func (*ReserveExecuteResponse) SetError 

func (x *ReserveExecuteResponse) SetError(v *dev1.RPCError)

func (*ReserveExecuteResponse) SetReservedId 

func (x *ReserveExecuteResponse) SetReservedId(v int64)

func (*ReserveExecuteResponse) SetResult 

func (x *ReserveExecuteResponse) SetResult(v *QueryResult)

func (*ReserveExecuteResponse) SetTabletAlias 

func (x *ReserveExecuteResponse) SetTabletAlias(v *dev.TabletAlias)

func (*ReserveExecuteResponse) String 

func (x *ReserveExecuteResponse) String() string

type ReserveExecuteResponse_builder 

type ReserveExecuteResponse_builder struct {
	Error  *dev1.RPCError
	Result *QueryResult
	// The following fields might be non-zero even if an error is present.
	ReservedId  int64
	TabletAlias *dev.TabletAlias
	// contains filtered or unexported fields
}

func (ReserveExecuteResponse_builder) Build 

func (b0 ReserveExecuteResponse_builder) Build() *ReserveExecuteResponse

type ReserveStreamExecuteRequest 

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

ReserveStreamExecuteRequest is the payload to ReserveStreamExecute

func (*ReserveStreamExecuteRequest) ClearEffectiveCallerId 

func (x *ReserveStreamExecuteRequest) ClearEffectiveCallerId()

func (*ReserveStreamExecuteRequest) ClearImmediateCallerId 

func (x *ReserveStreamExecuteRequest) ClearImmediateCallerId()

func (*ReserveStreamExecuteRequest) ClearOptions 

func (x *ReserveStreamExecuteRequest) ClearOptions()

func (*ReserveStreamExecuteRequest) ClearQuery 

func (x *ReserveStreamExecuteRequest) ClearQuery()

func (*ReserveStreamExecuteRequest) ClearTarget 

func (x *ReserveStreamExecuteRequest) ClearTarget()

func (*ReserveStreamExecuteRequest) GetEffectiveCallerId 

func (x *ReserveStreamExecuteRequest) GetEffectiveCallerId() *dev1.CallerID

func (*ReserveStreamExecuteRequest) GetImmediateCallerId 

func (x *ReserveStreamExecuteRequest) GetImmediateCallerId() *VTGateCallerID

func (*ReserveStreamExecuteRequest) GetOptions 

func (x *ReserveStreamExecuteRequest) GetOptions() *ExecuteOptions

func (*ReserveStreamExecuteRequest) GetPreQueries 

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

func (*ReserveStreamExecuteRequest) GetQuery 

func (x *ReserveStreamExecuteRequest) GetQuery() *BoundQuery

func (*ReserveStreamExecuteRequest) GetTarget 

func (x *ReserveStreamExecuteRequest) GetTarget() *Target

func (*ReserveStreamExecuteRequest) GetTransactionId 

func (x *ReserveStreamExecuteRequest) GetTransactionId() int64

func (*ReserveStreamExecuteRequest) HasEffectiveCallerId 

func (x *ReserveStreamExecuteRequest) HasEffectiveCallerId() bool

func (*ReserveStreamExecuteRequest) HasImmediateCallerId 

func (x *ReserveStreamExecuteRequest) HasImmediateCallerId() bool

func (*ReserveStreamExecuteRequest) HasOptions 

func (x *ReserveStreamExecuteRequest) HasOptions() bool

func (*ReserveStreamExecuteRequest) HasQuery 

func (x *ReserveStreamExecuteRequest) HasQuery() bool

func (*ReserveStreamExecuteRequest) HasTarget 

func (x *ReserveStreamExecuteRequest) HasTarget() bool

func (*ReserveStreamExecuteRequest) ProtoMessage 

func (*ReserveStreamExecuteRequest) ProtoMessage()

func (*ReserveStreamExecuteRequest) ProtoReflect 

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

func (*ReserveStreamExecuteRequest) Reset 

func (x *ReserveStreamExecuteRequest) Reset()

func (*ReserveStreamExecuteRequest) SetEffectiveCallerId 

func (x *ReserveStreamExecuteRequest) SetEffectiveCallerId(v *dev1.CallerID)

func (*ReserveStreamExecuteRequest) SetImmediateCallerId 

func (x *ReserveStreamExecuteRequest) SetImmediateCallerId(v *VTGateCallerID)

func (*ReserveStreamExecuteRequest) SetOptions 

func (x *ReserveStreamExecuteRequest) SetOptions(v *ExecuteOptions)

func (*ReserveStreamExecuteRequest) SetPreQueries 

func (x *ReserveStreamExecuteRequest) SetPreQueries(v []string)

func (*ReserveStreamExecuteRequest) SetQuery 

func (x *ReserveStreamExecuteRequest) SetQuery(v *BoundQuery)

func (*ReserveStreamExecuteRequest) SetTarget 

func (x *ReserveStreamExecuteRequest) SetTarget(v *Target)

func (*ReserveStreamExecuteRequest) SetTransactionId 

func (x *ReserveStreamExecuteRequest) SetTransactionId(v int64)

func (*ReserveStreamExecuteRequest) String 

func (x *ReserveStreamExecuteRequest) String() string

type ReserveStreamExecuteRequest_builder 

type ReserveStreamExecuteRequest_builder struct {
	EffectiveCallerId *dev1.CallerID
	ImmediateCallerId *VTGateCallerID
	Target            *Target
	Query             *BoundQuery
	Options           *ExecuteOptions
	TransactionId     int64
	PreQueries        []string
	// contains filtered or unexported fields
}

func (ReserveStreamExecuteRequest_builder) Build 

func (b0 ReserveStreamExecuteRequest_builder) Build() *ReserveStreamExecuteRequest

type ReserveStreamExecuteResponse 

type ReserveStreamExecuteResponse struct {
	Error  *dev1.RPCError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Result *QueryResult   `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// The following fields might be non-zero even if an error is present.
	ReservedId  int64            `protobuf:"varint,3,opt,name=reserved_id,json=reservedId,proto3" json:"reserved_id,omitempty"`
	TabletAlias *dev.TabletAlias `protobuf:"bytes,4,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	// contains filtered or unexported fields
}

ReserveStreamExecuteResponse is the returned value from ReserveStreamExecute

func (*ReserveStreamExecuteResponse) ClearError 

func (x *ReserveStreamExecuteResponse) ClearError()

func (*ReserveStreamExecuteResponse) ClearResult 

func (x *ReserveStreamExecuteResponse) ClearResult()

func (*ReserveStreamExecuteResponse) ClearTabletAlias 

func (x *ReserveStreamExecuteResponse) ClearTabletAlias()

func (*ReserveStreamExecuteResponse) GetError 

func (x *ReserveStreamExecuteResponse) GetError() *dev1.RPCError

func (*ReserveStreamExecuteResponse) GetReservedId 

func (x *ReserveStreamExecuteResponse) GetReservedId() int64

func (*ReserveStreamExecuteResponse) GetResult 

func (x *ReserveStreamExecuteResponse) GetResult() *QueryResult

func (*ReserveStreamExecuteResponse) GetTabletAlias 

func (x *ReserveStreamExecuteResponse) GetTabletAlias() *dev.TabletAlias

func (*ReserveStreamExecuteResponse) HasError 

func (x *ReserveStreamExecuteResponse) HasError() bool

func (*ReserveStreamExecuteResponse) HasResult 

func (x *ReserveStreamExecuteResponse) HasResult() bool

func (*ReserveStreamExecuteResponse) HasTabletAlias 

func (x *ReserveStreamExecuteResponse) HasTabletAlias() bool

func (*ReserveStreamExecuteResponse) ProtoMessage 

func (*ReserveStreamExecuteResponse) ProtoMessage()

func (*ReserveStreamExecuteResponse) ProtoReflect 

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

func (*ReserveStreamExecuteResponse) Reset 

func (x *ReserveStreamExecuteResponse) Reset()

func (*ReserveStreamExecuteResponse) SetError 

func (x *ReserveStreamExecuteResponse) SetError(v *dev1.RPCError)

func (*ReserveStreamExecuteResponse) SetReservedId 

func (x *ReserveStreamExecuteResponse) SetReservedId(v int64)

func (*ReserveStreamExecuteResponse) SetResult 

func (x *ReserveStreamExecuteResponse) SetResult(v *QueryResult)

func (*ReserveStreamExecuteResponse) SetTabletAlias 

func (x *ReserveStreamExecuteResponse) SetTabletAlias(v *dev.TabletAlias)

func (*ReserveStreamExecuteResponse) String 

func (x *ReserveStreamExecuteResponse) String() string

type ReserveStreamExecuteResponse_builder 

type ReserveStreamExecuteResponse_builder struct {
	Error  *dev1.RPCError
	Result *QueryResult
	// The following fields might be non-zero even if an error is present.
	ReservedId  int64
	TabletAlias *dev.TabletAlias
	// contains filtered or unexported fields
}

func (ReserveStreamExecuteResponse_builder) Build 

func (b0 ReserveStreamExecuteResponse_builder) Build() *ReserveStreamExecuteResponse

type ResultWithError 

type ResultWithError struct {

	// error contains an query level error, only set if result is unset.
	Error *dev1.RPCError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// result contains the query result, only set if error is unset.
	Result *QueryResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

ResultWithError represents a query response in the form of result or error but not both. TODO: To be used in ExecuteBatchResponse and BeginExecuteBatchResponse.

func (*ResultWithError) ClearError 

func (x *ResultWithError) ClearError()

func (*ResultWithError) ClearResult 

func (x *ResultWithError) ClearResult()

func (*ResultWithError) GetError 

func (x *ResultWithError) GetError() *dev1.RPCError

func (*ResultWithError) GetResult 

func (x *ResultWithError) GetResult() *QueryResult

func (*ResultWithError) HasError 

func (x *ResultWithError) HasError() bool

func (*ResultWithError) HasResult 

func (x *ResultWithError) HasResult() bool

func (*ResultWithError) ProtoMessage 

func (*ResultWithError) ProtoMessage()

func (*ResultWithError) ProtoReflect 

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

func (*ResultWithError) Reset 

func (x *ResultWithError) Reset()

func (*ResultWithError) SetError 

func (x *ResultWithError) SetError(v *dev1.RPCError)

func (*ResultWithError) SetResult 

func (x *ResultWithError) SetResult(v *QueryResult)

func (*ResultWithError) String 

func (x *ResultWithError) String() string

type ResultWithError_builder 

type ResultWithError_builder struct {

	// error contains an query level error, only set if result is unset.
	Error *dev1.RPCError
	// result contains the query result, only set if error is unset.
	Result *QueryResult
	// contains filtered or unexported fields
}

func (ResultWithError_builder) Build 

func (b0 ResultWithError_builder) Build() *ResultWithError

type RollbackPreparedRequest 

type RollbackPreparedRequest struct {
	EffectiveCallerId *dev1.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
}

RollbackPreparedRequest is the payload to RollbackPrepared

func (*RollbackPreparedRequest) ClearEffectiveCallerId 

func (x *RollbackPreparedRequest) ClearEffectiveCallerId()

func (*RollbackPreparedRequest) ClearImmediateCallerId 

func (x *RollbackPreparedRequest) ClearImmediateCallerId()

func (*RollbackPreparedRequest) ClearTarget 

func (x *RollbackPreparedRequest) ClearTarget()

func (*RollbackPreparedRequest) GetDtid 

func (x *RollbackPreparedRequest) GetDtid() string

func (*RollbackPreparedRequest) GetEffectiveCallerId 

func (x *RollbackPreparedRequest) GetEffectiveCallerId() *dev1.CallerID

func (*RollbackPreparedRequest) GetImmediateCallerId 

func (x *RollbackPreparedRequest) GetImmediateCallerId() *VTGateCallerID

func (*RollbackPreparedRequest) GetTarget 

func (x *RollbackPreparedRequest) GetTarget() *Target

func (*RollbackPreparedRequest) GetTransactionId 

func (x *RollbackPreparedRequest) GetTransactionId() int64

func (*RollbackPreparedRequest) HasEffectiveCallerId 

func (x *RollbackPreparedRequest) HasEffectiveCallerId() bool

func (*RollbackPreparedRequest) HasImmediateCallerId 

func (x *RollbackPreparedRequest) HasImmediateCallerId() bool

func (*RollbackPreparedRequest) HasTarget 

func (x *RollbackPreparedRequest) HasTarget() bool

func (*RollbackPreparedRequest) ProtoMessage 

func (*RollbackPreparedRequest) ProtoMessage()

func (*RollbackPreparedRequest) ProtoReflect 

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

func (*RollbackPreparedRequest) Reset 

func (x *RollbackPreparedRequest) Reset()

func (*RollbackPreparedRequest) SetDtid 

func (x *RollbackPreparedRequest) SetDtid(v string)

func (*RollbackPreparedRequest) SetEffectiveCallerId 

func (x *RollbackPreparedRequest) SetEffectiveCallerId(v *dev1.CallerID)

func (*RollbackPreparedRequest) SetImmediateCallerId 

func (x *RollbackPreparedRequest) SetImmediateCallerId(v *VTGateCallerID)

func (*RollbackPreparedRequest) SetTarget 

func (x *RollbackPreparedRequest) SetTarget(v *Target)

func (*RollbackPreparedRequest) SetTransactionId 

func (x *RollbackPreparedRequest) SetTransactionId(v int64)

func (*RollbackPreparedRequest) String 

func (x *RollbackPreparedRequest) String() string

type RollbackPreparedRequest_builder 

type RollbackPreparedRequest_builder struct {
	EffectiveCallerId *dev1.CallerID
	ImmediateCallerId *VTGateCallerID
	Target            *Target
	TransactionId     int64
	Dtid              string
	// contains filtered or unexported fields
}

func (RollbackPreparedRequest_builder) Build 

func (b0 RollbackPreparedRequest_builder) Build() *RollbackPreparedRequest

type RollbackPreparedResponse 

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

RollbackPreparedResponse is the returned value from RollbackPrepared

func (*RollbackPreparedResponse) ProtoMessage 

func (*RollbackPreparedResponse) ProtoMessage()

func (*RollbackPreparedResponse) ProtoReflect 

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

func (*RollbackPreparedResponse) Reset 

func (x *RollbackPreparedResponse) Reset()

func (*RollbackPreparedResponse) String 

func (x *RollbackPreparedResponse) String() string

type RollbackPreparedResponse_builder 

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

func (RollbackPreparedResponse_builder) Build 

func (b0 RollbackPreparedResponse_builder) Build() *RollbackPreparedResponse

type RollbackRequest 

type RollbackRequest struct {
	EffectiveCallerId *dev1.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
}

RollbackRequest is the payload to Rollback

func (*RollbackRequest) ClearEffectiveCallerId 

func (x *RollbackRequest) ClearEffectiveCallerId()

func (*RollbackRequest) ClearImmediateCallerId 

func (x *RollbackRequest) ClearImmediateCallerId()

func (*RollbackRequest) ClearTarget 

func (x *RollbackRequest) ClearTarget()

func (*RollbackRequest) GetEffectiveCallerId 

func (x *RollbackRequest) GetEffectiveCallerId() *dev1.CallerID

func (*RollbackRequest) GetImmediateCallerId 

func (x *RollbackRequest) GetImmediateCallerId() *VTGateCallerID

func (*RollbackRequest) GetTarget 

func (x *RollbackRequest) GetTarget() *Target

func (*RollbackRequest) GetTransactionId 

func (x *RollbackRequest) GetTransactionId() int64

func (*RollbackRequest) HasEffectiveCallerId 

func (x *RollbackRequest) HasEffectiveCallerId() bool

func (*RollbackRequest) HasImmediateCallerId 

func (x *RollbackRequest) HasImmediateCallerId() bool

func (*RollbackRequest) HasTarget 

func (x *RollbackRequest) HasTarget() bool

func (*RollbackRequest) ProtoMessage 

func (*RollbackRequest) ProtoMessage()

func (*RollbackRequest) ProtoReflect 

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

func (*RollbackRequest) Reset 

func (x *RollbackRequest) Reset()

func (*RollbackRequest) SetEffectiveCallerId 

func (x *RollbackRequest) SetEffectiveCallerId(v *dev1.CallerID)

func (*RollbackRequest) SetImmediateCallerId 

func (x *RollbackRequest) SetImmediateCallerId(v *VTGateCallerID)

func (*RollbackRequest) SetTarget 

func (x *RollbackRequest) SetTarget(v *Target)

func (*RollbackRequest) SetTransactionId 

func (x *RollbackRequest) SetTransactionId(v int64)

func (*RollbackRequest) String 

func (x *RollbackRequest) String() string

type RollbackRequest_builder 

type RollbackRequest_builder struct {
	EffectiveCallerId *dev1.CallerID
	ImmediateCallerId *VTGateCallerID
	Target            *Target
	TransactionId     int64
	// contains filtered or unexported fields
}

func (RollbackRequest_builder) Build 

func (b0 RollbackRequest_builder) Build() *RollbackRequest

type RollbackResponse 

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

RollbackResponse is the returned value from Rollback

func (*RollbackResponse) GetReservedId 

func (x *RollbackResponse) GetReservedId() int64

func (*RollbackResponse) ProtoMessage 

func (*RollbackResponse) ProtoMessage()

func (*RollbackResponse) ProtoReflect 

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

func (*RollbackResponse) Reset 

func (x *RollbackResponse) Reset()

func (*RollbackResponse) SetReservedId 

func (x *RollbackResponse) SetReservedId(v int64)

func (*RollbackResponse) String 

func (x *RollbackResponse) String() string

type RollbackResponse_builder 

type RollbackResponse_builder struct {
	ReservedId int64
	// contains filtered or unexported fields
}

func (RollbackResponse_builder) Build 

func (b0 RollbackResponse_builder) Build() *RollbackResponse

type Row 

type Row struct {

	// lengths contains the length of each value in values.
	// A length of -1 means that the field is NULL. While
	// reading values, you have to accummulate the length
	// to know the offset where the next value begins in values.
	Lengths []int64 `protobuf:"zigzag64,1,rep,packed,name=lengths,proto3" json:"lengths,omitempty"`
	// values contains a concatenation of all values in the row.
	Values []byte `protobuf:"bytes,2,opt,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

Row is a database row.

func (*Row) GetLengths 

func (x *Row) GetLengths() []int64

func (*Row) GetValues 

func (x *Row) GetValues() []byte

func (*Row) ProtoMessage 

func (*Row) ProtoMessage()

func (*Row) ProtoReflect 

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

func (*Row) Reset 

func (x *Row) Reset()

func (*Row) SetLengths 

func (x *Row) SetLengths(v []int64)

func (*Row) SetValues 

func (x *Row) SetValues(v []byte)

func (*Row) String 

func (x *Row) String() string

type Row_builder 

type Row_builder struct {

	// lengths contains the length of each value in values.
	// A length of -1 means that the field is NULL. While
	// reading values, you have to accummulate the length
	// to know the offset where the next value begins in values.
	Lengths []int64
	// values contains a concatenation of all values in the row.
	Values []byte
	// contains filtered or unexported fields
}

func (Row_builder) Build 

func (b0 Row_builder) Build() *Row

type SchemaTableType 

type SchemaTableType int32

SchemaTableType represents the type of table requested. 

const (
	SchemaTableType_VIEWS  SchemaTableType = 0
	SchemaTableType_TABLES SchemaTableType = 1
	SchemaTableType_ALL    SchemaTableType = 2
	SchemaTableType_UDFS   SchemaTableType = 3
)

func (SchemaTableType) Descriptor 

func (SchemaTableType) Descriptor() protoreflect.EnumDescriptor

func (SchemaTableType) Enum 

func (x SchemaTableType) Enum() *SchemaTableType

func (SchemaTableType) Number 

func (x SchemaTableType) Number() protoreflect.EnumNumber

func (SchemaTableType) String 

func (x SchemaTableType) String() string

func (SchemaTableType) Type 

func (SchemaTableType) Type() protoreflect.EnumType

type SetRollbackRequest 

type SetRollbackRequest struct {
	EffectiveCallerId *dev1.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
}

SetRollbackRequest is the payload to SetRollback

func (*SetRollbackRequest) ClearEffectiveCallerId 

func (x *SetRollbackRequest) ClearEffectiveCallerId()

func (*SetRollbackRequest) ClearImmediateCallerId 

func (x *SetRollbackRequest) ClearImmediateCallerId()

func (*SetRollbackRequest) ClearTarget 

func (x *SetRollbackRequest) ClearTarget()

func (*SetRollbackRequest) GetDtid 

func (x *SetRollbackRequest) GetDtid() string

func (*SetRollbackRequest) GetEffectiveCallerId 

func (x *SetRollbackRequest) GetEffectiveCallerId() *dev1.CallerID

func (*SetRollbackRequest) GetImmediateCallerId 

func (x *SetRollbackRequest) GetImmediateCallerId() *VTGateCallerID

func (*SetRollbackRequest) GetTarget 

func (x *SetRollbackRequest) GetTarget() *Target

func (*SetRollbackRequest) GetTransactionId 

func (x *SetRollbackRequest) GetTransactionId() int64

func (*SetRollbackRequest) HasEffectiveCallerId 

func (x *SetRollbackRequest) HasEffectiveCallerId() bool

func (*SetRollbackRequest) HasImmediateCallerId 

func (x *SetRollbackRequest) HasImmediateCallerId() bool

func (*SetRollbackRequest) HasTarget 

func (x *SetRollbackRequest) HasTarget() bool

func (*SetRollbackRequest) ProtoMessage 

func (*SetRollbackRequest) ProtoMessage()

func (*SetRollbackRequest) ProtoReflect 

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

func (*SetRollbackRequest) Reset 

func (x *SetRollbackRequest) Reset()

func (*SetRollbackRequest) SetDtid 

func (x *SetRollbackRequest) SetDtid(v string)

func (*SetRollbackRequest) SetEffectiveCallerId 

func (x *SetRollbackRequest) SetEffectiveCallerId(v *dev1.CallerID)

func (*SetRollbackRequest) SetImmediateCallerId 

func (x *SetRollbackRequest) SetImmediateCallerId(v *VTGateCallerID)

func (*SetRollbackRequest) SetTarget 

func (x *SetRollbackRequest) SetTarget(v *Target)

func (*SetRollbackRequest) SetTransactionId 

func (x *SetRollbackRequest) SetTransactionId(v int64)

func (*SetRollbackRequest) String 

func (x *SetRollbackRequest) String() string

type SetRollbackRequest_builder 

type SetRollbackRequest_builder struct {
	EffectiveCallerId *dev1.CallerID
	ImmediateCallerId *VTGateCallerID
	Target            *Target
	TransactionId     int64
	Dtid              string
	// contains filtered or unexported fields
}

func (SetRollbackRequest_builder) Build 

func (b0 SetRollbackRequest_builder) Build() *SetRollbackRequest

type SetRollbackResponse 

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

SetRollbackResponse is the returned value from SetRollback

func (*SetRollbackResponse) ProtoMessage 

func (*SetRollbackResponse) ProtoMessage()

func (*SetRollbackResponse) ProtoReflect 

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

func (*SetRollbackResponse) Reset 

func (x *SetRollbackResponse) Reset()

func (*SetRollbackResponse) String 

func (x *SetRollbackResponse) String() string

type SetRollbackResponse_builder 

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

func (SetRollbackResponse_builder) Build 

func (b0 SetRollbackResponse_builder) Build() *SetRollbackResponse

type StartCommitRequest 

type StartCommitRequest struct {
	EffectiveCallerId *dev1.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
}

StartCommitRequest is the payload to StartCommit

func (*StartCommitRequest) ClearEffectiveCallerId 

func (x *StartCommitRequest) ClearEffectiveCallerId()

func (*StartCommitRequest) ClearImmediateCallerId 

func (x *StartCommitRequest) ClearImmediateCallerId()

func (*StartCommitRequest) ClearTarget 

func (x *StartCommitRequest) ClearTarget()

func (*StartCommitRequest) GetDtid 

func (x *StartCommitRequest) GetDtid() string

func (*StartCommitRequest) GetEffectiveCallerId 

func (x *StartCommitRequest) GetEffectiveCallerId() *dev1.CallerID

func (*StartCommitRequest) GetImmediateCallerId 

func (x *StartCommitRequest) GetImmediateCallerId() *VTGateCallerID

func (*StartCommitRequest) GetTarget 

func (x *StartCommitRequest) GetTarget() *Target

func (*StartCommitRequest) GetTransactionId 

func (x *StartCommitRequest) GetTransactionId() int64

func (*StartCommitRequest) HasEffectiveCallerId 

func (x *StartCommitRequest) HasEffectiveCallerId() bool

func (*StartCommitRequest) HasImmediateCallerId 

func (x *StartCommitRequest) HasImmediateCallerId() bool

func (*StartCommitRequest) HasTarget 

func (x *StartCommitRequest) HasTarget() bool

func (*StartCommitRequest) ProtoMessage 

func (*StartCommitRequest) ProtoMessage()

func (*StartCommitRequest) ProtoReflect 

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

func (*StartCommitRequest) Reset 

func (x *StartCommitRequest) Reset()

func (*StartCommitRequest) SetDtid 

func (x *StartCommitRequest) SetDtid(v string)

func (*StartCommitRequest) SetEffectiveCallerId 

func (x *StartCommitRequest) SetEffectiveCallerId(v *dev1.CallerID)

func (*StartCommitRequest) SetImmediateCallerId 

func (x *StartCommitRequest) SetImmediateCallerId(v *VTGateCallerID)

func (*StartCommitRequest) SetTarget 

func (x *StartCommitRequest) SetTarget(v *Target)

func (*StartCommitRequest) SetTransactionId 

func (x *StartCommitRequest) SetTransactionId(v int64)

func (*StartCommitRequest) String 

func (x *StartCommitRequest) String() string

type StartCommitRequest_builder 

type StartCommitRequest_builder struct {
	EffectiveCallerId *dev1.CallerID
	ImmediateCallerId *VTGateCallerID
	Target            *Target
	TransactionId     int64
	Dtid              string
	// contains filtered or unexported fields
}

func (StartCommitRequest_builder) Build 

func (b0 StartCommitRequest_builder) Build() *StartCommitRequest

type StartCommitResponse 

type StartCommitResponse struct {
	State StartCommitState `protobuf:"varint,1,opt,name=state,proto3,enum=vitess.query.dev.StartCommitState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

StartCommitResponse is the returned value from StartCommit

func (*StartCommitResponse) GetState 

func (x *StartCommitResponse) GetState() StartCommitState

func (*StartCommitResponse) ProtoMessage 

func (*StartCommitResponse) ProtoMessage()

func (*StartCommitResponse) ProtoReflect 

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

func (*StartCommitResponse) Reset 

func (x *StartCommitResponse) Reset()

func (*StartCommitResponse) SetState 

func (x *StartCommitResponse) SetState(v StartCommitState)

func (*StartCommitResponse) String 

func (x *StartCommitResponse) String() string

type StartCommitResponse_builder 

type StartCommitResponse_builder struct {
	State StartCommitState
	// contains filtered or unexported fields
}

func (StartCommitResponse_builder) Build 

func (b0 StartCommitResponse_builder) Build() *StartCommitResponse

type StartCommitState 

type StartCommitState int32
const (
	StartCommitState_Unknown StartCommitState = 0
	StartCommitState_Fail    StartCommitState = 1
	StartCommitState_Success StartCommitState = 2
)

func (StartCommitState) Descriptor 

func (StartCommitState) Descriptor() protoreflect.EnumDescriptor

func (StartCommitState) Enum 

func (x StartCommitState) Enum() *StartCommitState

func (StartCommitState) Number 

func (x StartCommitState) Number() protoreflect.EnumNumber

func (StartCommitState) String 

func (x StartCommitState) String() string

func (StartCommitState) Type 

func (StartCommitState) Type() protoreflect.EnumType

type StreamEvent 

type StreamEvent struct {

	// The statements in this transaction.
	Statements []*StreamEvent_Statement `protobuf:"bytes,1,rep,name=statements,proto3" json:"statements,omitempty"`
	// The Event Token for this event.
	EventToken *EventToken `protobuf:"bytes,2,opt,name=event_token,json=eventToken,proto3" json:"event_token,omitempty"`
	// contains filtered or unexported fields
}

StreamEvent describes a set of transformations that happened as a single transactional unit on a server. It is streamed back by the Update Stream calls.

func (*StreamEvent) ClearEventToken 

func (x *StreamEvent) ClearEventToken()

func (*StreamEvent) GetEventToken 

func (x *StreamEvent) GetEventToken() *EventToken

func (*StreamEvent) GetStatements 

func (x *StreamEvent) GetStatements() []*StreamEvent_Statement

func (*StreamEvent) HasEventToken 

func (x *StreamEvent) HasEventToken() bool

func (*StreamEvent) ProtoMessage 

func (*StreamEvent) ProtoMessage()

func (*StreamEvent) ProtoReflect 

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

func (*StreamEvent) Reset 

func (x *StreamEvent) Reset()

func (*StreamEvent) SetEventToken 

func (x *StreamEvent) SetEventToken(v *EventToken)

func (*StreamEvent) SetStatements 

func (x *StreamEvent) SetStatements(v []*StreamEvent_Statement)

func (*StreamEvent) String 

func (x *StreamEvent) String() string

type StreamEvent_Statement 

type StreamEvent_Statement struct {
	Category StreamEvent_Statement_Category `protobuf:"varint,1,opt,name=category,proto3,enum=vitess.query.dev.StreamEvent_Statement_Category" json:"category,omitempty"`
	// table_name, primary_key_fields and primary_key_values are set for DML.
	TableName        string   `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	PrimaryKeyFields []*Field `protobuf:"bytes,3,rep,name=primary_key_fields,json=primaryKeyFields,proto3" json:"primary_key_fields,omitempty"`
	PrimaryKeyValues []*Row   `protobuf:"bytes,4,rep,name=primary_key_values,json=primaryKeyValues,proto3" json:"primary_key_values,omitempty"`
	// sql is set for all queries.
	// FIXME(alainjobart) we may not need it for DMLs.
	Sql []byte `protobuf:"bytes,5,opt,name=sql,proto3" json:"sql,omitempty"`
	// contains filtered or unexported fields
}

One individual Statement in a transaction.

func (*StreamEvent_Statement) GetCategory 

func (x *StreamEvent_Statement) GetCategory() StreamEvent_Statement_Category

func (*StreamEvent_Statement) GetPrimaryKeyFields 

func (x *StreamEvent_Statement) GetPrimaryKeyFields() []*Field

func (*StreamEvent_Statement) GetPrimaryKeyValues 

func (x *StreamEvent_Statement) GetPrimaryKeyValues() []*Row

func (*StreamEvent_Statement) GetSql 

func (x *StreamEvent_Statement) GetSql() []byte

func (*StreamEvent_Statement) GetTableName 

func (x *StreamEvent_Statement) GetTableName() string

func (*StreamEvent_Statement) ProtoMessage 

func (*StreamEvent_Statement) ProtoMessage()

func (*StreamEvent_Statement) ProtoReflect 

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

func (*StreamEvent_Statement) Reset 

func (x *StreamEvent_Statement) Reset()

func (*StreamEvent_Statement) SetCategory 

func (x *StreamEvent_Statement) SetCategory(v StreamEvent_Statement_Category)

func (*StreamEvent_Statement) SetPrimaryKeyFields 

func (x *StreamEvent_Statement) SetPrimaryKeyFields(v []*Field)

func (*StreamEvent_Statement) SetPrimaryKeyValues 

func (x *StreamEvent_Statement) SetPrimaryKeyValues(v []*Row)

func (*StreamEvent_Statement) SetSql 

func (x *StreamEvent_Statement) SetSql(v []byte)

func (*StreamEvent_Statement) SetTableName 

func (x *StreamEvent_Statement) SetTableName(v string)

func (*StreamEvent_Statement) String 

func (x *StreamEvent_Statement) String() string

type StreamEvent_Statement_Category 

type StreamEvent_Statement_Category int32

The category of one statement. 

const (
	StreamEvent_Statement_Error StreamEvent_Statement_Category = 0
	StreamEvent_Statement_DML   StreamEvent_Statement_Category = 1
	StreamEvent_Statement_DDL   StreamEvent_Statement_Category = 2
)

func (StreamEvent_Statement_Category) Descriptor 

func (StreamEvent_Statement_Category) Descriptor() protoreflect.EnumDescriptor

func (StreamEvent_Statement_Category) Enum 

func (x StreamEvent_Statement_Category) Enum() *StreamEvent_Statement_Category

func (StreamEvent_Statement_Category) Number 

func (x StreamEvent_Statement_Category) Number() protoreflect.EnumNumber

func (StreamEvent_Statement_Category) String 

func (x StreamEvent_Statement_Category) String() string

func (StreamEvent_Statement_Category) Type 

func (StreamEvent_Statement_Category) Type() protoreflect.EnumType

type StreamEvent_Statement_builder 

type StreamEvent_Statement_builder struct {
	Category StreamEvent_Statement_Category
	// table_name, primary_key_fields and primary_key_values are set for DML.
	TableName        string
	PrimaryKeyFields []*Field
	PrimaryKeyValues []*Row
	// sql is set for all queries.
	// FIXME(alainjobart) we may not need it for DMLs.
	Sql []byte
	// contains filtered or unexported fields
}

func (StreamEvent_Statement_builder) Build 

func (b0 StreamEvent_Statement_builder) Build() *StreamEvent_Statement

type StreamEvent_builder 

type StreamEvent_builder struct {

	// The statements in this transaction.
	Statements []*StreamEvent_Statement
	// The Event Token for this event.
	EventToken *EventToken
	// contains filtered or unexported fields
}

func (StreamEvent_builder) Build 

func (b0 StreamEvent_builder) Build() *StreamEvent

type StreamExecuteRequest 

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

StreamExecuteRequest is the payload to StreamExecute

func (*StreamExecuteRequest) ClearEffectiveCallerId 

func (x *StreamExecuteRequest) ClearEffectiveCallerId()

func (*StreamExecuteRequest) ClearImmediateCallerId 

func (x *StreamExecuteRequest) ClearImmediateCallerId()

func (*StreamExecuteRequest) ClearOptions 

func (x *StreamExecuteRequest) ClearOptions()

func (*StreamExecuteRequest) ClearQuery 

func (x *StreamExecuteRequest) ClearQuery()

func (*StreamExecuteRequest) ClearTarget 

func (x *StreamExecuteRequest) ClearTarget()

func (*StreamExecuteRequest) GetEffectiveCallerId 

func (x *StreamExecuteRequest) GetEffectiveCallerId() *dev1.CallerID

func (*StreamExecuteRequest) GetImmediateCallerId 

func (x *StreamExecuteRequest) GetImmediateCallerId() *VTGateCallerID

func (*StreamExecuteRequest) GetOptions 

func (x *StreamExecuteRequest) GetOptions() *ExecuteOptions

func (*StreamExecuteRequest) GetQuery 

func (x *StreamExecuteRequest) GetQuery() *BoundQuery

func (*StreamExecuteRequest) GetReservedId 

func (x *StreamExecuteRequest) GetReservedId() int64

func (*StreamExecuteRequest) GetTarget 

func (x *StreamExecuteRequest) GetTarget() *Target

func (*StreamExecuteRequest) GetTransactionId 

func (x *StreamExecuteRequest) GetTransactionId() int64

func (*StreamExecuteRequest) HasEffectiveCallerId 

func (x *StreamExecuteRequest) HasEffectiveCallerId() bool

func (*StreamExecuteRequest) HasImmediateCallerId 

func (x *StreamExecuteRequest) HasImmediateCallerId() bool

func (*StreamExecuteRequest) HasOptions 

func (x *StreamExecuteRequest) HasOptions() bool

func (*StreamExecuteRequest) HasQuery 

func (x *StreamExecuteRequest) HasQuery() bool

func (*StreamExecuteRequest) HasTarget 

func (x *StreamExecuteRequest) HasTarget() bool

func (*StreamExecuteRequest) ProtoMessage 

func (*StreamExecuteRequest) ProtoMessage()

func (*StreamExecuteRequest) ProtoReflect 

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

func (*StreamExecuteRequest) Reset 

func (x *StreamExecuteRequest) Reset()

func (*StreamExecuteRequest) SetEffectiveCallerId 

func (x *StreamExecuteRequest) SetEffectiveCallerId(v *dev1.CallerID)

func (*StreamExecuteRequest) SetImmediateCallerId 

func (x *StreamExecuteRequest) SetImmediateCallerId(v *VTGateCallerID)

func (*StreamExecuteRequest) SetOptions 

func (x *StreamExecuteRequest) SetOptions(v *ExecuteOptions)

func (*StreamExecuteRequest) SetQuery 

func (x *StreamExecuteRequest) SetQuery(v *BoundQuery)

func (*StreamExecuteRequest) SetReservedId 

func (x *StreamExecuteRequest) SetReservedId(v int64)

func (*StreamExecuteRequest) SetTarget 

func (x *StreamExecuteRequest) SetTarget(v *Target)

func (*StreamExecuteRequest) SetTransactionId 

func (x *StreamExecuteRequest) SetTransactionId(v int64)

func (*StreamExecuteRequest) String 

func (x *StreamExecuteRequest) String() string

type StreamExecuteRequest_builder 

type StreamExecuteRequest_builder struct {
	EffectiveCallerId *dev1.CallerID
	ImmediateCallerId *VTGateCallerID
	Target            *Target
	Query             *BoundQuery
	Options           *ExecuteOptions
	TransactionId     int64
	ReservedId        int64
	// contains filtered or unexported fields
}

func (StreamExecuteRequest_builder) Build 

func (b0 StreamExecuteRequest_builder) Build() *StreamExecuteRequest

type StreamExecuteResponse 

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

StreamExecuteResponse is the returned value from StreamExecute

func (*StreamExecuteResponse) ClearResult 

func (x *StreamExecuteResponse) ClearResult()

func (*StreamExecuteResponse) GetResult 

func (x *StreamExecuteResponse) GetResult() *QueryResult

func (*StreamExecuteResponse) HasResult 

func (x *StreamExecuteResponse) HasResult() bool

func (*StreamExecuteResponse) ProtoMessage 

func (*StreamExecuteResponse) ProtoMessage()

func (*StreamExecuteResponse) ProtoReflect 

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

func (*StreamExecuteResponse) Reset 

func (x *StreamExecuteResponse) Reset()

func (*StreamExecuteResponse) SetResult 

func (x *StreamExecuteResponse) SetResult(v *QueryResult)

func (*StreamExecuteResponse) String 

func (x *StreamExecuteResponse) String() string

type StreamExecuteResponse_builder 

type StreamExecuteResponse_builder struct {
	Result *QueryResult
	// contains filtered or unexported fields
}

func (StreamExecuteResponse_builder) Build 

func (b0 StreamExecuteResponse_builder) Build() *StreamExecuteResponse

type StreamHealthRequest 

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

StreamHealthRequest is the payload for StreamHealth

func (*StreamHealthRequest) ProtoMessage 

func (*StreamHealthRequest) ProtoMessage()

func (*StreamHealthRequest) ProtoReflect 

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

func (*StreamHealthRequest) Reset 

func (x *StreamHealthRequest) Reset()

func (*StreamHealthRequest) String 

func (x *StreamHealthRequest) String() string

type StreamHealthRequest_builder 

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

func (StreamHealthRequest_builder) Build 

func (b0 StreamHealthRequest_builder) Build() *StreamHealthRequest

type StreamHealthResponse 

type StreamHealthResponse struct {

	// target is the current server type. Only queries with that exact Target
	// record will be accepted (the cell may not match, however).
	Target *Target `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	// serving is true iff the tablet is serving. A tablet may not be serving
	// if filtered replication is enabled on a primary for instance,
	// or if a replica should not be used because the keyspace is being resharded.
	Serving bool `protobuf:"varint,2,opt,name=serving,proto3" json:"serving,omitempty"`
	// primary_term_start_timestamp can be interpreted as the
	// last time we knew that this tablet was promoted to a PRIMARY of this shard
	// (if StreamHealthResponse describes a group of tablets, between
	// two vtgates, only one primary will be present in the group, and
	// this is this primary's value).
	//
	// It is used by vtgate when determining the current PRIMARY of a shard.
	// If vtgate sees more than one PRIMARY tablet, this timestamp is used
	// as tiebreaker where the PRIMARY with the highest timestamp wins.
	// Another usage of this timestamp is in go/vt/vtgate/buffer to detect the end
	// of a reparent (failover) and stop buffering.
	//
	// In practice, this field is set to:
	// a) the last time the RPC tabletmanager.TabletExternallyReparented was
	//
	//	called on this tablet (usually done by an external failover tool e.g.
	//	Orchestrator). The failover tool can call this as long as we are the
	//	primary i.e. even ages after the last reparent occurred.
	//
	// OR
	// b) the last time an active reparent was executed through a vtctl command
	//
	//	(InitShardPrimary, PlannedReparentShard, EmergencyReparentShard)
	//
	// OR
	// c) the last time vttablet was started and it initialized its tablet type
	//
	//	as PRIMARY because it was recorded as the shard's current primary in the
	//	topology (see go/vt/vttablet/tabletmanager/init_tablet.go)
	//
	// OR
	// d) 0 if the vttablet is not a PRIMARY.
	PrimaryTermStartTimestamp int64 `` /* 141-byte string literal not displayed */
	// realtime_stats contains information about the tablet status.
	// It is only filled in if the information is about a tablet.
	RealtimeStats *RealtimeStats `protobuf:"bytes,4,opt,name=realtime_stats,json=realtimeStats,proto3" json:"realtime_stats,omitempty"`
	// tablet_alias is the alias of the sending tablet. The discovery/healthcheck.go
	// code uses it to verify that it's talking to the correct tablet and that it
	// hasn't changed in the meantime e.g. due to tablet restarts where ports or
	// ips have been reused but assigned differently.
	TabletAlias *dev.TabletAlias `protobuf:"bytes,5,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
	// contains filtered or unexported fields
}

StreamHealthResponse is streamed by StreamHealth on a regular basis. It is expected to be used between a vtgate and vttablet: - target describes the tablet. - realtime_stats is set. - aggregate_stats is not set (deprecated)

func (*StreamHealthResponse) ClearRealtimeStats 

func (x *StreamHealthResponse) ClearRealtimeStats()

func (*StreamHealthResponse) ClearTabletAlias 

func (x *StreamHealthResponse) ClearTabletAlias()

func (*StreamHealthResponse) ClearTarget 

func (x *StreamHealthResponse) ClearTarget()

func (*StreamHealthResponse) GetPrimaryTermStartTimestamp 

func (x *StreamHealthResponse) GetPrimaryTermStartTimestamp() int64

func (*StreamHealthResponse) GetRealtimeStats 

func (x *StreamHealthResponse) GetRealtimeStats() *RealtimeStats

func (*StreamHealthResponse) GetServing 

func (x *StreamHealthResponse) GetServing() bool

func (*StreamHealthResponse) GetTabletAlias 

func (x *StreamHealthResponse) GetTabletAlias() *dev.TabletAlias

func (*StreamHealthResponse) GetTarget 

func (x *StreamHealthResponse) GetTarget() *Target

func (*StreamHealthResponse) HasRealtimeStats 

func (x *StreamHealthResponse) HasRealtimeStats() bool

func (*StreamHealthResponse) HasTabletAlias 

func (x *StreamHealthResponse) HasTabletAlias() bool

func (*StreamHealthResponse) HasTarget 

func (x *StreamHealthResponse) HasTarget() bool

func (*StreamHealthResponse) ProtoMessage 

func (*StreamHealthResponse) ProtoMessage()

func (*StreamHealthResponse) ProtoReflect 

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

func (*StreamHealthResponse) Reset 

func (x *StreamHealthResponse) Reset()

func (*StreamHealthResponse) SetPrimaryTermStartTimestamp 

func (x *StreamHealthResponse) SetPrimaryTermStartTimestamp(v int64)

func (*StreamHealthResponse) SetRealtimeStats 

func (x *StreamHealthResponse) SetRealtimeStats(v *RealtimeStats)

func (*StreamHealthResponse) SetServing 

func (x *StreamHealthResponse) SetServing(v bool)

func (*StreamHealthResponse) SetTabletAlias 

func (x *StreamHealthResponse) SetTabletAlias(v *dev.TabletAlias)

func (*StreamHealthResponse) SetTarget 

func (x *StreamHealthResponse) SetTarget(v *Target)

func (*StreamHealthResponse) String 

func (x *StreamHealthResponse) String() string

type StreamHealthResponse_builder 

type StreamHealthResponse_builder struct {

	// target is the current server type. Only queries with that exact Target
	// record will be accepted (the cell may not match, however).
	Target *Target
	// serving is true iff the tablet is serving. A tablet may not be serving
	// if filtered replication is enabled on a primary for instance,
	// or if a replica should not be used because the keyspace is being resharded.
	Serving bool
	// primary_term_start_timestamp can be interpreted as the
	// last time we knew that this tablet was promoted to a PRIMARY of this shard
	// (if StreamHealthResponse describes a group of tablets, between
	// two vtgates, only one primary will be present in the group, and
	// this is this primary's value).
	//
	// It is used by vtgate when determining the current PRIMARY of a shard.
	// If vtgate sees more than one PRIMARY tablet, this timestamp is used
	// as tiebreaker where the PRIMARY with the highest timestamp wins.
	// Another usage of this timestamp is in go/vt/vtgate/buffer to detect the end
	// of a reparent (failover) and stop buffering.
	//
	// In practice, this field is set to:
	// a) the last time the RPC tabletmanager.TabletExternallyReparented was
	//
	//	called on this tablet (usually done by an external failover tool e.g.
	//	Orchestrator). The failover tool can call this as long as we are the
	//	primary i.e. even ages after the last reparent occurred.
	//
	// OR
	// b) the last time an active reparent was executed through a vtctl command
	//
	//	(InitShardPrimary, PlannedReparentShard, EmergencyReparentShard)
	//
	// OR
	// c) the last time vttablet was started and it initialized its tablet type
	//
	//	as PRIMARY because it was recorded as the shard's current primary in the
	//	topology (see go/vt/vttablet/tabletmanager/init_tablet.go)
	//
	// OR
	// d) 0 if the vttablet is not a PRIMARY.
	PrimaryTermStartTimestamp int64
	// realtime_stats contains information about the tablet status.
	// It is only filled in if the information is about a tablet.
	RealtimeStats *RealtimeStats
	// tablet_alias is the alias of the sending tablet. The discovery/healthcheck.go
	// code uses it to verify that it's talking to the correct tablet and that it
	// hasn't changed in the meantime e.g. due to tablet restarts where ports or
	// ips have been reused but assigned differently.
	TabletAlias *dev.TabletAlias
	// contains filtered or unexported fields
}

func (StreamHealthResponse_builder) Build 

func (b0 StreamHealthResponse_builder) Build() *StreamHealthResponse

type Target 

type Target struct {
	Keyspace   string         `protobuf:"bytes,1,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	Shard      string         `protobuf:"bytes,2,opt,name=shard,proto3" json:"shard,omitempty"`
	TabletType dev.TabletType `` /* 128-byte string literal not displayed */
	// cell is used for routing queries between vtgate and vttablets. It
	// is not used when Target is part of the Session sent by the client.
	Cell string `protobuf:"bytes,4,opt,name=cell,proto3" json:"cell,omitempty"`
	// contains filtered or unexported fields
}

Target describes what the client expects the tablet is. If the tablet does not match, an error is returned.

func (*Target) GetCell 

func (x *Target) GetCell() string

func (*Target) GetKeyspace 

func (x *Target) GetKeyspace() string

func (*Target) GetShard 

func (x *Target) GetShard() string

func (*Target) GetTabletType 

func (x *Target) GetTabletType() dev.TabletType

func (*Target) ProtoMessage 

func (*Target) ProtoMessage()

func (*Target) ProtoReflect 

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

func (*Target) Reset 

func (x *Target) Reset()

func (*Target) SetCell 

func (x *Target) SetCell(v string)

func (*Target) SetKeyspace 

func (x *Target) SetKeyspace(v string)

func (*Target) SetShard 

func (x *Target) SetShard(v string)

func (*Target) SetTabletType 

func (x *Target) SetTabletType(v dev.TabletType)

func (*Target) String 

func (x *Target) String() string

type Target_builder 

type Target_builder struct {
	Keyspace   string
	Shard      string
	TabletType dev.TabletType
	// cell is used for routing queries between vtgate and vttablets. It
	// is not used when Target is part of the Session sent by the client.
	Cell string
	// contains filtered or unexported fields
}

func (Target_builder) Build 

func (b0 Target_builder) Build() *Target

type TransactionMetadata 

type TransactionMetadata struct {
	Dtid         string           `protobuf:"bytes,1,opt,name=dtid,proto3" json:"dtid,omitempty"`
	State        TransactionState `protobuf:"varint,2,opt,name=state,proto3,enum=vitess.query.dev.TransactionState" json:"state,omitempty"`
	TimeCreated  int64            `protobuf:"varint,3,opt,name=time_created,json=timeCreated,proto3" json:"time_created,omitempty"`
	Participants []*Target        `protobuf:"bytes,4,rep,name=participants,proto3" json:"participants,omitempty"`
	// contains filtered or unexported fields
}

TransactionMetadata contains the metadata for a distributed transaction.

func (*TransactionMetadata) GetDtid 

func (x *TransactionMetadata) GetDtid() string

func (*TransactionMetadata) GetParticipants 

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

func (*TransactionMetadata) GetState 

func (x *TransactionMetadata) GetState() TransactionState

func (*TransactionMetadata) GetTimeCreated 

func (x *TransactionMetadata) GetTimeCreated() int64

func (*TransactionMetadata) ProtoMessage 

func (*TransactionMetadata) ProtoMessage()

func (*TransactionMetadata) ProtoReflect 

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

func (*TransactionMetadata) Reset 

func (x *TransactionMetadata) Reset()

func (*TransactionMetadata) SetDtid 

func (x *TransactionMetadata) SetDtid(v string)

func (*TransactionMetadata) SetParticipants 

func (x *TransactionMetadata) SetParticipants(v []*Target)

func (*TransactionMetadata) SetState 

func (x *TransactionMetadata) SetState(v TransactionState)

func (*TransactionMetadata) SetTimeCreated 

func (x *TransactionMetadata) SetTimeCreated(v int64)

func (*TransactionMetadata) String 

func (x *TransactionMetadata) String() string

type TransactionMetadata_builder 

type TransactionMetadata_builder struct {
	Dtid         string
	State        TransactionState
	TimeCreated  int64
	Participants []*Target
	// contains filtered or unexported fields
}

func (TransactionMetadata_builder) Build 

func (b0 TransactionMetadata_builder) Build() *TransactionMetadata

type TransactionState 

type TransactionState int32

TransactionState represents the state of a distributed transaction. 

const (
	TransactionState_UNKNOWN  TransactionState = 0
	TransactionState_PREPARE  TransactionState = 1
	TransactionState_ROLLBACK TransactionState = 2
	TransactionState_COMMIT   TransactionState = 3
)

func (TransactionState) Descriptor 

func (TransactionState) Descriptor() protoreflect.EnumDescriptor

func (TransactionState) Enum 

func (x TransactionState) Enum() *TransactionState

func (TransactionState) Number 

func (x TransactionState) Number() protoreflect.EnumNumber

func (TransactionState) String 

func (x TransactionState) String() string

func (TransactionState) Type 

func (TransactionState) Type() protoreflect.EnumType

type Type 

type Type int32

Type defines the various supported data types in bind vars and query results. 

const (
	// NULL_TYPE specifies a NULL type.
	Type_NULL_TYPE Type = 0
	// INT8 specifies a TINYINT type.
	// Properties: 1, IsNumber.
	Type_INT8 Type = 257
	// UINT8 specifies a TINYINT UNSIGNED type.
	// Properties: 2, IsNumber, IsUnsigned.
	Type_UINT8 Type = 770
	// INT16 specifies a SMALLINT type.
	// Properties: 3, IsNumber.
	Type_INT16 Type = 259
	// UINT16 specifies a SMALLINT UNSIGNED type.
	// Properties: 4, IsNumber, IsUnsigned.
	Type_UINT16 Type = 772
	// INT24 specifies a MEDIUMINT type.
	// Properties: 5, IsNumber.
	Type_INT24 Type = 261
	// UINT24 specifies a MEDIUMINT UNSIGNED type.
	// Properties: 6, IsNumber, IsUnsigned.
	Type_UINT24 Type = 774
	// INT32 specifies a INTEGER type.
	// Properties: 7, IsNumber.
	Type_INT32 Type = 263
	// UINT32 specifies a INTEGER UNSIGNED type.
	// Properties: 8, IsNumber, IsUnsigned.
	Type_UINT32 Type = 776
	// INT64 specifies a BIGINT type.
	// Properties: 9, IsNumber.
	Type_INT64 Type = 265
	// UINT64 specifies a BIGINT UNSIGNED type.
	// Properties: 10, IsNumber, IsUnsigned.
	Type_UINT64 Type = 778
	// FLOAT32 specifies a FLOAT type.
	// Properties: 11, IsFloat.
	Type_FLOAT32 Type = 1035
	// FLOAT64 specifies a DOUBLE or REAL type.
	// Properties: 12, IsFloat.
	Type_FLOAT64 Type = 1036
	// TIMESTAMP specifies a TIMESTAMP type.
	// Properties: 13, IsQuoted.
	Type_TIMESTAMP Type = 2061
	// DATE specifies a DATE type.
	// Properties: 14, IsQuoted.
	Type_DATE Type = 2062
	// TIME specifies a TIME type.
	// Properties: 15, IsQuoted.
	Type_TIME Type = 2063
	// DATETIME specifies a DATETIME type.
	// Properties: 16, IsQuoted.
	Type_DATETIME Type = 2064
	// YEAR specifies a YEAR type.
	// Properties: 17, IsNumber, IsUnsigned.
	Type_YEAR Type = 785
	// DECIMAL specifies a DECIMAL or NUMERIC type.
	// Properties: 18, None.
	Type_DECIMAL Type = 18
	// TEXT specifies a TEXT type.
	// Properties: 19, IsQuoted, IsText.
	Type_TEXT Type = 6163
	// BLOB specifies a BLOB type.
	// Properties: 20, IsQuoted, IsBinary.
	Type_BLOB Type = 10260
	// VARCHAR specifies a VARCHAR type.
	// Properties: 21, IsQuoted, IsText.
	Type_VARCHAR Type = 6165
	// VARBINARY specifies a VARBINARY type.
	// Properties: 22, IsQuoted, IsBinary.
	Type_VARBINARY Type = 10262
	// CHAR specifies a CHAR type.
	// Properties: 23, IsQuoted, IsText.
	Type_CHAR Type = 6167
	// BINARY specifies a BINARY type.
	// Properties: 24, IsQuoted, IsBinary.
	Type_BINARY Type = 10264
	// BIT specifies a BIT type.
	// Properties: 25, IsQuoted.
	Type_BIT Type = 2073
	// ENUM specifies an ENUM type.
	// Properties: 26, IsQuoted.
	Type_ENUM Type = 2074
	// SET specifies a SET type.
	// Properties: 27, IsQuoted.
	Type_SET Type = 2075
	// TUPLE specifies a tuple. This cannot
	// be returned in a QueryResult, but it can
	// be sent as a bind var.
	// Properties: 28, None.
	Type_TUPLE Type = 28
	// GEOMETRY specifies a GEOMETRY type.
	// Properties: 29, IsQuoted.
	Type_GEOMETRY Type = 2077
	// JSON specifies a JSON type.
	// Properties: 30, IsQuoted.
	Type_JSON Type = 2078
	// EXPRESSION specifies a SQL expression.
	// This type is for internal use only.
	// Properties: 31, None.
	Type_EXPRESSION Type = 31
	// HEXNUM specifies a HEXNUM type (unquoted varbinary).
	// Properties: 32, IsText.
	Type_HEXNUM Type = 4128
	// HEXVAL specifies a HEXVAL type (unquoted varbinary).
	// Properties: 33, IsText.
	Type_HEXVAL Type = 4129
	// BITNUM specifies a base 2 binary type (unquoted varbinary).
	// Properties: 34, IsText.
	Type_BITNUM Type = 4130
	// VECTOR specifies a VECTOR type
	// Properties: 35, IsQuoted.
	Type_VECTOR Type = 2083
	// RAW specifies a type which won't be quoted but the value used as-is while encoding.
	// Properties: 36, None.
	Type_RAW Type = 2084
	// ROW_TUPLE represents multiple rows.
	// Properties: 37, None.
	Type_ROW_TUPLE Type = 2085
)

func (Type) Descriptor 

func (Type) Descriptor() protoreflect.EnumDescriptor

func (Type) Enum 

func (x Type) Enum() *Type

func (Type) Number 

func (x Type) Number() protoreflect.EnumNumber

func (Type) String 

func (x Type) String() string

func (Type) Type 

func (Type) Type() protoreflect.EnumType

type UDFInfo 

type UDFInfo struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Aggregating bool   `protobuf:"varint,2,opt,name=aggregating,proto3" json:"aggregating,omitempty"`
	ReturnType  Type   `protobuf:"varint,3,opt,name=return_type,json=returnType,proto3,enum=vitess.query.dev.Type" json:"return_type,omitempty"`
	// contains filtered or unexported fields
}

UDFInfo represents the information about a UDF.

func (*UDFInfo) GetAggregating 

func (x *UDFInfo) GetAggregating() bool

func (*UDFInfo) GetName 

func (x *UDFInfo) GetName() string

func (*UDFInfo) GetReturnType 

func (x *UDFInfo) GetReturnType() Type

func (*UDFInfo) ProtoMessage 

func (*UDFInfo) ProtoMessage()

func (*UDFInfo) ProtoReflect 

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

func (*UDFInfo) Reset 

func (x *UDFInfo) Reset()

func (*UDFInfo) SetAggregating 

func (x *UDFInfo) SetAggregating(v bool)

func (*UDFInfo) SetName 

func (x *UDFInfo) SetName(v string)

func (*UDFInfo) SetReturnType 

func (x *UDFInfo) SetReturnType(v Type)

func (*UDFInfo) String 

func (x *UDFInfo) String() string

type UDFInfo_builder 

type UDFInfo_builder struct {
	Name        string
	Aggregating bool
	ReturnType  Type
	// contains filtered or unexported fields
}

func (UDFInfo_builder) Build 

func (b0 UDFInfo_builder) Build() *UDFInfo

type UnresolvedTransactionsRequest 

type UnresolvedTransactionsRequest struct {
	EffectiveCallerId *dev1.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"`
	AbandonAge        int64           `protobuf:"varint,4,opt,name=abandon_age,json=abandonAge,proto3" json:"abandon_age,omitempty"` // Unresolved Transactions older than this (in seconds).
	// contains filtered or unexported fields
}

UnresolvedTransactionsRequest is the payload to UnresolvedTransactions

func (*UnresolvedTransactionsRequest) ClearEffectiveCallerId 

func (x *UnresolvedTransactionsRequest) ClearEffectiveCallerId()

func (*UnresolvedTransactionsRequest) ClearImmediateCallerId 

func (x *UnresolvedTransactionsRequest) ClearImmediateCallerId()

func (*UnresolvedTransactionsRequest) ClearTarget 

func (x *UnresolvedTransactionsRequest) ClearTarget()

func (*UnresolvedTransactionsRequest) GetAbandonAge 

func (x *UnresolvedTransactionsRequest) GetAbandonAge() int64

func (*UnresolvedTransactionsRequest) GetEffectiveCallerId 

func (x *UnresolvedTransactionsRequest) GetEffectiveCallerId() *dev1.CallerID

func (*UnresolvedTransactionsRequest) GetImmediateCallerId 

func (x *UnresolvedTransactionsRequest) GetImmediateCallerId() *VTGateCallerID

func (*UnresolvedTransactionsRequest) GetTarget 

func (x *UnresolvedTransactionsRequest) GetTarget() *Target

func (*UnresolvedTransactionsRequest) HasEffectiveCallerId 

func (x *UnresolvedTransactionsRequest) HasEffectiveCallerId() bool

func (*UnresolvedTransactionsRequest) HasImmediateCallerId 

func (x *UnresolvedTransactionsRequest) HasImmediateCallerId() bool

func (*UnresolvedTransactionsRequest) HasTarget 

func (x *UnresolvedTransactionsRequest) HasTarget() bool

func (*UnresolvedTransactionsRequest) ProtoMessage 

func (*UnresolvedTransactionsRequest) ProtoMessage()

func (*UnresolvedTransactionsRequest) ProtoReflect 

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

func (*UnresolvedTransactionsRequest) Reset 

func (x *UnresolvedTransactionsRequest) Reset()

func (*UnresolvedTransactionsRequest) SetAbandonAge 

func (x *UnresolvedTransactionsRequest) SetAbandonAge(v int64)

func (*UnresolvedTransactionsRequest) SetEffectiveCallerId 

func (x *UnresolvedTransactionsRequest) SetEffectiveCallerId(v *dev1.CallerID)

func (*UnresolvedTransactionsRequest) SetImmediateCallerId 

func (x *UnresolvedTransactionsRequest) SetImmediateCallerId(v *VTGateCallerID)

func (*UnresolvedTransactionsRequest) SetTarget 

func (x *UnresolvedTransactionsRequest) SetTarget(v *Target)

func (*UnresolvedTransactionsRequest) String 

func (x *UnresolvedTransactionsRequest) String() string

type UnresolvedTransactionsRequest_builder 

type UnresolvedTransactionsRequest_builder struct {
	EffectiveCallerId *dev1.CallerID
	ImmediateCallerId *VTGateCallerID
	Target            *Target
	AbandonAge        int64
	// contains filtered or unexported fields
}

func (UnresolvedTransactionsRequest_builder) Build 

func (b0 UnresolvedTransactionsRequest_builder) Build() *UnresolvedTransactionsRequest

type UnresolvedTransactionsResponse 

type UnresolvedTransactionsResponse struct {
	Transactions []*TransactionMetadata `protobuf:"bytes,1,rep,name=transactions,proto3" json:"transactions,omitempty"`
	// contains filtered or unexported fields
}

UnresolvedTransactionsResponse is the returned value from UnresolvedTransactions

func (*UnresolvedTransactionsResponse) GetTransactions 

func (x *UnresolvedTransactionsResponse) GetTransactions() []*TransactionMetadata

func (*UnresolvedTransactionsResponse) ProtoMessage 

func (*UnresolvedTransactionsResponse) ProtoMessage()

func (*UnresolvedTransactionsResponse) ProtoReflect 

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

func (*UnresolvedTransactionsResponse) Reset 

func (x *UnresolvedTransactionsResponse) Reset()

func (*UnresolvedTransactionsResponse) SetTransactions 

func (x *UnresolvedTransactionsResponse) SetTransactions(v []*TransactionMetadata)

func (*UnresolvedTransactionsResponse) String 

func (x *UnresolvedTransactionsResponse) String() string

type UnresolvedTransactionsResponse_builder 

type UnresolvedTransactionsResponse_builder struct {
	Transactions []*TransactionMetadata
	// contains filtered or unexported fields
}

func (UnresolvedTransactionsResponse_builder) Build 

func (b0 UnresolvedTransactionsResponse_builder) Build() *UnresolvedTransactionsResponse

type VTGateCallerID 

type VTGateCallerID struct {
	Username string   `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Groups   []string `protobuf:"bytes,2,rep,name=groups,proto3" json:"groups,omitempty"`
	// contains filtered or unexported fields
}

VTGateCallerID is sent by VTGate to VTTablet to describe the caller. If possible, this information is secure. For instance, if using unique certificates that guarantee that VTGate->VTTablet traffic cannot be spoofed, then VTTablet can trust this information, and VTTablet will use it for tablet ACLs, for instance. Because of this security guarantee, this is different than the CallerID structure, which is not secure at all, because it is provided by the Vitess client.

func (*VTGateCallerID) GetGroups 

func (x *VTGateCallerID) GetGroups() []string

func (*VTGateCallerID) GetUsername 

func (x *VTGateCallerID) GetUsername() string

func (*VTGateCallerID) ProtoMessage 

func (*VTGateCallerID) ProtoMessage()

func (*VTGateCallerID) ProtoReflect 

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

func (*VTGateCallerID) Reset 

func (x *VTGateCallerID) Reset()

func (*VTGateCallerID) SetGroups 

func (x *VTGateCallerID) SetGroups(v []string)

func (*VTGateCallerID) SetUsername 

func (x *VTGateCallerID) SetUsername(v string)

func (*VTGateCallerID) String 

func (x *VTGateCallerID) String() string

type VTGateCallerID_builder 

type VTGateCallerID_builder struct {
	Username string
	Groups   []string
	// contains filtered or unexported fields
}

func (VTGateCallerID_builder) Build 

func (b0 VTGateCallerID_builder) Build() *VTGateCallerID

type Value 

type Value struct {
	Type  Type   `protobuf:"varint,1,opt,name=type,proto3,enum=vitess.query.dev.Type" json:"type,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Value represents a typed value.

func (*Value) GetType 

func (x *Value) GetType() Type

func (*Value) GetValue 

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

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) ProtoReflect 

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

func (*Value) Reset 

func (x *Value) Reset()

func (*Value) SetType 

func (x *Value) SetType(v Type)

func (*Value) SetValue 

func (x *Value) SetValue(v []byte)

func (*Value) String 

func (x *Value) String() string

type Value_builder 

type Value_builder struct {
	Type  Type
	Value []byte
	// contains filtered or unexported fields
}

func (Value_builder) Build 

func (b0 Value_builder) Build() *Value

Source Files

  • query.pb.go

Jump to

Keyboard shortcuts

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