vtgate

package
v2.0.0-alpha5+incompat... Latest Latest
Warning

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

 Go to latest Published: Oct 23, 2015 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

View Source 
var ExecuteEntityIdsRequest_EntityId_Type_name = map[int32]string{
	0: "TYPE_NULL",
	1: "TYPE_BYTES",
	2: "TYPE_INT",
	3: "TYPE_UINT",
	4: "TYPE_FLOAT",
}
View Source 
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 {
	Session *Session `protobuf:"bytes,1,opt,name=session" json:"session,omitempty"`
}

BeginResponse is the returned value from Begin

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 {
}

CommitResponse is the returned value from Commit

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 {
}

RollbackResponse is the returned value from Rollback

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

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:"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 {
	Result *query.QueryResult `protobuf:"bytes,1,opt,name=result" json:"result,omitempty"`
}

StreamExecuteKeyRangesResponse is the returned value from StreamExecuteKeyRanges

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 {
	Result *query.QueryResult `protobuf:"bytes,1,opt,name=result" json:"result,omitempty"`
}

StreamExecuteKeyspaceIdsResponse is the returned value from StreamExecuteKeyspaceIds

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 {
	Result *query.QueryResult `protobuf:"bytes,1,opt,name=result" json:"result,omitempty"`
}

StreamExecuteResponse is the returned value from StreamExecute

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 {
	Result *query.QueryResult `protobuf:"bytes,1,opt,name=result" json:"result,omitempty"`
}

StreamExecuteShardsResponse is the returned value from StreamExecuteShards

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.