query

package
v2.1.0-alpha.1+incompa... Latest Latest
Warning

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

Go to latest
Published: Nov 8, 2016 License: BSD-3-Clause Imports: 5 Imported by: 0

Documentation

Overview

Package query is a generated protocol buffer package.

It is generated from these files:

query.proto

It has these top-level messages:

Target
VTGateCallerID
EventToken
Value
BindVariable
BoundQuery
ExecuteOptions
Field
Row
ResultExtras
QueryResult
StreamEvent
ExecuteRequest
ExecuteResponse
ExecuteBatchRequest
ExecuteBatchResponse
StreamExecuteRequest
StreamExecuteResponse
BeginRequest
BeginResponse
CommitRequest
CommitResponse
RollbackRequest
RollbackResponse
PrepareRequest
PrepareResponse
CommitPreparedRequest
CommitPreparedResponse
RollbackPreparedRequest
RollbackPreparedResponse
CreateTransactionRequest
CreateTransactionResponse
StartCommitRequest
StartCommitResponse
SetRollbackRequest
SetRollbackResponse
ResolveTransactionRequest
ResolveTransactionResponse
ReadTransactionRequest
ReadTransactionResponse
BeginExecuteRequest
BeginExecuteResponse
BeginExecuteBatchRequest
BeginExecuteBatchResponse
SplitQueryRequest
QuerySplit
SplitQueryResponse
StreamHealthRequest
RealtimeStats
StreamHealthResponse
UpdateStreamRequest
UpdateStreamResponse
TransactionMetadata

Index

Constants

This section is empty.

Variables

View Source
var Flag_name = map[int32]string{
	0:    "NONE",
	256:  "ISINTEGRAL",
	512:  "ISUNSIGNED",
	1024: "ISFLOAT",
	2048: "ISQUOTED",
	4096: "ISTEXT",
	8192: "ISBINARY",
}
View Source
var Flag_value = map[string]int32{
	"NONE":       0,
	"ISINTEGRAL": 256,
	"ISUNSIGNED": 512,
	"ISFLOAT":    1024,
	"ISQUOTED":   2048,
	"ISTEXT":     4096,
	"ISBINARY":   8192,
}
View Source
var SplitQueryRequest_Algorithm_name = map[int32]string{
	0: "EQUAL_SPLITS",
	1: "FULL_SCAN",
}
View Source
var SplitQueryRequest_Algorithm_value = map[string]int32{
	"EQUAL_SPLITS": 0,
	"FULL_SCAN":    1,
}
View Source
var StreamEvent_Statement_Category_name = map[int32]string{
	0: "Error",
	1: "DML",
	2: "DDL",
}
View Source
var StreamEvent_Statement_Category_value = map[string]int32{
	"Error": 0,
	"DML":   1,
	"DDL":   2,
}
View Source
var TransactionState_name = map[int32]string{
	0: "UNKNOWN",
	1: "PREPARE",
	2: "COMMIT",
	3: "ROLLBACK",
}
View Source
var TransactionState_value = map[string]int32{
	"UNKNOWN":  0,
	"PREPARE":  1,
	"COMMIT":   2,
	"ROLLBACK": 3,
}
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",
}
View Source
var Type_value = map[string]int32{
	"NULL_TYPE": 0,
	"INT8":      257,
	"UINT8":     770,
	"INT16":     259,
	"UINT16":    772,
	"INT24":     261,
	"UINT24":    774,
	"INT32":     263,
	"UINT32":    776,
	"INT64":     265,
	"UINT64":    778,
	"FLOAT32":   1035,
	"FLOAT64":   1036,
	"TIMESTAMP": 2061,
	"DATE":      2062,
	"TIME":      2063,
	"DATETIME":  2064,
	"YEAR":      785,
	"DECIMAL":   18,
	"TEXT":      6163,
	"BLOB":      10260,
	"VARCHAR":   6165,
	"VARBINARY": 10262,
	"CHAR":      6167,
	"BINARY":    10264,
	"BIT":       2073,
	"ENUM":      2074,
	"SET":       2075,
	"TUPLE":     28,
}

Functions

This section is empty.

Types

type BeginExecuteBatchRequest

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

BeginExecuteBatchRequest is the payload to BeginExecuteBatch

func (*BeginExecuteBatchRequest) Descriptor

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

func (*BeginExecuteBatchRequest) GetEffectiveCallerId

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

func (*BeginExecuteBatchRequest) GetImmediateCallerId

func (m *BeginExecuteBatchRequest) GetImmediateCallerId() *VTGateCallerID

func (*BeginExecuteBatchRequest) GetOptions

func (m *BeginExecuteBatchRequest) GetOptions() *ExecuteOptions

func (*BeginExecuteBatchRequest) GetQueries

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

func (*BeginExecuteBatchRequest) GetTarget

func (m *BeginExecuteBatchRequest) GetTarget() *Target

func (*BeginExecuteBatchRequest) ProtoMessage

func (*BeginExecuteBatchRequest) ProtoMessage()

func (*BeginExecuteBatchRequest) Reset

func (m *BeginExecuteBatchRequest) Reset()

func (*BeginExecuteBatchRequest) String

func (m *BeginExecuteBatchRequest) String() string

type BeginExecuteBatchResponse

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

BeginExecuteBatchResponse is the returned value from BeginExecuteBatch

func (*BeginExecuteBatchResponse) Descriptor

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

func (*BeginExecuteBatchResponse) GetError

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

func (*BeginExecuteBatchResponse) GetResults

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

func (*BeginExecuteBatchResponse) ProtoMessage

func (*BeginExecuteBatchResponse) ProtoMessage()

func (*BeginExecuteBatchResponse) Reset

func (m *BeginExecuteBatchResponse) Reset()

func (*BeginExecuteBatchResponse) String

func (m *BeginExecuteBatchResponse) String() string

type BeginExecuteRequest

type BeginExecuteRequest struct {
	EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId" json:"effective_caller_id,omitempty"`
	ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId" json:"immediate_caller_id,omitempty"`
	Target            *Target         `protobuf:"bytes,3,opt,name=target" json:"target,omitempty"`
	Query             *BoundQuery     `protobuf:"bytes,4,opt,name=query" json:"query,omitempty"`
	Options           *ExecuteOptions `protobuf:"bytes,5,opt,name=options" json:"options,omitempty"`
}

BeginExecuteRequest is the payload to BeginExecute

func (*BeginExecuteRequest) Descriptor

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

func (*BeginExecuteRequest) GetEffectiveCallerId

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

func (*BeginExecuteRequest) GetImmediateCallerId

func (m *BeginExecuteRequest) GetImmediateCallerId() *VTGateCallerID

func (*BeginExecuteRequest) GetOptions

func (m *BeginExecuteRequest) GetOptions() *ExecuteOptions

func (*BeginExecuteRequest) GetQuery

func (m *BeginExecuteRequest) GetQuery() *BoundQuery

func (*BeginExecuteRequest) GetTarget

func (m *BeginExecuteRequest) GetTarget() *Target

func (*BeginExecuteRequest) ProtoMessage

func (*BeginExecuteRequest) ProtoMessage()

func (*BeginExecuteRequest) Reset

func (m *BeginExecuteRequest) Reset()

func (*BeginExecuteRequest) String

func (m *BeginExecuteRequest) String() string

type BeginExecuteResponse

type BeginExecuteResponse struct {
	// error contains an application level error if necessary. Note the
	// transaction_id may be set, even when an error is returned, if the begin
	// worked but the execute failed.
	Error  *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	Result *QueryResult    `protobuf:"bytes,2,opt,name=result" 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" json:"transaction_id,omitempty"`
}

BeginExecuteResponse is the returned value from BeginExecute

func (*BeginExecuteResponse) Descriptor

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

func (*BeginExecuteResponse) GetError

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

func (*BeginExecuteResponse) GetResult

func (m *BeginExecuteResponse) GetResult() *QueryResult

func (*BeginExecuteResponse) ProtoMessage

func (*BeginExecuteResponse) ProtoMessage()

func (*BeginExecuteResponse) Reset

func (m *BeginExecuteResponse) Reset()

func (*BeginExecuteResponse) String

func (m *BeginExecuteResponse) String() string

type BeginRequest

type BeginRequest struct {
	EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId" json:"effective_caller_id,omitempty"`
	ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId" json:"immediate_caller_id,omitempty"`
	Target            *Target         `protobuf:"bytes,3,opt,name=target" json:"target,omitempty"`
}

BeginRequest is the payload to Begin

func (*BeginRequest) Descriptor

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

func (*BeginRequest) GetEffectiveCallerId

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

func (*BeginRequest) GetImmediateCallerId

func (m *BeginRequest) GetImmediateCallerId() *VTGateCallerID

func (*BeginRequest) GetTarget

func (m *BeginRequest) GetTarget() *Target

func (*BeginRequest) ProtoMessage

func (*BeginRequest) ProtoMessage()

func (*BeginRequest) Reset

func (m *BeginRequest) Reset()

func (*BeginRequest) String

func (m *BeginRequest) String() string

type BeginResponse

type BeginResponse struct {
	TransactionId int64 `protobuf:"varint,1,opt,name=transaction_id,json=transactionId" json:"transaction_id,omitempty"`
}

BeginResponse is the returned value from Begin

func (*BeginResponse) Descriptor

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

func (*BeginResponse) ProtoMessage

func (*BeginResponse) ProtoMessage()

func (*BeginResponse) Reset

func (m *BeginResponse) Reset()

func (*BeginResponse) String

func (m *BeginResponse) String() string

type BindVariable

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

BindVariable represents a single bind variable in a Query.

func (*BindVariable) Descriptor

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

func (*BindVariable) GetValues

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

func (*BindVariable) ProtoMessage

func (*BindVariable) ProtoMessage()

func (*BindVariable) Reset

func (m *BindVariable) Reset()

func (*BindVariable) String

func (m *BindVariable) String() string

type BoundQuery

type BoundQuery struct {
	// sql is the SQL query to execute
	Sql string `protobuf:"bytes,1,opt,name=sql" json:"sql,omitempty"`
	// bind_variables is a map of all bind variables to expand in the query
	BindVariables map[string]*BindVariable `` /* 167-byte string literal not displayed */
}

BoundQuery is a query with its bind variables

func (*BoundQuery) Descriptor

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

func (*BoundQuery) GetBindVariables

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

func (*BoundQuery) ProtoMessage

func (*BoundQuery) ProtoMessage()

func (*BoundQuery) Reset

func (m *BoundQuery) Reset()

func (*BoundQuery) String

func (m *BoundQuery) String() string

type CommitPreparedRequest

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

CommitPreparedRequest is the payload to CommitPrepared

func (*CommitPreparedRequest) Descriptor

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

func (*CommitPreparedRequest) GetEffectiveCallerId

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

func (*CommitPreparedRequest) GetImmediateCallerId

func (m *CommitPreparedRequest) GetImmediateCallerId() *VTGateCallerID

func (*CommitPreparedRequest) GetTarget

func (m *CommitPreparedRequest) GetTarget() *Target

func (*CommitPreparedRequest) ProtoMessage

func (*CommitPreparedRequest) ProtoMessage()

func (*CommitPreparedRequest) Reset

func (m *CommitPreparedRequest) Reset()

func (*CommitPreparedRequest) String

func (m *CommitPreparedRequest) String() string

type CommitPreparedResponse

type CommitPreparedResponse struct {
}

CommitPreparedResponse is the returned value from CommitPrepared

func (*CommitPreparedResponse) Descriptor

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

func (*CommitPreparedResponse) ProtoMessage

func (*CommitPreparedResponse) ProtoMessage()

func (*CommitPreparedResponse) Reset

func (m *CommitPreparedResponse) Reset()

func (*CommitPreparedResponse) String

func (m *CommitPreparedResponse) String() string

type CommitRequest

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

CommitRequest is the payload to Commit

func (*CommitRequest) Descriptor

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

func (*CommitRequest) GetEffectiveCallerId

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

func (*CommitRequest) GetImmediateCallerId

func (m *CommitRequest) GetImmediateCallerId() *VTGateCallerID

func (*CommitRequest) GetTarget

func (m *CommitRequest) GetTarget() *Target

func (*CommitRequest) ProtoMessage

func (*CommitRequest) ProtoMessage()

func (*CommitRequest) Reset

func (m *CommitRequest) Reset()

func (*CommitRequest) String

func (m *CommitRequest) String() string

type CommitResponse

type CommitResponse struct {
}

CommitResponse is the returned value from Commit

func (*CommitResponse) Descriptor

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

func (*CommitResponse) ProtoMessage

func (*CommitResponse) ProtoMessage()

func (*CommitResponse) Reset

func (m *CommitResponse) Reset()

func (*CommitResponse) String

func (m *CommitResponse) String() string

type CreateTransactionRequest

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

CreateTransactionRequest is the payload to CreateTransaction

func (*CreateTransactionRequest) Descriptor

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

func (*CreateTransactionRequest) GetEffectiveCallerId

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

func (*CreateTransactionRequest) GetImmediateCallerId

func (m *CreateTransactionRequest) GetImmediateCallerId() *VTGateCallerID

func (*CreateTransactionRequest) GetParticipants

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

func (*CreateTransactionRequest) GetTarget

func (m *CreateTransactionRequest) GetTarget() *Target

func (*CreateTransactionRequest) ProtoMessage

func (*CreateTransactionRequest) ProtoMessage()

func (*CreateTransactionRequest) Reset

func (m *CreateTransactionRequest) Reset()

func (*CreateTransactionRequest) String

func (m *CreateTransactionRequest) String() string

type CreateTransactionResponse

type CreateTransactionResponse struct {
}

CreateTransactionResponse is the returned value from CreateTransaction

func (*CreateTransactionResponse) Descriptor

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

func (*CreateTransactionResponse) ProtoMessage

func (*CreateTransactionResponse) ProtoMessage()

func (*CreateTransactionResponse) Reset

func (m *CreateTransactionResponse) Reset()

func (*CreateTransactionResponse) String

func (m *CreateTransactionResponse) String() string

type EventToken

type EventToken struct {
	// timestamp is the MySQL timestamp of the statements. Seconds since Epoch.
	Timestamp int64 `protobuf:"varint,1,opt,name=timestamp" 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" 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" json:"position,omitempty"`
}

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

func (*EventToken) Descriptor

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

func (*EventToken) ProtoMessage

func (*EventToken) ProtoMessage()

func (*EventToken) Reset

func (m *EventToken) Reset()

func (*EventToken) String

func (m *EventToken) String() string

type ExecuteBatchRequest

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

ExecuteBatchRequest is the payload to ExecuteBatch

func (*ExecuteBatchRequest) Descriptor

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

func (*ExecuteBatchRequest) GetEffectiveCallerId

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

func (*ExecuteBatchRequest) GetImmediateCallerId

func (m *ExecuteBatchRequest) GetImmediateCallerId() *VTGateCallerID

func (*ExecuteBatchRequest) GetOptions

func (m *ExecuteBatchRequest) GetOptions() *ExecuteOptions

func (*ExecuteBatchRequest) GetQueries

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

func (*ExecuteBatchRequest) GetTarget

func (m *ExecuteBatchRequest) GetTarget() *Target

func (*ExecuteBatchRequest) ProtoMessage

func (*ExecuteBatchRequest) ProtoMessage()

func (*ExecuteBatchRequest) Reset

func (m *ExecuteBatchRequest) Reset()

func (*ExecuteBatchRequest) String

func (m *ExecuteBatchRequest) String() string

type ExecuteBatchResponse

type ExecuteBatchResponse struct {
	Results []*QueryResult `protobuf:"bytes,1,rep,name=results" json:"results,omitempty"`
}

ExecuteBatchResponse is the returned value from ExecuteBatch

func (*ExecuteBatchResponse) Descriptor

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

func (*ExecuteBatchResponse) GetResults

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

func (*ExecuteBatchResponse) ProtoMessage

func (*ExecuteBatchResponse) ProtoMessage()

func (*ExecuteBatchResponse) Reset

func (m *ExecuteBatchResponse) Reset()

func (*ExecuteBatchResponse) String

func (m *ExecuteBatchResponse) String() string

type ExecuteOptions

type ExecuteOptions struct {
	// If set, the resulting Field array won’t have a Name, just a Type.
	// This is an optimization for high-QPS queries where the client knows
	// what it's getting.
	ExcludeFieldNames bool `protobuf:"varint,1,opt,name=exclude_field_names,json=excludeFieldNames" json:"exclude_field_names,omitempty"`
	// If set, we will try to include an EventToken with the responses.
	IncludeEventToken bool `protobuf:"varint,2,opt,name=include_event_token,json=includeEventToken" json:"include_event_token,omitempty"`
	// If set, the fresher field may be set as a result comparison to this token.
	// This is a shortcut so the application doesn't need to care about
	// comparing EventTokens.
	CompareEventToken *EventToken `protobuf:"bytes,3,opt,name=compare_event_token,json=compareEventToken" json:"compare_event_token,omitempty"`
}

ExecuteOptions is passed around for all Execute calls.

func (*ExecuteOptions) Descriptor

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

func (*ExecuteOptions) GetCompareEventToken

func (m *ExecuteOptions) GetCompareEventToken() *EventToken

func (*ExecuteOptions) ProtoMessage

func (*ExecuteOptions) ProtoMessage()

func (*ExecuteOptions) Reset

func (m *ExecuteOptions) Reset()

func (*ExecuteOptions) String

func (m *ExecuteOptions) String() string

type ExecuteRequest

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

ExecuteRequest is the payload to Execute

func (*ExecuteRequest) Descriptor

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

func (*ExecuteRequest) GetEffectiveCallerId

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

func (*ExecuteRequest) GetImmediateCallerId

func (m *ExecuteRequest) GetImmediateCallerId() *VTGateCallerID

func (*ExecuteRequest) GetOptions

func (m *ExecuteRequest) GetOptions() *ExecuteOptions

func (*ExecuteRequest) GetQuery

func (m *ExecuteRequest) GetQuery() *BoundQuery

func (*ExecuteRequest) GetTarget

func (m *ExecuteRequest) GetTarget() *Target

func (*ExecuteRequest) ProtoMessage

func (*ExecuteRequest) ProtoMessage()

func (*ExecuteRequest) Reset

func (m *ExecuteRequest) Reset()

func (*ExecuteRequest) String

func (m *ExecuteRequest) String() string

type ExecuteResponse

type ExecuteResponse struct {
	Result *QueryResult `protobuf:"bytes,1,opt,name=result" json:"result,omitempty"`
}

ExecuteResponse is the returned value from Execute

func (*ExecuteResponse) Descriptor

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

func (*ExecuteResponse) GetResult

func (m *ExecuteResponse) GetResult() *QueryResult

func (*ExecuteResponse) ProtoMessage

func (*ExecuteResponse) ProtoMessage()

func (*ExecuteResponse) Reset

func (m *ExecuteResponse) Reset()

func (*ExecuteResponse) String

func (m *ExecuteResponse) String() string

type Field

type Field struct {
	// name of the field as returned by mysql C API
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	// vitess-defined type. Conversion function is in sqltypes package.
	Type Type `protobuf:"varint,2,opt,name=type,enum=query.Type" json:"type,omitempty"`
}

Field describes a single column returned by a query

func (*Field) Descriptor

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

func (*Field) ProtoMessage

func (*Field) ProtoMessage()

func (*Field) Reset

func (m *Field) Reset()

func (*Field) String

func (m *Field) String() string

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

func (Flag) EnumDescriptor() ([]byte, []int)

func (Flag) String

func (x Flag) String() string

type PrepareRequest

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

PrepareRequest is the payload to Prepare

func (*PrepareRequest) Descriptor

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

func (*PrepareRequest) GetEffectiveCallerId

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

func (*PrepareRequest) GetImmediateCallerId

func (m *PrepareRequest) GetImmediateCallerId() *VTGateCallerID

func (*PrepareRequest) GetTarget

func (m *PrepareRequest) GetTarget() *Target

func (*PrepareRequest) ProtoMessage

func (*PrepareRequest) ProtoMessage()

func (*PrepareRequest) Reset

func (m *PrepareRequest) Reset()

func (*PrepareRequest) String

func (m *PrepareRequest) String() string

type PrepareResponse

type PrepareResponse struct {
}

PrepareResponse is the returned value from Prepare

func (*PrepareResponse) Descriptor

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

func (*PrepareResponse) ProtoMessage

func (*PrepareResponse) ProtoMessage()

func (*PrepareResponse) Reset

func (m *PrepareResponse) Reset()

func (*PrepareResponse) String

func (m *PrepareResponse) String() string

type QueryResult

type QueryResult struct {
	Fields       []*Field      `protobuf:"bytes,1,rep,name=fields" json:"fields,omitempty"`
	RowsAffected uint64        `protobuf:"varint,2,opt,name=rows_affected,json=rowsAffected" json:"rows_affected,omitempty"`
	InsertId     uint64        `protobuf:"varint,3,opt,name=insert_id,json=insertId" json:"insert_id,omitempty"`
	Rows         []*Row        `protobuf:"bytes,4,rep,name=rows" json:"rows,omitempty"`
	Extras       *ResultExtras `protobuf:"bytes,5,opt,name=extras" json:"extras,omitempty"`
}

QueryResult is returned by Execute and ExecuteStream.

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

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

func (*QueryResult) Descriptor

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

func (*QueryResult) GetExtras

func (m *QueryResult) GetExtras() *ResultExtras

func (*QueryResult) GetFields

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

func (*QueryResult) GetRows

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

func (*QueryResult) ProtoMessage

func (*QueryResult) ProtoMessage()

func (*QueryResult) Reset

func (m *QueryResult) Reset()

func (*QueryResult) String

func (m *QueryResult) String() string

type QuerySplit

type QuerySplit struct {
	// query is the query to execute
	Query *BoundQuery `protobuf:"bytes,1,opt,name=query" json:"query,omitempty"`
	// row_count is the approximate row count the query will return
	RowCount int64 `protobuf:"varint,2,opt,name=row_count,json=rowCount" json:"row_count,omitempty"`
}

QuerySplit represents one query to execute on the tablet

func (*QuerySplit) Descriptor

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

func (*QuerySplit) GetQuery

func (m *QuerySplit) GetQuery() *BoundQuery

func (*QuerySplit) ProtoMessage

func (*QuerySplit) ProtoMessage()

func (*QuerySplit) Reset

func (m *QuerySplit) Reset()

func (*QuerySplit) String

func (m *QuerySplit) String() string

type ReadTransactionRequest

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

ReadTransactionRequest is the payload to ReadTransaction

func (*ReadTransactionRequest) Descriptor

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

func (*ReadTransactionRequest) GetEffectiveCallerId

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

func (*ReadTransactionRequest) GetImmediateCallerId

func (m *ReadTransactionRequest) GetImmediateCallerId() *VTGateCallerID

func (*ReadTransactionRequest) GetTarget

func (m *ReadTransactionRequest) GetTarget() *Target

func (*ReadTransactionRequest) ProtoMessage

func (*ReadTransactionRequest) ProtoMessage()

func (*ReadTransactionRequest) Reset

func (m *ReadTransactionRequest) Reset()

func (*ReadTransactionRequest) String

func (m *ReadTransactionRequest) String() string

type ReadTransactionResponse

type ReadTransactionResponse struct {
	Metadata *TransactionMetadata `protobuf:"bytes,1,opt,name=metadata" json:"metadata,omitempty"`
}

ReadTransactionResponse is the returned value from ReadTransaction

func (*ReadTransactionResponse) Descriptor

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

func (*ReadTransactionResponse) GetMetadata

func (m *ReadTransactionResponse) GetMetadata() *TransactionMetadata

func (*ReadTransactionResponse) ProtoMessage

func (*ReadTransactionResponse) ProtoMessage()

func (*ReadTransactionResponse) Reset

func (m *ReadTransactionResponse) Reset()

func (*ReadTransactionResponse) String

func (m *ReadTransactionResponse) String() string

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" json:"health_error,omitempty"`
	// seconds_behind_master is populated for slaves only. It indicates
	// how far behind on (MySQL) replication a slave currently is.  It is used
	// by clients for subset selection (so we don't try to send traffic
	// to tablets that are too far behind).
	// NOTE: This field must not be evaluated if "health_error" is not empty.
	// TODO(mberlin): Let's switch it to int64 instead?
	SecondsBehindMaster uint32 `protobuf:"varint,2,opt,name=seconds_behind_master,json=secondsBehindMaster" json:"seconds_behind_master,omitempty"`
	// bin_log_players_count is the number of currently running binlog players.
	// if the value is 0, it means that filtered replication is currently not
	// running on the tablet. If >0, filtered replication is running.
	// NOTE: This field must not be evaluated if "health_error" is not empty.
	BinlogPlayersCount int32 `protobuf:"varint,3,opt,name=binlog_players_count,json=binlogPlayersCount" json:"binlog_players_count,omitempty"`
	// seconds_behind_master_filtered_replication is populated for the receiving
	// master of an ongoing filtered replication only.
	// It specifies how far the receiving master lags behind the sending master.
	// NOTE: This field must not be evaluated if "health_error" is not empty.
	// NOTE: This field must not be evaluated if "bin_log_players_count" is 0.
	SecondsBehindMasterFilteredReplication int64 `` /* 175-byte string literal not displayed */
	// cpu_usage is used for load-based balancing
	CpuUsage float64 `protobuf:"fixed64,5,opt,name=cpu_usage,json=cpuUsage" 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" json:"qps,omitempty"`
}

RealtimeStats contains information about the tablet status

func (*RealtimeStats) Descriptor

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

func (*RealtimeStats) ProtoMessage

func (*RealtimeStats) ProtoMessage()

func (*RealtimeStats) Reset

func (m *RealtimeStats) Reset()

func (*RealtimeStats) String

func (m *RealtimeStats) String() string

type ResolveTransactionRequest

type ResolveTransactionRequest struct {
	EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId" json:"effective_caller_id,omitempty"`
	ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId" json:"immediate_caller_id,omitempty"`
	Target            *Target         `protobuf:"bytes,3,opt,name=target" json:"target,omitempty"`
	Dtid              string          `protobuf:"bytes,4,opt,name=dtid" json:"dtid,omitempty"`
}

ResolveTransactionRequest is the payload to ResolveTransaction

func (*ResolveTransactionRequest) Descriptor

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

func (*ResolveTransactionRequest) GetEffectiveCallerId

func (m *ResolveTransactionRequest) GetEffectiveCallerId() *vtrpc.CallerID

func (*ResolveTransactionRequest) GetImmediateCallerId

func (m *ResolveTransactionRequest) GetImmediateCallerId() *VTGateCallerID

func (*ResolveTransactionRequest) GetTarget

func (m *ResolveTransactionRequest) GetTarget() *Target

func (*ResolveTransactionRequest) ProtoMessage

func (*ResolveTransactionRequest) ProtoMessage()

func (*ResolveTransactionRequest) Reset

func (m *ResolveTransactionRequest) Reset()

func (*ResolveTransactionRequest) String

func (m *ResolveTransactionRequest) String() string

type ResolveTransactionResponse

type ResolveTransactionResponse struct {
}

ResolveTransactionResponse is the returned value from ResolveTransaction

func (*ResolveTransactionResponse) Descriptor

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

func (*ResolveTransactionResponse) ProtoMessage

func (*ResolveTransactionResponse) ProtoMessage()

func (*ResolveTransactionResponse) Reset

func (m *ResolveTransactionResponse) Reset()

func (*ResolveTransactionResponse) String

func (m *ResolveTransactionResponse) String() string

type ResultExtras

type ResultExtras struct {
	// event_token is populated if the include_event_token flag is set
	// in ExecuteOptions.
	EventToken *EventToken `protobuf:"bytes,1,opt,name=event_token,json=eventToken" json:"event_token,omitempty"`
	// If set, it means the data returned with this result is fresher
	// than the compare_token passed in the ExecuteOptions.
	Fresher bool `protobuf:"varint,2,opt,name=fresher" json:"fresher,omitempty"`
}

ResultExtras contains optional out-of-band information. Usually the extras are requested by adding ExecuteOptions flags.

func (*ResultExtras) Descriptor

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

func (*ResultExtras) GetEventToken

func (m *ResultExtras) GetEventToken() *EventToken

func (*ResultExtras) ProtoMessage

func (*ResultExtras) ProtoMessage()

func (*ResultExtras) Reset

func (m *ResultExtras) Reset()

func (*ResultExtras) String

func (m *ResultExtras) String() string

type RollbackPreparedRequest

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

RollbackPreparedRequest is the payload to RollbackPrepared

func (*RollbackPreparedRequest) Descriptor

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

func (*RollbackPreparedRequest) GetEffectiveCallerId

func (m *RollbackPreparedRequest) GetEffectiveCallerId() *vtrpc.CallerID

func (*RollbackPreparedRequest) GetImmediateCallerId

func (m *RollbackPreparedRequest) GetImmediateCallerId() *VTGateCallerID

func (*RollbackPreparedRequest) GetTarget

func (m *RollbackPreparedRequest) GetTarget() *Target

func (*RollbackPreparedRequest) ProtoMessage

func (*RollbackPreparedRequest) ProtoMessage()

func (*RollbackPreparedRequest) Reset

func (m *RollbackPreparedRequest) Reset()

func (*RollbackPreparedRequest) String

func (m *RollbackPreparedRequest) String() string

type RollbackPreparedResponse

type RollbackPreparedResponse struct {
}

RollbackPreparedResponse is the returned value from RollbackPrepared

func (*RollbackPreparedResponse) Descriptor

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

func (*RollbackPreparedResponse) ProtoMessage

func (*RollbackPreparedResponse) ProtoMessage()

func (*RollbackPreparedResponse) Reset

func (m *RollbackPreparedResponse) Reset()

func (*RollbackPreparedResponse) String

func (m *RollbackPreparedResponse) String() string

type RollbackRequest

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

RollbackRequest is the payload to Rollback

func (*RollbackRequest) Descriptor

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

func (*RollbackRequest) GetEffectiveCallerId

func (m *RollbackRequest) GetEffectiveCallerId() *vtrpc.CallerID

func (*RollbackRequest) GetImmediateCallerId

func (m *RollbackRequest) GetImmediateCallerId() *VTGateCallerID

func (*RollbackRequest) GetTarget

func (m *RollbackRequest) GetTarget() *Target

func (*RollbackRequest) ProtoMessage

func (*RollbackRequest) ProtoMessage()

func (*RollbackRequest) Reset

func (m *RollbackRequest) Reset()

func (*RollbackRequest) String

func (m *RollbackRequest) String() string

type RollbackResponse

type RollbackResponse struct {
}

RollbackResponse is the returned value from Rollback

func (*RollbackResponse) Descriptor

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

func (*RollbackResponse) ProtoMessage

func (*RollbackResponse) ProtoMessage()

func (*RollbackResponse) Reset

func (m *RollbackResponse) Reset()

func (*RollbackResponse) String

func (m *RollbackResponse) String() string

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" 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"`
}

Row is a database row.

func (*Row) Descriptor

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

func (*Row) ProtoMessage

func (*Row) ProtoMessage()

func (*Row) Reset

func (m *Row) Reset()

func (*Row) String

func (m *Row) String() string

type SetRollbackRequest

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

SetRollbackRequest is the payload to SetRollback

func (*SetRollbackRequest) Descriptor

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

func (*SetRollbackRequest) GetEffectiveCallerId

func (m *SetRollbackRequest) GetEffectiveCallerId() *vtrpc.CallerID

func (*SetRollbackRequest) GetImmediateCallerId

func (m *SetRollbackRequest) GetImmediateCallerId() *VTGateCallerID

func (*SetRollbackRequest) GetTarget

func (m *SetRollbackRequest) GetTarget() *Target

func (*SetRollbackRequest) ProtoMessage

func (*SetRollbackRequest) ProtoMessage()

func (*SetRollbackRequest) Reset

func (m *SetRollbackRequest) Reset()

func (*SetRollbackRequest) String

func (m *SetRollbackRequest) String() string

type SetRollbackResponse

type SetRollbackResponse struct {
}

SetRollbackResponse is the returned value from SetRollback

func (*SetRollbackResponse) Descriptor

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

func (*SetRollbackResponse) ProtoMessage

func (*SetRollbackResponse) ProtoMessage()

func (*SetRollbackResponse) Reset

func (m *SetRollbackResponse) Reset()

func (*SetRollbackResponse) String

func (m *SetRollbackResponse) String() string

type SplitQueryRequest

type SplitQueryRequest struct {
	EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId" json:"effective_caller_id,omitempty"`
	ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId" json:"immediate_caller_id,omitempty"`
	Target            *Target         `protobuf:"bytes,3,opt,name=target" json:"target,omitempty"`
	Query             *BoundQuery     `protobuf:"bytes,4,opt,name=query" json:"query,omitempty"`
	SplitColumn       []string        `protobuf:"bytes,5,rep,name=split_column,json=splitColumn" json:"split_column,omitempty"`
	// Exactly one of the following must be nonzero.
	SplitCount          int64                       `protobuf:"varint,6,opt,name=split_count,json=splitCount" json:"split_count,omitempty"`
	NumRowsPerQueryPart int64                       `protobuf:"varint,8,opt,name=num_rows_per_query_part,json=numRowsPerQueryPart" json:"num_rows_per_query_part,omitempty"`
	Algorithm           SplitQueryRequest_Algorithm `protobuf:"varint,9,opt,name=algorithm,enum=query.SplitQueryRequest_Algorithm" json:"algorithm,omitempty"`
}

SplitQueryRequest is the payload for SplitQuery sent by VTGate to a VTTablet. See vtgate.SplitQueryRequest for more details.

func (*SplitQueryRequest) Descriptor

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

func (*SplitQueryRequest) GetEffectiveCallerId

func (m *SplitQueryRequest) GetEffectiveCallerId() *vtrpc.CallerID

func (*SplitQueryRequest) GetImmediateCallerId

func (m *SplitQueryRequest) GetImmediateCallerId() *VTGateCallerID

func (*SplitQueryRequest) GetQuery

func (m *SplitQueryRequest) GetQuery() *BoundQuery

func (*SplitQueryRequest) GetTarget

func (m *SplitQueryRequest) GetTarget() *Target

func (*SplitQueryRequest) ProtoMessage

func (*SplitQueryRequest) ProtoMessage()

func (*SplitQueryRequest) Reset

func (m *SplitQueryRequest) Reset()

func (*SplitQueryRequest) String

func (m *SplitQueryRequest) String() string

type SplitQueryRequest_Algorithm

type SplitQueryRequest_Algorithm int32
const (
	SplitQueryRequest_EQUAL_SPLITS SplitQueryRequest_Algorithm = 0
	SplitQueryRequest_FULL_SCAN    SplitQueryRequest_Algorithm = 1
)

func (SplitQueryRequest_Algorithm) EnumDescriptor

func (SplitQueryRequest_Algorithm) EnumDescriptor() ([]byte, []int)

func (SplitQueryRequest_Algorithm) String

type SplitQueryResponse

type SplitQueryResponse struct {
	Queries []*QuerySplit `protobuf:"bytes,1,rep,name=queries" json:"queries,omitempty"`
}

SplitQueryResponse is returned by SplitQuery and represents all the queries to execute in order to get the entire data set.

func (*SplitQueryResponse) Descriptor

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

func (*SplitQueryResponse) GetQueries

func (m *SplitQueryResponse) GetQueries() []*QuerySplit

func (*SplitQueryResponse) ProtoMessage

func (*SplitQueryResponse) ProtoMessage()

func (*SplitQueryResponse) Reset

func (m *SplitQueryResponse) Reset()

func (*SplitQueryResponse) String

func (m *SplitQueryResponse) String() string

type StartCommitRequest

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

StartCommitRequest is the payload to StartCommit

func (*StartCommitRequest) Descriptor

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

func (*StartCommitRequest) GetEffectiveCallerId

func (m *StartCommitRequest) GetEffectiveCallerId() *vtrpc.CallerID

func (*StartCommitRequest) GetImmediateCallerId

func (m *StartCommitRequest) GetImmediateCallerId() *VTGateCallerID

func (*StartCommitRequest) GetTarget

func (m *StartCommitRequest) GetTarget() *Target

func (*StartCommitRequest) ProtoMessage

func (*StartCommitRequest) ProtoMessage()

func (*StartCommitRequest) Reset

func (m *StartCommitRequest) Reset()

func (*StartCommitRequest) String

func (m *StartCommitRequest) String() string

type StartCommitResponse

type StartCommitResponse struct {
}

StartCommitResponse is the returned value from StartCommit

func (*StartCommitResponse) Descriptor

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

func (*StartCommitResponse) ProtoMessage

func (*StartCommitResponse) ProtoMessage()

func (*StartCommitResponse) Reset

func (m *StartCommitResponse) Reset()

func (*StartCommitResponse) String

func (m *StartCommitResponse) String() string

type StreamEvent

type StreamEvent struct {
	// The statements in this transaction.
	Statements []*StreamEvent_Statement `protobuf:"bytes,1,rep,name=statements" json:"statements,omitempty"`
	// The Event Token for this event.
	EventToken *EventToken `protobuf:"bytes,2,opt,name=event_token,json=eventToken" json:"event_token,omitempty"`
}

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

func (*StreamEvent) Descriptor

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

func (*StreamEvent) GetEventToken

func (m *StreamEvent) GetEventToken() *EventToken

func (*StreamEvent) GetStatements

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

func (*StreamEvent) ProtoMessage

func (*StreamEvent) ProtoMessage()

func (*StreamEvent) Reset

func (m *StreamEvent) Reset()

func (*StreamEvent) String

func (m *StreamEvent) String() string

type StreamEvent_Statement

type StreamEvent_Statement struct {
	Category StreamEvent_Statement_Category `protobuf:"varint,1,opt,name=category,enum=query.StreamEvent_Statement_Category" json:"category,omitempty"`
	// table_name, primary_key_fields and primary_key_values are set for DML.
	TableName        string   `protobuf:"bytes,2,opt,name=table_name,json=tableName" json:"table_name,omitempty"`
	PrimaryKeyFields []*Field `protobuf:"bytes,3,rep,name=primary_key_fields,json=primaryKeyFields" json:"primary_key_fields,omitempty"`
	PrimaryKeyValues []*Row   `protobuf:"bytes,4,rep,name=primary_key_values,json=primaryKeyValues" 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"`
}

One individual Statement in a transaction.

func (*StreamEvent_Statement) Descriptor

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

func (*StreamEvent_Statement) GetPrimaryKeyFields

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

func (*StreamEvent_Statement) GetPrimaryKeyValues

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

func (*StreamEvent_Statement) ProtoMessage

func (*StreamEvent_Statement) ProtoMessage()

func (*StreamEvent_Statement) Reset

func (m *StreamEvent_Statement) Reset()

func (*StreamEvent_Statement) String

func (m *StreamEvent_Statement) String() string

type StreamEvent_Statement_Category

type StreamEvent_Statement_Category int32

The category of one statement.

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

func (StreamEvent_Statement_Category) EnumDescriptor

func (StreamEvent_Statement_Category) EnumDescriptor() ([]byte, []int)

func (StreamEvent_Statement_Category) String

type StreamExecuteRequest

type StreamExecuteRequest struct {
	EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId" json:"effective_caller_id,omitempty"`
	ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId" json:"immediate_caller_id,omitempty"`
	Target            *Target         `protobuf:"bytes,3,opt,name=target" json:"target,omitempty"`
	Query             *BoundQuery     `protobuf:"bytes,4,opt,name=query" json:"query,omitempty"`
	Options           *ExecuteOptions `protobuf:"bytes,5,opt,name=options" json:"options,omitempty"`
}

StreamExecuteRequest is the payload to StreamExecute

func (*StreamExecuteRequest) Descriptor

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

func (*StreamExecuteRequest) GetEffectiveCallerId

func (m *StreamExecuteRequest) GetEffectiveCallerId() *vtrpc.CallerID

func (*StreamExecuteRequest) GetImmediateCallerId

func (m *StreamExecuteRequest) GetImmediateCallerId() *VTGateCallerID

func (*StreamExecuteRequest) GetOptions

func (m *StreamExecuteRequest) GetOptions() *ExecuteOptions

func (*StreamExecuteRequest) GetQuery

func (m *StreamExecuteRequest) GetQuery() *BoundQuery

func (*StreamExecuteRequest) GetTarget

func (m *StreamExecuteRequest) GetTarget() *Target

func (*StreamExecuteRequest) ProtoMessage

func (*StreamExecuteRequest) ProtoMessage()

func (*StreamExecuteRequest) Reset

func (m *StreamExecuteRequest) Reset()

func (*StreamExecuteRequest) String

func (m *StreamExecuteRequest) String() string

type StreamExecuteResponse

type StreamExecuteResponse struct {
	Result *QueryResult `protobuf:"bytes,1,opt,name=result" json:"result,omitempty"`
}

StreamExecuteResponse is the returned value from StreamExecute

func (*StreamExecuteResponse) Descriptor

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

func (*StreamExecuteResponse) GetResult

func (m *StreamExecuteResponse) GetResult() *QueryResult

func (*StreamExecuteResponse) ProtoMessage

func (*StreamExecuteResponse) ProtoMessage()

func (*StreamExecuteResponse) Reset

func (m *StreamExecuteResponse) Reset()

func (*StreamExecuteResponse) String

func (m *StreamExecuteResponse) String() string

type StreamHealthRequest

type StreamHealthRequest struct {
}

StreamHealthRequest is the payload for StreamHealth

func (*StreamHealthRequest) Descriptor

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

func (*StreamHealthRequest) ProtoMessage

func (*StreamHealthRequest) ProtoMessage()

func (*StreamHealthRequest) Reset

func (m *StreamHealthRequest) Reset()

func (*StreamHealthRequest) String

func (m *StreamHealthRequest) String() string

type StreamHealthResponse

type StreamHealthResponse struct {
	// target is the current server type. Only queries with that exact Target
	// record will be accepted.
	Target *Target `protobuf:"bytes,1,opt,name=target" json:"target,omitempty"`
	// serving is true iff the tablet is serving. A tablet may not be serving
	// if filtered replication is enabled on a master for instance,
	// or if a replica should not be used because the keyspace is being resharded.
	Serving bool `protobuf:"varint,2,opt,name=serving" json:"serving,omitempty"`
	// tablet_externally_reparented_timestamp contains the last time
	// tabletmanager.TabletExternallyReparented was called on this tablet,
	// or 0 if it was never called. This is meant to differentiate two tablets
	// that report a target.TabletType of MASTER, only the one with the latest
	// timestamp should be trusted.
	TabletExternallyReparentedTimestamp int64 `` /* 164-byte string literal not displayed */
	// realtime_stats contains information about the tablet status
	RealtimeStats *RealtimeStats `protobuf:"bytes,4,opt,name=realtime_stats,json=realtimeStats" json:"realtime_stats,omitempty"`
}

StreamHealthResponse is streamed by StreamHealth on a regular basis

func (*StreamHealthResponse) Descriptor

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

func (*StreamHealthResponse) GetRealtimeStats

func (m *StreamHealthResponse) GetRealtimeStats() *RealtimeStats

func (*StreamHealthResponse) GetTarget

func (m *StreamHealthResponse) GetTarget() *Target

func (*StreamHealthResponse) ProtoMessage

func (*StreamHealthResponse) ProtoMessage()

func (*StreamHealthResponse) Reset

func (m *StreamHealthResponse) Reset()

func (*StreamHealthResponse) String

func (m *StreamHealthResponse) String() string

type Target

type Target struct {
	Keyspace   string              `protobuf:"bytes,1,opt,name=keyspace" json:"keyspace,omitempty"`
	Shard      string              `protobuf:"bytes,2,opt,name=shard" json:"shard,omitempty"`
	TabletType topodata.TabletType `protobuf:"varint,3,opt,name=tablet_type,json=tabletType,enum=topodata.TabletType" json:"tablet_type,omitempty"`
}

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

func (*Target) Descriptor

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

func (*Target) ProtoMessage

func (*Target) ProtoMessage()

func (*Target) Reset

func (m *Target) Reset()

func (*Target) String

func (m *Target) String() string

type TransactionMetadata

type TransactionMetadata struct {
	Dtid         string           `protobuf:"bytes,1,opt,name=dtid" json:"dtid,omitempty"`
	State        TransactionState `protobuf:"varint,2,opt,name=state,enum=query.TransactionState" json:"state,omitempty"`
	TimeCreated  int64            `protobuf:"varint,3,opt,name=time_created,json=timeCreated" json:"time_created,omitempty"`
	TimeUpdated  int64            `protobuf:"varint,4,opt,name=time_updated,json=timeUpdated" json:"time_updated,omitempty"`
	Participants []*Target        `protobuf:"bytes,5,rep,name=participants" json:"participants,omitempty"`
}

TransactionMetadata contains the metadata for a distributed transaction.

func (*TransactionMetadata) Descriptor

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

func (*TransactionMetadata) GetParticipants

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

func (*TransactionMetadata) ProtoMessage

func (*TransactionMetadata) ProtoMessage()

func (*TransactionMetadata) Reset

func (m *TransactionMetadata) Reset()

func (*TransactionMetadata) String

func (m *TransactionMetadata) String() string

type TransactionState

type TransactionState int32

TransactionState represents the state of a distributed transaction.

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

func (TransactionState) EnumDescriptor

func (TransactionState) EnumDescriptor() ([]byte, []int)

func (TransactionState) String

func (x TransactionState) String() string

type Type

type Type int32

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

const (
	// NULL_TYPE specifies a NULL type.
	Type_NULL_TYPE Type = 0
	// INT8 specifies a TINYINT type.
	// Properties: 1, IsNumber.
	Type_INT8 Type = 257
	// UINT8 specifies a TINYINT UNSIGNED type.
	// Properties: 2, IsNumber, IsUnsigned.
	Type_UINT8 Type = 770
	// INT16 specifies a SMALLINT type.
	// Properties: 3, IsNumber.
	Type_INT16 Type = 259
	// UINT16 specifies a SMALLINT UNSIGNED type.
	// Properties: 4, IsNumber, IsUnsigned.
	Type_UINT16 Type = 772
	// INT24 specifies a MEDIUMINT type.
	// Properties: 5, IsNumber.
	Type_INT24 Type = 261
	// UINT24 specifies a MEDIUMINT UNSIGNED type.
	// Properties: 6, IsNumber, IsUnsigned.
	Type_UINT24 Type = 774
	// INT32 specifies a INTEGER type.
	// Properties: 7, IsNumber.
	Type_INT32 Type = 263
	// UINT32 specifies a INTEGER UNSIGNED type.
	// Properties: 8, IsNumber, IsUnsigned.
	Type_UINT32 Type = 776
	// INT64 specifies a BIGINT type.
	// Properties: 9, IsNumber.
	Type_INT64 Type = 265
	// UINT64 specifies a BIGINT UNSIGNED type.
	// Properties: 10, IsNumber, IsUnsigned.
	Type_UINT64 Type = 778
	// FLOAT32 specifies a FLOAT type.
	// Properties: 11, IsFloat.
	Type_FLOAT32 Type = 1035
	// FLOAT64 specifies a DOUBLE or REAL type.
	// Properties: 12, IsFloat.
	Type_FLOAT64 Type = 1036
	// TIMESTAMP specifies a TIMESTAMP type.
	// Properties: 13, IsQuoted.
	Type_TIMESTAMP Type = 2061
	// DATE specifies a DATE type.
	// Properties: 14, IsQuoted.
	Type_DATE Type = 2062
	// TIME specifies a TIME type.
	// Properties: 15, IsQuoted.
	Type_TIME Type = 2063
	// DATETIME specifies a DATETIME type.
	// Properties: 16, IsQuoted.
	Type_DATETIME Type = 2064
	// YEAR specifies a YEAR type.
	// Properties: 17, IsNumber, IsUnsigned.
	Type_YEAR Type = 785
	// DECIMAL specifies a DECIMAL or NUMERIC type.
	// Properties: 18, None.
	Type_DECIMAL Type = 18
	// TEXT specifies a TEXT type.
	// Properties: 19, IsQuoted, IsText.
	Type_TEXT Type = 6163
	// BLOB specifies a BLOB type.
	// Properties: 20, IsQuoted, IsBinary.
	Type_BLOB Type = 10260
	// VARCHAR specifies a VARCHAR type.
	// Properties: 21, IsQuoted, IsText.
	Type_VARCHAR Type = 6165
	// VARBINARY specifies a VARBINARY type.
	// Properties: 22, IsQuoted, IsBinary.
	Type_VARBINARY Type = 10262
	// CHAR specifies a CHAR type.
	// Properties: 23, IsQuoted, IsText.
	Type_CHAR Type = 6167
	// BINARY specifies a BINARY type.
	// Properties: 24, IsQuoted, IsBinary.
	Type_BINARY Type = 10264
	// BIT specifies a BIT type.
	// Properties: 25, IsQuoted.
	Type_BIT Type = 2073
	// ENUM specifies an ENUM type.
	// Properties: 26, IsQuoted.
	Type_ENUM Type = 2074
	// SET specifies a SET type.
	// Properties: 27, IsQuoted.
	Type_SET Type = 2075
	// TUPLE specifies a 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
)

func (Type) EnumDescriptor

func (Type) EnumDescriptor() ([]byte, []int)

func (Type) String

func (x Type) String() string

type UpdateStreamRequest

type UpdateStreamRequest struct {
	EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId" json:"effective_caller_id,omitempty"`
	ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId" json:"immediate_caller_id,omitempty"`
	Target            *Target         `protobuf:"bytes,3,opt,name=target" json:"target,omitempty"`
	// If position is set, we will start the streaming from that replication
	// position. Incompatible with timestamp.
	Position string `protobuf:"bytes,4,opt,name=position" json:"position,omitempty"`
	// If timestamp is set, we will start the streaming from the first
	// event in the binlogs that have that timestamp. Incompatible with position.
	Timestamp int64 `protobuf:"varint,5,opt,name=timestamp" json:"timestamp,omitempty"`
}

UpdateStreamRequest is the payload for UpdateStream. At most one of position and timestamp can be set. If neither is set, we will start streaming from the current binlog position.

func (*UpdateStreamRequest) Descriptor

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

func (*UpdateStreamRequest) GetEffectiveCallerId

func (m *UpdateStreamRequest) GetEffectiveCallerId() *vtrpc.CallerID

func (*UpdateStreamRequest) GetImmediateCallerId

func (m *UpdateStreamRequest) GetImmediateCallerId() *VTGateCallerID

func (*UpdateStreamRequest) GetTarget

func (m *UpdateStreamRequest) GetTarget() *Target

func (*UpdateStreamRequest) ProtoMessage

func (*UpdateStreamRequest) ProtoMessage()

func (*UpdateStreamRequest) Reset

func (m *UpdateStreamRequest) Reset()

func (*UpdateStreamRequest) String

func (m *UpdateStreamRequest) String() string

type UpdateStreamResponse

type UpdateStreamResponse struct {
	Event *StreamEvent `protobuf:"bytes,1,opt,name=event" json:"event,omitempty"`
}

UpdateStreamResponse is returned by UpdateStream

func (*UpdateStreamResponse) Descriptor

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

func (*UpdateStreamResponse) GetEvent

func (m *UpdateStreamResponse) GetEvent() *StreamEvent

func (*UpdateStreamResponse) ProtoMessage

func (*UpdateStreamResponse) ProtoMessage()

func (*UpdateStreamResponse) Reset

func (m *UpdateStreamResponse) Reset()

func (*UpdateStreamResponse) String

func (m *UpdateStreamResponse) String() string

type VTGateCallerID

type VTGateCallerID struct {
	Username string `protobuf:"bytes,1,opt,name=username" json:"username,omitempty"`
}

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

func (*VTGateCallerID) Descriptor

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

func (*VTGateCallerID) ProtoMessage

func (*VTGateCallerID) ProtoMessage()

func (*VTGateCallerID) Reset

func (m *VTGateCallerID) Reset()

func (*VTGateCallerID) String

func (m *VTGateCallerID) String() string

type Value

type Value struct {
	Type  Type   `protobuf:"varint,1,opt,name=type,enum=query.Type" json:"type,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

Value represents a typed value.

func (*Value) Descriptor

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

func (*Value) ProtoMessage

func (*Value) ProtoMessage()

func (*Value) Reset

func (m *Value) Reset()

func (*Value) String

func (m *Value) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL