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 ¶
- Variables
- type BeginRequest
- type BeginResponse
- type BoundKeyspaceIdQuery
- type BoundShardQuery
- type CommitRequest
- type CommitResponse
- type ExecuteBatchKeyspaceIdsRequest
- func (m *ExecuteBatchKeyspaceIdsRequest) GetCallerId() *vtrpc.CallerID
- func (m *ExecuteBatchKeyspaceIdsRequest) GetQueries() []*BoundKeyspaceIdQuery
- func (m *ExecuteBatchKeyspaceIdsRequest) GetSession() *Session
- func (*ExecuteBatchKeyspaceIdsRequest) ProtoMessage()
- func (m *ExecuteBatchKeyspaceIdsRequest) Reset()
- func (m *ExecuteBatchKeyspaceIdsRequest) String() string
- type ExecuteBatchKeyspaceIdsResponse
- func (m *ExecuteBatchKeyspaceIdsResponse) GetError() *vtrpc.RPCError
- func (m *ExecuteBatchKeyspaceIdsResponse) GetResults() []*query.QueryResult
- func (m *ExecuteBatchKeyspaceIdsResponse) GetSession() *Session
- func (*ExecuteBatchKeyspaceIdsResponse) ProtoMessage()
- func (m *ExecuteBatchKeyspaceIdsResponse) Reset()
- func (m *ExecuteBatchKeyspaceIdsResponse) String() string
- type ExecuteBatchShardsRequest
- func (m *ExecuteBatchShardsRequest) GetCallerId() *vtrpc.CallerID
- func (m *ExecuteBatchShardsRequest) GetQueries() []*BoundShardQuery
- func (m *ExecuteBatchShardsRequest) GetSession() *Session
- func (*ExecuteBatchShardsRequest) ProtoMessage()
- func (m *ExecuteBatchShardsRequest) Reset()
- func (m *ExecuteBatchShardsRequest) String() string
- type ExecuteBatchShardsResponse
- func (m *ExecuteBatchShardsResponse) GetError() *vtrpc.RPCError
- func (m *ExecuteBatchShardsResponse) GetResults() []*query.QueryResult
- func (m *ExecuteBatchShardsResponse) GetSession() *Session
- func (*ExecuteBatchShardsResponse) ProtoMessage()
- func (m *ExecuteBatchShardsResponse) Reset()
- func (m *ExecuteBatchShardsResponse) String() string
- type ExecuteEntityIdsRequest
- func (m *ExecuteEntityIdsRequest) GetCallerId() *vtrpc.CallerID
- func (m *ExecuteEntityIdsRequest) GetEntityKeyspaceIds() []*ExecuteEntityIdsRequest_EntityId
- func (m *ExecuteEntityIdsRequest) GetQuery() *query.BoundQuery
- func (m *ExecuteEntityIdsRequest) GetSession() *Session
- func (*ExecuteEntityIdsRequest) ProtoMessage()
- func (m *ExecuteEntityIdsRequest) Reset()
- func (m *ExecuteEntityIdsRequest) String() string
- type ExecuteEntityIdsRequest_EntityId
- type ExecuteEntityIdsRequest_EntityId_Type
- type ExecuteEntityIdsResponse
- func (m *ExecuteEntityIdsResponse) GetError() *vtrpc.RPCError
- func (m *ExecuteEntityIdsResponse) GetResult() *query.QueryResult
- func (m *ExecuteEntityIdsResponse) GetSession() *Session
- func (*ExecuteEntityIdsResponse) ProtoMessage()
- func (m *ExecuteEntityIdsResponse) Reset()
- func (m *ExecuteEntityIdsResponse) String() string
- type ExecuteKeyRangesRequest
- func (m *ExecuteKeyRangesRequest) GetCallerId() *vtrpc.CallerID
- func (m *ExecuteKeyRangesRequest) GetKeyRanges() []*topodata.KeyRange
- func (m *ExecuteKeyRangesRequest) GetQuery() *query.BoundQuery
- func (m *ExecuteKeyRangesRequest) GetSession() *Session
- func (*ExecuteKeyRangesRequest) ProtoMessage()
- func (m *ExecuteKeyRangesRequest) Reset()
- func (m *ExecuteKeyRangesRequest) String() string
- type ExecuteKeyRangesResponse
- func (m *ExecuteKeyRangesResponse) GetError() *vtrpc.RPCError
- func (m *ExecuteKeyRangesResponse) GetResult() *query.QueryResult
- func (m *ExecuteKeyRangesResponse) GetSession() *Session
- func (*ExecuteKeyRangesResponse) ProtoMessage()
- func (m *ExecuteKeyRangesResponse) Reset()
- func (m *ExecuteKeyRangesResponse) String() string
- type ExecuteKeyspaceIdsRequest
- func (m *ExecuteKeyspaceIdsRequest) GetCallerId() *vtrpc.CallerID
- func (m *ExecuteKeyspaceIdsRequest) GetQuery() *query.BoundQuery
- func (m *ExecuteKeyspaceIdsRequest) GetSession() *Session
- func (*ExecuteKeyspaceIdsRequest) ProtoMessage()
- func (m *ExecuteKeyspaceIdsRequest) Reset()
- func (m *ExecuteKeyspaceIdsRequest) String() string
- type ExecuteKeyspaceIdsResponse
- func (m *ExecuteKeyspaceIdsResponse) GetError() *vtrpc.RPCError
- func (m *ExecuteKeyspaceIdsResponse) GetResult() *query.QueryResult
- func (m *ExecuteKeyspaceIdsResponse) GetSession() *Session
- func (*ExecuteKeyspaceIdsResponse) ProtoMessage()
- func (m *ExecuteKeyspaceIdsResponse) Reset()
- func (m *ExecuteKeyspaceIdsResponse) String() string
- type ExecuteRequest
- type ExecuteResponse
- type ExecuteShardsRequest
- func (m *ExecuteShardsRequest) GetCallerId() *vtrpc.CallerID
- func (m *ExecuteShardsRequest) GetQuery() *query.BoundQuery
- func (m *ExecuteShardsRequest) GetSession() *Session
- func (*ExecuteShardsRequest) ProtoMessage()
- func (m *ExecuteShardsRequest) Reset()
- func (m *ExecuteShardsRequest) String() string
- type ExecuteShardsResponse
- func (m *ExecuteShardsResponse) GetError() *vtrpc.RPCError
- func (m *ExecuteShardsResponse) GetResult() *query.QueryResult
- func (m *ExecuteShardsResponse) GetSession() *Session
- func (*ExecuteShardsResponse) ProtoMessage()
- func (m *ExecuteShardsResponse) Reset()
- func (m *ExecuteShardsResponse) String() string
- type GetSrvKeyspaceRequest
- type GetSrvKeyspaceResponse
- type RollbackRequest
- type RollbackResponse
- type Session
- type Session_ShardSession
- type SplitQueryRequest
- type SplitQueryResponse
- type SplitQueryResponse_KeyRangePart
- type SplitQueryResponse_Part
- func (m *SplitQueryResponse_Part) GetKeyRangePart() *SplitQueryResponse_KeyRangePart
- func (m *SplitQueryResponse_Part) GetQuery() *query.BoundQuery
- func (m *SplitQueryResponse_Part) GetShardPart() *SplitQueryResponse_ShardPart
- func (*SplitQueryResponse_Part) ProtoMessage()
- func (m *SplitQueryResponse_Part) Reset()
- func (m *SplitQueryResponse_Part) String() string
- type SplitQueryResponse_ShardPart
- type StreamExecuteKeyRangesRequest
- func (m *StreamExecuteKeyRangesRequest) GetCallerId() *vtrpc.CallerID
- func (m *StreamExecuteKeyRangesRequest) GetKeyRanges() []*topodata.KeyRange
- func (m *StreamExecuteKeyRangesRequest) GetQuery() *query.BoundQuery
- func (*StreamExecuteKeyRangesRequest) ProtoMessage()
- func (m *StreamExecuteKeyRangesRequest) Reset()
- func (m *StreamExecuteKeyRangesRequest) String() string
- type StreamExecuteKeyRangesResponse
- type StreamExecuteKeyspaceIdsRequest
- func (m *StreamExecuteKeyspaceIdsRequest) GetCallerId() *vtrpc.CallerID
- func (m *StreamExecuteKeyspaceIdsRequest) GetQuery() *query.BoundQuery
- func (*StreamExecuteKeyspaceIdsRequest) ProtoMessage()
- func (m *StreamExecuteKeyspaceIdsRequest) Reset()
- func (m *StreamExecuteKeyspaceIdsRequest) String() string
- type StreamExecuteKeyspaceIdsResponse
- func (m *StreamExecuteKeyspaceIdsResponse) GetError() *vtrpc.RPCError
- func (m *StreamExecuteKeyspaceIdsResponse) GetResult() *query.QueryResult
- func (*StreamExecuteKeyspaceIdsResponse) ProtoMessage()
- func (m *StreamExecuteKeyspaceIdsResponse) Reset()
- func (m *StreamExecuteKeyspaceIdsResponse) String() string
- type StreamExecuteRequest
- type StreamExecuteResponse
- type StreamExecuteShardsRequest
- type StreamExecuteShardsResponse
Constants ¶
This section is empty.
Variables ¶
var ExecuteEntityIdsRequest_EntityId_Type_name = map[int32]string{
0: "TYPE_NULL",
1: "TYPE_BYTES",
2: "TYPE_INT",
3: "TYPE_UINT",
4: "TYPE_FLOAT",
}
var ExecuteEntityIdsRequest_EntityId_Type_value = map[string]int32{
"TYPE_NULL": 0,
"TYPE_BYTES": 1,
"TYPE_INT": 2,
"TYPE_UINT": 3,
"TYPE_FLOAT": 4,
}
Functions ¶
This section is empty.
Types ¶
type BeginRequest ¶
type BeginRequest struct {
CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id" json:"caller_id,omitempty"`
}
BeginRequest is the payload to Begin
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 { Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"` }
BeginResponse is the returned value from Begin
func (*BeginResponse) GetError ¶
func (m *BeginResponse) GetError() *vtrpc.RPCError
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 *query.BoundQuery `protobuf:"bytes,1,opt,name=query" json:"query,omitempty"` Keyspace string `protobuf:"bytes,2,opt,name=keyspace" json:"keyspace,omitempty"` KeyspaceIds [][]byte `protobuf:"bytes,3,rep,name=keyspace_ids,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) 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 *query.BoundQuery `protobuf:"bytes,1,opt,name=query" json:"query,omitempty"` Keyspace string `protobuf:"bytes,2,opt,name=keyspace" json:"keyspace,omitempty"` 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) 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 { CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id" json:"caller_id,omitempty"` Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"` }
CommitRequest is the payload to Commit
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 {
Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}
CommitResponse is the returned value from Commit
func (*CommitResponse) GetError ¶
func (m *CommitResponse) GetError() *vtrpc.RPCError
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 { CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id" json:"caller_id,omitempty"` Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"` Queries []*BoundKeyspaceIdQuery `protobuf:"bytes,3,rep,name=queries" json:"queries,omitempty"` TabletType topodata.TabletType `protobuf:"varint,4,opt,name=tablet_type,enum=topodata.TabletType" json:"tablet_type,omitempty"` AsTransaction bool `protobuf:"varint,5,opt,name=as_transaction" json:"as_transaction,omitempty"` }
ExecuteBatchKeyspaceIdsRequest is the payload to ExecuteBatchKeyspaceId
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 *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"` Results []*query.QueryResult `protobuf:"bytes,3,rep,name=results" json:"results,omitempty"` }
ExecuteBatchKeyspaceIdsResponse is the returned value from ExecuteBatchKeyspaceId
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 { CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id" json:"caller_id,omitempty"` Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"` Queries []*BoundShardQuery `protobuf:"bytes,3,rep,name=queries" json:"queries,omitempty"` TabletType topodata.TabletType `protobuf:"varint,4,opt,name=tablet_type,enum=topodata.TabletType" json:"tablet_type,omitempty"` AsTransaction bool `protobuf:"varint,5,opt,name=as_transaction" json:"as_transaction,omitempty"` }
ExecuteBatchShardsRequest is the payload to ExecuteBatchShards
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 *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"` Results []*query.QueryResult `protobuf:"bytes,3,rep,name=results" json:"results,omitempty"` }
ExecuteBatchShardsResponse is the returned value from ExecuteBatchShards
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 { CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id" json:"caller_id,omitempty"` Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"` Query *query.BoundQuery `protobuf:"bytes,3,opt,name=query" json:"query,omitempty"` Keyspace string `protobuf:"bytes,4,opt,name=keyspace" json:"keyspace,omitempty"` EntityColumnName string `protobuf:"bytes,5,opt,name=entity_column_name" json:"entity_column_name,omitempty"` EntityKeyspaceIds []*ExecuteEntityIdsRequest_EntityId `protobuf:"bytes,6,rep,name=entity_keyspace_ids" json:"entity_keyspace_ids,omitempty"` TabletType topodata.TabletType `protobuf:"varint,7,opt,name=tablet_type,enum=topodata.TabletType" json:"tablet_type,omitempty"` NotInTransaction bool `protobuf:"varint,8,opt,name=not_in_transaction" json:"not_in_transaction,omitempty"` }
ExecuteEntityIdsRequest is the payload to ExecuteEntityIds
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 { XidType ExecuteEntityIdsRequest_EntityId_Type `protobuf:"varint,1,opt,name=xid_type,enum=vtgate.ExecuteEntityIdsRequest_EntityId_Type" json:"xid_type,omitempty"` XidBytes []byte `protobuf:"bytes,2,opt,name=xid_bytes,proto3" json:"xid_bytes,omitempty"` XidInt int64 `protobuf:"varint,3,opt,name=xid_int" json:"xid_int,omitempty"` XidUint uint64 `protobuf:"varint,4,opt,name=xid_uint" json:"xid_uint,omitempty"` XidFloat float64 `protobuf:"fixed64,5,opt,name=xid_float" json:"xid_float,omitempty"` KeyspaceId []byte `protobuf:"bytes,6,opt,name=keyspace_id,proto3" json:"keyspace_id,omitempty"` }
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 ExecuteEntityIdsRequest_EntityId_Type ¶
type ExecuteEntityIdsRequest_EntityId_Type int32
const ( ExecuteEntityIdsRequest_EntityId_TYPE_NULL ExecuteEntityIdsRequest_EntityId_Type = 0 ExecuteEntityIdsRequest_EntityId_TYPE_BYTES ExecuteEntityIdsRequest_EntityId_Type = 1 ExecuteEntityIdsRequest_EntityId_TYPE_INT ExecuteEntityIdsRequest_EntityId_Type = 2 ExecuteEntityIdsRequest_EntityId_TYPE_UINT ExecuteEntityIdsRequest_EntityId_Type = 3 ExecuteEntityIdsRequest_EntityId_TYPE_FLOAT ExecuteEntityIdsRequest_EntityId_Type = 4 )
func (ExecuteEntityIdsRequest_EntityId_Type) String ¶
func (x ExecuteEntityIdsRequest_EntityId_Type) String() string
type ExecuteEntityIdsResponse ¶
type ExecuteEntityIdsResponse struct { Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"` Result *query.QueryResult `protobuf:"bytes,3,opt,name=result" json:"result,omitempty"` }
ExecuteEntityIdsResponse is the returned value from ExecuteEntityIds
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 { CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id" json:"caller_id,omitempty"` Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"` Query *query.BoundQuery `protobuf:"bytes,3,opt,name=query" json:"query,omitempty"` Keyspace string `protobuf:"bytes,4,opt,name=keyspace" json:"keyspace,omitempty"` KeyRanges []*topodata.KeyRange `protobuf:"bytes,5,rep,name=key_ranges" json:"key_ranges,omitempty"` TabletType topodata.TabletType `protobuf:"varint,6,opt,name=tablet_type,enum=topodata.TabletType" json:"tablet_type,omitempty"` NotInTransaction bool `protobuf:"varint,7,opt,name=not_in_transaction" json:"not_in_transaction,omitempty"` }
ExecuteKeyRangesRequest is the payload to ExecuteKeyRanges
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 *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"` Result *query.QueryResult `protobuf:"bytes,3,opt,name=result" json:"result,omitempty"` }
ExecuteKeyRangesResponse is the returned value from ExecuteKeyRanges
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 { CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id" json:"caller_id,omitempty"` Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"` Query *query.BoundQuery `protobuf:"bytes,3,opt,name=query" json:"query,omitempty"` Keyspace string `protobuf:"bytes,4,opt,name=keyspace" json:"keyspace,omitempty"` KeyspaceIds [][]byte `protobuf:"bytes,5,rep,name=keyspace_ids,proto3" json:"keyspace_ids,omitempty"` TabletType topodata.TabletType `protobuf:"varint,6,opt,name=tablet_type,enum=topodata.TabletType" json:"tablet_type,omitempty"` NotInTransaction bool `protobuf:"varint,7,opt,name=not_in_transaction" json:"not_in_transaction,omitempty"` }
ExecuteKeyspaceIdsRequest is the payload to ExecuteKeyspaceIds
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 *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"` Result *query.QueryResult `protobuf:"bytes,3,opt,name=result" json:"result,omitempty"` }
ExecuteKeyspaceIdsResponse is the returned value from ExecuteKeyspaceIds
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 { CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id" json:"caller_id,omitempty"` Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"` Query *query.BoundQuery `protobuf:"bytes,3,opt,name=query" json:"query,omitempty"` TabletType topodata.TabletType `protobuf:"varint,4,opt,name=tablet_type,enum=topodata.TabletType" json:"tablet_type,omitempty"` NotInTransaction bool `protobuf:"varint,5,opt,name=not_in_transaction" json:"not_in_transaction,omitempty"` }
ExecuteRequest is the payload to Execute
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 *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"` Result *query.QueryResult `protobuf:"bytes,3,opt,name=result" json:"result,omitempty"` }
ExecuteResponse is the returned value from Execute
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 { CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id" json:"caller_id,omitempty"` Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"` Query *query.BoundQuery `protobuf:"bytes,3,opt,name=query" json:"query,omitempty"` Keyspace string `protobuf:"bytes,4,opt,name=keyspace" json:"keyspace,omitempty"` Shards []string `protobuf:"bytes,5,rep,name=shards" json:"shards,omitempty"` TabletType topodata.TabletType `protobuf:"varint,6,opt,name=tablet_type,enum=topodata.TabletType" json:"tablet_type,omitempty"` NotInTransaction bool `protobuf:"varint,7,opt,name=not_in_transaction" json:"not_in_transaction,omitempty"` }
ExecuteShardsRequest is the payload to ExecuteShards
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 *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"` Result *query.QueryResult `protobuf:"bytes,3,opt,name=result" json:"result,omitempty"` }
ExecuteShardsResponse is the returned value from ExecuteShards
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 string `protobuf:"bytes,1,opt,name=keyspace" json:"keyspace,omitempty"`
}
GetSrvKeyspaceRequest is the payload to GetSrvKeyspace
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 {
SrvKeyspace *topodata.SrvKeyspace `protobuf:"bytes,1,opt,name=srv_keyspace" json:"srv_keyspace,omitempty"`
}
GetSrvKeyspaceResponse is the returned value from GetSrvKeyspace
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 { CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id" json:"caller_id,omitempty"` Session *Session `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"` }
RollbackRequest is the payload to Rollback
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 {
Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}
RollbackResponse is the returned value from Rollback
func (*RollbackResponse) GetError ¶
func (m *RollbackResponse) GetError() *vtrpc.RPCError
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:"in_transaction,omitempty"` ShardSessions []*Session_ShardSession `protobuf:"bytes,2,rep,name=shard_sessions" 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) GetShardSessions ¶
func (m *Session) GetShardSessions() []*Session_ShardSession
func (*Session) ProtoMessage ¶
func (*Session) ProtoMessage()
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:"transaction_id,omitempty"` }
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 { CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id" json:"caller_id,omitempty"` Keyspace string `protobuf:"bytes,2,opt,name=keyspace" json:"keyspace,omitempty"` Query *query.BoundQuery `protobuf:"bytes,3,opt,name=query" json:"query,omitempty"` SplitColumn string `protobuf:"bytes,4,opt,name=split_column" json:"split_column,omitempty"` SplitCount int64 `protobuf:"varint,5,opt,name=split_count" json:"split_count,omitempty"` }
SplitQueryRequest is the payload to SplitQuery
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 []*SplitQueryResponse_Part `protobuf:"bytes,1,rep,name=splits" json:"splits,omitempty"`
}
SplitQueryResponse is the returned value from SplitQuery
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 string `protobuf:"bytes,1,opt,name=keyspace" json:"keyspace,omitempty"` KeyRanges []*topodata.KeyRange `protobuf:"bytes,2,rep,name=key_ranges" json:"key_ranges,omitempty"` }
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 *query.BoundQuery `protobuf:"bytes,1,opt,name=query" json:"query,omitempty"` KeyRangePart *SplitQueryResponse_KeyRangePart `protobuf:"bytes,2,opt,name=key_range_part" json:"key_range_part,omitempty"` ShardPart *SplitQueryResponse_ShardPart `protobuf:"bytes,3,opt,name=shard_part" json:"shard_part,omitempty"` Size int64 `protobuf:"varint,4,opt,name=size" json:"size,omitempty"` }
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 string `protobuf:"bytes,1,opt,name=keyspace" json:"keyspace,omitempty"` Shards []string `protobuf:"bytes,2,rep,name=shards" json:"shards,omitempty"` }
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 { CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id" json:"caller_id,omitempty"` Query *query.BoundQuery `protobuf:"bytes,2,opt,name=query" json:"query,omitempty"` Keyspace string `protobuf:"bytes,3,opt,name=keyspace" json:"keyspace,omitempty"` KeyRanges []*topodata.KeyRange `protobuf:"bytes,4,rep,name=key_ranges" json:"key_ranges,omitempty"` TabletType topodata.TabletType `protobuf:"varint,5,opt,name=tablet_type,enum=topodata.TabletType" json:"tablet_type,omitempty"` }
StreamExecuteKeyRangesRequest is the payload to StreamExecuteKeyRanges
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 { Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` Result *query.QueryResult `protobuf:"bytes,2,opt,name=result" json:"result,omitempty"` }
StreamExecuteKeyRangesResponse is the returned value from StreamExecuteKeyRanges
func (*StreamExecuteKeyRangesResponse) GetError ¶
func (m *StreamExecuteKeyRangesResponse) GetError() *vtrpc.RPCError
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 { CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id" json:"caller_id,omitempty"` Query *query.BoundQuery `protobuf:"bytes,2,opt,name=query" json:"query,omitempty"` Keyspace string `protobuf:"bytes,3,opt,name=keyspace" json:"keyspace,omitempty"` KeyspaceIds [][]byte `protobuf:"bytes,4,rep,name=keyspace_ids,proto3" json:"keyspace_ids,omitempty"` TabletType topodata.TabletType `protobuf:"varint,5,opt,name=tablet_type,enum=topodata.TabletType" json:"tablet_type,omitempty"` }
StreamExecuteKeyspaceIdsRequest is the payload to StreamExecuteKeyspaceIds
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 { Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` Result *query.QueryResult `protobuf:"bytes,2,opt,name=result" json:"result,omitempty"` }
StreamExecuteKeyspaceIdsResponse is the returned value from StreamExecuteKeyspaceIds
func (*StreamExecuteKeyspaceIdsResponse) GetError ¶
func (m *StreamExecuteKeyspaceIdsResponse) GetError() *vtrpc.RPCError
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 { CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id" json:"caller_id,omitempty"` Query *query.BoundQuery `protobuf:"bytes,2,opt,name=query" json:"query,omitempty"` TabletType topodata.TabletType `protobuf:"varint,3,opt,name=tablet_type,enum=topodata.TabletType" json:"tablet_type,omitempty"` }
StreamExecuteRequest is the payload to StreamExecute
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 { Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` Result *query.QueryResult `protobuf:"bytes,2,opt,name=result" json:"result,omitempty"` }
StreamExecuteResponse is the returned value from StreamExecute
func (*StreamExecuteResponse) GetError ¶
func (m *StreamExecuteResponse) GetError() *vtrpc.RPCError
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 { CallerId *vtrpc.CallerID `protobuf:"bytes,1,opt,name=caller_id" json:"caller_id,omitempty"` Query *query.BoundQuery `protobuf:"bytes,2,opt,name=query" json:"query,omitempty"` Keyspace string `protobuf:"bytes,3,opt,name=keyspace" json:"keyspace,omitempty"` Shards []string `protobuf:"bytes,4,rep,name=shards" json:"shards,omitempty"` TabletType topodata.TabletType `protobuf:"varint,5,opt,name=tablet_type,enum=topodata.TabletType" json:"tablet_type,omitempty"` }
StreamExecuteShardsRequest is the payload to StreamExecuteShards
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 { Error *vtrpc.RPCError `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"` Result *query.QueryResult `protobuf:"bytes,2,opt,name=result" json:"result,omitempty"` }
StreamExecuteShardsResponse is the returned value from StreamExecuteShards
func (*StreamExecuteShardsResponse) GetError ¶
func (m *StreamExecuteShardsResponse) GetError() *vtrpc.RPCError
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