proto

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

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

Go to latest
Published: Aug 25, 2015 License: BSD-3-Clause Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BoundQueryToProto3

func BoundQueryToProto3(sql string, bindVars map[string]interface{}) *pb.BoundQuery

BoundQueryToProto3 converts internal types to proto3 BoundQuery

func Proto3ToBindVariables

func Proto3ToBindVariables(bv map[string]*pb.BindVariable) map[string]interface{}

Proto3ToBindVariables converts a proto.BinVariable map to internal data structure

func QueryResultListToProto3

func QueryResultListToProto3(results []mproto.QueryResult) []*pb.QueryResult

QueryResultListToProto3 changes the internal array of QueryResult to the proto3 version

func QuerySplitsToProto3

func QuerySplitsToProto3(queries []QuerySplit) []*pb.QuerySplit

QuerySplitsToProto3 converts a native QuerySplit array to the proto3 version

func TargetToProto3

func TargetToProto3(target *Target) *pb.Target

TargetToProto3 transform the bson RPC target to proto3

Types

type BeginRequest

type BeginRequest struct {
	EffectiveCallerID *CallerID
	ImmediateCallerID *VTGateCallerID
	Target            *Target
	// Although SessionId is not part of the proto3 interface, we're adding it here
	// for backwards compatibility reasons. The proto3 interface defines the future,
	// where we think there might not be a need for SessionID.
	SessionId int64
}

BeginRequest is the BSON implementation of the proto3 query.BeginkRequest

type BeginResponse

type BeginResponse struct {
	// Err is named 'Err' instead of 'Error' (as the proto3 version is) to remain
	// consistent with other BSON structs.
	Err           *mproto.RPCError
	TransactionId int64
}

BeginResponse is the BSON implementation of the proto3 query.BeginResponse

type BoundQuery

type BoundQuery struct {
	Sql           string
	BindVariables map[string]interface{}
}

BoundQuery is one query in a QueryList.

func Proto3ToBoundQuery

func Proto3ToBoundQuery(query *pb.BoundQuery) *BoundQuery

Proto3ToBoundQuery converts a proto.BoundQuery to the internal data structure

func Proto3ToBoundQueryList

func Proto3ToBoundQueryList(queries []*pb.BoundQuery) []BoundQuery

Proto3ToBoundQueryList converts am array of proto.BoundQuery to the internal data structure

func (*BoundQuery) MarshalBson

func (boundQuery *BoundQuery) MarshalBson(buf *bytes2.ChunkedWriter, key string)

MarshalBson bson-encodes BoundQuery.

func (*BoundQuery) UnmarshalBson

func (boundQuery *BoundQuery) UnmarshalBson(buf *bytes.Buffer, kind byte)

UnmarshalBson bson-decodes into BoundQuery.

type CallerID

type CallerID struct {
	Principal    string
	Component    string
	Subcomponent string
}

CallerID is the BSON implementation of the proto3 vtrpc.CallerID

func (*CallerID) MarshalBson

func (callerID *CallerID) MarshalBson(buf *bytes2.ChunkedWriter, key string)

MarshalBson bson-encodes CallerID.

func (*CallerID) UnmarshalBson

func (callerID *CallerID) UnmarshalBson(buf *bytes.Buffer, kind byte)

UnmarshalBson bson-decodes into CallerID.

type CommitRequest

type CommitRequest struct {
	EffectiveCallerID *CallerID
	ImmediateCallerID *VTGateCallerID
	Target            *Target
	TransactionId     int64
	// Although SessionId is not part of the proto3 interface, we're adding it here
	// for backwards compatibility reasons. The proto3 interface defines the future,
	// where we think there might not be a need for SessionID.
	SessionId int64
}

CommitRequest is the BSON implementation of the proto3 query.CommitRequest

type CommitResponse

type CommitResponse struct {
	// Err is named 'Err' instead of 'Error' (as the proto3 version is) to remain
	// consistent with other BSON structs.
	Err *mproto.RPCError
}

CommitResponse is the BSON implementation of the proto3 query.CommitResponse

type ExecuteBatchRequest

type ExecuteBatchRequest struct {
	QueryBatch        QueryList
	EffectiveCallerID *CallerID
	ImmediateCallerID *VTGateCallerID
	Target            *Target
}

ExecuteBatchRequest is the payload to ExecuteBatch2, it contains both QueryList which is the actual payload and the CallerIDs

type ExecuteRequest

type ExecuteRequest struct {
	QueryRequest      Query
	EffectiveCallerID *CallerID
	ImmediateCallerID *VTGateCallerID
	Target            *Target
}

ExecuteRequest contains Query and CallerIDs. it is the payload to Execute2, which is the CallerID enabled version of Execute

type GetSessionIdRequest

type GetSessionIdRequest struct {
	Params            SessionParams
	EffectiveCallerID *CallerID
	ImmediateCallerID *VTGateCallerID
}

GetSessionIdRequest is the CallerID enabled version of SessionParams. It contains SessionParams, which is passed to GetSessionId. The server will double-check the keyspace and shard are what the tablet is serving.

type Query

type Query struct {
	Sql           string
	BindVariables map[string]interface{}
	SessionId     int64
	TransactionId int64
}

Query is the payload to Execute.

func (*Query) MarshalBson

func (query *Query) MarshalBson(buf *bytes2.ChunkedWriter, key string)

MarshalBson bson-encodes Query.

func (*Query) String

func (query *Query) String() string

String prints a readable version of Query, and also truncates data if it's too long

func (*Query) UnmarshalBson

func (query *Query) UnmarshalBson(buf *bytes.Buffer, kind byte)

UnmarshalBson bson-decodes into Query.

type QueryList

type QueryList struct {
	Queries       []BoundQuery
	SessionId     int64
	AsTransaction bool
	TransactionId int64
}

QueryList is the payload to ExecuteBatch.

func (*QueryList) MarshalBson

func (queryList *QueryList) MarshalBson(buf *bytes2.ChunkedWriter, key string)

MarshalBson bson-encodes QueryList.

func (*QueryList) UnmarshalBson

func (queryList *QueryList) UnmarshalBson(buf *bytes.Buffer, kind byte)

UnmarshalBson bson-decodes into QueryList.

type QueryResultList

type QueryResultList struct {
	List []mproto.QueryResult
	Err  *mproto.RPCError
}

QueryResultList is the return type for ExecuteBatch.

func Proto3ToQueryResultList

func Proto3ToQueryResultList(results []*pb.QueryResult) *QueryResultList

Proto3ToQueryResultList converts a proto3 QueryResult to an internal data structure.

func (*QueryResultList) MarshalBson

func (queryResultList *QueryResultList) MarshalBson(buf *bytes2.ChunkedWriter, key string)

MarshalBson bson-encodes QueryResultList.

func (*QueryResultList) UnmarshalBson

func (queryResultList *QueryResultList) UnmarshalBson(buf *bytes.Buffer, kind byte)

UnmarshalBson bson-decodes into QueryResultList.

type QuerySplit

type QuerySplit struct {
	Query    BoundQuery
	RowCount int64
}

QuerySplit represents a split of SplitQueryRequest.Query. RowCount is only approximate.

func Proto3ToQuerySplits

func Proto3ToQuerySplits(queries []*pb.QuerySplit) []QuerySplit

Proto3ToQuerySplits converts a proto3 QuerySplit array to a native QuerySplit array

type RollbackRequest

type RollbackRequest struct {
	EffectiveCallerID *CallerID
	ImmediateCallerID *VTGateCallerID
	Target            *Target
	TransactionId     int64
	// Although SessionId is not part of the proto3 interface, we're adding it here
	// for backwards compatibility reasons. The proto3 interface defines the future,
	// where we think there might not be a need for SessionID.
	SessionId int64
}

RollbackRequest is the BSON implementation of the proto3 query.RollbackRequest

type RollbackResponse

type RollbackResponse struct {
	// Err is named 'Err' instead of 'Error' (as the proto3 version is) to remain
	// consistent with other BSON structs.
	Err *mproto.RPCError
}

RollbackResponse is the BSON implementation of the proto3 query.RollbackResponse

type Session

type Session struct {
	SessionId     int64
	TransactionId int64
}

Session is passed to all calls.

func (*Session) MarshalBson

func (session *Session) MarshalBson(buf *bytes2.ChunkedWriter, key string)

MarshalBson bson-encodes Session.

func (*Session) UnmarshalBson

func (session *Session) UnmarshalBson(buf *bytes.Buffer, kind byte)

UnmarshalBson bson-decodes into Session.

type SessionInfo

type SessionInfo struct {
	SessionId int64
	Err       *mproto.RPCError
}

SessionInfo is returned by GetSessionId. Use the provided session_id in the Session object for any subsequent call.

func (*SessionInfo) MarshalBson

func (sessionInfo *SessionInfo) MarshalBson(buf *bytes2.ChunkedWriter, key string)

MarshalBson bson-encodes SessionInfo.

func (*SessionInfo) UnmarshalBson

func (sessionInfo *SessionInfo) UnmarshalBson(buf *bytes.Buffer, kind byte)

UnmarshalBson bson-decodes into SessionInfo.

type SessionParams

type SessionParams struct {
	Keyspace string
	Shard    string
}

SessionParams is passed to GetSessionId. The server will double-check the keyspace and shard are what the tablet is serving.

type SplitQueryRequest

type SplitQueryRequest struct {
	Query             BoundQuery
	SplitColumn       string
	SplitCount        int
	SessionID         int64
	EffectiveCallerID *CallerID
	ImmediateCallerID *VTGateCallerID
	Target            *Target
}

SplitQueryRequest represents a request to split a Query into queries that each return a subset of the original query. SplitColumn: preferred column to split. Server will pick a random PK column

if this field is empty or returns an error if this field is not
empty but not found in schema info or not be indexed.

type SplitQueryResult

type SplitQueryResult struct {
	Queries []QuerySplit
	Err     *mproto.RPCError
}

SplitQueryResult represents the result of a SplitQueryRequest

type StreamExecuteRequest

type StreamExecuteRequest struct {
	EffectiveCallerID *CallerID
	ImmediateCallerID *VTGateCallerID
	Target            *Target
	// Query here is of type Query instead of BoundQuery because of backwards compatibility.
	// The proto3 interface defines the future, where we think there might not be a need for SessionID.
	Query *Query
}

StreamExecuteRequest is the BSON implementation of the proto3 query.StreamExecuteRequest

type StreamExecuteResponse

type StreamExecuteResponse struct {
	Result *mproto.QueryResult
	// Err is named 'Err' instead of 'Error' (as the proto3 version is) to remain
	// consistent with other BSON structs.
	Err *mproto.RPCError
}

StreamExecuteResponse is the BSON implementation of the proto3 query.StreamExecuteResponse

type TabletType

type TabletType int64

TabletType is the BSON implementation of the proto3 query.TabletType. Assumes that enums are expressed as int64 in BSON.

type Target

type Target struct {
	Keyspace   string
	Shard      string
	TabletType TabletType
}

Target is the BSON implementation of the proto3 query.Target

type TransactionInfo

type TransactionInfo struct {
	TransactionId int64
	Err           *mproto.RPCError
}

TransactionInfo is returned by Begin. Use the provided transaction_id in the Session object for any subsequent call to be inside the transaction.

func (*TransactionInfo) MarshalBson

func (transactionInfo *TransactionInfo) MarshalBson(buf *bytes2.ChunkedWriter, key string)

MarshalBson bson-encodes TransactionInfo.

func (*TransactionInfo) UnmarshalBson

func (transactionInfo *TransactionInfo) UnmarshalBson(buf *bytes.Buffer, kind byte)

UnmarshalBson bson-decodes into TransactionInfo.

type VTGateCallerID

type VTGateCallerID struct {
	Username string
}

VTGateCallerID is the BSON implementation of the proto3 query.VTGateCallerID

Jump to

Keyboard shortcuts

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