query

package

Go to main page

Versions in this module

v1

v1.8.0

Jun 2, 2019

v1.7.0

May 23, 2019

v1.6.0

Apr 24, 2019

Changes in this version

type ExecuteOptions_TransactionIsolation

+ const ExecuteOptions_AUTOCOMMIT

v1.5.0

Feb 12, 2019

Changes in this version

type ExecuteOptions_TransactionIsolation

+ const ExecuteOptions_CONSISTENT_SNAPSHOT_READ_ONLY

type StreamExecuteRequest

+ TransactionId int64

+ func (m *StreamExecuteRequest) GetTransactionId() int64

v1.4.0

Nov 13, 2018

v1.3.0

Oct 31, 2018

Changes in this version

+ var ExecuteOptions_IncludedFields_name = map[int32]string

+ var ExecuteOptions_IncludedFields_value = map[string]int32

+ var ExecuteOptions_TransactionIsolation_name = map[int32]string

+ var ExecuteOptions_TransactionIsolation_value = map[string]int32

+ var ExecuteOptions_Workload_name = map[int32]string

+ var ExecuteOptions_Workload_value = map[string]int32

+ var Flag_name = map[int32]string

+ var Flag_value = map[string]int32

+ var MySqlFlag_name = map[int32]string

+ var MySqlFlag_value = map[string]int32

+ var SplitQueryRequest_Algorithm_name = map[int32]string

+ var SplitQueryRequest_Algorithm_value = map[string]int32

+ var StreamEvent_Statement_Category_name = map[int32]string

+ var StreamEvent_Statement_Category_value = map[string]int32

+ var TransactionState_name = map[int32]string

+ var TransactionState_value = map[string]int32

+ var Type_name = map[int32]string

+ var Type_value = map[string]int32

+ type AggregateStats struct

+ HealthyTabletCount int32

+ SecondsBehindMasterMax uint32

+ SecondsBehindMasterMin uint32

+ UnhealthyTabletCount int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AggregateStats) ProtoMessage()

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

+ func (m *AggregateStats) GetHealthyTabletCount() int32

+ func (m *AggregateStats) GetSecondsBehindMasterMax() uint32

+ func (m *AggregateStats) GetSecondsBehindMasterMin() uint32

+ func (m *AggregateStats) GetUnhealthyTabletCount() int32

+ func (m *AggregateStats) Reset()

+ func (m *AggregateStats) String() string

+ func (m *AggregateStats) XXX_DiscardUnknown()

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

+ func (m *AggregateStats) XXX_Size() int

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

+ type BeginExecuteBatchRequest struct

+ AsTransaction bool

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Options *ExecuteOptions

+ Queries []*BoundQuery

+ Target *Target

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BeginExecuteBatchRequest) ProtoMessage()

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

+ func (m *BeginExecuteBatchRequest) GetAsTransaction() bool

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

+ func (m *BeginExecuteBatchRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *BeginExecuteBatchRequest) GetOptions() *ExecuteOptions

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

+ func (m *BeginExecuteBatchRequest) GetTarget() *Target

+ func (m *BeginExecuteBatchRequest) Reset()

+ func (m *BeginExecuteBatchRequest) String() string

+ func (m *BeginExecuteBatchRequest) XXX_DiscardUnknown()

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

+ func (m *BeginExecuteBatchRequest) XXX_Size() int

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

+ type BeginExecuteBatchResponse struct

+ Error *vtrpc.RPCError

+ Results []*QueryResult

+ TransactionId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BeginExecuteBatchResponse) ProtoMessage()

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

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

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

+ func (m *BeginExecuteBatchResponse) GetTransactionId() int64

+ func (m *BeginExecuteBatchResponse) Reset()

+ func (m *BeginExecuteBatchResponse) String() string

+ func (m *BeginExecuteBatchResponse) XXX_DiscardUnknown()

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

+ func (m *BeginExecuteBatchResponse) XXX_Size() int

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

+ type BeginExecuteRequest struct

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Options *ExecuteOptions

+ Query *BoundQuery

+ Target *Target

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BeginExecuteRequest) ProtoMessage()

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

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

+ func (m *BeginExecuteRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *BeginExecuteRequest) GetOptions() *ExecuteOptions

+ func (m *BeginExecuteRequest) GetQuery() *BoundQuery

+ func (m *BeginExecuteRequest) GetTarget() *Target

+ func (m *BeginExecuteRequest) Reset()

+ func (m *BeginExecuteRequest) String() string

+ func (m *BeginExecuteRequest) XXX_DiscardUnknown()

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

+ func (m *BeginExecuteRequest) XXX_Size() int

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

+ type BeginExecuteResponse struct

+ Error *vtrpc.RPCError

+ Result *QueryResult

+ TransactionId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BeginExecuteResponse) ProtoMessage()

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

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

+ func (m *BeginExecuteResponse) GetResult() *QueryResult

+ func (m *BeginExecuteResponse) GetTransactionId() int64

+ func (m *BeginExecuteResponse) Reset()

+ func (m *BeginExecuteResponse) String() string

+ func (m *BeginExecuteResponse) XXX_DiscardUnknown()

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

+ func (m *BeginExecuteResponse) XXX_Size() int

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

+ type BeginRequest struct

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Options *ExecuteOptions

+ Target *Target

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BeginRequest) ProtoMessage()

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

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

+ func (m *BeginRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *BeginRequest) GetOptions() *ExecuteOptions

+ func (m *BeginRequest) GetTarget() *Target

+ func (m *BeginRequest) Reset()

+ func (m *BeginRequest) String() string

+ func (m *BeginRequest) XXX_DiscardUnknown()

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

+ func (m *BeginRequest) XXX_Size() int

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

+ type BeginResponse struct

+ TransactionId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BeginResponse) ProtoMessage()

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

+ func (m *BeginResponse) GetTransactionId() int64

+ func (m *BeginResponse) Reset()

+ func (m *BeginResponse) String() string

+ func (m *BeginResponse) XXX_DiscardUnknown()

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

+ func (m *BeginResponse) XXX_Size() int

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

+ type BindVariable struct

+ Type Type

+ Value []byte

+ Values []*Value

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BindVariable) ProtoMessage()

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

+ func (m *BindVariable) GetType() Type

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

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

+ func (m *BindVariable) Reset()

+ func (m *BindVariable) String() string

+ func (m *BindVariable) XXX_DiscardUnknown()

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

+ func (m *BindVariable) XXX_Size() int

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

+ type BoundQuery struct

+ BindVariables map[string]*BindVariable

+ Sql string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BoundQuery) ProtoMessage()

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

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

+ func (m *BoundQuery) GetSql() string

+ func (m *BoundQuery) Reset()

+ func (m *BoundQuery) String() string

+ func (m *BoundQuery) XXX_DiscardUnknown()

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

+ func (m *BoundQuery) XXX_Size() int

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

+ type CommitPreparedRequest struct

+ Dtid string

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Target *Target

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CommitPreparedRequest) ProtoMessage()

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

+ func (m *CommitPreparedRequest) GetDtid() string

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

+ func (m *CommitPreparedRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *CommitPreparedRequest) GetTarget() *Target

+ func (m *CommitPreparedRequest) Reset()

+ func (m *CommitPreparedRequest) String() string

+ func (m *CommitPreparedRequest) XXX_DiscardUnknown()

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

+ func (m *CommitPreparedRequest) XXX_Size() int

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

+ type CommitPreparedResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CommitPreparedResponse) ProtoMessage()

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

+ func (m *CommitPreparedResponse) Reset()

+ func (m *CommitPreparedResponse) String() string

+ func (m *CommitPreparedResponse) XXX_DiscardUnknown()

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

+ func (m *CommitPreparedResponse) XXX_Size() int

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

+ type CommitRequest struct

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Target *Target

+ TransactionId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CommitRequest) ProtoMessage()

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

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

+ func (m *CommitRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *CommitRequest) GetTarget() *Target

+ func (m *CommitRequest) GetTransactionId() int64

+ func (m *CommitRequest) Reset()

+ func (m *CommitRequest) String() string

+ func (m *CommitRequest) XXX_DiscardUnknown()

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

+ func (m *CommitRequest) XXX_Size() int

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

+ type CommitResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CommitResponse) ProtoMessage()

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

+ func (m *CommitResponse) Reset()

+ func (m *CommitResponse) String() string

+ func (m *CommitResponse) XXX_DiscardUnknown()

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

+ func (m *CommitResponse) XXX_Size() int

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

+ type ConcludeTransactionRequest struct

+ Dtid string

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Target *Target

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ConcludeTransactionRequest) ProtoMessage()

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

+ func (m *ConcludeTransactionRequest) GetDtid() string

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

+ func (m *ConcludeTransactionRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *ConcludeTransactionRequest) GetTarget() *Target

+ func (m *ConcludeTransactionRequest) Reset()

+ func (m *ConcludeTransactionRequest) String() string

+ func (m *ConcludeTransactionRequest) XXX_DiscardUnknown()

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

+ func (m *ConcludeTransactionRequest) XXX_Size() int

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

+ type ConcludeTransactionResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ConcludeTransactionResponse) ProtoMessage()

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

+ func (m *ConcludeTransactionResponse) Reset()

+ func (m *ConcludeTransactionResponse) String() string

+ func (m *ConcludeTransactionResponse) XXX_DiscardUnknown()

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

+ func (m *ConcludeTransactionResponse) XXX_Size() int

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

+ type CreateTransactionRequest struct

+ Dtid string

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Participants []*Target

+ Target *Target

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateTransactionRequest) ProtoMessage()

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

+ func (m *CreateTransactionRequest) GetDtid() string

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

+ func (m *CreateTransactionRequest) GetImmediateCallerId() *VTGateCallerID

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

+ func (m *CreateTransactionRequest) GetTarget() *Target

+ func (m *CreateTransactionRequest) Reset()

+ func (m *CreateTransactionRequest) String() string

+ func (m *CreateTransactionRequest) XXX_DiscardUnknown()

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

+ func (m *CreateTransactionRequest) XXX_Size() int

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

+ type CreateTransactionResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateTransactionResponse) ProtoMessage()

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

+ func (m *CreateTransactionResponse) Reset()

+ func (m *CreateTransactionResponse) String() string

+ func (m *CreateTransactionResponse) XXX_DiscardUnknown()

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

+ func (m *CreateTransactionResponse) XXX_Size() int

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

+ type EventToken struct

+ Position string

+ Shard string

+ Timestamp int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*EventToken) ProtoMessage()

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

+ func (m *EventToken) GetPosition() string

+ func (m *EventToken) GetShard() string

+ func (m *EventToken) GetTimestamp() int64

+ func (m *EventToken) Reset()

+ func (m *EventToken) String() string

+ func (m *EventToken) XXX_DiscardUnknown()

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

+ func (m *EventToken) XXX_Size() int

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

+ type ExecuteBatchRequest struct

+ AsTransaction bool

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Options *ExecuteOptions

+ Queries []*BoundQuery

+ Target *Target

+ TransactionId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ExecuteBatchRequest) ProtoMessage()

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

+ func (m *ExecuteBatchRequest) GetAsTransaction() bool

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

+ func (m *ExecuteBatchRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *ExecuteBatchRequest) GetOptions() *ExecuteOptions

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

+ func (m *ExecuteBatchRequest) GetTarget() *Target

+ func (m *ExecuteBatchRequest) GetTransactionId() int64

+ func (m *ExecuteBatchRequest) Reset()

+ func (m *ExecuteBatchRequest) String() string

+ func (m *ExecuteBatchRequest) XXX_DiscardUnknown()

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

+ func (m *ExecuteBatchRequest) XXX_Size() int

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

+ type ExecuteBatchResponse struct

+ Results []*QueryResult

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ExecuteBatchResponse) ProtoMessage()

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

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

+ func (m *ExecuteBatchResponse) Reset()

+ func (m *ExecuteBatchResponse) String() string

+ func (m *ExecuteBatchResponse) XXX_DiscardUnknown()

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

+ func (m *ExecuteBatchResponse) XXX_Size() int

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

+ type ExecuteOptions struct

+ ClientFoundRows bool

+ CompareEventToken *EventToken

+ IncludeEventToken bool

+ IncludedFields ExecuteOptions_IncludedFields

+ SkipQueryPlanCache bool

+ SqlSelectLimit int64

+ TransactionIsolation ExecuteOptions_TransactionIsolation

+ Workload ExecuteOptions_Workload

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ExecuteOptions) ProtoMessage()

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

+ func (m *ExecuteOptions) GetClientFoundRows() bool

+ func (m *ExecuteOptions) GetCompareEventToken() *EventToken

+ func (m *ExecuteOptions) GetIncludeEventToken() bool

+ func (m *ExecuteOptions) GetIncludedFields() ExecuteOptions_IncludedFields

+ func (m *ExecuteOptions) GetSkipQueryPlanCache() bool

+ func (m *ExecuteOptions) GetSqlSelectLimit() int64

+ func (m *ExecuteOptions) GetTransactionIsolation() ExecuteOptions_TransactionIsolation

+ func (m *ExecuteOptions) GetWorkload() ExecuteOptions_Workload

+ func (m *ExecuteOptions) Reset()

+ func (m *ExecuteOptions) String() string

+ func (m *ExecuteOptions) XXX_DiscardUnknown()

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

+ func (m *ExecuteOptions) XXX_Size() int

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

+ type ExecuteOptions_IncludedFields int32

+ const ExecuteOptions_ALL

+ const ExecuteOptions_TYPE_AND_NAME

+ const ExecuteOptions_TYPE_ONLY

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

+ func (x ExecuteOptions_IncludedFields) String() string

+ type ExecuteOptions_TransactionIsolation int32

+ const ExecuteOptions_DEFAULT

+ const ExecuteOptions_READ_COMMITTED

+ const ExecuteOptions_READ_UNCOMMITTED

+ const ExecuteOptions_REPEATABLE_READ

+ const ExecuteOptions_SERIALIZABLE

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

+ func (x ExecuteOptions_TransactionIsolation) String() string

+ type ExecuteOptions_Workload int32

+ const ExecuteOptions_DBA

+ const ExecuteOptions_OLAP

+ const ExecuteOptions_OLTP

+ const ExecuteOptions_UNSPECIFIED

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

+ func (x ExecuteOptions_Workload) String() string

+ type ExecuteRequest struct

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Options *ExecuteOptions

+ Query *BoundQuery

+ Target *Target

+ TransactionId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ExecuteRequest) ProtoMessage()

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

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

+ func (m *ExecuteRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *ExecuteRequest) GetOptions() *ExecuteOptions

+ func (m *ExecuteRequest) GetQuery() *BoundQuery

+ func (m *ExecuteRequest) GetTarget() *Target

+ func (m *ExecuteRequest) GetTransactionId() int64

+ func (m *ExecuteRequest) Reset()

+ func (m *ExecuteRequest) String() string

+ func (m *ExecuteRequest) XXX_DiscardUnknown()

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

+ func (m *ExecuteRequest) XXX_Size() int

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

+ type ExecuteResponse struct

+ Result *QueryResult

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ExecuteResponse) ProtoMessage()

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

+ func (m *ExecuteResponse) GetResult() *QueryResult

+ func (m *ExecuteResponse) Reset()

+ func (m *ExecuteResponse) String() string

+ func (m *ExecuteResponse) XXX_DiscardUnknown()

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

+ func (m *ExecuteResponse) XXX_Size() int

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

+ type Field struct

+ Charset uint32

+ ColumnLength uint32

+ Database string

+ Decimals uint32

+ Flags uint32

+ Name string

+ OrgName string

+ OrgTable string

+ Table string

+ Type Type

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Field) ProtoMessage()

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

+ func (m *Field) GetCharset() uint32

+ func (m *Field) GetColumnLength() uint32

+ func (m *Field) GetDatabase() string

+ func (m *Field) GetDecimals() uint32

+ func (m *Field) GetFlags() uint32

+ func (m *Field) GetName() string

+ func (m *Field) GetOrgName() string

+ func (m *Field) GetOrgTable() string

+ func (m *Field) GetTable() string

+ func (m *Field) GetType() Type

+ func (m *Field) Reset()

+ func (m *Field) String() string

+ func (m *Field) XXX_DiscardUnknown()

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

+ func (m *Field) XXX_Size() int

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

+ type Flag int32

+ const Flag_ISBINARY

+ const Flag_ISFLOAT

+ const Flag_ISINTEGRAL

+ const Flag_ISQUOTED

+ const Flag_ISTEXT

+ const Flag_ISUNSIGNED

+ const Flag_NONE

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

+ func (x Flag) String() string

+ type MessageAckRequest struct

+ EffectiveCallerId *vtrpc.CallerID

+ Ids []*Value

+ ImmediateCallerId *VTGateCallerID

+ Name string

+ Target *Target

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MessageAckRequest) ProtoMessage()

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

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

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

+ func (m *MessageAckRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *MessageAckRequest) GetName() string

+ func (m *MessageAckRequest) GetTarget() *Target

+ func (m *MessageAckRequest) Reset()

+ func (m *MessageAckRequest) String() string

+ func (m *MessageAckRequest) XXX_DiscardUnknown()

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

+ func (m *MessageAckRequest) XXX_Size() int

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

+ type MessageAckResponse struct

+ Result *QueryResult

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MessageAckResponse) ProtoMessage()

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

+ func (m *MessageAckResponse) GetResult() *QueryResult

+ func (m *MessageAckResponse) Reset()

+ func (m *MessageAckResponse) String() string

+ func (m *MessageAckResponse) XXX_DiscardUnknown()

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

+ func (m *MessageAckResponse) XXX_Size() int

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

+ type MessageStreamRequest struct

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Name string

+ Target *Target

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MessageStreamRequest) ProtoMessage()

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

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

+ func (m *MessageStreamRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *MessageStreamRequest) GetName() string

+ func (m *MessageStreamRequest) GetTarget() *Target

+ func (m *MessageStreamRequest) Reset()

+ func (m *MessageStreamRequest) String() string

+ func (m *MessageStreamRequest) XXX_DiscardUnknown()

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

+ func (m *MessageStreamRequest) XXX_Size() int

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

+ type MessageStreamResponse struct

+ Result *QueryResult

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*MessageStreamResponse) ProtoMessage()

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

+ func (m *MessageStreamResponse) GetResult() *QueryResult

+ func (m *MessageStreamResponse) Reset()

+ func (m *MessageStreamResponse) String() string

+ func (m *MessageStreamResponse) XXX_DiscardUnknown()

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

+ func (m *MessageStreamResponse) XXX_Size() int

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

+ type MySqlFlag int32

+ const MySqlFlag_AUTO_INCREMENT_FLAG

+ const MySqlFlag_BINARY_FLAG

+ const MySqlFlag_BINCMP_FLAG

+ const MySqlFlag_BLOB_FLAG

+ const MySqlFlag_EMPTY

+ const MySqlFlag_ENUM_FLAG

+ const MySqlFlag_GROUP_FLAG

+ const MySqlFlag_MULTIPLE_KEY_FLAG

+ const MySqlFlag_NOT_NULL_FLAG

+ const MySqlFlag_NO_DEFAULT_VALUE_FLAG

+ const MySqlFlag_NUM_FLAG

+ const MySqlFlag_ON_UPDATE_NOW_FLAG

+ const MySqlFlag_PART_KEY_FLAG

+ const MySqlFlag_PRI_KEY_FLAG

+ const MySqlFlag_SET_FLAG

+ const MySqlFlag_TIMESTAMP_FLAG

+ const MySqlFlag_UNIQUE_FLAG

+ const MySqlFlag_UNIQUE_KEY_FLAG

+ const MySqlFlag_UNSIGNED_FLAG

+ const MySqlFlag_ZEROFILL_FLAG

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

+ func (x MySqlFlag) String() string

+ type PrepareRequest struct

+ Dtid string

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Target *Target

+ TransactionId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PrepareRequest) ProtoMessage()

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

+ func (m *PrepareRequest) GetDtid() string

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

+ func (m *PrepareRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *PrepareRequest) GetTarget() *Target

+ func (m *PrepareRequest) GetTransactionId() int64

+ func (m *PrepareRequest) Reset()

+ func (m *PrepareRequest) String() string

+ func (m *PrepareRequest) XXX_DiscardUnknown()

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

+ func (m *PrepareRequest) XXX_Size() int

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

+ type PrepareResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PrepareResponse) ProtoMessage()

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

+ func (m *PrepareResponse) Reset()

+ func (m *PrepareResponse) String() string

+ func (m *PrepareResponse) XXX_DiscardUnknown()

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

+ func (m *PrepareResponse) XXX_Size() int

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

+ type QueryResult struct

+ Extras *ResultExtras

+ Fields []*Field

+ InsertId uint64

+ Rows []*Row

+ RowsAffected uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*QueryResult) ProtoMessage()

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

+ func (m *QueryResult) GetExtras() *ResultExtras

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

+ func (m *QueryResult) GetInsertId() uint64

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

+ func (m *QueryResult) GetRowsAffected() uint64

+ func (m *QueryResult) Reset()

+ func (m *QueryResult) String() string

+ func (m *QueryResult) XXX_DiscardUnknown()

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

+ func (m *QueryResult) XXX_Size() int

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

+ type QuerySplit struct

+ Query *BoundQuery

+ RowCount int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*QuerySplit) ProtoMessage()

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

+ func (m *QuerySplit) GetQuery() *BoundQuery

+ func (m *QuerySplit) GetRowCount() int64

+ func (m *QuerySplit) Reset()

+ func (m *QuerySplit) String() string

+ func (m *QuerySplit) XXX_DiscardUnknown()

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

+ func (m *QuerySplit) XXX_Size() int

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

+ type QueryWarning struct

+ Code uint32

+ Message string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*QueryWarning) ProtoMessage()

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

+ func (m *QueryWarning) GetCode() uint32

+ func (m *QueryWarning) GetMessage() string

+ func (m *QueryWarning) Reset()

+ func (m *QueryWarning) String() string

+ func (m *QueryWarning) XXX_DiscardUnknown()

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

+ func (m *QueryWarning) XXX_Size() int

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

+ type ReadTransactionRequest struct

+ Dtid string

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Target *Target

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadTransactionRequest) ProtoMessage()

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

+ func (m *ReadTransactionRequest) GetDtid() string

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

+ func (m *ReadTransactionRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *ReadTransactionRequest) GetTarget() *Target

+ func (m *ReadTransactionRequest) Reset()

+ func (m *ReadTransactionRequest) String() string

+ func (m *ReadTransactionRequest) XXX_DiscardUnknown()

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

+ func (m *ReadTransactionRequest) XXX_Size() int

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

+ type ReadTransactionResponse struct

+ Metadata *TransactionMetadata

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ReadTransactionResponse) ProtoMessage()

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

+ func (m *ReadTransactionResponse) GetMetadata() *TransactionMetadata

+ func (m *ReadTransactionResponse) Reset()

+ func (m *ReadTransactionResponse) String() string

+ func (m *ReadTransactionResponse) XXX_DiscardUnknown()

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

+ func (m *ReadTransactionResponse) XXX_Size() int

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

+ type RealtimeStats struct

+ BinlogPlayersCount int32

+ CpuUsage float64

+ HealthError string

+ Qps float64

+ SecondsBehindMaster uint32

+ SecondsBehindMasterFilteredReplication int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RealtimeStats) ProtoMessage()

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

+ func (m *RealtimeStats) GetBinlogPlayersCount() int32

+ func (m *RealtimeStats) GetCpuUsage() float64

+ func (m *RealtimeStats) GetHealthError() string

+ func (m *RealtimeStats) GetQps() float64

+ func (m *RealtimeStats) GetSecondsBehindMaster() uint32

+ func (m *RealtimeStats) GetSecondsBehindMasterFilteredReplication() int64

+ func (m *RealtimeStats) Reset()

+ func (m *RealtimeStats) String() string

+ func (m *RealtimeStats) XXX_DiscardUnknown()

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

+ func (m *RealtimeStats) XXX_Size() int

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

+ type ResultExtras struct

+ EventToken *EventToken

+ Fresher bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ResultExtras) ProtoMessage()

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

+ func (m *ResultExtras) GetEventToken() *EventToken

+ func (m *ResultExtras) GetFresher() bool

+ func (m *ResultExtras) Reset()

+ func (m *ResultExtras) String() string

+ func (m *ResultExtras) XXX_DiscardUnknown()

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

+ func (m *ResultExtras) XXX_Size() int

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

+ type ResultWithError struct

+ Error *vtrpc.RPCError

+ Result *QueryResult

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ResultWithError) ProtoMessage()

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

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

+ func (m *ResultWithError) GetResult() *QueryResult

+ func (m *ResultWithError) Reset()

+ func (m *ResultWithError) String() string

+ func (m *ResultWithError) XXX_DiscardUnknown()

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

+ func (m *ResultWithError) XXX_Size() int

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

+ type RollbackPreparedRequest struct

+ Dtid string

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Target *Target

+ TransactionId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RollbackPreparedRequest) ProtoMessage()

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

+ func (m *RollbackPreparedRequest) GetDtid() string

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

+ func (m *RollbackPreparedRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *RollbackPreparedRequest) GetTarget() *Target

+ func (m *RollbackPreparedRequest) GetTransactionId() int64

+ func (m *RollbackPreparedRequest) Reset()

+ func (m *RollbackPreparedRequest) String() string

+ func (m *RollbackPreparedRequest) XXX_DiscardUnknown()

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

+ func (m *RollbackPreparedRequest) XXX_Size() int

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

+ type RollbackPreparedResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RollbackPreparedResponse) ProtoMessage()

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

+ func (m *RollbackPreparedResponse) Reset()

+ func (m *RollbackPreparedResponse) String() string

+ func (m *RollbackPreparedResponse) XXX_DiscardUnknown()

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

+ func (m *RollbackPreparedResponse) XXX_Size() int

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

+ type RollbackRequest struct

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Target *Target

+ TransactionId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RollbackRequest) ProtoMessage()

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

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

+ func (m *RollbackRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *RollbackRequest) GetTarget() *Target

+ func (m *RollbackRequest) GetTransactionId() int64

+ func (m *RollbackRequest) Reset()

+ func (m *RollbackRequest) String() string

+ func (m *RollbackRequest) XXX_DiscardUnknown()

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

+ func (m *RollbackRequest) XXX_Size() int

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

+ type RollbackResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RollbackResponse) ProtoMessage()

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

+ func (m *RollbackResponse) Reset()

+ func (m *RollbackResponse) String() string

+ func (m *RollbackResponse) XXX_DiscardUnknown()

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

+ func (m *RollbackResponse) XXX_Size() int

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

+ type Row struct

+ Lengths []int64

+ Values []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Row) ProtoMessage()

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

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

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

+ func (m *Row) Reset()

+ func (m *Row) String() string

+ func (m *Row) XXX_DiscardUnknown()

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

+ func (m *Row) XXX_Size() int

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

+ type SetRollbackRequest struct

+ Dtid string

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Target *Target

+ TransactionId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SetRollbackRequest) ProtoMessage()

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

+ func (m *SetRollbackRequest) GetDtid() string

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

+ func (m *SetRollbackRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *SetRollbackRequest) GetTarget() *Target

+ func (m *SetRollbackRequest) GetTransactionId() int64

+ func (m *SetRollbackRequest) Reset()

+ func (m *SetRollbackRequest) String() string

+ func (m *SetRollbackRequest) XXX_DiscardUnknown()

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

+ func (m *SetRollbackRequest) XXX_Size() int

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

+ type SetRollbackResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SetRollbackResponse) ProtoMessage()

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

+ func (m *SetRollbackResponse) Reset()

+ func (m *SetRollbackResponse) String() string

+ func (m *SetRollbackResponse) XXX_DiscardUnknown()

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

+ func (m *SetRollbackResponse) XXX_Size() int

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

+ type SplitQueryRequest struct

+ Algorithm SplitQueryRequest_Algorithm

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ NumRowsPerQueryPart int64

+ Query *BoundQuery

+ SplitColumn []string

+ SplitCount int64

+ Target *Target

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SplitQueryRequest) ProtoMessage()

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

+ func (m *SplitQueryRequest) GetAlgorithm() SplitQueryRequest_Algorithm

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

+ func (m *SplitQueryRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *SplitQueryRequest) GetNumRowsPerQueryPart() int64

+ func (m *SplitQueryRequest) GetQuery() *BoundQuery

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

+ func (m *SplitQueryRequest) GetSplitCount() int64

+ func (m *SplitQueryRequest) GetTarget() *Target

+ func (m *SplitQueryRequest) Reset()

+ func (m *SplitQueryRequest) String() string

+ func (m *SplitQueryRequest) XXX_DiscardUnknown()

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

+ func (m *SplitQueryRequest) XXX_Size() int

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

+ type SplitQueryRequest_Algorithm int32

+ const SplitQueryRequest_EQUAL_SPLITS

+ const SplitQueryRequest_FULL_SCAN

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

+ func (x SplitQueryRequest_Algorithm) String() string

+ type SplitQueryResponse struct

+ Queries []*QuerySplit

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SplitQueryResponse) ProtoMessage()

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

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

+ func (m *SplitQueryResponse) Reset()

+ func (m *SplitQueryResponse) String() string

+ func (m *SplitQueryResponse) XXX_DiscardUnknown()

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

+ func (m *SplitQueryResponse) XXX_Size() int

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

+ type StartCommitRequest struct

+ Dtid string

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Target *Target

+ TransactionId int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StartCommitRequest) ProtoMessage()

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

+ func (m *StartCommitRequest) GetDtid() string

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

+ func (m *StartCommitRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *StartCommitRequest) GetTarget() *Target

+ func (m *StartCommitRequest) GetTransactionId() int64

+ func (m *StartCommitRequest) Reset()

+ func (m *StartCommitRequest) String() string

+ func (m *StartCommitRequest) XXX_DiscardUnknown()

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

+ func (m *StartCommitRequest) XXX_Size() int

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

+ type StartCommitResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StartCommitResponse) ProtoMessage()

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

+ func (m *StartCommitResponse) Reset()

+ func (m *StartCommitResponse) String() string

+ func (m *StartCommitResponse) XXX_DiscardUnknown()

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

+ func (m *StartCommitResponse) XXX_Size() int

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

+ type StreamEvent struct

+ EventToken *EventToken

+ Statements []*StreamEvent_Statement

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamEvent) ProtoMessage()

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

+ func (m *StreamEvent) GetEventToken() *EventToken

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

+ func (m *StreamEvent) Reset()

+ func (m *StreamEvent) String() string

+ func (m *StreamEvent) XXX_DiscardUnknown()

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

+ func (m *StreamEvent) XXX_Size() int

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

+ type StreamEvent_Statement struct

+ Category StreamEvent_Statement_Category

+ PrimaryKeyFields []*Field

+ PrimaryKeyValues []*Row

+ Sql []byte

+ TableName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamEvent_Statement) ProtoMessage()

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

+ func (m *StreamEvent_Statement) GetCategory() StreamEvent_Statement_Category

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

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

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

+ func (m *StreamEvent_Statement) GetTableName() string

+ func (m *StreamEvent_Statement) Reset()

+ func (m *StreamEvent_Statement) String() string

+ func (m *StreamEvent_Statement) XXX_DiscardUnknown()

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

+ func (m *StreamEvent_Statement) XXX_Size() int

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

+ type StreamEvent_Statement_Category int32

+ const StreamEvent_Statement_DDL

+ const StreamEvent_Statement_DML

+ const StreamEvent_Statement_Error

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

+ func (x StreamEvent_Statement_Category) String() string

+ type StreamExecuteRequest struct

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Options *ExecuteOptions

+ Query *BoundQuery

+ Target *Target

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamExecuteRequest) ProtoMessage()

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

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

+ func (m *StreamExecuteRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *StreamExecuteRequest) GetOptions() *ExecuteOptions

+ func (m *StreamExecuteRequest) GetQuery() *BoundQuery

+ func (m *StreamExecuteRequest) GetTarget() *Target

+ func (m *StreamExecuteRequest) Reset()

+ func (m *StreamExecuteRequest) String() string

+ func (m *StreamExecuteRequest) XXX_DiscardUnknown()

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

+ func (m *StreamExecuteRequest) XXX_Size() int

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

+ type StreamExecuteResponse struct

+ Result *QueryResult

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamExecuteResponse) ProtoMessage()

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

+ func (m *StreamExecuteResponse) GetResult() *QueryResult

+ func (m *StreamExecuteResponse) Reset()

+ func (m *StreamExecuteResponse) String() string

+ func (m *StreamExecuteResponse) XXX_DiscardUnknown()

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

+ func (m *StreamExecuteResponse) XXX_Size() int

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

+ type StreamHealthRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamHealthRequest) ProtoMessage()

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

+ func (m *StreamHealthRequest) Reset()

+ func (m *StreamHealthRequest) String() string

+ func (m *StreamHealthRequest) XXX_DiscardUnknown()

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

+ func (m *StreamHealthRequest) XXX_Size() int

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

+ type StreamHealthResponse struct

+ AggregateStats *AggregateStats

+ RealtimeStats *RealtimeStats

+ Serving bool

+ TabletAlias *topodata.TabletAlias

+ TabletExternallyReparentedTimestamp int64

+ Target *Target

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*StreamHealthResponse) ProtoMessage()

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

+ func (m *StreamHealthResponse) GetAggregateStats() *AggregateStats

+ func (m *StreamHealthResponse) GetRealtimeStats() *RealtimeStats

+ func (m *StreamHealthResponse) GetServing() bool

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

+ func (m *StreamHealthResponse) GetTabletExternallyReparentedTimestamp() int64

+ func (m *StreamHealthResponse) GetTarget() *Target

+ func (m *StreamHealthResponse) Reset()

+ func (m *StreamHealthResponse) String() string

+ func (m *StreamHealthResponse) XXX_DiscardUnknown()

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

+ func (m *StreamHealthResponse) XXX_Size() int

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

+ type Target struct

+ Cell string

+ Keyspace string

+ Shard string

+ TabletType topodata.TabletType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Target) ProtoMessage()

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

+ func (m *Target) GetCell() string

+ func (m *Target) GetKeyspace() string

+ func (m *Target) GetShard() string

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

+ func (m *Target) Reset()

+ func (m *Target) String() string

+ func (m *Target) XXX_DiscardUnknown()

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

+ func (m *Target) XXX_Size() int

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

+ type TransactionMetadata struct

+ Dtid string

+ Participants []*Target

+ State TransactionState

+ TimeCreated int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TransactionMetadata) ProtoMessage()

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

+ func (m *TransactionMetadata) GetDtid() string

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

+ func (m *TransactionMetadata) GetState() TransactionState

+ func (m *TransactionMetadata) GetTimeCreated() int64

+ func (m *TransactionMetadata) Reset()

+ func (m *TransactionMetadata) String() string

+ func (m *TransactionMetadata) XXX_DiscardUnknown()

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

+ func (m *TransactionMetadata) XXX_Size() int

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

+ type TransactionState int32

+ const TransactionState_COMMIT

+ const TransactionState_PREPARE

+ const TransactionState_ROLLBACK

+ const TransactionState_UNKNOWN

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

+ func (x TransactionState) String() string

+ type Type int32

+ const Type_BINARY

+ const Type_BIT

+ const Type_BLOB

+ const Type_CHAR

+ const Type_DATE

+ const Type_DATETIME

+ const Type_DECIMAL

+ const Type_ENUM

+ const Type_EXPRESSION

+ const Type_FLOAT32

+ const Type_FLOAT64

+ const Type_GEOMETRY

+ const Type_INT16

+ const Type_INT24

+ const Type_INT32

+ const Type_INT64

+ const Type_INT8

+ const Type_JSON

+ const Type_NULL_TYPE

+ const Type_SET

+ const Type_TEXT

+ const Type_TIME

+ const Type_TIMESTAMP

+ const Type_TUPLE

+ const Type_UINT16

+ const Type_UINT24

+ const Type_UINT32

+ const Type_UINT64

+ const Type_UINT8

+ const Type_VARBINARY

+ const Type_VARCHAR

+ const Type_YEAR

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

+ func (x Type) String() string

+ type UpdateStreamRequest struct

+ EffectiveCallerId *vtrpc.CallerID

+ ImmediateCallerId *VTGateCallerID

+ Position string

+ Target *Target

+ Timestamp int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UpdateStreamRequest) ProtoMessage()

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

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

+ func (m *UpdateStreamRequest) GetImmediateCallerId() *VTGateCallerID

+ func (m *UpdateStreamRequest) GetPosition() string

+ func (m *UpdateStreamRequest) GetTarget() *Target

+ func (m *UpdateStreamRequest) GetTimestamp() int64

+ func (m *UpdateStreamRequest) Reset()

+ func (m *UpdateStreamRequest) String() string

+ func (m *UpdateStreamRequest) XXX_DiscardUnknown()

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

+ func (m *UpdateStreamRequest) XXX_Size() int

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

+ type UpdateStreamResponse struct

+ Event *StreamEvent

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UpdateStreamResponse) ProtoMessage()

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

+ func (m *UpdateStreamResponse) GetEvent() *StreamEvent

+ func (m *UpdateStreamResponse) Reset()

+ func (m *UpdateStreamResponse) String() string

+ func (m *UpdateStreamResponse) XXX_DiscardUnknown()

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

+ func (m *UpdateStreamResponse) XXX_Size() int

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

+ type VTGateCallerID struct

+ Groups []string

+ Username string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*VTGateCallerID) ProtoMessage()

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

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

+ func (m *VTGateCallerID) GetUsername() string

+ func (m *VTGateCallerID) Reset()

+ func (m *VTGateCallerID) String() string

+ func (m *VTGateCallerID) XXX_DiscardUnknown()

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

+ func (m *VTGateCallerID) XXX_Size() int

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

+ type Value struct

+ Type Type

+ Value []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Value) ProtoMessage()

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

+ func (m *Value) GetType() Type

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

+ func (m *Value) Reset()

+ func (m *Value) String() string

+ func (m *Value) XXX_DiscardUnknown()

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

+ func (m *Value) XXX_Size() int

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

v1.2.0

Oct 1, 2018

v1.1.0

Sep 27, 2018

Other modules containing this package

gopkg.in/src-d/go-vitess.v0

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