vtgate

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

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

Go to latest
Published: Aug 28, 2015 License: BSD-3-Clause Imports: 4 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 {
	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 (*ExecuteBatchKeyspaceIdsRequest) GetSession

func (m *ExecuteBatchKeyspaceIdsRequest) GetSession() *Session

func (*ExecuteBatchKeyspaceIdsRequest) ProtoMessage

func (*ExecuteBatchKeyspaceIdsRequest) ProtoMessage()

func (*ExecuteBatchKeyspaceIdsRequest) Reset

func (m *ExecuteBatchKeyspaceIdsRequest) Reset()

func (*ExecuteBatchKeyspaceIdsRequest) 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 (*ExecuteBatchKeyspaceIdsResponse) GetResults

func (*ExecuteBatchKeyspaceIdsResponse) GetSession

func (m *ExecuteBatchKeyspaceIdsResponse) GetSession() *Session

func (*ExecuteBatchKeyspaceIdsResponse) ProtoMessage

func (*ExecuteBatchKeyspaceIdsResponse) ProtoMessage()

func (*ExecuteBatchKeyspaceIdsResponse) Reset

func (*ExecuteBatchKeyspaceIdsResponse) 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 (*ExecuteEntityIdsRequest_EntityId) 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

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

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 (*SplitQueryResponse_KeyRangePart) 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 (*SplitQueryResponse_Part) GetQuery

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

func (*SplitQueryResponse_Part) GetShardPart

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

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 (*StreamExecuteKeyRangesRequest) ProtoMessage

func (*StreamExecuteKeyRangesRequest) ProtoMessage()

func (*StreamExecuteKeyRangesRequest) Reset

func (m *StreamExecuteKeyRangesRequest) Reset()

func (*StreamExecuteKeyRangesRequest) 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 (*StreamExecuteKeyRangesResponse) GetResult

func (*StreamExecuteKeyRangesResponse) ProtoMessage

func (*StreamExecuteKeyRangesResponse) ProtoMessage()

func (*StreamExecuteKeyRangesResponse) Reset

func (m *StreamExecuteKeyRangesResponse) Reset()

func (*StreamExecuteKeyRangesResponse) 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 (*StreamExecuteKeyspaceIdsRequest) GetQuery

func (*StreamExecuteKeyspaceIdsRequest) ProtoMessage

func (*StreamExecuteKeyspaceIdsRequest) ProtoMessage()

func (*StreamExecuteKeyspaceIdsRequest) Reset

func (*StreamExecuteKeyspaceIdsRequest) 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 (*StreamExecuteKeyspaceIdsResponse) GetResult

func (*StreamExecuteKeyspaceIdsResponse) ProtoMessage

func (*StreamExecuteKeyspaceIdsResponse) ProtoMessage()

func (*StreamExecuteKeyspaceIdsResponse) Reset

func (*StreamExecuteKeyspaceIdsResponse) 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 (*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 (*StreamExecuteShardsResponse) GetResult

func (*StreamExecuteShardsResponse) ProtoMessage

func (*StreamExecuteShardsResponse) ProtoMessage()

func (*StreamExecuteShardsResponse) Reset

func (m *StreamExecuteShardsResponse) Reset()

func (*StreamExecuteShardsResponse) String

func (m *StreamExecuteShardsResponse) String() string

Jump to

Keyboard shortcuts

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