go-vitess.v1: gopkg.in/src-d/go-vitess.v1/vt/proto/query Index | Files

package query

import "gopkg.in/src-d/go-vitess.v1/vt/proto/query"

Index

Package Files

query.pb.go

Variables

var ExecuteOptions_IncludedFields_name = map[int32]string{
    0:  "TYPE_AND_NAME",
    1:  "TYPE_ONLY",
    2:  "ALL",
}
var ExecuteOptions_IncludedFields_value = map[string]int32{
    "TYPE_AND_NAME": 0,
    "TYPE_ONLY":     1,
    "ALL":           2,
}
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",
}
var 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,
}
var ExecuteOptions_Workload_name = map[int32]string{
    0:  "UNSPECIFIED",
    1:  "OLTP",
    2:  "OLAP",
    3:  "DBA",
}
var ExecuteOptions_Workload_value = map[string]int32{
    "UNSPECIFIED": 0,
    "OLTP":        1,
    "OLAP":        2,
    "DBA":         3,
}
var Flag_name = map[int32]string{
    0:    "NONE",
    256:  "ISINTEGRAL",
    512:  "ISUNSIGNED",
    1024: "ISFLOAT",
    2048: "ISQUOTED",
    4096: "ISTEXT",
    8192: "ISBINARY",
}
var Flag_value = map[string]int32{
    "NONE":       0,
    "ISINTEGRAL": 256,
    "ISUNSIGNED": 512,
    "ISFLOAT":    1024,
    "ISQUOTED":   2048,
    "ISTEXT":     4096,
    "ISBINARY":   8192,
}
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",
}
var 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,
}
var SplitQueryRequest_Algorithm_name = map[int32]string{
    0:  "EQUAL_SPLITS",
    1:  "FULL_SCAN",
}
var SplitQueryRequest_Algorithm_value = map[string]int32{
    "EQUAL_SPLITS": 0,
    "FULL_SCAN":    1,
}
var StreamEvent_Statement_Category_name = map[int32]string{
    0:  "Error",
    1:  "DML",
    2:  "DDL",
}
var StreamEvent_Statement_Category_value = map[string]int32{
    "Error": 0,
    "DML":   1,
    "DDL":   2,
}
var TransactionState_name = map[int32]string{
    0:  "UNKNOWN",
    1:  "PREPARE",
    2:  "COMMIT",
    3:  "ROLLBACK",
}
var TransactionState_value = map[string]int32{
    "UNKNOWN":  0,
    "PREPARE":  1,
    "COMMIT":   2,
    "ROLLBACK": 3,
}
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",
}
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,
    "GEOMETRY":   2077,
    "JSON":       2078,
    "EXPRESSION": 31,
}

type AggregateStats Uses

type AggregateStats struct {
    // healthy_tablet_count is the number of healthy tablets in the group.
    HealthyTabletCount int32 `protobuf:"varint,1,opt,name=healthy_tablet_count,json=healthyTabletCount,proto3" json:"healthy_tablet_count,omitempty"`
    // unhealthy_tablet_count is the number of unhealthy tablets in the group.
    UnhealthyTabletCount int32 `protobuf:"varint,2,opt,name=unhealthy_tablet_count,json=unhealthyTabletCount,proto3" json:"unhealthy_tablet_count,omitempty"`
    // seconds_behind_master_min is the minimum of the
    // seconds_behind_master values of the healthy tablets. It is unset
    // if the tablet type is master.
    SecondsBehindMasterMin uint32 `protobuf:"varint,3,opt,name=seconds_behind_master_min,json=secondsBehindMasterMin,proto3" json:"seconds_behind_master_min,omitempty"`
    // seconds_behind_master_max is the maximum of the
    // seconds_behind_master values of the healthy tablets. It is unset
    // if the tablet type is master.
    SecondsBehindMasterMax uint32   `protobuf:"varint,4,opt,name=seconds_behind_master_max,json=secondsBehindMasterMax,proto3" json:"seconds_behind_master_max,omitempty"`
    XXX_NoUnkeyedLiteral   struct{} `json:"-"`
    XXX_unrecognized       []byte   `json:"-"`
    XXX_sizecache          int32    `json:"-"`
}

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

func (*AggregateStats) Descriptor Uses

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

func (*AggregateStats) GetHealthyTabletCount Uses

func (m *AggregateStats) GetHealthyTabletCount() int32

func (*AggregateStats) GetSecondsBehindMasterMax Uses

func (m *AggregateStats) GetSecondsBehindMasterMax() uint32

func (*AggregateStats) GetSecondsBehindMasterMin Uses

func (m *AggregateStats) GetSecondsBehindMasterMin() uint32

func (*AggregateStats) GetUnhealthyTabletCount Uses

func (m *AggregateStats) GetUnhealthyTabletCount() int32

func (*AggregateStats) ProtoMessage Uses

func (*AggregateStats) ProtoMessage()

func (*AggregateStats) Reset Uses

func (m *AggregateStats) Reset()

func (*AggregateStats) String Uses

func (m *AggregateStats) String() string

func (*AggregateStats) XXX_DiscardUnknown Uses

func (m *AggregateStats) XXX_DiscardUnknown()

func (*AggregateStats) XXX_Marshal Uses

func (m *AggregateStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AggregateStats) XXX_Merge Uses

func (dst *AggregateStats) XXX_Merge(src proto.Message)

func (*AggregateStats) XXX_Size Uses

func (m *AggregateStats) XXX_Size() int

func (*AggregateStats) XXX_Unmarshal Uses

func (m *AggregateStats) XXX_Unmarshal(b []byte) error

type BeginExecuteBatchRequest Uses

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

BeginExecuteBatchRequest is the payload to BeginExecuteBatch

func (*BeginExecuteBatchRequest) Descriptor Uses

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

func (*BeginExecuteBatchRequest) GetAsTransaction Uses

func (m *BeginExecuteBatchRequest) GetAsTransaction() bool

func (*BeginExecuteBatchRequest) GetEffectiveCallerId Uses

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

func (*BeginExecuteBatchRequest) GetImmediateCallerId Uses

func (m *BeginExecuteBatchRequest) GetImmediateCallerId() *VTGateCallerID

func (*BeginExecuteBatchRequest) GetOptions Uses

func (m *BeginExecuteBatchRequest) GetOptions() *ExecuteOptions

func (*BeginExecuteBatchRequest) GetQueries Uses

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

func (*BeginExecuteBatchRequest) GetTarget Uses

func (m *BeginExecuteBatchRequest) GetTarget() *Target

func (*BeginExecuteBatchRequest) ProtoMessage Uses

func (*BeginExecuteBatchRequest) ProtoMessage()

func (*BeginExecuteBatchRequest) Reset Uses

func (m *BeginExecuteBatchRequest) Reset()

func (*BeginExecuteBatchRequest) String Uses

func (m *BeginExecuteBatchRequest) String() string

func (*BeginExecuteBatchRequest) XXX_DiscardUnknown Uses

func (m *BeginExecuteBatchRequest) XXX_DiscardUnknown()

func (*BeginExecuteBatchRequest) XXX_Marshal Uses

func (m *BeginExecuteBatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BeginExecuteBatchRequest) XXX_Merge Uses

func (dst *BeginExecuteBatchRequest) XXX_Merge(src proto.Message)

func (*BeginExecuteBatchRequest) XXX_Size Uses

func (m *BeginExecuteBatchRequest) XXX_Size() int

func (*BeginExecuteBatchRequest) XXX_Unmarshal Uses

func (m *BeginExecuteBatchRequest) XXX_Unmarshal(b []byte) error

type BeginExecuteBatchResponse Uses

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

BeginExecuteBatchResponse is the returned value from BeginExecuteBatch

func (*BeginExecuteBatchResponse) Descriptor Uses

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

func (*BeginExecuteBatchResponse) GetError Uses

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

func (*BeginExecuteBatchResponse) GetResults Uses

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

func (*BeginExecuteBatchResponse) GetTransactionId Uses

func (m *BeginExecuteBatchResponse) GetTransactionId() int64

func (*BeginExecuteBatchResponse) ProtoMessage Uses

func (*BeginExecuteBatchResponse) ProtoMessage()

func (*BeginExecuteBatchResponse) Reset Uses

func (m *BeginExecuteBatchResponse) Reset()

func (*BeginExecuteBatchResponse) String Uses

func (m *BeginExecuteBatchResponse) String() string

func (*BeginExecuteBatchResponse) XXX_DiscardUnknown Uses

func (m *BeginExecuteBatchResponse) XXX_DiscardUnknown()

func (*BeginExecuteBatchResponse) XXX_Marshal Uses

func (m *BeginExecuteBatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BeginExecuteBatchResponse) XXX_Merge Uses

func (dst *BeginExecuteBatchResponse) XXX_Merge(src proto.Message)

func (*BeginExecuteBatchResponse) XXX_Size Uses

func (m *BeginExecuteBatchResponse) XXX_Size() int

func (*BeginExecuteBatchResponse) XXX_Unmarshal Uses

func (m *BeginExecuteBatchResponse) XXX_Unmarshal(b []byte) error

type BeginExecuteRequest Uses

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

BeginExecuteRequest is the payload to BeginExecute

func (*BeginExecuteRequest) Descriptor Uses

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

func (*BeginExecuteRequest) GetEffectiveCallerId Uses

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

func (*BeginExecuteRequest) GetImmediateCallerId Uses

func (m *BeginExecuteRequest) GetImmediateCallerId() *VTGateCallerID

func (*BeginExecuteRequest) GetOptions Uses

func (m *BeginExecuteRequest) GetOptions() *ExecuteOptions

func (*BeginExecuteRequest) GetQuery Uses

func (m *BeginExecuteRequest) GetQuery() *BoundQuery

func (*BeginExecuteRequest) GetTarget Uses

func (m *BeginExecuteRequest) GetTarget() *Target

func (*BeginExecuteRequest) ProtoMessage Uses

func (*BeginExecuteRequest) ProtoMessage()

func (*BeginExecuteRequest) Reset Uses

func (m *BeginExecuteRequest) Reset()

func (*BeginExecuteRequest) String Uses

func (m *BeginExecuteRequest) String() string

func (*BeginExecuteRequest) XXX_DiscardUnknown Uses

func (m *BeginExecuteRequest) XXX_DiscardUnknown()

func (*BeginExecuteRequest) XXX_Marshal Uses

func (m *BeginExecuteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BeginExecuteRequest) XXX_Merge Uses

func (dst *BeginExecuteRequest) XXX_Merge(src proto.Message)

func (*BeginExecuteRequest) XXX_Size Uses

func (m *BeginExecuteRequest) XXX_Size() int

func (*BeginExecuteRequest) XXX_Unmarshal Uses

func (m *BeginExecuteRequest) XXX_Unmarshal(b []byte) error

type BeginExecuteResponse Uses

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

BeginExecuteResponse is the returned value from BeginExecute

func (*BeginExecuteResponse) Descriptor Uses

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

func (*BeginExecuteResponse) GetError Uses

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

func (*BeginExecuteResponse) GetResult Uses

func (m *BeginExecuteResponse) GetResult() *QueryResult

func (*BeginExecuteResponse) GetTransactionId Uses

func (m *BeginExecuteResponse) GetTransactionId() int64

func (*BeginExecuteResponse) ProtoMessage Uses

func (*BeginExecuteResponse) ProtoMessage()

func (*BeginExecuteResponse) Reset Uses

func (m *BeginExecuteResponse) Reset()

func (*BeginExecuteResponse) String Uses

func (m *BeginExecuteResponse) String() string

func (*BeginExecuteResponse) XXX_DiscardUnknown Uses

func (m *BeginExecuteResponse) XXX_DiscardUnknown()

func (*BeginExecuteResponse) XXX_Marshal Uses

func (m *BeginExecuteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BeginExecuteResponse) XXX_Merge Uses

func (dst *BeginExecuteResponse) XXX_Merge(src proto.Message)

func (*BeginExecuteResponse) XXX_Size Uses

func (m *BeginExecuteResponse) XXX_Size() int

func (*BeginExecuteResponse) XXX_Unmarshal Uses

func (m *BeginExecuteResponse) XXX_Unmarshal(b []byte) error

type BeginRequest Uses

type BeginRequest struct {
    EffectiveCallerId    *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
    ImmediateCallerId    *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
    Target               *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
    Options              *ExecuteOptions `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
    XXX_NoUnkeyedLiteral struct{}        `json:"-"`
    XXX_unrecognized     []byte          `json:"-"`
    XXX_sizecache        int32           `json:"-"`
}

BeginRequest is the payload to Begin

func (*BeginRequest) Descriptor Uses

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

func (*BeginRequest) GetEffectiveCallerId Uses

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

func (*BeginRequest) GetImmediateCallerId Uses

func (m *BeginRequest) GetImmediateCallerId() *VTGateCallerID

func (*BeginRequest) GetOptions Uses

func (m *BeginRequest) GetOptions() *ExecuteOptions

func (*BeginRequest) GetTarget Uses

func (m *BeginRequest) GetTarget() *Target

func (*BeginRequest) ProtoMessage Uses

func (*BeginRequest) ProtoMessage()

func (*BeginRequest) Reset Uses

func (m *BeginRequest) Reset()

func (*BeginRequest) String Uses

func (m *BeginRequest) String() string

func (*BeginRequest) XXX_DiscardUnknown Uses

func (m *BeginRequest) XXX_DiscardUnknown()

func (*BeginRequest) XXX_Marshal Uses

func (m *BeginRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BeginRequest) XXX_Merge Uses

func (dst *BeginRequest) XXX_Merge(src proto.Message)

func (*BeginRequest) XXX_Size Uses

func (m *BeginRequest) XXX_Size() int

func (*BeginRequest) XXX_Unmarshal Uses

func (m *BeginRequest) XXX_Unmarshal(b []byte) error

type BeginResponse Uses

type BeginResponse struct {
    TransactionId        int64    `protobuf:"varint,1,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

BeginResponse is the returned value from Begin

func (*BeginResponse) Descriptor Uses

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

func (*BeginResponse) GetTransactionId Uses

func (m *BeginResponse) GetTransactionId() int64

func (*BeginResponse) ProtoMessage Uses

func (*BeginResponse) ProtoMessage()

func (*BeginResponse) Reset Uses

func (m *BeginResponse) Reset()

func (*BeginResponse) String Uses

func (m *BeginResponse) String() string

func (*BeginResponse) XXX_DiscardUnknown Uses

func (m *BeginResponse) XXX_DiscardUnknown()

func (*BeginResponse) XXX_Marshal Uses

func (m *BeginResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BeginResponse) XXX_Merge Uses

func (dst *BeginResponse) XXX_Merge(src proto.Message)

func (*BeginResponse) XXX_Size Uses

func (m *BeginResponse) XXX_Size() int

func (*BeginResponse) XXX_Unmarshal Uses

func (m *BeginResponse) XXX_Unmarshal(b []byte) error

type BindVariable Uses

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

BindVariable represents a single bind variable in a Query.

func (*BindVariable) Descriptor Uses

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

func (*BindVariable) GetType Uses

func (m *BindVariable) GetType() Type

func (*BindVariable) GetValue Uses

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

func (*BindVariable) GetValues Uses

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

func (*BindVariable) ProtoMessage Uses

func (*BindVariable) ProtoMessage()

func (*BindVariable) Reset Uses

func (m *BindVariable) Reset()

func (*BindVariable) String Uses

func (m *BindVariable) String() string

func (*BindVariable) XXX_DiscardUnknown Uses

func (m *BindVariable) XXX_DiscardUnknown()

func (*BindVariable) XXX_Marshal Uses

func (m *BindVariable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BindVariable) XXX_Merge Uses

func (dst *BindVariable) XXX_Merge(src proto.Message)

func (*BindVariable) XXX_Size Uses

func (m *BindVariable) XXX_Size() int

func (*BindVariable) XXX_Unmarshal Uses

func (m *BindVariable) XXX_Unmarshal(b []byte) error

type BoundQuery Uses

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 `protobuf:"bytes,2,rep,name=bind_variables,json=bindVariables,proto3" json:"bind_variables,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
    XXX_unrecognized     []byte                   `json:"-"`
    XXX_sizecache        int32                    `json:"-"`
}

BoundQuery is a query with its bind variables

func (*BoundQuery) Descriptor Uses

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

func (*BoundQuery) GetBindVariables Uses

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

func (*BoundQuery) GetSql Uses

func (m *BoundQuery) GetSql() string

func (*BoundQuery) ProtoMessage Uses

func (*BoundQuery) ProtoMessage()

func (*BoundQuery) Reset Uses

func (m *BoundQuery) Reset()

func (*BoundQuery) String Uses

func (m *BoundQuery) String() string

func (*BoundQuery) XXX_DiscardUnknown Uses

func (m *BoundQuery) XXX_DiscardUnknown()

func (*BoundQuery) XXX_Marshal Uses

func (m *BoundQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BoundQuery) XXX_Merge Uses

func (dst *BoundQuery) XXX_Merge(src proto.Message)

func (*BoundQuery) XXX_Size Uses

func (m *BoundQuery) XXX_Size() int

func (*BoundQuery) XXX_Unmarshal Uses

func (m *BoundQuery) XXX_Unmarshal(b []byte) error

type CommitPreparedRequest Uses

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

CommitPreparedRequest is the payload to CommitPrepared

func (*CommitPreparedRequest) Descriptor Uses

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

func (*CommitPreparedRequest) GetDtid Uses

func (m *CommitPreparedRequest) GetDtid() string

func (*CommitPreparedRequest) GetEffectiveCallerId Uses

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

func (*CommitPreparedRequest) GetImmediateCallerId Uses

func (m *CommitPreparedRequest) GetImmediateCallerId() *VTGateCallerID

func (*CommitPreparedRequest) GetTarget Uses

func (m *CommitPreparedRequest) GetTarget() *Target

func (*CommitPreparedRequest) ProtoMessage Uses

func (*CommitPreparedRequest) ProtoMessage()

func (*CommitPreparedRequest) Reset Uses

func (m *CommitPreparedRequest) Reset()

func (*CommitPreparedRequest) String Uses

func (m *CommitPreparedRequest) String() string

func (*CommitPreparedRequest) XXX_DiscardUnknown Uses

func (m *CommitPreparedRequest) XXX_DiscardUnknown()

func (*CommitPreparedRequest) XXX_Marshal Uses

func (m *CommitPreparedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommitPreparedRequest) XXX_Merge Uses

func (dst *CommitPreparedRequest) XXX_Merge(src proto.Message)

func (*CommitPreparedRequest) XXX_Size Uses

func (m *CommitPreparedRequest) XXX_Size() int

func (*CommitPreparedRequest) XXX_Unmarshal Uses

func (m *CommitPreparedRequest) XXX_Unmarshal(b []byte) error

type CommitPreparedResponse Uses

type CommitPreparedResponse struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

CommitPreparedResponse is the returned value from CommitPrepared

func (*CommitPreparedResponse) Descriptor Uses

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

func (*CommitPreparedResponse) ProtoMessage Uses

func (*CommitPreparedResponse) ProtoMessage()

func (*CommitPreparedResponse) Reset Uses

func (m *CommitPreparedResponse) Reset()

func (*CommitPreparedResponse) String Uses

func (m *CommitPreparedResponse) String() string

func (*CommitPreparedResponse) XXX_DiscardUnknown Uses

func (m *CommitPreparedResponse) XXX_DiscardUnknown()

func (*CommitPreparedResponse) XXX_Marshal Uses

func (m *CommitPreparedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommitPreparedResponse) XXX_Merge Uses

func (dst *CommitPreparedResponse) XXX_Merge(src proto.Message)

func (*CommitPreparedResponse) XXX_Size Uses

func (m *CommitPreparedResponse) XXX_Size() int

func (*CommitPreparedResponse) XXX_Unmarshal Uses

func (m *CommitPreparedResponse) XXX_Unmarshal(b []byte) error

type CommitRequest Uses

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

CommitRequest is the payload to Commit

func (*CommitRequest) Descriptor Uses

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

func (*CommitRequest) GetEffectiveCallerId Uses

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

func (*CommitRequest) GetImmediateCallerId Uses

func (m *CommitRequest) GetImmediateCallerId() *VTGateCallerID

func (*CommitRequest) GetTarget Uses

func (m *CommitRequest) GetTarget() *Target

func (*CommitRequest) GetTransactionId Uses

func (m *CommitRequest) GetTransactionId() int64

func (*CommitRequest) ProtoMessage Uses

func (*CommitRequest) ProtoMessage()

func (*CommitRequest) Reset Uses

func (m *CommitRequest) Reset()

func (*CommitRequest) String Uses

func (m *CommitRequest) String() string

func (*CommitRequest) XXX_DiscardUnknown Uses

func (m *CommitRequest) XXX_DiscardUnknown()

func (*CommitRequest) XXX_Marshal Uses

func (m *CommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommitRequest) XXX_Merge Uses

func (dst *CommitRequest) XXX_Merge(src proto.Message)

func (*CommitRequest) XXX_Size Uses

func (m *CommitRequest) XXX_Size() int

func (*CommitRequest) XXX_Unmarshal Uses

func (m *CommitRequest) XXX_Unmarshal(b []byte) error

type CommitResponse Uses

type CommitResponse struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

CommitResponse is the returned value from Commit

func (*CommitResponse) Descriptor Uses

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

func (*CommitResponse) ProtoMessage Uses

func (*CommitResponse) ProtoMessage()

func (*CommitResponse) Reset Uses

func (m *CommitResponse) Reset()

func (*CommitResponse) String Uses

func (m *CommitResponse) String() string

func (*CommitResponse) XXX_DiscardUnknown Uses

func (m *CommitResponse) XXX_DiscardUnknown()

func (*CommitResponse) XXX_Marshal Uses

func (m *CommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CommitResponse) XXX_Merge Uses

func (dst *CommitResponse) XXX_Merge(src proto.Message)

func (*CommitResponse) XXX_Size Uses

func (m *CommitResponse) XXX_Size() int

func (*CommitResponse) XXX_Unmarshal Uses

func (m *CommitResponse) XXX_Unmarshal(b []byte) error

type ConcludeTransactionRequest Uses

type ConcludeTransactionRequest struct {
    EffectiveCallerId    *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
    ImmediateCallerId    *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
    Target               *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
    Dtid                 string          `protobuf:"bytes,4,opt,name=dtid,proto3" json:"dtid,omitempty"`
    XXX_NoUnkeyedLiteral struct{}        `json:"-"`
    XXX_unrecognized     []byte          `json:"-"`
    XXX_sizecache        int32           `json:"-"`
}

ConcludeTransactionRequest is the payload to ConcludeTransaction

func (*ConcludeTransactionRequest) Descriptor Uses

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

func (*ConcludeTransactionRequest) GetDtid Uses

func (m *ConcludeTransactionRequest) GetDtid() string

func (*ConcludeTransactionRequest) GetEffectiveCallerId Uses

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

func (*ConcludeTransactionRequest) GetImmediateCallerId Uses

func (m *ConcludeTransactionRequest) GetImmediateCallerId() *VTGateCallerID

func (*ConcludeTransactionRequest) GetTarget Uses

func (m *ConcludeTransactionRequest) GetTarget() *Target

func (*ConcludeTransactionRequest) ProtoMessage Uses

func (*ConcludeTransactionRequest) ProtoMessage()

func (*ConcludeTransactionRequest) Reset Uses

func (m *ConcludeTransactionRequest) Reset()

func (*ConcludeTransactionRequest) String Uses

func (m *ConcludeTransactionRequest) String() string

func (*ConcludeTransactionRequest) XXX_DiscardUnknown Uses

func (m *ConcludeTransactionRequest) XXX_DiscardUnknown()

func (*ConcludeTransactionRequest) XXX_Marshal Uses

func (m *ConcludeTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConcludeTransactionRequest) XXX_Merge Uses

func (dst *ConcludeTransactionRequest) XXX_Merge(src proto.Message)

func (*ConcludeTransactionRequest) XXX_Size Uses

func (m *ConcludeTransactionRequest) XXX_Size() int

func (*ConcludeTransactionRequest) XXX_Unmarshal Uses

func (m *ConcludeTransactionRequest) XXX_Unmarshal(b []byte) error

type ConcludeTransactionResponse Uses

type ConcludeTransactionResponse struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

ConcludeTransactionResponse is the returned value from ConcludeTransaction

func (*ConcludeTransactionResponse) Descriptor Uses

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

func (*ConcludeTransactionResponse) ProtoMessage Uses

func (*ConcludeTransactionResponse) ProtoMessage()

func (*ConcludeTransactionResponse) Reset Uses

func (m *ConcludeTransactionResponse) Reset()

func (*ConcludeTransactionResponse) String Uses

func (m *ConcludeTransactionResponse) String() string

func (*ConcludeTransactionResponse) XXX_DiscardUnknown Uses

func (m *ConcludeTransactionResponse) XXX_DiscardUnknown()

func (*ConcludeTransactionResponse) XXX_Marshal Uses

func (m *ConcludeTransactionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConcludeTransactionResponse) XXX_Merge Uses

func (dst *ConcludeTransactionResponse) XXX_Merge(src proto.Message)

func (*ConcludeTransactionResponse) XXX_Size Uses

func (m *ConcludeTransactionResponse) XXX_Size() int

func (*ConcludeTransactionResponse) XXX_Unmarshal Uses

func (m *ConcludeTransactionResponse) XXX_Unmarshal(b []byte) error

type CreateTransactionRequest Uses

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

CreateTransactionRequest is the payload to CreateTransaction

func (*CreateTransactionRequest) Descriptor Uses

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

func (*CreateTransactionRequest) GetDtid Uses

func (m *CreateTransactionRequest) GetDtid() string

func (*CreateTransactionRequest) GetEffectiveCallerId Uses

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

func (*CreateTransactionRequest) GetImmediateCallerId Uses

func (m *CreateTransactionRequest) GetImmediateCallerId() *VTGateCallerID

func (*CreateTransactionRequest) GetParticipants Uses

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

func (*CreateTransactionRequest) GetTarget Uses

func (m *CreateTransactionRequest) GetTarget() *Target

func (*CreateTransactionRequest) ProtoMessage Uses

func (*CreateTransactionRequest) ProtoMessage()

func (*CreateTransactionRequest) Reset Uses

func (m *CreateTransactionRequest) Reset()

func (*CreateTransactionRequest) String Uses

func (m *CreateTransactionRequest) String() string

func (*CreateTransactionRequest) XXX_DiscardUnknown Uses

func (m *CreateTransactionRequest) XXX_DiscardUnknown()

func (*CreateTransactionRequest) XXX_Marshal Uses

func (m *CreateTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateTransactionRequest) XXX_Merge Uses

func (dst *CreateTransactionRequest) XXX_Merge(src proto.Message)

func (*CreateTransactionRequest) XXX_Size Uses

func (m *CreateTransactionRequest) XXX_Size() int

func (*CreateTransactionRequest) XXX_Unmarshal Uses

func (m *CreateTransactionRequest) XXX_Unmarshal(b []byte) error

type CreateTransactionResponse Uses

type CreateTransactionResponse struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

CreateTransactionResponse is the returned value from CreateTransaction

func (*CreateTransactionResponse) Descriptor Uses

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

func (*CreateTransactionResponse) ProtoMessage Uses

func (*CreateTransactionResponse) ProtoMessage()

func (*CreateTransactionResponse) Reset Uses

func (m *CreateTransactionResponse) Reset()

func (*CreateTransactionResponse) String Uses

func (m *CreateTransactionResponse) String() string

func (*CreateTransactionResponse) XXX_DiscardUnknown Uses

func (m *CreateTransactionResponse) XXX_DiscardUnknown()

func (*CreateTransactionResponse) XXX_Marshal Uses

func (m *CreateTransactionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateTransactionResponse) XXX_Merge Uses

func (dst *CreateTransactionResponse) XXX_Merge(src proto.Message)

func (*CreateTransactionResponse) XXX_Size Uses

func (m *CreateTransactionResponse) XXX_Size() int

func (*CreateTransactionResponse) XXX_Unmarshal Uses

func (m *CreateTransactionResponse) XXX_Unmarshal(b []byte) error

type EventToken Uses

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"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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 Uses

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

func (*EventToken) GetPosition Uses

func (m *EventToken) GetPosition() string

func (*EventToken) GetShard Uses

func (m *EventToken) GetShard() string

func (*EventToken) GetTimestamp Uses

func (m *EventToken) GetTimestamp() int64

func (*EventToken) ProtoMessage Uses

func (*EventToken) ProtoMessage()

func (*EventToken) Reset Uses

func (m *EventToken) Reset()

func (*EventToken) String Uses

func (m *EventToken) String() string

func (*EventToken) XXX_DiscardUnknown Uses

func (m *EventToken) XXX_DiscardUnknown()

func (*EventToken) XXX_Marshal Uses

func (m *EventToken) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventToken) XXX_Merge Uses

func (dst *EventToken) XXX_Merge(src proto.Message)

func (*EventToken) XXX_Size Uses

func (m *EventToken) XXX_Size() int

func (*EventToken) XXX_Unmarshal Uses

func (m *EventToken) XXX_Unmarshal(b []byte) error

type ExecuteBatchRequest Uses

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

ExecuteBatchRequest is the payload to ExecuteBatch

func (*ExecuteBatchRequest) Descriptor Uses

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

func (*ExecuteBatchRequest) GetAsTransaction Uses

func (m *ExecuteBatchRequest) GetAsTransaction() bool

func (*ExecuteBatchRequest) GetEffectiveCallerId Uses

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

func (*ExecuteBatchRequest) GetImmediateCallerId Uses

func (m *ExecuteBatchRequest) GetImmediateCallerId() *VTGateCallerID

func (*ExecuteBatchRequest) GetOptions Uses

func (m *ExecuteBatchRequest) GetOptions() *ExecuteOptions

func (*ExecuteBatchRequest) GetQueries Uses

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

func (*ExecuteBatchRequest) GetTarget Uses

func (m *ExecuteBatchRequest) GetTarget() *Target

func (*ExecuteBatchRequest) GetTransactionId Uses

func (m *ExecuteBatchRequest) GetTransactionId() int64

func (*ExecuteBatchRequest) ProtoMessage Uses

func (*ExecuteBatchRequest) ProtoMessage()

func (*ExecuteBatchRequest) Reset Uses

func (m *ExecuteBatchRequest) Reset()

func (*ExecuteBatchRequest) String Uses

func (m *ExecuteBatchRequest) String() string

func (*ExecuteBatchRequest) XXX_DiscardUnknown Uses

func (m *ExecuteBatchRequest) XXX_DiscardUnknown()

func (*ExecuteBatchRequest) XXX_Marshal Uses

func (m *ExecuteBatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteBatchRequest) XXX_Merge Uses

func (dst *ExecuteBatchRequest) XXX_Merge(src proto.Message)

func (*ExecuteBatchRequest) XXX_Size Uses

func (m *ExecuteBatchRequest) XXX_Size() int

func (*ExecuteBatchRequest) XXX_Unmarshal Uses

func (m *ExecuteBatchRequest) XXX_Unmarshal(b []byte) error

type ExecuteBatchResponse Uses

type ExecuteBatchResponse struct {
    Results              []*QueryResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
    XXX_NoUnkeyedLiteral struct{}       `json:"-"`
    XXX_unrecognized     []byte         `json:"-"`
    XXX_sizecache        int32          `json:"-"`
}

ExecuteBatchResponse is the returned value from ExecuteBatch

func (*ExecuteBatchResponse) Descriptor Uses

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

func (*ExecuteBatchResponse) GetResults Uses

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

func (*ExecuteBatchResponse) ProtoMessage Uses

func (*ExecuteBatchResponse) ProtoMessage()

func (*ExecuteBatchResponse) Reset Uses

func (m *ExecuteBatchResponse) Reset()

func (*ExecuteBatchResponse) String Uses

func (m *ExecuteBatchResponse) String() string

func (*ExecuteBatchResponse) XXX_DiscardUnknown Uses

func (m *ExecuteBatchResponse) XXX_DiscardUnknown()

func (*ExecuteBatchResponse) XXX_Marshal Uses

func (m *ExecuteBatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteBatchResponse) XXX_Merge Uses

func (dst *ExecuteBatchResponse) XXX_Merge(src proto.Message)

func (*ExecuteBatchResponse) XXX_Size Uses

func (m *ExecuteBatchResponse) XXX_Size() int

func (*ExecuteBatchResponse) XXX_Unmarshal Uses

func (m *ExecuteBatchResponse) XXX_Unmarshal(b []byte) error

type ExecuteOptions Uses

type ExecuteOptions struct {
    // If set, we will try to include an EventToken with the responses.
    IncludeEventToken bool `protobuf:"varint,2,opt,name=include_event_token,json=includeEventToken,proto3" 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,proto3" json:"compare_event_token,omitempty"`
    // 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 `protobuf:"varint,4,opt,name=included_fields,json=includedFields,proto3,enum=query.ExecuteOptions_IncludedFields" json:"included_fields,omitempty"`
    // client_rows_found specifies if rows_affected should return
    // rows found instead of rows affected. Behavior is defined
    // by MySQL's CLIENT_FOUND_ROWS flag.
    ClientFoundRows bool `protobuf:"varint,5,opt,name=client_found_rows,json=clientFoundRows,proto3" json:"client_found_rows,omitempty"`
    // workload specifies the type of workload:
    // OLTP: DMLs allowed, results have row count limit, and
    // query timeouts are shorter.
    // OLAP: DMLS not allowed, no limit on row count, timeouts
    // can be as high as desired.
    // DBA: no limit on rowcount or timeout, all queries allowed
    // but intended for long DMLs and DDLs.
    Workload ExecuteOptions_Workload `protobuf:"varint,6,opt,name=workload,proto3,enum=query.ExecuteOptions_Workload" json:"workload,omitempty"`
    // sql_select_limit sets an implicit limit on all select statements. Since
    // vitess also sets a rowcount limit on queries, the smallest value wins.
    SqlSelectLimit       int64                               `protobuf:"varint,8,opt,name=sql_select_limit,json=sqlSelectLimit,proto3" json:"sql_select_limit,omitempty"`
    TransactionIsolation ExecuteOptions_TransactionIsolation `protobuf:"varint,9,opt,name=transaction_isolation,json=transactionIsolation,proto3,enum=query.ExecuteOptions_TransactionIsolation" json:"transaction_isolation,omitempty"`
    // 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"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

ExecuteOptions is passed around for all Execute calls.

func (*ExecuteOptions) Descriptor Uses

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

func (*ExecuteOptions) GetClientFoundRows Uses

func (m *ExecuteOptions) GetClientFoundRows() bool

func (*ExecuteOptions) GetCompareEventToken Uses

func (m *ExecuteOptions) GetCompareEventToken() *EventToken

func (*ExecuteOptions) GetIncludeEventToken Uses

func (m *ExecuteOptions) GetIncludeEventToken() bool

func (*ExecuteOptions) GetIncludedFields Uses

func (m *ExecuteOptions) GetIncludedFields() ExecuteOptions_IncludedFields

func (*ExecuteOptions) GetSkipQueryPlanCache Uses

func (m *ExecuteOptions) GetSkipQueryPlanCache() bool

func (*ExecuteOptions) GetSqlSelectLimit Uses

func (m *ExecuteOptions) GetSqlSelectLimit() int64

func (*ExecuteOptions) GetTransactionIsolation Uses

func (m *ExecuteOptions) GetTransactionIsolation() ExecuteOptions_TransactionIsolation

func (*ExecuteOptions) GetWorkload Uses

func (m *ExecuteOptions) GetWorkload() ExecuteOptions_Workload

func (*ExecuteOptions) ProtoMessage Uses

func (*ExecuteOptions) ProtoMessage()

func (*ExecuteOptions) Reset Uses

func (m *ExecuteOptions) Reset()

func (*ExecuteOptions) String Uses

func (m *ExecuteOptions) String() string

func (*ExecuteOptions) XXX_DiscardUnknown Uses

func (m *ExecuteOptions) XXX_DiscardUnknown()

func (*ExecuteOptions) XXX_Marshal Uses

func (m *ExecuteOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteOptions) XXX_Merge Uses

func (dst *ExecuteOptions) XXX_Merge(src proto.Message)

func (*ExecuteOptions) XXX_Size Uses

func (m *ExecuteOptions) XXX_Size() int

func (*ExecuteOptions) XXX_Unmarshal Uses

func (m *ExecuteOptions) XXX_Unmarshal(b []byte) error

type ExecuteOptions_IncludedFields Uses

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

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

func (ExecuteOptions_IncludedFields) String Uses

func (x ExecuteOptions_IncludedFields) String() string

type ExecuteOptions_TransactionIsolation Uses

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

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

func (ExecuteOptions_TransactionIsolation) String Uses

func (x ExecuteOptions_TransactionIsolation) String() string

type ExecuteOptions_Workload Uses

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

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

func (ExecuteOptions_Workload) String Uses

func (x ExecuteOptions_Workload) String() string

type ExecuteRequest Uses

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

ExecuteRequest is the payload to Execute

func (*ExecuteRequest) Descriptor Uses

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

func (*ExecuteRequest) GetEffectiveCallerId Uses

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

func (*ExecuteRequest) GetImmediateCallerId Uses

func (m *ExecuteRequest) GetImmediateCallerId() *VTGateCallerID

func (*ExecuteRequest) GetOptions Uses

func (m *ExecuteRequest) GetOptions() *ExecuteOptions

func (*ExecuteRequest) GetQuery Uses

func (m *ExecuteRequest) GetQuery() *BoundQuery

func (*ExecuteRequest) GetTarget Uses

func (m *ExecuteRequest) GetTarget() *Target

func (*ExecuteRequest) GetTransactionId Uses

func (m *ExecuteRequest) GetTransactionId() int64

func (*ExecuteRequest) ProtoMessage Uses

func (*ExecuteRequest) ProtoMessage()

func (*ExecuteRequest) Reset Uses

func (m *ExecuteRequest) Reset()

func (*ExecuteRequest) String Uses

func (m *ExecuteRequest) String() string

func (*ExecuteRequest) XXX_DiscardUnknown Uses

func (m *ExecuteRequest) XXX_DiscardUnknown()

func (*ExecuteRequest) XXX_Marshal Uses

func (m *ExecuteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteRequest) XXX_Merge Uses

func (dst *ExecuteRequest) XXX_Merge(src proto.Message)

func (*ExecuteRequest) XXX_Size Uses

func (m *ExecuteRequest) XXX_Size() int

func (*ExecuteRequest) XXX_Unmarshal Uses

func (m *ExecuteRequest) XXX_Unmarshal(b []byte) error

type ExecuteResponse Uses

type ExecuteResponse struct {
    Result               *QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
    XXX_NoUnkeyedLiteral struct{}     `json:"-"`
    XXX_unrecognized     []byte       `json:"-"`
    XXX_sizecache        int32        `json:"-"`
}

ExecuteResponse is the returned value from Execute

func (*ExecuteResponse) Descriptor Uses

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

func (*ExecuteResponse) GetResult Uses

func (m *ExecuteResponse) GetResult() *QueryResult

func (*ExecuteResponse) ProtoMessage Uses

func (*ExecuteResponse) ProtoMessage()

func (*ExecuteResponse) Reset Uses

func (m *ExecuteResponse) Reset()

func (*ExecuteResponse) String Uses

func (m *ExecuteResponse) String() string

func (*ExecuteResponse) XXX_DiscardUnknown Uses

func (m *ExecuteResponse) XXX_DiscardUnknown()

func (*ExecuteResponse) XXX_Marshal Uses

func (m *ExecuteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecuteResponse) XXX_Merge Uses

func (dst *ExecuteResponse) XXX_Merge(src proto.Message)

func (*ExecuteResponse) XXX_Size Uses

func (m *ExecuteResponse) XXX_Size() int

func (*ExecuteResponse) XXX_Unmarshal Uses

func (m *ExecuteResponse) XXX_Unmarshal(b []byte) error

type Field Uses

type Field struct {
    // name of the field as returned by mysql C API
    Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    // vitess-defined type. Conversion function is in sqltypes package.
    Type Type `protobuf:"varint,2,opt,name=type,proto3,enum=query.Type" json:"type,omitempty"`
    // Remaining fields from mysql C API.
    // These fields are only populated when ExecuteOptions.included_fields
    // is set to IncludedFields.ALL.
    Table    string `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
    OrgTable string `protobuf:"bytes,4,opt,name=org_table,json=orgTable,proto3" json:"org_table,omitempty"`
    Database string `protobuf:"bytes,5,opt,name=database,proto3" json:"database,omitempty"`
    OrgName  string `protobuf:"bytes,6,opt,name=org_name,json=orgName,proto3" json:"org_name,omitempty"`
    // column_length is really a uint32. All 32 bits can be used.
    ColumnLength uint32 `protobuf:"varint,7,opt,name=column_length,json=columnLength,proto3" json:"column_length,omitempty"`
    // charset is actually a uint16. Only the lower 16 bits are used.
    Charset uint32 `protobuf:"varint,8,opt,name=charset,proto3" json:"charset,omitempty"`
    // decimals is actualy 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"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Field describes a single column returned by a query

func (*Field) Descriptor Uses

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

func (*Field) GetCharset Uses

func (m *Field) GetCharset() uint32

func (*Field) GetColumnLength Uses

func (m *Field) GetColumnLength() uint32

func (*Field) GetDatabase Uses

func (m *Field) GetDatabase() string

func (*Field) GetDecimals Uses

func (m *Field) GetDecimals() uint32

func (*Field) GetFlags Uses

func (m *Field) GetFlags() uint32

func (*Field) GetName Uses

func (m *Field) GetName() string

func (*Field) GetOrgName Uses

func (m *Field) GetOrgName() string

func (*Field) GetOrgTable Uses

func (m *Field) GetOrgTable() string

func (*Field) GetTable Uses

func (m *Field) GetTable() string

func (*Field) GetType Uses

func (m *Field) GetType() Type

func (*Field) ProtoMessage Uses

func (*Field) ProtoMessage()

func (*Field) Reset Uses

func (m *Field) Reset()

func (*Field) String Uses

func (m *Field) String() string

func (*Field) XXX_DiscardUnknown Uses

func (m *Field) XXX_DiscardUnknown()

func (*Field) XXX_Marshal Uses

func (m *Field) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Field) XXX_Merge Uses

func (dst *Field) XXX_Merge(src proto.Message)

func (*Field) XXX_Size Uses

func (m *Field) XXX_Size() int

func (*Field) XXX_Unmarshal Uses

func (m *Field) XXX_Unmarshal(b []byte) error

type Flag Uses

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 Uses

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

func (Flag) String Uses

func (x Flag) String() string

type MessageAckRequest Uses

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

MessageAckRequest is the request payload for MessageAck.

func (*MessageAckRequest) Descriptor Uses

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

func (*MessageAckRequest) GetEffectiveCallerId Uses

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

func (*MessageAckRequest) GetIds Uses

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

func (*MessageAckRequest) GetImmediateCallerId Uses

func (m *MessageAckRequest) GetImmediateCallerId() *VTGateCallerID

func (*MessageAckRequest) GetName Uses

func (m *MessageAckRequest) GetName() string

func (*MessageAckRequest) GetTarget Uses

func (m *MessageAckRequest) GetTarget() *Target

func (*MessageAckRequest) ProtoMessage Uses

func (*MessageAckRequest) ProtoMessage()

func (*MessageAckRequest) Reset Uses

func (m *MessageAckRequest) Reset()

func (*MessageAckRequest) String Uses

func (m *MessageAckRequest) String() string

func (*MessageAckRequest) XXX_DiscardUnknown Uses

func (m *MessageAckRequest) XXX_DiscardUnknown()

func (*MessageAckRequest) XXX_Marshal Uses

func (m *MessageAckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MessageAckRequest) XXX_Merge Uses

func (dst *MessageAckRequest) XXX_Merge(src proto.Message)

func (*MessageAckRequest) XXX_Size Uses

func (m *MessageAckRequest) XXX_Size() int

func (*MessageAckRequest) XXX_Unmarshal Uses

func (m *MessageAckRequest) XXX_Unmarshal(b []byte) error

type MessageAckResponse Uses

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"`
    XXX_NoUnkeyedLiteral struct{}     `json:"-"`
    XXX_unrecognized     []byte       `json:"-"`
    XXX_sizecache        int32        `json:"-"`
}

MessageAckResponse is the response for MessageAck.

func (*MessageAckResponse) Descriptor Uses

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

func (*MessageAckResponse) GetResult Uses

func (m *MessageAckResponse) GetResult() *QueryResult

func (*MessageAckResponse) ProtoMessage Uses

func (*MessageAckResponse) ProtoMessage()

func (*MessageAckResponse) Reset Uses

func (m *MessageAckResponse) Reset()

func (*MessageAckResponse) String Uses

func (m *MessageAckResponse) String() string

func (*MessageAckResponse) XXX_DiscardUnknown Uses

func (m *MessageAckResponse) XXX_DiscardUnknown()

func (*MessageAckResponse) XXX_Marshal Uses

func (m *MessageAckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MessageAckResponse) XXX_Merge Uses

func (dst *MessageAckResponse) XXX_Merge(src proto.Message)

func (*MessageAckResponse) XXX_Size Uses

func (m *MessageAckResponse) XXX_Size() int

func (*MessageAckResponse) XXX_Unmarshal Uses

func (m *MessageAckResponse) XXX_Unmarshal(b []byte) error

type MessageStreamRequest Uses

type MessageStreamRequest struct {
    EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
    ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
    Target            *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
    // name is the message table name.
    Name                 string   `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

MessageStreamRequest is the request payload for MessageStream.

func (*MessageStreamRequest) Descriptor Uses

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

func (*MessageStreamRequest) GetEffectiveCallerId Uses

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

func (*MessageStreamRequest) GetImmediateCallerId Uses

func (m *MessageStreamRequest) GetImmediateCallerId() *VTGateCallerID

func (*MessageStreamRequest) GetName Uses

func (m *MessageStreamRequest) GetName() string

func (*MessageStreamRequest) GetTarget Uses

func (m *MessageStreamRequest) GetTarget() *Target

func (*MessageStreamRequest) ProtoMessage Uses

func (*MessageStreamRequest) ProtoMessage()

func (*MessageStreamRequest) Reset Uses

func (m *MessageStreamRequest) Reset()

func (*MessageStreamRequest) String Uses

func (m *MessageStreamRequest) String() string

func (*MessageStreamRequest) XXX_DiscardUnknown Uses

func (m *MessageStreamRequest) XXX_DiscardUnknown()

func (*MessageStreamRequest) XXX_Marshal Uses

func (m *MessageStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MessageStreamRequest) XXX_Merge Uses

func (dst *MessageStreamRequest) XXX_Merge(src proto.Message)

func (*MessageStreamRequest) XXX_Size Uses

func (m *MessageStreamRequest) XXX_Size() int

func (*MessageStreamRequest) XXX_Unmarshal Uses

func (m *MessageStreamRequest) XXX_Unmarshal(b []byte) error

type MessageStreamResponse Uses

type MessageStreamResponse struct {
    Result               *QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
    XXX_NoUnkeyedLiteral struct{}     `json:"-"`
    XXX_unrecognized     []byte       `json:"-"`
    XXX_sizecache        int32        `json:"-"`
}

MessageStreamResponse is a response for MessageStream.

func (*MessageStreamResponse) Descriptor Uses

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

func (*MessageStreamResponse) GetResult Uses

func (m *MessageStreamResponse) GetResult() *QueryResult

func (*MessageStreamResponse) ProtoMessage Uses

func (*MessageStreamResponse) ProtoMessage()

func (*MessageStreamResponse) Reset Uses

func (m *MessageStreamResponse) Reset()

func (*MessageStreamResponse) String Uses

func (m *MessageStreamResponse) String() string

func (*MessageStreamResponse) XXX_DiscardUnknown Uses

func (m *MessageStreamResponse) XXX_DiscardUnknown()

func (*MessageStreamResponse) XXX_Marshal Uses

func (m *MessageStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MessageStreamResponse) XXX_Merge Uses

func (dst *MessageStreamResponse) XXX_Merge(src proto.Message)

func (*MessageStreamResponse) XXX_Size Uses

func (m *MessageStreamResponse) XXX_Size() int

func (*MessageStreamResponse) XXX_Unmarshal Uses

func (m *MessageStreamResponse) XXX_Unmarshal(b []byte) error

type MySqlFlag Uses

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

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

func (MySqlFlag) String Uses

func (x MySqlFlag) String() string

type PrepareRequest Uses

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

PrepareRequest is the payload to Prepare

func (*PrepareRequest) Descriptor Uses

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

func (*PrepareRequest) GetDtid Uses

func (m *PrepareRequest) GetDtid() string

func (*PrepareRequest) GetEffectiveCallerId Uses

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

func (*PrepareRequest) GetImmediateCallerId Uses

func (m *PrepareRequest) GetImmediateCallerId() *VTGateCallerID

func (*PrepareRequest) GetTarget Uses

func (m *PrepareRequest) GetTarget() *Target

func (*PrepareRequest) GetTransactionId Uses

func (m *PrepareRequest) GetTransactionId() int64

func (*PrepareRequest) ProtoMessage Uses

func (*PrepareRequest) ProtoMessage()

func (*PrepareRequest) Reset Uses

func (m *PrepareRequest) Reset()

func (*PrepareRequest) String Uses

func (m *PrepareRequest) String() string

func (*PrepareRequest) XXX_DiscardUnknown Uses

func (m *PrepareRequest) XXX_DiscardUnknown()

func (*PrepareRequest) XXX_Marshal Uses

func (m *PrepareRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrepareRequest) XXX_Merge Uses

func (dst *PrepareRequest) XXX_Merge(src proto.Message)

func (*PrepareRequest) XXX_Size Uses

func (m *PrepareRequest) XXX_Size() int

func (*PrepareRequest) XXX_Unmarshal Uses

func (m *PrepareRequest) XXX_Unmarshal(b []byte) error

type PrepareResponse Uses

type PrepareResponse struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

PrepareResponse is the returned value from Prepare

func (*PrepareResponse) Descriptor Uses

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

func (*PrepareResponse) ProtoMessage Uses

func (*PrepareResponse) ProtoMessage()

func (*PrepareResponse) Reset Uses

func (m *PrepareResponse) Reset()

func (*PrepareResponse) String Uses

func (m *PrepareResponse) String() string

func (*PrepareResponse) XXX_DiscardUnknown Uses

func (m *PrepareResponse) XXX_DiscardUnknown()

func (*PrepareResponse) XXX_Marshal Uses

func (m *PrepareResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrepareResponse) XXX_Merge Uses

func (dst *PrepareResponse) XXX_Merge(src proto.Message)

func (*PrepareResponse) XXX_Size Uses

func (m *PrepareResponse) XXX_Size() int

func (*PrepareResponse) XXX_Unmarshal Uses

func (m *PrepareResponse) XXX_Unmarshal(b []byte) error

type QueryResult Uses

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"`
    Extras               *ResultExtras `protobuf:"bytes,5,opt,name=extras,proto3" json:"extras,omitempty"`
    XXX_NoUnkeyedLiteral struct{}      `json:"-"`
    XXX_unrecognized     []byte        `json:"-"`
    XXX_sizecache        int32         `json:"-"`
}

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 Uses

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

func (*QueryResult) GetExtras Uses

func (m *QueryResult) GetExtras() *ResultExtras

func (*QueryResult) GetFields Uses

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

func (*QueryResult) GetInsertId Uses

func (m *QueryResult) GetInsertId() uint64

func (*QueryResult) GetRows Uses

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

func (*QueryResult) GetRowsAffected Uses

func (m *QueryResult) GetRowsAffected() uint64

func (*QueryResult) ProtoMessage Uses

func (*QueryResult) ProtoMessage()

func (*QueryResult) Reset Uses

func (m *QueryResult) Reset()

func (*QueryResult) String Uses

func (m *QueryResult) String() string

func (*QueryResult) XXX_DiscardUnknown Uses

func (m *QueryResult) XXX_DiscardUnknown()

func (*QueryResult) XXX_Marshal Uses

func (m *QueryResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryResult) XXX_Merge Uses

func (dst *QueryResult) XXX_Merge(src proto.Message)

func (*QueryResult) XXX_Size Uses

func (m *QueryResult) XXX_Size() int

func (*QueryResult) XXX_Unmarshal Uses

func (m *QueryResult) XXX_Unmarshal(b []byte) error

type QuerySplit Uses

type QuerySplit struct {
    // query is the query to execute
    Query *BoundQuery `protobuf:"bytes,1,opt,name=query,proto3" 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,proto3" json:"row_count,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

QuerySplit represents one query to execute on the tablet

func (*QuerySplit) Descriptor Uses

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

func (*QuerySplit) GetQuery Uses

func (m *QuerySplit) GetQuery() *BoundQuery

func (*QuerySplit) GetRowCount Uses

func (m *QuerySplit) GetRowCount() int64

func (*QuerySplit) ProtoMessage Uses

func (*QuerySplit) ProtoMessage()

func (*QuerySplit) Reset Uses

func (m *QuerySplit) Reset()

func (*QuerySplit) String Uses

func (m *QuerySplit) String() string

func (*QuerySplit) XXX_DiscardUnknown Uses

func (m *QuerySplit) XXX_DiscardUnknown()

func (*QuerySplit) XXX_Marshal Uses

func (m *QuerySplit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QuerySplit) XXX_Merge Uses

func (dst *QuerySplit) XXX_Merge(src proto.Message)

func (*QuerySplit) XXX_Size Uses

func (m *QuerySplit) XXX_Size() int

func (*QuerySplit) XXX_Unmarshal Uses

func (m *QuerySplit) XXX_Unmarshal(b []byte) error

type QueryWarning Uses

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"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*QueryWarning) Descriptor Uses

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

func (*QueryWarning) GetCode Uses

func (m *QueryWarning) GetCode() uint32

func (*QueryWarning) GetMessage Uses

func (m *QueryWarning) GetMessage() string

func (*QueryWarning) ProtoMessage Uses

func (*QueryWarning) ProtoMessage()

func (*QueryWarning) Reset Uses

func (m *QueryWarning) Reset()

func (*QueryWarning) String Uses

func (m *QueryWarning) String() string

func (*QueryWarning) XXX_DiscardUnknown Uses

func (m *QueryWarning) XXX_DiscardUnknown()

func (*QueryWarning) XXX_Marshal Uses

func (m *QueryWarning) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryWarning) XXX_Merge Uses

func (dst *QueryWarning) XXX_Merge(src proto.Message)

func (*QueryWarning) XXX_Size Uses

func (m *QueryWarning) XXX_Size() int

func (*QueryWarning) XXX_Unmarshal Uses

func (m *QueryWarning) XXX_Unmarshal(b []byte) error

type ReadTransactionRequest Uses

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

ReadTransactionRequest is the payload to ReadTransaction

func (*ReadTransactionRequest) Descriptor Uses

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

func (*ReadTransactionRequest) GetDtid Uses

func (m *ReadTransactionRequest) GetDtid() string

func (*ReadTransactionRequest) GetEffectiveCallerId Uses

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

func (*ReadTransactionRequest) GetImmediateCallerId Uses

func (m *ReadTransactionRequest) GetImmediateCallerId() *VTGateCallerID

func (*ReadTransactionRequest) GetTarget Uses

func (m *ReadTransactionRequest) GetTarget() *Target

func (*ReadTransactionRequest) ProtoMessage Uses

func (*ReadTransactionRequest) ProtoMessage()

func (*ReadTransactionRequest) Reset Uses

func (m *ReadTransactionRequest) Reset()

func (*ReadTransactionRequest) String Uses

func (m *ReadTransactionRequest) String() string

func (*ReadTransactionRequest) XXX_DiscardUnknown Uses

func (m *ReadTransactionRequest) XXX_DiscardUnknown()

func (*ReadTransactionRequest) XXX_Marshal Uses

func (m *ReadTransactionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadTransactionRequest) XXX_Merge Uses

func (dst *ReadTransactionRequest) XXX_Merge(src proto.Message)

func (*ReadTransactionRequest) XXX_Size Uses

func (m *ReadTransactionRequest) XXX_Size() int

func (*ReadTransactionRequest) XXX_Unmarshal Uses

func (m *ReadTransactionRequest) XXX_Unmarshal(b []byte) error

type ReadTransactionResponse Uses

type ReadTransactionResponse struct {
    Metadata             *TransactionMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
    XXX_NoUnkeyedLiteral struct{}             `json:"-"`
    XXX_unrecognized     []byte               `json:"-"`
    XXX_sizecache        int32                `json:"-"`
}

ReadTransactionResponse is the returned value from ReadTransaction

func (*ReadTransactionResponse) Descriptor Uses

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

func (*ReadTransactionResponse) GetMetadata Uses

func (m *ReadTransactionResponse) GetMetadata() *TransactionMetadata

func (*ReadTransactionResponse) ProtoMessage Uses

func (*ReadTransactionResponse) ProtoMessage()

func (*ReadTransactionResponse) Reset Uses

func (m *ReadTransactionResponse) Reset()

func (*ReadTransactionResponse) String Uses

func (m *ReadTransactionResponse) String() string

func (*ReadTransactionResponse) XXX_DiscardUnknown Uses

func (m *ReadTransactionResponse) XXX_DiscardUnknown()

func (*ReadTransactionResponse) XXX_Marshal Uses

func (m *ReadTransactionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadTransactionResponse) XXX_Merge Uses

func (dst *ReadTransactionResponse) XXX_Merge(src proto.Message)

func (*ReadTransactionResponse) XXX_Size Uses

func (m *ReadTransactionResponse) XXX_Size() int

func (*ReadTransactionResponse) XXX_Unmarshal Uses

func (m *ReadTransactionResponse) XXX_Unmarshal(b []byte) error

type RealtimeStats Uses

type RealtimeStats struct {
    // health_error is the last error we got from health check,
    // or empty is the server is healthy. This is used for subset selection,
    // we do not send queries to servers that are not healthy.
    HealthError string `protobuf:"bytes,1,opt,name=health_error,json=healthError,proto3" json:"health_error,omitempty"`
    // seconds_behind_master is populated for 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,proto3" json:"seconds_behind_master,omitempty"`
    // bin_log_players_count is the number of currently running binlog players.
    // if the value is 0, it means that filtered replication is currently not
    // running on the tablet. If >0, filtered replication is running.
    // NOTE: This field must not be evaluated if "health_error" is not empty.
    BinlogPlayersCount int32 `protobuf:"varint,3,opt,name=binlog_players_count,json=binlogPlayersCount,proto3" json:"binlog_players_count,omitempty"`
    // seconds_behind_master_filtered_replication is populated for the receiving
    // master of an ongoing filtered replication only.
    // It specifies how far the receiving master lags behind the sending master.
    // NOTE: This field must not be evaluated if "health_error" is not empty.
    // NOTE: This field must not be evaluated if "bin_log_players_count" is 0.
    SecondsBehindMasterFilteredReplication int64 `protobuf:"varint,4,opt,name=seconds_behind_master_filtered_replication,json=secondsBehindMasterFilteredReplication,proto3" json:"seconds_behind_master_filtered_replication,omitempty"`
    // 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"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*RealtimeStats) Descriptor Uses

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

func (*RealtimeStats) GetBinlogPlayersCount Uses

func (m *RealtimeStats) GetBinlogPlayersCount() int32

func (*RealtimeStats) GetCpuUsage Uses

func (m *RealtimeStats) GetCpuUsage() float64

func (*RealtimeStats) GetHealthError Uses

func (m *RealtimeStats) GetHealthError() string

func (*RealtimeStats) GetQps Uses

func (m *RealtimeStats) GetQps() float64

func (*RealtimeStats) GetSecondsBehindMaster Uses

func (m *RealtimeStats) GetSecondsBehindMaster() uint32

func (*RealtimeStats) GetSecondsBehindMasterFilteredReplication Uses

func (m *RealtimeStats) GetSecondsBehindMasterFilteredReplication() int64

func (*RealtimeStats) ProtoMessage Uses

func (*RealtimeStats) ProtoMessage()

func (*RealtimeStats) Reset Uses

func (m *RealtimeStats) Reset()

func (*RealtimeStats) String Uses

func (m *RealtimeStats) String() string

func (*RealtimeStats) XXX_DiscardUnknown Uses

func (m *RealtimeStats) XXX_DiscardUnknown()

func (*RealtimeStats) XXX_Marshal Uses

func (m *RealtimeStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RealtimeStats) XXX_Merge Uses

func (dst *RealtimeStats) XXX_Merge(src proto.Message)

func (*RealtimeStats) XXX_Size Uses

func (m *RealtimeStats) XXX_Size() int

func (*RealtimeStats) XXX_Unmarshal Uses

func (m *RealtimeStats) XXX_Unmarshal(b []byte) error

type ResultExtras Uses

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,proto3" 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,proto3" json:"fresher,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*ResultExtras) Descriptor Uses

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

func (*ResultExtras) GetEventToken Uses

func (m *ResultExtras) GetEventToken() *EventToken

func (*ResultExtras) GetFresher Uses

func (m *ResultExtras) GetFresher() bool

func (*ResultExtras) ProtoMessage Uses

func (*ResultExtras) ProtoMessage()

func (*ResultExtras) Reset Uses

func (m *ResultExtras) Reset()

func (*ResultExtras) String Uses

func (m *ResultExtras) String() string

func (*ResultExtras) XXX_DiscardUnknown Uses

func (m *ResultExtras) XXX_DiscardUnknown()

func (*ResultExtras) XXX_Marshal Uses

func (m *ResultExtras) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResultExtras) XXX_Merge Uses

func (dst *ResultExtras) XXX_Merge(src proto.Message)

func (*ResultExtras) XXX_Size Uses

func (m *ResultExtras) XXX_Size() int

func (*ResultExtras) XXX_Unmarshal Uses

func (m *ResultExtras) XXX_Unmarshal(b []byte) error

type ResultWithError Uses

type ResultWithError struct {
    // error contains an query level error, only set if result is unset.
    Error *vtrpc.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"`
    XXX_NoUnkeyedLiteral struct{}     `json:"-"`
    XXX_unrecognized     []byte       `json:"-"`
    XXX_sizecache        int32        `json:"-"`
}

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) Descriptor Uses

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

func (*ResultWithError) GetError Uses

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

func (*ResultWithError) GetResult Uses

func (m *ResultWithError) GetResult() *QueryResult

func (*ResultWithError) ProtoMessage Uses

func (*ResultWithError) ProtoMessage()

func (*ResultWithError) Reset Uses

func (m *ResultWithError) Reset()

func (*ResultWithError) String Uses

func (m *ResultWithError) String() string

func (*ResultWithError) XXX_DiscardUnknown Uses

func (m *ResultWithError) XXX_DiscardUnknown()

func (*ResultWithError) XXX_Marshal Uses

func (m *ResultWithError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResultWithError) XXX_Merge Uses

func (dst *ResultWithError) XXX_Merge(src proto.Message)

func (*ResultWithError) XXX_Size Uses

func (m *ResultWithError) XXX_Size() int

func (*ResultWithError) XXX_Unmarshal Uses

func (m *ResultWithError) XXX_Unmarshal(b []byte) error

type RollbackPreparedRequest Uses

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

RollbackPreparedRequest is the payload to RollbackPrepared

func (*RollbackPreparedRequest) Descriptor Uses

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

func (*RollbackPreparedRequest) GetDtid Uses

func (m *RollbackPreparedRequest) GetDtid() string

func (*RollbackPreparedRequest) GetEffectiveCallerId Uses

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

func (*RollbackPreparedRequest) GetImmediateCallerId Uses

func (m *RollbackPreparedRequest) GetImmediateCallerId() *VTGateCallerID

func (*RollbackPreparedRequest) GetTarget Uses

func (m *RollbackPreparedRequest) GetTarget() *Target

func (*RollbackPreparedRequest) GetTransactionId Uses

func (m *RollbackPreparedRequest) GetTransactionId() int64

func (*RollbackPreparedRequest) ProtoMessage Uses

func (*RollbackPreparedRequest) ProtoMessage()

func (*RollbackPreparedRequest) Reset Uses

func (m *RollbackPreparedRequest) Reset()

func (*RollbackPreparedRequest) String Uses

func (m *RollbackPreparedRequest) String() string

func (*RollbackPreparedRequest) XXX_DiscardUnknown Uses

func (m *RollbackPreparedRequest) XXX_DiscardUnknown()

func (*RollbackPreparedRequest) XXX_Marshal Uses

func (m *RollbackPreparedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RollbackPreparedRequest) XXX_Merge Uses

func (dst *RollbackPreparedRequest) XXX_Merge(src proto.Message)

func (*RollbackPreparedRequest) XXX_Size Uses

func (m *RollbackPreparedRequest) XXX_Size() int

func (*RollbackPreparedRequest) XXX_Unmarshal Uses

func (m *RollbackPreparedRequest) XXX_Unmarshal(b []byte) error

type RollbackPreparedResponse Uses

type RollbackPreparedResponse struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

RollbackPreparedResponse is the returned value from RollbackPrepared

func (*RollbackPreparedResponse) Descriptor Uses

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

func (*RollbackPreparedResponse) ProtoMessage Uses

func (*RollbackPreparedResponse) ProtoMessage()

func (*RollbackPreparedResponse) Reset Uses

func (m *RollbackPreparedResponse) Reset()

func (*RollbackPreparedResponse) String Uses

func (m *RollbackPreparedResponse) String() string

func (*RollbackPreparedResponse) XXX_DiscardUnknown Uses

func (m *RollbackPreparedResponse) XXX_DiscardUnknown()

func (*RollbackPreparedResponse) XXX_Marshal Uses

func (m *RollbackPreparedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RollbackPreparedResponse) XXX_Merge Uses

func (dst *RollbackPreparedResponse) XXX_Merge(src proto.Message)

func (*RollbackPreparedResponse) XXX_Size Uses

func (m *RollbackPreparedResponse) XXX_Size() int

func (*RollbackPreparedResponse) XXX_Unmarshal Uses

func (m *RollbackPreparedResponse) XXX_Unmarshal(b []byte) error

type RollbackRequest Uses

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

RollbackRequest is the payload to Rollback

func (*RollbackRequest) Descriptor Uses

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

func (*RollbackRequest) GetEffectiveCallerId Uses

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

func (*RollbackRequest) GetImmediateCallerId Uses

func (m *RollbackRequest) GetImmediateCallerId() *VTGateCallerID

func (*RollbackRequest) GetTarget Uses

func (m *RollbackRequest) GetTarget() *Target

func (*RollbackRequest) GetTransactionId Uses

func (m *RollbackRequest) GetTransactionId() int64

func (*RollbackRequest) ProtoMessage Uses

func (*RollbackRequest) ProtoMessage()

func (*RollbackRequest) Reset Uses

func (m *RollbackRequest) Reset()

func (*RollbackRequest) String Uses

func (m *RollbackRequest) String() string

func (*RollbackRequest) XXX_DiscardUnknown Uses

func (m *RollbackRequest) XXX_DiscardUnknown()

func (*RollbackRequest) XXX_Marshal Uses

func (m *RollbackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RollbackRequest) XXX_Merge Uses

func (dst *RollbackRequest) XXX_Merge(src proto.Message)

func (*RollbackRequest) XXX_Size Uses

func (m *RollbackRequest) XXX_Size() int

func (*RollbackRequest) XXX_Unmarshal Uses

func (m *RollbackRequest) XXX_Unmarshal(b []byte) error

type RollbackResponse Uses

type RollbackResponse struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

RollbackResponse is the returned value from Rollback

func (*RollbackResponse) Descriptor Uses

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

func (*RollbackResponse) ProtoMessage Uses

func (*RollbackResponse) ProtoMessage()

func (*RollbackResponse) Reset Uses

func (m *RollbackResponse) Reset()

func (*RollbackResponse) String Uses

func (m *RollbackResponse) String() string

func (*RollbackResponse) XXX_DiscardUnknown Uses

func (m *RollbackResponse) XXX_DiscardUnknown()

func (*RollbackResponse) XXX_Marshal Uses

func (m *RollbackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RollbackResponse) XXX_Merge Uses

func (dst *RollbackResponse) XXX_Merge(src proto.Message)

func (*RollbackResponse) XXX_Size Uses

func (m *RollbackResponse) XXX_Size() int

func (*RollbackResponse) XXX_Unmarshal Uses

func (m *RollbackResponse) XXX_Unmarshal(b []byte) error

type Row Uses

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"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Row is a database row.

func (*Row) Descriptor Uses

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

func (*Row) GetLengths Uses

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

func (*Row) GetValues Uses

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

func (*Row) ProtoMessage Uses

func (*Row) ProtoMessage()

func (*Row) Reset Uses

func (m *Row) Reset()

func (*Row) String Uses

func (m *Row) String() string

func (*Row) XXX_DiscardUnknown Uses

func (m *Row) XXX_DiscardUnknown()

func (*Row) XXX_Marshal Uses

func (m *Row) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Row) XXX_Merge Uses

func (dst *Row) XXX_Merge(src proto.Message)

func (*Row) XXX_Size Uses

func (m *Row) XXX_Size() int

func (*Row) XXX_Unmarshal Uses

func (m *Row) XXX_Unmarshal(b []byte) error

type SetRollbackRequest Uses

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

SetRollbackRequest is the payload to SetRollback

func (*SetRollbackRequest) Descriptor Uses

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

func (*SetRollbackRequest) GetDtid Uses

func (m *SetRollbackRequest) GetDtid() string

func (*SetRollbackRequest) GetEffectiveCallerId Uses

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

func (*SetRollbackRequest) GetImmediateCallerId Uses

func (m *SetRollbackRequest) GetImmediateCallerId() *VTGateCallerID

func (*SetRollbackRequest) GetTarget Uses

func (m *SetRollbackRequest) GetTarget() *Target

func (*SetRollbackRequest) GetTransactionId Uses

func (m *SetRollbackRequest) GetTransactionId() int64

func (*SetRollbackRequest) ProtoMessage Uses

func (*SetRollbackRequest) ProtoMessage()

func (*SetRollbackRequest) Reset Uses

func (m *SetRollbackRequest) Reset()

func (*SetRollbackRequest) String Uses

func (m *SetRollbackRequest) String() string

func (*SetRollbackRequest) XXX_DiscardUnknown Uses

func (m *SetRollbackRequest) XXX_DiscardUnknown()

func (*SetRollbackRequest) XXX_Marshal Uses

func (m *SetRollbackRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetRollbackRequest) XXX_Merge Uses

func (dst *SetRollbackRequest) XXX_Merge(src proto.Message)

func (*SetRollbackRequest) XXX_Size Uses

func (m *SetRollbackRequest) XXX_Size() int

func (*SetRollbackRequest) XXX_Unmarshal Uses

func (m *SetRollbackRequest) XXX_Unmarshal(b []byte) error

type SetRollbackResponse Uses

type SetRollbackResponse struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

SetRollbackResponse is the returned value from SetRollback

func (*SetRollbackResponse) Descriptor Uses

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

func (*SetRollbackResponse) ProtoMessage Uses

func (*SetRollbackResponse) ProtoMessage()

func (*SetRollbackResponse) Reset Uses

func (m *SetRollbackResponse) Reset()

func (*SetRollbackResponse) String Uses

func (m *SetRollbackResponse) String() string

func (*SetRollbackResponse) XXX_DiscardUnknown Uses

func (m *SetRollbackResponse) XXX_DiscardUnknown()

func (*SetRollbackResponse) XXX_Marshal Uses

func (m *SetRollbackResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetRollbackResponse) XXX_Merge Uses

func (dst *SetRollbackResponse) XXX_Merge(src proto.Message)

func (*SetRollbackResponse) XXX_Size Uses

func (m *SetRollbackResponse) XXX_Size() int

func (*SetRollbackResponse) XXX_Unmarshal Uses

func (m *SetRollbackResponse) XXX_Unmarshal(b []byte) error

type SplitQueryRequest Uses

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

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

func (*SplitQueryRequest) Descriptor Uses

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

func (*SplitQueryRequest) GetAlgorithm Uses

func (m *SplitQueryRequest) GetAlgorithm() SplitQueryRequest_Algorithm

func (*SplitQueryRequest) GetEffectiveCallerId Uses

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

func (*SplitQueryRequest) GetImmediateCallerId Uses

func (m *SplitQueryRequest) GetImmediateCallerId() *VTGateCallerID

func (*SplitQueryRequest) GetNumRowsPerQueryPart Uses

func (m *SplitQueryRequest) GetNumRowsPerQueryPart() int64

func (*SplitQueryRequest) GetQuery Uses

func (m *SplitQueryRequest) GetQuery() *BoundQuery

func (*SplitQueryRequest) GetSplitColumn Uses

func (m *SplitQueryRequest) GetSplitColumn() []string

func (*SplitQueryRequest) GetSplitCount Uses

func (m *SplitQueryRequest) GetSplitCount() int64

func (*SplitQueryRequest) GetTarget Uses

func (m *SplitQueryRequest) GetTarget() *Target

func (*SplitQueryRequest) ProtoMessage Uses

func (*SplitQueryRequest) ProtoMessage()

func (*SplitQueryRequest) Reset Uses

func (m *SplitQueryRequest) Reset()

func (*SplitQueryRequest) String Uses

func (m *SplitQueryRequest) String() string

func (*SplitQueryRequest) XXX_DiscardUnknown Uses

func (m *SplitQueryRequest) XXX_DiscardUnknown()

func (*SplitQueryRequest) XXX_Marshal Uses

func (m *SplitQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SplitQueryRequest) XXX_Merge Uses

func (dst *SplitQueryRequest) XXX_Merge(src proto.Message)

func (*SplitQueryRequest) XXX_Size Uses

func (m *SplitQueryRequest) XXX_Size() int

func (*SplitQueryRequest) XXX_Unmarshal Uses

func (m *SplitQueryRequest) XXX_Unmarshal(b []byte) error

type SplitQueryRequest_Algorithm Uses

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

func (SplitQueryRequest_Algorithm) EnumDescriptor Uses

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

func (SplitQueryRequest_Algorithm) String Uses

func (x SplitQueryRequest_Algorithm) String() string

type SplitQueryResponse Uses

type SplitQueryResponse struct {
    Queries              []*QuerySplit `protobuf:"bytes,1,rep,name=queries,proto3" json:"queries,omitempty"`
    XXX_NoUnkeyedLiteral struct{}      `json:"-"`
    XXX_unrecognized     []byte        `json:"-"`
    XXX_sizecache        int32         `json:"-"`
}

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

func (*SplitQueryResponse) Descriptor Uses

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

func (*SplitQueryResponse) GetQueries Uses

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

func (*SplitQueryResponse) ProtoMessage Uses

func (*SplitQueryResponse) ProtoMessage()

func (*SplitQueryResponse) Reset Uses

func (m *SplitQueryResponse) Reset()

func (*SplitQueryResponse) String Uses

func (m *SplitQueryResponse) String() string

func (*SplitQueryResponse) XXX_DiscardUnknown Uses

func (m *SplitQueryResponse) XXX_DiscardUnknown()

func (*SplitQueryResponse) XXX_Marshal Uses

func (m *SplitQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SplitQueryResponse) XXX_Merge Uses

func (dst *SplitQueryResponse) XXX_Merge(src proto.Message)

func (*SplitQueryResponse) XXX_Size Uses

func (m *SplitQueryResponse) XXX_Size() int

func (*SplitQueryResponse) XXX_Unmarshal Uses

func (m *SplitQueryResponse) XXX_Unmarshal(b []byte) error

type StartCommitRequest Uses

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

StartCommitRequest is the payload to StartCommit

func (*StartCommitRequest) Descriptor Uses

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

func (*StartCommitRequest) GetDtid Uses

func (m *StartCommitRequest) GetDtid() string

func (*StartCommitRequest) GetEffectiveCallerId Uses

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

func (*StartCommitRequest) GetImmediateCallerId Uses

func (m *StartCommitRequest) GetImmediateCallerId() *VTGateCallerID

func (*StartCommitRequest) GetTarget Uses

func (m *StartCommitRequest) GetTarget() *Target

func (*StartCommitRequest) GetTransactionId Uses

func (m *StartCommitRequest) GetTransactionId() int64

func (*StartCommitRequest) ProtoMessage Uses

func (*StartCommitRequest) ProtoMessage()

func (*StartCommitRequest) Reset Uses

func (m *StartCommitRequest) Reset()

func (*StartCommitRequest) String Uses

func (m *StartCommitRequest) String() string

func (*StartCommitRequest) XXX_DiscardUnknown Uses

func (m *StartCommitRequest) XXX_DiscardUnknown()

func (*StartCommitRequest) XXX_Marshal Uses

func (m *StartCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartCommitRequest) XXX_Merge Uses

func (dst *StartCommitRequest) XXX_Merge(src proto.Message)

func (*StartCommitRequest) XXX_Size Uses

func (m *StartCommitRequest) XXX_Size() int

func (*StartCommitRequest) XXX_Unmarshal Uses

func (m *StartCommitRequest) XXX_Unmarshal(b []byte) error

type StartCommitResponse Uses

type StartCommitResponse struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

StartCommitResponse is the returned value from StartCommit

func (*StartCommitResponse) Descriptor Uses

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

func (*StartCommitResponse) ProtoMessage Uses

func (*StartCommitResponse) ProtoMessage()

func (*StartCommitResponse) Reset Uses

func (m *StartCommitResponse) Reset()

func (*StartCommitResponse) String Uses

func (m *StartCommitResponse) String() string

func (*StartCommitResponse) XXX_DiscardUnknown Uses

func (m *StartCommitResponse) XXX_DiscardUnknown()

func (*StartCommitResponse) XXX_Marshal Uses

func (m *StartCommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartCommitResponse) XXX_Merge Uses

func (dst *StartCommitResponse) XXX_Merge(src proto.Message)

func (*StartCommitResponse) XXX_Size Uses

func (m *StartCommitResponse) XXX_Size() int

func (*StartCommitResponse) XXX_Unmarshal Uses

func (m *StartCommitResponse) XXX_Unmarshal(b []byte) error

type StreamEvent Uses

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"`
    XXX_NoUnkeyedLiteral struct{}    `json:"-"`
    XXX_unrecognized     []byte      `json:"-"`
    XXX_sizecache        int32       `json:"-"`
}

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 Uses

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

func (*StreamEvent) GetEventToken Uses

func (m *StreamEvent) GetEventToken() *EventToken

func (*StreamEvent) GetStatements Uses

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

func (*StreamEvent) ProtoMessage Uses

func (*StreamEvent) ProtoMessage()

func (*StreamEvent) Reset Uses

func (m *StreamEvent) Reset()

func (*StreamEvent) String Uses

func (m *StreamEvent) String() string

func (*StreamEvent) XXX_DiscardUnknown Uses

func (m *StreamEvent) XXX_DiscardUnknown()

func (*StreamEvent) XXX_Marshal Uses

func (m *StreamEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamEvent) XXX_Merge Uses

func (dst *StreamEvent) XXX_Merge(src proto.Message)

func (*StreamEvent) XXX_Size Uses

func (m *StreamEvent) XXX_Size() int

func (*StreamEvent) XXX_Unmarshal Uses

func (m *StreamEvent) XXX_Unmarshal(b []byte) error

type StreamEvent_Statement Uses

type StreamEvent_Statement struct {
    Category StreamEvent_Statement_Category `protobuf:"varint,1,opt,name=category,proto3,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,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"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

One individual Statement in a transaction.

func (*StreamEvent_Statement) Descriptor Uses

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

func (*StreamEvent_Statement) GetCategory Uses

func (m *StreamEvent_Statement) GetCategory() StreamEvent_Statement_Category

func (*StreamEvent_Statement) GetPrimaryKeyFields Uses

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

func (*StreamEvent_Statement) GetPrimaryKeyValues Uses

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

func (*StreamEvent_Statement) GetSql Uses

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

func (*StreamEvent_Statement) GetTableName Uses

func (m *StreamEvent_Statement) GetTableName() string

func (*StreamEvent_Statement) ProtoMessage Uses

func (*StreamEvent_Statement) ProtoMessage()

func (*StreamEvent_Statement) Reset Uses

func (m *StreamEvent_Statement) Reset()

func (*StreamEvent_Statement) String Uses

func (m *StreamEvent_Statement) String() string

func (*StreamEvent_Statement) XXX_DiscardUnknown Uses

func (m *StreamEvent_Statement) XXX_DiscardUnknown()

func (*StreamEvent_Statement) XXX_Marshal Uses

func (m *StreamEvent_Statement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamEvent_Statement) XXX_Merge Uses

func (dst *StreamEvent_Statement) XXX_Merge(src proto.Message)

func (*StreamEvent_Statement) XXX_Size Uses

func (m *StreamEvent_Statement) XXX_Size() int

func (*StreamEvent_Statement) XXX_Unmarshal Uses

func (m *StreamEvent_Statement) XXX_Unmarshal(b []byte) error

type StreamEvent_Statement_Category Uses

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 Uses

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

func (StreamEvent_Statement_Category) String Uses

func (x StreamEvent_Statement_Category) String() string

type StreamExecuteRequest Uses

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

StreamExecuteRequest is the payload to StreamExecute

func (*StreamExecuteRequest) Descriptor Uses

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

func (*StreamExecuteRequest) GetEffectiveCallerId Uses

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

func (*StreamExecuteRequest) GetImmediateCallerId Uses

func (m *StreamExecuteRequest) GetImmediateCallerId() *VTGateCallerID

func (*StreamExecuteRequest) GetOptions Uses

func (m *StreamExecuteRequest) GetOptions() *ExecuteOptions

func (*StreamExecuteRequest) GetQuery Uses

func (m *StreamExecuteRequest) GetQuery() *BoundQuery

func (*StreamExecuteRequest) GetTarget Uses

func (m *StreamExecuteRequest) GetTarget() *Target

func (*StreamExecuteRequest) GetTransactionId Uses

func (m *StreamExecuteRequest) GetTransactionId() int64

func (*StreamExecuteRequest) ProtoMessage Uses

func (*StreamExecuteRequest) ProtoMessage()

func (*StreamExecuteRequest) Reset Uses

func (m *StreamExecuteRequest) Reset()

func (*StreamExecuteRequest) String Uses

func (m *StreamExecuteRequest) String() string

func (*StreamExecuteRequest) XXX_DiscardUnknown Uses

func (m *StreamExecuteRequest) XXX_DiscardUnknown()

func (*StreamExecuteRequest) XXX_Marshal Uses

func (m *StreamExecuteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamExecuteRequest) XXX_Merge Uses

func (dst *StreamExecuteRequest) XXX_Merge(src proto.Message)

func (*StreamExecuteRequest) XXX_Size Uses

func (m *StreamExecuteRequest) XXX_Size() int

func (*StreamExecuteRequest) XXX_Unmarshal Uses

func (m *StreamExecuteRequest) XXX_Unmarshal(b []byte) error

type StreamExecuteResponse Uses

type StreamExecuteResponse struct {
    Result               *QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
    XXX_NoUnkeyedLiteral struct{}     `json:"-"`
    XXX_unrecognized     []byte       `json:"-"`
    XXX_sizecache        int32        `json:"-"`
}

StreamExecuteResponse is the returned value from StreamExecute

func (*StreamExecuteResponse) Descriptor Uses

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

func (*StreamExecuteResponse) GetResult Uses

func (m *StreamExecuteResponse) GetResult() *QueryResult

func (*StreamExecuteResponse) ProtoMessage Uses

func (*StreamExecuteResponse) ProtoMessage()

func (*StreamExecuteResponse) Reset Uses

func (m *StreamExecuteResponse) Reset()

func (*StreamExecuteResponse) String Uses

func (m *StreamExecuteResponse) String() string

func (*StreamExecuteResponse) XXX_DiscardUnknown Uses

func (m *StreamExecuteResponse) XXX_DiscardUnknown()

func (*StreamExecuteResponse) XXX_Marshal Uses

func (m *StreamExecuteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamExecuteResponse) XXX_Merge Uses

func (dst *StreamExecuteResponse) XXX_Merge(src proto.Message)

func (*StreamExecuteResponse) XXX_Size Uses

func (m *StreamExecuteResponse) XXX_Size() int

func (*StreamExecuteResponse) XXX_Unmarshal Uses

func (m *StreamExecuteResponse) XXX_Unmarshal(b []byte) error

type StreamHealthRequest Uses

type StreamHealthRequest struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

StreamHealthRequest is the payload for StreamHealth

func (*StreamHealthRequest) Descriptor Uses

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

func (*StreamHealthRequest) ProtoMessage Uses

func (*StreamHealthRequest) ProtoMessage()

func (*StreamHealthRequest) Reset Uses

func (m *StreamHealthRequest) Reset()

func (*StreamHealthRequest) String Uses

func (m *StreamHealthRequest) String() string

func (*StreamHealthRequest) XXX_DiscardUnknown Uses

func (m *StreamHealthRequest) XXX_DiscardUnknown()

func (*StreamHealthRequest) XXX_Marshal Uses

func (m *StreamHealthRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamHealthRequest) XXX_Merge Uses

func (dst *StreamHealthRequest) XXX_Merge(src proto.Message)

func (*StreamHealthRequest) XXX_Size Uses

func (m *StreamHealthRequest) XXX_Size() int

func (*StreamHealthRequest) XXX_Unmarshal Uses

func (m *StreamHealthRequest) XXX_Unmarshal(b []byte) error

type StreamHealthResponse Uses

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 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,proto3" json:"serving,omitempty"`
    // tablet_externally_reparented_timestamp can be interpreted as the
    // last time we knew that this tablet was the MASTER of this shard
    // (if StreamHealthResponse describes a group of tablets, between
    // two vtgates, only one master will be present in the group, and
    // this is this master's value).
    //
    // It is used by vtgate when determining the current MASTER of a shard.
    // If vtgate sees more than one MASTER tablet, this timestamp is used
    // as tiebreaker where the MASTER 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
    //    master i.e. even ages after the last reparent occurred.
    // OR
    // b) the last time an active reparent was executed through a vtctl command
    //    (InitShardMaster, PlannedReparentShard, EmergencyReparentShard)
    // OR
    // c) the last time vttablet was started and it initialized its tablet type
    //    as MASTER because it was recorded as the shard's current master in the
    //    topology (see go/vt/vttablet/tabletmanager/init_tablet.go)
    // OR
    // d) 0 if the vttablet was never a MASTER.
    TabletExternallyReparentedTimestamp int64 `protobuf:"varint,3,opt,name=tablet_externally_reparented_timestamp,json=tabletExternallyReparentedTimestamp,proto3" json:"tablet_externally_reparented_timestamp,omitempty"`
    // 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"`
    // AggregateStats constains information about the group of tablet status.
    // It is only filled in if the information is about a group of tablets.
    AggregateStats *AggregateStats `protobuf:"bytes,6,opt,name=aggregate_stats,json=aggregateStats,proto3" json:"aggregate_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          *topodata.TabletAlias `protobuf:"bytes,5,opt,name=tablet_alias,json=tabletAlias,proto3" json:"tablet_alias,omitempty"`
    XXX_NoUnkeyedLiteral struct{}              `json:"-"`
    XXX_unrecognized     []byte                `json:"-"`
    XXX_sizecache        int32                 `json:"-"`
}

StreamHealthResponse is streamed by StreamHealth on a regular basis. When StreamHealth is used between a vtgate and vttablet: - target describes the tablet. - realtime_stats is set. - aggregate_stats is not set. When StreamHealth is used between two vtgates: - target describes the group of tablets. - realtime_stats is not set. - aggregate_stats is set.

func (*StreamHealthResponse) Descriptor Uses

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

func (*StreamHealthResponse) GetAggregateStats Uses

func (m *StreamHealthResponse) GetAggregateStats() *AggregateStats

func (*StreamHealthResponse) GetRealtimeStats Uses

func (m *StreamHealthResponse) GetRealtimeStats() *RealtimeStats

func (*StreamHealthResponse) GetServing Uses

func (m *StreamHealthResponse) GetServing() bool

func (*StreamHealthResponse) GetTabletAlias Uses

func (m *StreamHealthResponse) GetTabletAlias() *topodata.TabletAlias

func (*StreamHealthResponse) GetTabletExternallyReparentedTimestamp Uses

func (m *StreamHealthResponse) GetTabletExternallyReparentedTimestamp() int64

func (*StreamHealthResponse) GetTarget Uses

func (m *StreamHealthResponse) GetTarget() *Target

func (*StreamHealthResponse) ProtoMessage Uses

func (*StreamHealthResponse) ProtoMessage()

func (*StreamHealthResponse) Reset Uses

func (m *StreamHealthResponse) Reset()

func (*StreamHealthResponse) String Uses

func (m *StreamHealthResponse) String() string

func (*StreamHealthResponse) XXX_DiscardUnknown Uses

func (m *StreamHealthResponse) XXX_DiscardUnknown()

func (*StreamHealthResponse) XXX_Marshal Uses

func (m *StreamHealthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamHealthResponse) XXX_Merge Uses

func (dst *StreamHealthResponse) XXX_Merge(src proto.Message)

func (*StreamHealthResponse) XXX_Size Uses

func (m *StreamHealthResponse) XXX_Size() int

func (*StreamHealthResponse) XXX_Unmarshal Uses

func (m *StreamHealthResponse) XXX_Unmarshal(b []byte) error

type Target Uses

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 topodata.TabletType `protobuf:"varint,3,opt,name=tablet_type,json=tabletType,proto3,enum=topodata.TabletType" json:"tablet_type,omitempty"`
    // 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"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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

func (*Target) Descriptor Uses

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

func (*Target) GetCell Uses

func (m *Target) GetCell() string

func (*Target) GetKeyspace Uses

func (m *Target) GetKeyspace() string

func (*Target) GetShard Uses

func (m *Target) GetShard() string

func (*Target) GetTabletType Uses

func (m *Target) GetTabletType() topodata.TabletType

func (*Target) ProtoMessage Uses

func (*Target) ProtoMessage()

func (*Target) Reset Uses

func (m *Target) Reset()

func (*Target) String Uses

func (m *Target) String() string

func (*Target) XXX_DiscardUnknown Uses

func (m *Target) XXX_DiscardUnknown()

func (*Target) XXX_Marshal Uses

func (m *Target) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Target) XXX_Merge Uses

func (dst *Target) XXX_Merge(src proto.Message)

func (*Target) XXX_Size Uses

func (m *Target) XXX_Size() int

func (*Target) XXX_Unmarshal Uses

func (m *Target) XXX_Unmarshal(b []byte) error

type TransactionMetadata Uses

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=query.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"`
    XXX_NoUnkeyedLiteral struct{}         `json:"-"`
    XXX_unrecognized     []byte           `json:"-"`
    XXX_sizecache        int32            `json:"-"`
}

TransactionMetadata contains the metadata for a distributed transaction.

func (*TransactionMetadata) Descriptor Uses

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

func (*TransactionMetadata) GetDtid Uses

func (m *TransactionMetadata) GetDtid() string

func (*TransactionMetadata) GetParticipants Uses

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

func (*TransactionMetadata) GetState Uses

func (m *TransactionMetadata) GetState() TransactionState

func (*TransactionMetadata) GetTimeCreated Uses

func (m *TransactionMetadata) GetTimeCreated() int64

func (*TransactionMetadata) ProtoMessage Uses

func (*TransactionMetadata) ProtoMessage()

func (*TransactionMetadata) Reset Uses

func (m *TransactionMetadata) Reset()

func (*TransactionMetadata) String Uses

func (m *TransactionMetadata) String() string

func (*TransactionMetadata) XXX_DiscardUnknown Uses

func (m *TransactionMetadata) XXX_DiscardUnknown()

func (*TransactionMetadata) XXX_Marshal Uses

func (m *TransactionMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TransactionMetadata) XXX_Merge Uses

func (dst *TransactionMetadata) XXX_Merge(src proto.Message)

func (*TransactionMetadata) XXX_Size Uses

func (m *TransactionMetadata) XXX_Size() int

func (*TransactionMetadata) XXX_Unmarshal Uses

func (m *TransactionMetadata) XXX_Unmarshal(b []byte) error

type TransactionState Uses

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 Uses

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

func (TransactionState) String Uses

func (x TransactionState) String() string

type Type Uses

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
)

func (Type) EnumDescriptor Uses

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

func (Type) String Uses

func (x Type) String() string

type UpdateStreamRequest Uses

type UpdateStreamRequest struct {
    EffectiveCallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=effective_caller_id,json=effectiveCallerId,proto3" json:"effective_caller_id,omitempty"`
    ImmediateCallerId *VTGateCallerID `protobuf:"bytes,2,opt,name=immediate_caller_id,json=immediateCallerId,proto3" json:"immediate_caller_id,omitempty"`
    Target            *Target         `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
    // If position is set, we will start the streaming from that replication
    // position. Incompatible with timestamp.
    Position string `protobuf:"bytes,4,opt,name=position,proto3" 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,proto3" json:"timestamp,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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 Uses

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

func (*UpdateStreamRequest) GetEffectiveCallerId Uses

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

func (*UpdateStreamRequest) GetImmediateCallerId Uses

func (m *UpdateStreamRequest) GetImmediateCallerId() *VTGateCallerID

func (*UpdateStreamRequest) GetPosition Uses

func (m *UpdateStreamRequest) GetPosition() string

func (*UpdateStreamRequest) GetTarget Uses

func (m *UpdateStreamRequest) GetTarget() *Target

func (*UpdateStreamRequest) GetTimestamp Uses

func (m *UpdateStreamRequest) GetTimestamp() int64

func (*UpdateStreamRequest) ProtoMessage Uses

func (*UpdateStreamRequest) ProtoMessage()

func (*UpdateStreamRequest) Reset Uses

func (m *UpdateStreamRequest) Reset()

func (*UpdateStreamRequest) String Uses

func (m *UpdateStreamRequest) String() string

func (*UpdateStreamRequest) XXX_DiscardUnknown Uses

func (m *UpdateStreamRequest) XXX_DiscardUnknown()

func (*UpdateStreamRequest) XXX_Marshal Uses

func (m *UpdateStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateStreamRequest) XXX_Merge Uses

func (dst *UpdateStreamRequest) XXX_Merge(src proto.Message)

func (*UpdateStreamRequest) XXX_Size Uses

func (m *UpdateStreamRequest) XXX_Size() int

func (*UpdateStreamRequest) XXX_Unmarshal Uses

func (m *UpdateStreamRequest) XXX_Unmarshal(b []byte) error

type UpdateStreamResponse Uses

type UpdateStreamResponse struct {
    Event                *StreamEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
    XXX_NoUnkeyedLiteral struct{}     `json:"-"`
    XXX_unrecognized     []byte       `json:"-"`
    XXX_sizecache        int32        `json:"-"`
}

UpdateStreamResponse is returned by UpdateStream

func (*UpdateStreamResponse) Descriptor Uses

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

func (*UpdateStreamResponse) GetEvent Uses

func (m *UpdateStreamResponse) GetEvent() *StreamEvent

func (*UpdateStreamResponse) ProtoMessage Uses

func (*UpdateStreamResponse) ProtoMessage()

func (*UpdateStreamResponse) Reset Uses

func (m *UpdateStreamResponse) Reset()

func (*UpdateStreamResponse) String Uses

func (m *UpdateStreamResponse) String() string

func (*UpdateStreamResponse) XXX_DiscardUnknown Uses

func (m *UpdateStreamResponse) XXX_DiscardUnknown()

func (*UpdateStreamResponse) XXX_Marshal Uses

func (m *UpdateStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateStreamResponse) XXX_Merge Uses

func (dst *UpdateStreamResponse) XXX_Merge(src proto.Message)

func (*UpdateStreamResponse) XXX_Size Uses

func (m *UpdateStreamResponse) XXX_Size() int

func (*UpdateStreamResponse) XXX_Unmarshal Uses

func (m *UpdateStreamResponse) XXX_Unmarshal(b []byte) error

type VTGateCallerID Uses

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"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

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 Uses

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

func (*VTGateCallerID) GetGroups Uses

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

func (*VTGateCallerID) GetUsername Uses

func (m *VTGateCallerID) GetUsername() string

func (*VTGateCallerID) ProtoMessage Uses

func (*VTGateCallerID) ProtoMessage()

func (*VTGateCallerID) Reset Uses

func (m *VTGateCallerID) Reset()

func (*VTGateCallerID) String Uses

func (m *VTGateCallerID) String() string

func (*VTGateCallerID) XXX_DiscardUnknown Uses

func (m *VTGateCallerID) XXX_DiscardUnknown()

func (*VTGateCallerID) XXX_Marshal Uses

func (m *VTGateCallerID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VTGateCallerID) XXX_Merge Uses

func (dst *VTGateCallerID) XXX_Merge(src proto.Message)

func (*VTGateCallerID) XXX_Size Uses

func (m *VTGateCallerID) XXX_Size() int

func (*VTGateCallerID) XXX_Unmarshal Uses

func (m *VTGateCallerID) XXX_Unmarshal(b []byte) error

type Value Uses

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

Value represents a typed value.

func (*Value) Descriptor Uses

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

func (*Value) GetType Uses

func (m *Value) GetType() Type

func (*Value) GetValue Uses

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

func (*Value) ProtoMessage Uses

func (*Value) ProtoMessage()

func (*Value) Reset Uses

func (m *Value) Reset()

func (*Value) String Uses

func (m *Value) String() string

func (*Value) XXX_DiscardUnknown Uses

func (m *Value) XXX_DiscardUnknown()

func (*Value) XXX_Marshal Uses

func (m *Value) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Value) XXX_Merge Uses

func (dst *Value) XXX_Merge(src proto.Message)

func (*Value) XXX_Size Uses

func (m *Value) XXX_Size() int

func (*Value) XXX_Unmarshal Uses

func (m *Value) XXX_Unmarshal(b []byte) error

Package query imports 5 packages (graph) and is imported by 117 packages. Updated 2019-06-13. Refresh now. Tools for package owners.