vtgate

package
v2.0.0-beta.1+incompat... Latest Latest
Warning

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

 Go to latest Published: Mar 3, 2016 License: BSD-3-Clause Imports: 6 Imported by: 0

Documentation

Overview

Package vtgate is a generated protocol buffer package.

It is generated from these files: 

vtgate.proto

It has these top-level messages: 

Session
ExecuteRequest
ExecuteResponse
ExecuteShardsRequest
ExecuteShardsResponse
ExecuteKeyspaceIdsRequest
ExecuteKeyspaceIdsResponse
ExecuteKeyRangesRequest
ExecuteKeyRangesResponse
ExecuteEntityIdsRequest
ExecuteEntityIdsResponse
BoundShardQuery
ExecuteBatchShardsRequest
ExecuteBatchShardsResponse
BoundKeyspaceIdQuery
ExecuteBatchKeyspaceIdsRequest
ExecuteBatchKeyspaceIdsResponse
StreamExecuteRequest
StreamExecuteResponse
StreamExecuteShardsRequest
StreamExecuteShardsResponse
StreamExecuteKeyspaceIdsRequest
StreamExecuteKeyspaceIdsResponse
StreamExecuteKeyRangesRequest
StreamExecuteKeyRangesResponse
BeginRequest
BeginResponse
CommitRequest
CommitResponse
RollbackRequest
RollbackResponse
SplitQueryRequest
SplitQueryResponse
GetSrvKeyspaceRequest
GetSrvKeyspaceResponse

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BeginRequest 

type BeginRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId" json:"caller_id,omitempty"`
}

BeginRequest is the payload to Begin.

func (*BeginRequest) Descriptor 

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

func (*BeginRequest) GetCallerId 

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

func (*BeginRequest) ProtoMessage 

func (*BeginRequest) ProtoMessage()

func (*BeginRequest) Reset 

func (m *BeginRequest) Reset()

func (*BeginRequest) String 

func (m *BeginRequest) String() string

type BeginResponse 

type BeginResponse struct {
	// session is the initial session information to use for subsequent queries.
	Session *Session `protobuf:"bytes,1,opt,name=session" json:"session,omitempty"`
}

BeginResponse is the returned value from Begin.

func (*BeginResponse) Descriptor 

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

func (*BeginResponse) GetSession 

func (m *BeginResponse) GetSession() *Session

func (*BeginResponse) ProtoMessage 

func (*BeginResponse) ProtoMessage()

func (*BeginResponse) Reset 

func (m *BeginResponse) Reset()

func (*BeginResponse) String 

func (m *BeginResponse) String() string

type BoundKeyspaceIdQuery 

type BoundKeyspaceIdQuery struct {
	// query is the query and bind variables to execute.
	Query *query.BoundQuery `protobuf:"bytes,1,opt,name=query" json:"query,omitempty"`
	// keyspace to target the query to.
	Keyspace string `protobuf:"bytes,2,opt,name=keyspace" json:"keyspace,omitempty"`
	// keyspace_ids contains the list of keyspace_ids affected by this query.
	// Will be used to find the shards to send the query to.
	KeyspaceIds [][]byte `protobuf:"bytes,3,rep,name=keyspace_ids,json=keyspaceIds,proto3" json:"keyspace_ids,omitempty"`
}

BoundKeyspaceIdQuery represents a single query request for the specified list of keyspace ids. This is used in a list for ExecuteBatchKeyspaceIdsRequest.

func (*BoundKeyspaceIdQuery) Descriptor 

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

func (*BoundKeyspaceIdQuery) GetQuery 

func (m *BoundKeyspaceIdQuery) GetQuery() *query.BoundQuery

func (*BoundKeyspaceIdQuery) ProtoMessage 

func (*BoundKeyspaceIdQuery) ProtoMessage()

func (*BoundKeyspaceIdQuery) Reset 

func (m *BoundKeyspaceIdQuery) Reset()

func (*BoundKeyspaceIdQuery) String 

func (m *BoundKeyspaceIdQuery) String() string

type BoundShardQuery 

type BoundShardQuery struct {
	// query is the query and bind variables to execute.
	Query *query.BoundQuery `protobuf:"bytes,1,opt,name=query" json:"query,omitempty"`
	// keyspace to target the query to.
	Keyspace string `protobuf:"bytes,2,opt,name=keyspace" json:"keyspace,omitempty"`
	// shards to target the query to. A DML can only target one shard.
	Shards []string `protobuf:"bytes,3,rep,name=shards" json:"shards,omitempty"`
}

BoundShardQuery represents a single query request for the specified list of shards. This is used in a list for ExecuteBatchShardsRequest.

func (*BoundShardQuery) Descriptor 

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

func (*BoundShardQuery) GetQuery 

func (m *BoundShardQuery) GetQuery() *query.BoundQuery

func (*BoundShardQuery) ProtoMessage 

func (*BoundShardQuery) ProtoMessage()

func (*BoundShardQuery) Reset 

func (m *BoundShardQuery) Reset()

func (*BoundShardQuery) String 

func (m *BoundShardQuery) String() string

type CommitRequest 

type CommitRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId" json:"caller_id,omitempty"`
	// session carries the current transaction data to commit.
	Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"`
}

CommitRequest is the payload to Commit.

func (*CommitRequest) Descriptor 

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

func (*CommitRequest) GetCallerId 

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

func (*CommitRequest) GetSession 

func (m *CommitRequest) GetSession() *Session

func (*CommitRequest) ProtoMessage 

func (*CommitRequest) ProtoMessage()

func (*CommitRequest) Reset 

func (m *CommitRequest) Reset()

func (*CommitRequest) String 

func (m *CommitRequest) String() string

type CommitResponse 

type CommitResponse struct {
}

CommitResponse is the returned value from Commit.

func (*CommitResponse) Descriptor 

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

func (*CommitResponse) ProtoMessage 

func (*CommitResponse) ProtoMessage()

func (*CommitResponse) Reset 

func (m *CommitResponse) Reset()

func (*CommitResponse) String 

func (m *CommitResponse) String() string

type ExecuteBatchKeyspaceIdsRequest 

type ExecuteBatchKeyspaceIdsRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId" json:"caller_id,omitempty"`
	// session carries the current transaction data. It is returned by Begin.
	// Do not fill it in if outside of a transaction.
	Session *Session                `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"`
	Queries []*BoundKeyspaceIdQuery `protobuf:"bytes,3,rep,name=queries" json:"queries,omitempty"`
	// tablet_type is the type of tablets that this query is targeted to.
	TabletType topodata.TabletType `protobuf:"varint,4,opt,name=tablet_type,json=tabletType,enum=topodata.TabletType" json:"tablet_type,omitempty"`
	// as_transaction will execute the queries in this batch in a single transaction per shard, created for this purpose.
	// (this can be seen as adding a 'begin' before and 'commit' after the queries).
	// Only makes sense if tablet_type is master. If set, the Session is ignored.
	AsTransaction bool `protobuf:"varint,5,opt,name=as_transaction,json=asTransaction" json:"as_transaction,omitempty"`
}

ExecuteBatchKeyspaceIdsRequest is the payload to ExecuteBatchKeyspaceId.

func (*ExecuteBatchKeyspaceIdsRequest) Descriptor 

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

func (*ExecuteBatchKeyspaceIdsRequest) GetCallerId 

func (m *ExecuteBatchKeyspaceIdsRequest) GetCallerId() *vtrpc.CallerID

func (*ExecuteBatchKeyspaceIdsRequest) GetQueries 

func (m *ExecuteBatchKeyspaceIdsRequest) GetQueries() []*BoundKeyspaceIdQuery

func (*ExecuteBatchKeyspaceIdsRequest) GetSession 

func (m *ExecuteBatchKeyspaceIdsRequest) GetSession() *Session

func (*ExecuteBatchKeyspaceIdsRequest) ProtoMessage 

func (*ExecuteBatchKeyspaceIdsRequest) ProtoMessage()

func (*ExecuteBatchKeyspaceIdsRequest) Reset 

func (m *ExecuteBatchKeyspaceIdsRequest) Reset()

func (*ExecuteBatchKeyspaceIdsRequest) String 

func (m *ExecuteBatchKeyspaceIdsRequest) String() string

type ExecuteBatchKeyspaceIdsResponse 

type ExecuteBatchKeyspaceIdsResponse struct {
	// error contains an application level error if necessary. Note the
	// session may have changed, even when an error is returned (for
	// instance if a database integrity error happened).
	Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	// session is the updated session information (only returned inside a transaction).
	Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"`
	// result contains the query result, only set if error is unset.
	Results []*query.QueryResult `protobuf:"bytes,3,rep,name=results" json:"results,omitempty"`
}

ExecuteBatchKeyspaceIdsResponse is the returned value from ExecuteBatchKeyspaceId.

func (*ExecuteBatchKeyspaceIdsResponse) Descriptor 

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

func (*ExecuteBatchKeyspaceIdsResponse) GetError 

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

func (*ExecuteBatchKeyspaceIdsResponse) GetResults 

func (m *ExecuteBatchKeyspaceIdsResponse) GetResults() []*query.QueryResult

func (*ExecuteBatchKeyspaceIdsResponse) GetSession 

func (m *ExecuteBatchKeyspaceIdsResponse) GetSession() *Session

func (*ExecuteBatchKeyspaceIdsResponse) ProtoMessage 

func (*ExecuteBatchKeyspaceIdsResponse) ProtoMessage()

func (*ExecuteBatchKeyspaceIdsResponse) Reset 

func (m *ExecuteBatchKeyspaceIdsResponse) Reset()

func (*ExecuteBatchKeyspaceIdsResponse) String 

func (m *ExecuteBatchKeyspaceIdsResponse) String() string

type ExecuteBatchShardsRequest 

type ExecuteBatchShardsRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId" json:"caller_id,omitempty"`
	// session carries the current transaction data. It is returned by Begin.
	// Do not fill it in if outside of a transaction.
	Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"`
	// queries carries all the queries to execute.
	Queries []*BoundShardQuery `protobuf:"bytes,3,rep,name=queries" json:"queries,omitempty"`
	// tablet_type is the type of tablets that this query is targeted to.
	TabletType topodata.TabletType `protobuf:"varint,4,opt,name=tablet_type,json=tabletType,enum=topodata.TabletType" json:"tablet_type,omitempty"`
	// as_transaction will execute the queries in this batch in a single transaction per shard, created for this purpose.
	// (this can be seen as adding a 'begin' before and 'commit' after the queries).
	// Only makes sense if tablet_type is master. If set, the Session is ignored.
	AsTransaction bool `protobuf:"varint,5,opt,name=as_transaction,json=asTransaction" json:"as_transaction,omitempty"`
}

ExecuteBatchShardsRequest is the payload to ExecuteBatchShards

func (*ExecuteBatchShardsRequest) Descriptor 

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

func (*ExecuteBatchShardsRequest) GetCallerId 

func (m *ExecuteBatchShardsRequest) GetCallerId() *vtrpc.CallerID

func (*ExecuteBatchShardsRequest) GetQueries 

func (m *ExecuteBatchShardsRequest) GetQueries() []*BoundShardQuery

func (*ExecuteBatchShardsRequest) GetSession 

func (m *ExecuteBatchShardsRequest) GetSession() *Session

func (*ExecuteBatchShardsRequest) ProtoMessage 

func (*ExecuteBatchShardsRequest) ProtoMessage()

func (*ExecuteBatchShardsRequest) Reset 

func (m *ExecuteBatchShardsRequest) Reset()

func (*ExecuteBatchShardsRequest) String 

func (m *ExecuteBatchShardsRequest) String() string

type ExecuteBatchShardsResponse 

type ExecuteBatchShardsResponse struct {
	// error contains an application level error if necessary. Note the
	// session may have changed, even when an error is returned (for
	// instance if a database integrity error happened).
	Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	// session is the updated session information (only returned inside a transaction).
	Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"`
	// result contains the query result, only set if error is unset.
	Results []*query.QueryResult `protobuf:"bytes,3,rep,name=results" json:"results,omitempty"`
}

ExecuteBatchShardsResponse is the returned value from ExecuteBatchShards.

func (*ExecuteBatchShardsResponse) Descriptor 

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

func (*ExecuteBatchShardsResponse) GetError 

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

func (*ExecuteBatchShardsResponse) GetResults 

func (m *ExecuteBatchShardsResponse) GetResults() []*query.QueryResult

func (*ExecuteBatchShardsResponse) GetSession 

func (m *ExecuteBatchShardsResponse) GetSession() *Session

func (*ExecuteBatchShardsResponse) ProtoMessage 

func (*ExecuteBatchShardsResponse) ProtoMessage()

func (*ExecuteBatchShardsResponse) Reset 

func (m *ExecuteBatchShardsResponse) Reset()

func (*ExecuteBatchShardsResponse) String 

func (m *ExecuteBatchShardsResponse) String() string

type ExecuteEntityIdsRequest 

type ExecuteEntityIdsRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId" json:"caller_id,omitempty"`
	// session carries the current transaction data. It is returned by Begin.
	// Do not fill it in if outside of a transaction.
	Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"`
	// query is the query and bind variables to execute.
	Query *query.BoundQuery `protobuf:"bytes,3,opt,name=query" json:"query,omitempty"`
	// keyspace to target the query to.
	Keyspace string `protobuf:"bytes,4,opt,name=keyspace" json:"keyspace,omitempty"`
	// entity_column_name is the column name to use.
	EntityColumnName string `protobuf:"bytes,5,opt,name=entity_column_name,json=entityColumnName" json:"entity_column_name,omitempty"`
	// entity_keyspace_ids are pairs of entity_column_name values
	// associated with its corresponding keyspace_id.
	EntityKeyspaceIds []*ExecuteEntityIdsRequest_EntityId `protobuf:"bytes,6,rep,name=entity_keyspace_ids,json=entityKeyspaceIds" json:"entity_keyspace_ids,omitempty"`
	// tablet_type is the type of tablets that this query is targeted to.
	TabletType topodata.TabletType `protobuf:"varint,7,opt,name=tablet_type,json=tabletType,enum=topodata.TabletType" json:"tablet_type,omitempty"`
	// not_in_transaction is deprecated and should not be used.
	NotInTransaction bool `protobuf:"varint,8,opt,name=not_in_transaction,json=notInTransaction" json:"not_in_transaction,omitempty"`
}

ExecuteEntityIdsRequest is the payload to ExecuteEntityIds.

func (*ExecuteEntityIdsRequest) Descriptor 

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

func (*ExecuteEntityIdsRequest) GetCallerId 

func (m *ExecuteEntityIdsRequest) GetCallerId() *vtrpc.CallerID

func (*ExecuteEntityIdsRequest) GetEntityKeyspaceIds 

func (m *ExecuteEntityIdsRequest) GetEntityKeyspaceIds() []*ExecuteEntityIdsRequest_EntityId

func (*ExecuteEntityIdsRequest) GetQuery 

func (m *ExecuteEntityIdsRequest) GetQuery() *query.BoundQuery

func (*ExecuteEntityIdsRequest) GetSession 

func (m *ExecuteEntityIdsRequest) GetSession() *Session

func (*ExecuteEntityIdsRequest) ProtoMessage 

func (*ExecuteEntityIdsRequest) ProtoMessage()

func (*ExecuteEntityIdsRequest) Reset 

func (m *ExecuteEntityIdsRequest) Reset()

func (*ExecuteEntityIdsRequest) String 

func (m *ExecuteEntityIdsRequest) String() string

type ExecuteEntityIdsRequest_EntityId 

type ExecuteEntityIdsRequest_EntityId struct {
	// type is the type of the entity's value. Can be NULL_TYPE.
	Type query.Type `protobuf:"varint,1,opt,name=type,enum=query.Type" json:"type,omitempty"`
	// value is the value for the entity. Not set if type is NULL_TYPE.
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// keyspace_id is the associated keyspace_id for the entity.
	KeyspaceId []byte `protobuf:"bytes,3,opt,name=keyspace_id,json=keyspaceId,proto3" json:"keyspace_id,omitempty"`
}

func (*ExecuteEntityIdsRequest_EntityId) Descriptor 

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

func (*ExecuteEntityIdsRequest_EntityId) ProtoMessage 

func (*ExecuteEntityIdsRequest_EntityId) ProtoMessage()

func (*ExecuteEntityIdsRequest_EntityId) Reset 

func (m *ExecuteEntityIdsRequest_EntityId) Reset()

func (*ExecuteEntityIdsRequest_EntityId) String 

func (m *ExecuteEntityIdsRequest_EntityId) String() string

type ExecuteEntityIdsResponse 

type ExecuteEntityIdsResponse struct {
	// error contains an application level error if necessary. Note the
	// session may have changed, even when an error is returned (for
	// instance if a database integrity error happened).
	Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	// session is the updated session information (only returned inside a transaction).
	Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"`
	// result contains the query result, only set if error is unset.
	Result *query.QueryResult `protobuf:"bytes,3,opt,name=result" json:"result,omitempty"`
}

ExecuteEntityIdsResponse is the returned value from ExecuteEntityIds.

func (*ExecuteEntityIdsResponse) Descriptor 

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

func (*ExecuteEntityIdsResponse) GetError 

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

func (*ExecuteEntityIdsResponse) GetResult 

func (m *ExecuteEntityIdsResponse) GetResult() *query.QueryResult

func (*ExecuteEntityIdsResponse) GetSession 

func (m *ExecuteEntityIdsResponse) GetSession() *Session

func (*ExecuteEntityIdsResponse) ProtoMessage 

func (*ExecuteEntityIdsResponse) ProtoMessage()

func (*ExecuteEntityIdsResponse) Reset 

func (m *ExecuteEntityIdsResponse) Reset()

func (*ExecuteEntityIdsResponse) String 

func (m *ExecuteEntityIdsResponse) String() string

type ExecuteKeyRangesRequest 

type ExecuteKeyRangesRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId" json:"caller_id,omitempty"`
	// session carries the current transaction data. It is returned by Begin.
	// Do not fill it in if outside of a transaction.
	Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"`
	// query is the query and bind variables to execute.
	Query *query.BoundQuery `protobuf:"bytes,3,opt,name=query" json:"query,omitempty"`
	// keyspace to target the query to
	Keyspace string `protobuf:"bytes,4,opt,name=keyspace" json:"keyspace,omitempty"`
	// key_ranges contains the list of key ranges affected by this query.
	// Will be used to find the shards to send the query to.
	KeyRanges []*topodata.KeyRange `protobuf:"bytes,5,rep,name=key_ranges,json=keyRanges" json:"key_ranges,omitempty"`
	// tablet_type is the type of tablets that this query is targeted to.
	TabletType topodata.TabletType `protobuf:"varint,6,opt,name=tablet_type,json=tabletType,enum=topodata.TabletType" json:"tablet_type,omitempty"`
	// not_in_transaction is deprecated and should not be used.
	NotInTransaction bool `protobuf:"varint,7,opt,name=not_in_transaction,json=notInTransaction" json:"not_in_transaction,omitempty"`
}

ExecuteKeyRangesRequest is the payload to ExecuteKeyRanges.

func (*ExecuteKeyRangesRequest) Descriptor 

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

func (*ExecuteKeyRangesRequest) GetCallerId 

func (m *ExecuteKeyRangesRequest) GetCallerId() *vtrpc.CallerID

func (*ExecuteKeyRangesRequest) GetKeyRanges 

func (m *ExecuteKeyRangesRequest) GetKeyRanges() []*topodata.KeyRange

func (*ExecuteKeyRangesRequest) GetQuery 

func (m *ExecuteKeyRangesRequest) GetQuery() *query.BoundQuery

func (*ExecuteKeyRangesRequest) GetSession 

func (m *ExecuteKeyRangesRequest) GetSession() *Session

func (*ExecuteKeyRangesRequest) ProtoMessage 

func (*ExecuteKeyRangesRequest) ProtoMessage()

func (*ExecuteKeyRangesRequest) Reset 

func (m *ExecuteKeyRangesRequest) Reset()

func (*ExecuteKeyRangesRequest) String 

func (m *ExecuteKeyRangesRequest) String() string

type ExecuteKeyRangesResponse 

type ExecuteKeyRangesResponse struct {
	// error contains an application level error if necessary. Note the
	// session may have changed, even when an error is returned (for
	// instance if a database integrity error happened).
	Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	// session is the updated session information (only returned inside a transaction).
	Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"`
	// result contains the query result, only set if error is unset.
	Result *query.QueryResult `protobuf:"bytes,3,opt,name=result" json:"result,omitempty"`
}

ExecuteKeyRangesResponse is the returned value from ExecuteKeyRanges.

func (*ExecuteKeyRangesResponse) Descriptor 

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

func (*ExecuteKeyRangesResponse) GetError 

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

func (*ExecuteKeyRangesResponse) GetResult 

func (m *ExecuteKeyRangesResponse) GetResult() *query.QueryResult

func (*ExecuteKeyRangesResponse) GetSession 

func (m *ExecuteKeyRangesResponse) GetSession() *Session

func (*ExecuteKeyRangesResponse) ProtoMessage 

func (*ExecuteKeyRangesResponse) ProtoMessage()

func (*ExecuteKeyRangesResponse) Reset 

func (m *ExecuteKeyRangesResponse) Reset()

func (*ExecuteKeyRangesResponse) String 

func (m *ExecuteKeyRangesResponse) String() string

type ExecuteKeyspaceIdsRequest 

type ExecuteKeyspaceIdsRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId" json:"caller_id,omitempty"`
	// session carries the current transaction data. It is returned by Begin.
	// Do not fill it in if outside of a transaction.
	Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"`
	// query is the query and bind variables to execute.
	Query *query.BoundQuery `protobuf:"bytes,3,opt,name=query" json:"query,omitempty"`
	// keyspace to target the query to.
	Keyspace string `protobuf:"bytes,4,opt,name=keyspace" json:"keyspace,omitempty"`
	// keyspace_ids contains the list of keyspace_ids affected by this query.
	// Will be used to find the shards to send the query to.
	KeyspaceIds [][]byte `protobuf:"bytes,5,rep,name=keyspace_ids,json=keyspaceIds,proto3" json:"keyspace_ids,omitempty"`
	// tablet_type is the type of tablets that this query is targeted to.
	TabletType topodata.TabletType `protobuf:"varint,6,opt,name=tablet_type,json=tabletType,enum=topodata.TabletType" json:"tablet_type,omitempty"`
	// not_in_transaction is deprecated and should not be used.
	NotInTransaction bool `protobuf:"varint,7,opt,name=not_in_transaction,json=notInTransaction" json:"not_in_transaction,omitempty"`
}

ExecuteKeyspaceIdsRequest is the payload to ExecuteKeyspaceIds.

func (*ExecuteKeyspaceIdsRequest) Descriptor 

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

func (*ExecuteKeyspaceIdsRequest) GetCallerId 

func (m *ExecuteKeyspaceIdsRequest) GetCallerId() *vtrpc.CallerID

func (*ExecuteKeyspaceIdsRequest) GetQuery 

func (m *ExecuteKeyspaceIdsRequest) GetQuery() *query.BoundQuery

func (*ExecuteKeyspaceIdsRequest) GetSession 

func (m *ExecuteKeyspaceIdsRequest) GetSession() *Session

func (*ExecuteKeyspaceIdsRequest) ProtoMessage 

func (*ExecuteKeyspaceIdsRequest) ProtoMessage()

func (*ExecuteKeyspaceIdsRequest) Reset 

func (m *ExecuteKeyspaceIdsRequest) Reset()

func (*ExecuteKeyspaceIdsRequest) String 

func (m *ExecuteKeyspaceIdsRequest) String() string

type ExecuteKeyspaceIdsResponse 

type ExecuteKeyspaceIdsResponse struct {
	// error contains an application level error if necessary. Note the
	// session may have changed, even when an error is returned (for
	// instance if a database integrity error happened).
	Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	// session is the updated session information (only returned inside a transaction).
	Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"`
	// result contains the query result, only set if error is unset.
	Result *query.QueryResult `protobuf:"bytes,3,opt,name=result" json:"result,omitempty"`
}

ExecuteKeyspaceIdsResponse is the returned value from ExecuteKeyspaceIds.

func (*ExecuteKeyspaceIdsResponse) Descriptor 

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

func (*ExecuteKeyspaceIdsResponse) GetError 

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

func (*ExecuteKeyspaceIdsResponse) GetResult 

func (m *ExecuteKeyspaceIdsResponse) GetResult() *query.QueryResult

func (*ExecuteKeyspaceIdsResponse) GetSession 

func (m *ExecuteKeyspaceIdsResponse) GetSession() *Session

func (*ExecuteKeyspaceIdsResponse) ProtoMessage 

func (*ExecuteKeyspaceIdsResponse) ProtoMessage()

func (*ExecuteKeyspaceIdsResponse) Reset 

func (m *ExecuteKeyspaceIdsResponse) Reset()

func (*ExecuteKeyspaceIdsResponse) String 

func (m *ExecuteKeyspaceIdsResponse) String() string

type ExecuteRequest 

type ExecuteRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId" json:"caller_id,omitempty"`
	// session carries the current transaction data. It is returned by Begin.
	// Do not fill it in if outside of a transaction.
	Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"`
	// query is the query and bind variables to execute.
	Query *query.BoundQuery `protobuf:"bytes,3,opt,name=query" json:"query,omitempty"`
	// tablet_type is the type of tablets that this query is targeted to.
	TabletType topodata.TabletType `protobuf:"varint,4,opt,name=tablet_type,json=tabletType,enum=topodata.TabletType" json:"tablet_type,omitempty"`
	// not_in_transaction is deprecated and should not be used.
	NotInTransaction bool `protobuf:"varint,5,opt,name=not_in_transaction,json=notInTransaction" json:"not_in_transaction,omitempty"`
}

ExecuteRequest is the payload to Execute.

func (*ExecuteRequest) Descriptor 

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

func (*ExecuteRequest) GetCallerId 

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

func (*ExecuteRequest) GetQuery 

func (m *ExecuteRequest) GetQuery() *query.BoundQuery

func (*ExecuteRequest) GetSession 

func (m *ExecuteRequest) GetSession() *Session

func (*ExecuteRequest) ProtoMessage 

func (*ExecuteRequest) ProtoMessage()

func (*ExecuteRequest) Reset 

func (m *ExecuteRequest) Reset()

func (*ExecuteRequest) String 

func (m *ExecuteRequest) String() string

type ExecuteResponse 

type ExecuteResponse struct {
	// error contains an application level error if necessary. Note the
	// session may have changed, even when an error is returned (for
	// instance if a database integrity error happened).
	Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	// session is the updated session information (only returned inside a transaction).
	Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"`
	// result contains the query result, only set if error is unset.
	Result *query.QueryResult `protobuf:"bytes,3,opt,name=result" json:"result,omitempty"`
}

ExecuteResponse is the returned value from Execute.

func (*ExecuteResponse) Descriptor 

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

func (*ExecuteResponse) GetError 

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

func (*ExecuteResponse) GetResult 

func (m *ExecuteResponse) GetResult() *query.QueryResult

func (*ExecuteResponse) GetSession 

func (m *ExecuteResponse) GetSession() *Session

func (*ExecuteResponse) ProtoMessage 

func (*ExecuteResponse) ProtoMessage()

func (*ExecuteResponse) Reset 

func (m *ExecuteResponse) Reset()

func (*ExecuteResponse) String 

func (m *ExecuteResponse) String() string

type ExecuteShardsRequest 

type ExecuteShardsRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId" json:"caller_id,omitempty"`
	// session carries the current transaction data. It is returned by Begin.
	// Do not fill it in if outside of a transaction.
	Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"`
	// query is the query and bind variables to execute.
	Query *query.BoundQuery `protobuf:"bytes,3,opt,name=query" json:"query,omitempty"`
	// keyspace to target the query to.
	Keyspace string `protobuf:"bytes,4,opt,name=keyspace" json:"keyspace,omitempty"`
	// shards to target the query to. A DML can only target one shard.
	Shards []string `protobuf:"bytes,5,rep,name=shards" json:"shards,omitempty"`
	// tablet_type is the type of tablets that this query is targeted to.
	TabletType topodata.TabletType `protobuf:"varint,6,opt,name=tablet_type,json=tabletType,enum=topodata.TabletType" json:"tablet_type,omitempty"`
	// not_in_transaction is deprecated and should not be used.
	NotInTransaction bool `protobuf:"varint,7,opt,name=not_in_transaction,json=notInTransaction" json:"not_in_transaction,omitempty"`
}

ExecuteShardsRequest is the payload to ExecuteShards.

func (*ExecuteShardsRequest) Descriptor 

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

func (*ExecuteShardsRequest) GetCallerId 

func (m *ExecuteShardsRequest) GetCallerId() *vtrpc.CallerID

func (*ExecuteShardsRequest) GetQuery 

func (m *ExecuteShardsRequest) GetQuery() *query.BoundQuery

func (*ExecuteShardsRequest) GetSession 

func (m *ExecuteShardsRequest) GetSession() *Session

func (*ExecuteShardsRequest) ProtoMessage 

func (*ExecuteShardsRequest) ProtoMessage()

func (*ExecuteShardsRequest) Reset 

func (m *ExecuteShardsRequest) Reset()

func (*ExecuteShardsRequest) String 

func (m *ExecuteShardsRequest) String() string

type ExecuteShardsResponse 

type ExecuteShardsResponse struct {
	// error contains an application level error if necessary. Note the
	// session may have changed, even when an error is returned (for
	// instance if a database integrity error happened).
	Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	// session is the updated session information (only returned inside a transaction).
	Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"`
	// result contains the query result, only set if error is unset.
	Result *query.QueryResult `protobuf:"bytes,3,opt,name=result" json:"result,omitempty"`
}

ExecuteShardsResponse is the returned value from ExecuteShards.

func (*ExecuteShardsResponse) Descriptor 

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

func (*ExecuteShardsResponse) GetError 

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

func (*ExecuteShardsResponse) GetResult 

func (m *ExecuteShardsResponse) GetResult() *query.QueryResult

func (*ExecuteShardsResponse) GetSession 

func (m *ExecuteShardsResponse) GetSession() *Session

func (*ExecuteShardsResponse) ProtoMessage 

func (*ExecuteShardsResponse) ProtoMessage()

func (*ExecuteShardsResponse) Reset 

func (m *ExecuteShardsResponse) Reset()

func (*ExecuteShardsResponse) String 

func (m *ExecuteShardsResponse) String() string

type GetSrvKeyspaceRequest 

type GetSrvKeyspaceRequest struct {
	// keyspace name to fetch.
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace" json:"keyspace,omitempty"`
}

GetSrvKeyspaceRequest is the payload to GetSrvKeyspace.

func (*GetSrvKeyspaceRequest) Descriptor 

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

func (*GetSrvKeyspaceRequest) ProtoMessage 

func (*GetSrvKeyspaceRequest) ProtoMessage()

func (*GetSrvKeyspaceRequest) Reset 

func (m *GetSrvKeyspaceRequest) Reset()

func (*GetSrvKeyspaceRequest) String 

func (m *GetSrvKeyspaceRequest) String() string

type GetSrvKeyspaceResponse 

type GetSrvKeyspaceResponse struct {
	// srv_keyspace is the topology object for the SrvKeyspace.
	SrvKeyspace *topodata.SrvKeyspace `protobuf:"bytes,1,opt,name=srv_keyspace,json=srvKeyspace" json:"srv_keyspace,omitempty"`
}

GetSrvKeyspaceResponse is the returned value from GetSrvKeyspace.

func (*GetSrvKeyspaceResponse) Descriptor 

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

func (*GetSrvKeyspaceResponse) GetSrvKeyspace 

func (m *GetSrvKeyspaceResponse) GetSrvKeyspace() *topodata.SrvKeyspace

func (*GetSrvKeyspaceResponse) ProtoMessage 

func (*GetSrvKeyspaceResponse) ProtoMessage()

func (*GetSrvKeyspaceResponse) Reset 

func (m *GetSrvKeyspaceResponse) Reset()

func (*GetSrvKeyspaceResponse) String 

func (m *GetSrvKeyspaceResponse) String() string

type RollbackRequest 

type RollbackRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId" json:"caller_id,omitempty"`
	// session carries the current transaction data to rollback.
	Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"`
}

RollbackRequest is the payload to Rollback.

func (*RollbackRequest) Descriptor 

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

func (*RollbackRequest) GetCallerId 

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

func (*RollbackRequest) GetSession 

func (m *RollbackRequest) GetSession() *Session

func (*RollbackRequest) ProtoMessage 

func (*RollbackRequest) ProtoMessage()

func (*RollbackRequest) Reset 

func (m *RollbackRequest) Reset()

func (*RollbackRequest) String 

func (m *RollbackRequest) String() string

type RollbackResponse 

type RollbackResponse struct {
}

RollbackResponse is the returned value from Rollback.

func (*RollbackResponse) Descriptor 

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

func (*RollbackResponse) ProtoMessage 

func (*RollbackResponse) ProtoMessage()

func (*RollbackResponse) Reset 

func (m *RollbackResponse) Reset()

func (*RollbackResponse) String 

func (m *RollbackResponse) String() string

type Session 

type Session struct {
	InTransaction bool                    `protobuf:"varint,1,opt,name=in_transaction,json=inTransaction" json:"in_transaction,omitempty"`
	ShardSessions []*Session_ShardSession `protobuf:"bytes,2,rep,name=shard_sessions,json=shardSessions" json:"shard_sessions,omitempty"`
}

Session objects are session cookies and are invalidated on use. Query results will contain updated session values. Their content should be opaque to the user.

func (*Session) Descriptor 

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

func (*Session) GetShardSessions 

func (m *Session) GetShardSessions() []*Session_ShardSession

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) Reset 

func (m *Session) Reset()

func (*Session) String 

func (m *Session) String() string

type Session_ShardSession 

type Session_ShardSession struct {
	Target        *query.Target `protobuf:"bytes,1,opt,name=target" json:"target,omitempty"`
	TransactionId int64         `protobuf:"varint,2,opt,name=transaction_id,json=transactionId" json:"transaction_id,omitempty"`
}

func (*Session_ShardSession) Descriptor 

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

func (*Session_ShardSession) GetTarget 

func (m *Session_ShardSession) GetTarget() *query.Target

func (*Session_ShardSession) ProtoMessage 

func (*Session_ShardSession) ProtoMessage()

func (*Session_ShardSession) Reset 

func (m *Session_ShardSession) Reset()

func (*Session_ShardSession) String 

func (m *Session_ShardSession) String() string

type SplitQueryRequest 

type SplitQueryRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId" json:"caller_id,omitempty"`
	// keyspace to target the query to.
	Keyspace string `protobuf:"bytes,2,opt,name=keyspace" json:"keyspace,omitempty"`
	// query is the query and bind variables to produce splits for.
	Query *query.BoundQuery `protobuf:"bytes,3,opt,name=query" json:"query,omitempty"`
	// split_column is an optional hint on the column to use to split the query.
	SplitColumn string `protobuf:"bytes,4,opt,name=split_column,json=splitColumn" json:"split_column,omitempty"`
	// split_count describes how many splits we want for this query.
	SplitCount int64 `protobuf:"varint,5,opt,name=split_count,json=splitCount" json:"split_count,omitempty"`
}

SplitQueryRequest is the payload to SplitQuery.

func (*SplitQueryRequest) Descriptor 

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

func (*SplitQueryRequest) GetCallerId 

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

func (*SplitQueryRequest) GetQuery 

func (m *SplitQueryRequest) GetQuery() *query.BoundQuery

func (*SplitQueryRequest) ProtoMessage 

func (*SplitQueryRequest) ProtoMessage()

func (*SplitQueryRequest) Reset 

func (m *SplitQueryRequest) Reset()

func (*SplitQueryRequest) String 

func (m *SplitQueryRequest) String() string

type SplitQueryResponse 

type SplitQueryResponse struct {
	// splits contains the queries to run to fetch the entire data set.
	Splits []*SplitQueryResponse_Part `protobuf:"bytes,1,rep,name=splits" json:"splits,omitempty"`
}

SplitQueryResponse is the returned value from SplitQuery.

func (*SplitQueryResponse) Descriptor 

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

func (*SplitQueryResponse) GetSplits 

func (m *SplitQueryResponse) GetSplits() []*SplitQueryResponse_Part

func (*SplitQueryResponse) ProtoMessage 

func (*SplitQueryResponse) ProtoMessage()

func (*SplitQueryResponse) Reset 

func (m *SplitQueryResponse) Reset()

func (*SplitQueryResponse) String 

func (m *SplitQueryResponse) String() string

type SplitQueryResponse_KeyRangePart 

type SplitQueryResponse_KeyRangePart struct {
	// keyspace to target the query to.
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace" json:"keyspace,omitempty"`
	// key ranges to target the query to.
	KeyRanges []*topodata.KeyRange `protobuf:"bytes,2,rep,name=key_ranges,json=keyRanges" json:"key_ranges,omitempty"`
}

func (*SplitQueryResponse_KeyRangePart) Descriptor 

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

func (*SplitQueryResponse_KeyRangePart) GetKeyRanges 

func (m *SplitQueryResponse_KeyRangePart) GetKeyRanges() []*topodata.KeyRange

func (*SplitQueryResponse_KeyRangePart) ProtoMessage 

func (*SplitQueryResponse_KeyRangePart) ProtoMessage()

func (*SplitQueryResponse_KeyRangePart) Reset 

func (m *SplitQueryResponse_KeyRangePart) Reset()

func (*SplitQueryResponse_KeyRangePart) String 

func (m *SplitQueryResponse_KeyRangePart) String() string

type SplitQueryResponse_Part 

type SplitQueryResponse_Part struct {
	// query is the query and bind variables to execute.
	Query *query.BoundQuery `protobuf:"bytes,1,opt,name=query" json:"query,omitempty"`
	// key_range_part is set if the query should be executed by ExecuteKeyRanges.
	KeyRangePart *SplitQueryResponse_KeyRangePart `protobuf:"bytes,2,opt,name=key_range_part,json=keyRangePart" json:"key_range_part,omitempty"`
	// shard_part is set if the query should be executed by ExecuteShards.
	ShardPart *SplitQueryResponse_ShardPart `protobuf:"bytes,3,opt,name=shard_part,json=shardPart" json:"shard_part,omitempty"`
	// size is the approximate number of rows this query will return.
	Size int64 `protobuf:"varint,4,opt,name=size" json:"size,omitempty"`
}

func (*SplitQueryResponse_Part) Descriptor 

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

func (*SplitQueryResponse_Part) GetKeyRangePart 

func (m *SplitQueryResponse_Part) GetKeyRangePart() *SplitQueryResponse_KeyRangePart

func (*SplitQueryResponse_Part) GetQuery 

func (m *SplitQueryResponse_Part) GetQuery() *query.BoundQuery

func (*SplitQueryResponse_Part) GetShardPart 

func (m *SplitQueryResponse_Part) GetShardPart() *SplitQueryResponse_ShardPart

func (*SplitQueryResponse_Part) ProtoMessage 

func (*SplitQueryResponse_Part) ProtoMessage()

func (*SplitQueryResponse_Part) Reset 

func (m *SplitQueryResponse_Part) Reset()

func (*SplitQueryResponse_Part) String 

func (m *SplitQueryResponse_Part) String() string

type SplitQueryResponse_ShardPart 

type SplitQueryResponse_ShardPart struct {
	// keyspace to target the query to.
	Keyspace string `protobuf:"bytes,1,opt,name=keyspace" json:"keyspace,omitempty"`
	// shards to target the query to.
	Shards []string `protobuf:"bytes,2,rep,name=shards" json:"shards,omitempty"`
}

func (*SplitQueryResponse_ShardPart) Descriptor 

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

func (*SplitQueryResponse_ShardPart) ProtoMessage 

func (*SplitQueryResponse_ShardPart) ProtoMessage()

func (*SplitQueryResponse_ShardPart) Reset 

func (m *SplitQueryResponse_ShardPart) Reset()

func (*SplitQueryResponse_ShardPart) String 

func (m *SplitQueryResponse_ShardPart) String() string

type StreamExecuteKeyRangesRequest 

type StreamExecuteKeyRangesRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId" json:"caller_id,omitempty"`
	// query is the query and bind variables to execute.
	Query *query.BoundQuery `protobuf:"bytes,2,opt,name=query" json:"query,omitempty"`
	// keyspace to target the query to.
	Keyspace string `protobuf:"bytes,3,opt,name=keyspace" json:"keyspace,omitempty"`
	// key_ranges contains the list of key ranges affected by this query.
	// Will be used to find the shards to send the query to.
	KeyRanges []*topodata.KeyRange `protobuf:"bytes,4,rep,name=key_ranges,json=keyRanges" json:"key_ranges,omitempty"`
	// tablet_type is the type of tablets that this query is targeted to.
	TabletType topodata.TabletType `protobuf:"varint,5,opt,name=tablet_type,json=tabletType,enum=topodata.TabletType" json:"tablet_type,omitempty"`
}

StreamExecuteKeyRangesRequest is the payload to StreamExecuteKeyRanges.

func (*StreamExecuteKeyRangesRequest) Descriptor 

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

func (*StreamExecuteKeyRangesRequest) GetCallerId 

func (m *StreamExecuteKeyRangesRequest) GetCallerId() *vtrpc.CallerID

func (*StreamExecuteKeyRangesRequest) GetKeyRanges 

func (m *StreamExecuteKeyRangesRequest) GetKeyRanges() []*topodata.KeyRange

func (*StreamExecuteKeyRangesRequest) GetQuery 

func (m *StreamExecuteKeyRangesRequest) GetQuery() *query.BoundQuery

func (*StreamExecuteKeyRangesRequest) ProtoMessage 

func (*StreamExecuteKeyRangesRequest) ProtoMessage()

func (*StreamExecuteKeyRangesRequest) Reset 

func (m *StreamExecuteKeyRangesRequest) Reset()

func (*StreamExecuteKeyRangesRequest) String 

func (m *StreamExecuteKeyRangesRequest) String() string

type StreamExecuteKeyRangesResponse 

type StreamExecuteKeyRangesResponse struct {
	// result contains the result data.
	// The first value contains only Fields information.
	// The next values contain the actual rows, a few values per result.
	Result *query.QueryResult `protobuf:"bytes,1,opt,name=result" json:"result,omitempty"`
}

StreamExecuteKeyRangesResponse is the returned value from StreamExecuteKeyRanges.

func (*StreamExecuteKeyRangesResponse) Descriptor 

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

func (*StreamExecuteKeyRangesResponse) GetResult 

func (m *StreamExecuteKeyRangesResponse) GetResult() *query.QueryResult

func (*StreamExecuteKeyRangesResponse) ProtoMessage 

func (*StreamExecuteKeyRangesResponse) ProtoMessage()

func (*StreamExecuteKeyRangesResponse) Reset 

func (m *StreamExecuteKeyRangesResponse) Reset()

func (*StreamExecuteKeyRangesResponse) String 

func (m *StreamExecuteKeyRangesResponse) String() string

type StreamExecuteKeyspaceIdsRequest 

type StreamExecuteKeyspaceIdsRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId" json:"caller_id,omitempty"`
	// query is the query and bind variables to execute.
	Query *query.BoundQuery `protobuf:"bytes,2,opt,name=query" json:"query,omitempty"`
	// keyspace to target the query to.
	Keyspace string `protobuf:"bytes,3,opt,name=keyspace" json:"keyspace,omitempty"`
	// keyspace_ids contains the list of keyspace_ids affected by this query.
	// Will be used to find the shards to send the query to.
	KeyspaceIds [][]byte `protobuf:"bytes,4,rep,name=keyspace_ids,json=keyspaceIds,proto3" json:"keyspace_ids,omitempty"`
	// tablet_type is the type of tablets that this query is targeted to.
	TabletType topodata.TabletType `protobuf:"varint,5,opt,name=tablet_type,json=tabletType,enum=topodata.TabletType" json:"tablet_type,omitempty"`
}

StreamExecuteKeyspaceIdsRequest is the payload to StreamExecuteKeyspaceIds.

func (*StreamExecuteKeyspaceIdsRequest) Descriptor 

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

func (*StreamExecuteKeyspaceIdsRequest) GetCallerId 

func (m *StreamExecuteKeyspaceIdsRequest) GetCallerId() *vtrpc.CallerID

func (*StreamExecuteKeyspaceIdsRequest) GetQuery 

func (m *StreamExecuteKeyspaceIdsRequest) GetQuery() *query.BoundQuery

func (*StreamExecuteKeyspaceIdsRequest) ProtoMessage 

func (*StreamExecuteKeyspaceIdsRequest) ProtoMessage()

func (*StreamExecuteKeyspaceIdsRequest) Reset 

func (m *StreamExecuteKeyspaceIdsRequest) Reset()

func (*StreamExecuteKeyspaceIdsRequest) String 

func (m *StreamExecuteKeyspaceIdsRequest) String() string

type StreamExecuteKeyspaceIdsResponse 

type StreamExecuteKeyspaceIdsResponse struct {
	// result contains the result data.
	// The first value contains only Fields information.
	// The next values contain the actual rows, a few values per result.
	Result *query.QueryResult `protobuf:"bytes,1,opt,name=result" json:"result,omitempty"`
}

StreamExecuteKeyspaceIdsResponse is the returned value from StreamExecuteKeyspaceIds.

func (*StreamExecuteKeyspaceIdsResponse) Descriptor 

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

func (*StreamExecuteKeyspaceIdsResponse) GetResult 

func (m *StreamExecuteKeyspaceIdsResponse) GetResult() *query.QueryResult

func (*StreamExecuteKeyspaceIdsResponse) ProtoMessage 

func (*StreamExecuteKeyspaceIdsResponse) ProtoMessage()

func (*StreamExecuteKeyspaceIdsResponse) Reset 

func (m *StreamExecuteKeyspaceIdsResponse) Reset()

func (*StreamExecuteKeyspaceIdsResponse) String 

func (m *StreamExecuteKeyspaceIdsResponse) String() string

type StreamExecuteRequest 

type StreamExecuteRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId" json:"caller_id,omitempty"`
	// query is the query and bind variables to execute.
	Query *query.BoundQuery `protobuf:"bytes,2,opt,name=query" json:"query,omitempty"`
	// tablet_type is the type of tablets that this query is targeted to.
	TabletType topodata.TabletType `protobuf:"varint,3,opt,name=tablet_type,json=tabletType,enum=topodata.TabletType" json:"tablet_type,omitempty"`
}

StreamExecuteRequest is the payload to StreamExecute.

func (*StreamExecuteRequest) Descriptor 

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

func (*StreamExecuteRequest) GetCallerId 

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

func (*StreamExecuteRequest) GetQuery 

func (m *StreamExecuteRequest) GetQuery() *query.BoundQuery

func (*StreamExecuteRequest) ProtoMessage 

func (*StreamExecuteRequest) ProtoMessage()

func (*StreamExecuteRequest) Reset 

func (m *StreamExecuteRequest) Reset()

func (*StreamExecuteRequest) String 

func (m *StreamExecuteRequest) String() string

type StreamExecuteResponse 

type StreamExecuteResponse struct {
	// result contains the result data.
	// The first value contains only Fields information.
	// The next values contain the actual rows, a few values per result.
	Result *query.QueryResult `protobuf:"bytes,1,opt,name=result" json:"result,omitempty"`
}

StreamExecuteResponse is the returned value from StreamExecute.

func (*StreamExecuteResponse) Descriptor 

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

func (*StreamExecuteResponse) GetResult 

func (m *StreamExecuteResponse) GetResult() *query.QueryResult

func (*StreamExecuteResponse) ProtoMessage 

func (*StreamExecuteResponse) ProtoMessage()

func (*StreamExecuteResponse) Reset 

func (m *StreamExecuteResponse) Reset()

func (*StreamExecuteResponse) String 

func (m *StreamExecuteResponse) String() string

type StreamExecuteShardsRequest 

type StreamExecuteShardsRequest struct {
	// caller_id identifies the caller. This is the effective caller ID,
	// set by the application to further identify the caller.
	CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id,json=callerId" json:"caller_id,omitempty"`
	// query is the query and bind variables to execute.
	Query *query.BoundQuery `protobuf:"bytes,2,opt,name=query" json:"query,omitempty"`
	// keyspace to target the query to.
	Keyspace string `protobuf:"bytes,3,opt,name=keyspace" json:"keyspace,omitempty"`
	// shards to target the query to.
	Shards []string `protobuf:"bytes,4,rep,name=shards" json:"shards,omitempty"`
	// tablet_type is the type of tablets that this query is targeted to.
	TabletType topodata.TabletType `protobuf:"varint,5,opt,name=tablet_type,json=tabletType,enum=topodata.TabletType" json:"tablet_type,omitempty"`
}

StreamExecuteShardsRequest is the payload to StreamExecuteShards.

func (*StreamExecuteShardsRequest) Descriptor 

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

func (*StreamExecuteShardsRequest) GetCallerId 

func (m *StreamExecuteShardsRequest) GetCallerId() *vtrpc.CallerID

func (*StreamExecuteShardsRequest) GetQuery 

func (m *StreamExecuteShardsRequest) GetQuery() *query.BoundQuery

func (*StreamExecuteShardsRequest) ProtoMessage 

func (*StreamExecuteShardsRequest) ProtoMessage()

func (*StreamExecuteShardsRequest) Reset 

func (m *StreamExecuteShardsRequest) Reset()

func (*StreamExecuteShardsRequest) String 

func (m *StreamExecuteShardsRequest) String() string

type StreamExecuteShardsResponse 

type StreamExecuteShardsResponse struct {
	// result contains the result data.
	// The first value contains only Fields information.
	// The next values contain the actual rows, a few values per result.
	Result *query.QueryResult `protobuf:"bytes,1,opt,name=result" json:"result,omitempty"`
}

StreamExecuteShardsResponse is the returned value from StreamExecuteShards.

func (*StreamExecuteShardsResponse) Descriptor 

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

func (*StreamExecuteShardsResponse) GetResult 

func (m *StreamExecuteShardsResponse) GetResult() *query.QueryResult

func (*StreamExecuteShardsResponse) ProtoMessage 

func (*StreamExecuteShardsResponse) ProtoMessage()

func (*StreamExecuteShardsResponse) Reset 

func (m *StreamExecuteShardsResponse) Reset()

func (*StreamExecuteShardsResponse) String 

func (m *StreamExecuteShardsResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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