gorpcvtgateservice

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: 10 Imported by: 0

Documentation

Overview

Package gorpcvtgateservice provides to go rpc glue for vtgate

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type VTGate 

type VTGate struct {
	// contains filtered or unexported fields
}

VTGate is the public structure that is exported via BSON RPC

func New 

func New(vtGate vtgateservice.VTGateService) *VTGate

New returns a new VTGate service

func (*VTGate) Begin 

func (vtg *VTGate) Begin(ctx context.Context, noInput *rpc.Unused, outSession *proto.Session) (err error)

Begin is the RPC version of vtgateservice.VTGateService method

func (*VTGate) Begin2 

func (vtg *VTGate) Begin2(ctx context.Context, request *proto.BeginRequest, reply *proto.BeginResponse) (err error)

Begin2 is the RPC version of vtgateservice.VTGateService method

func (*VTGate) Commit 

func (vtg *VTGate) Commit(ctx context.Context, inSession *proto.Session, noOutput *rpc.Unused) (err error)

Commit is the RPC version of vtgateservice.VTGateService method

func (*VTGate) Commit2 

func (vtg *VTGate) Commit2(ctx context.Context, request *proto.CommitRequest, reply *proto.CommitResponse) (err error)

Commit2 is the RPC version of vtgateservice.VTGateService method

func (*VTGate) Execute 

func (vtg *VTGate) Execute(ctx context.Context, request *proto.Query, reply *proto.QueryResult) (err error)

Execute is the RPC version of vtgateservice.VTGateService method

func (*VTGate) ExecuteBatchKeyspaceIds 

func (vtg *VTGate) ExecuteBatchKeyspaceIds(ctx context.Context, request *proto.KeyspaceIdBatchQuery, reply *proto.QueryResultList) (err error)

ExecuteBatchKeyspaceIds is the RPC version of vtgateservice.VTGateService method

func (*VTGate) ExecuteBatchShard 

func (vtg *VTGate) ExecuteBatchShard(ctx context.Context, request *proto.BatchQueryShard, reply *proto.QueryResultList) (err error)

ExecuteBatchShard is the RPC version of vtgateservice.VTGateService method

func (*VTGate) ExecuteEntityIds 

func (vtg *VTGate) ExecuteEntityIds(ctx context.Context, request *proto.EntityIdsQuery, reply *proto.QueryResult) (err error)

ExecuteEntityIds is the RPC version of vtgateservice.VTGateService method

func (*VTGate) ExecuteKeyRanges 

func (vtg *VTGate) ExecuteKeyRanges(ctx context.Context, request *proto.KeyRangeQuery, reply *proto.QueryResult) (err error)

ExecuteKeyRanges is the RPC version of vtgateservice.VTGateService method

func (*VTGate) ExecuteKeyspaceIds 

func (vtg *VTGate) ExecuteKeyspaceIds(ctx context.Context, request *proto.KeyspaceIdQuery, reply *proto.QueryResult) (err error)

ExecuteKeyspaceIds is the RPC version of vtgateservice.VTGateService method

func (*VTGate) ExecuteShard 

func (vtg *VTGate) ExecuteShard(ctx context.Context, request *proto.QueryShard, reply *proto.QueryResult) (err error)

ExecuteShard is the RPC version of vtgateservice.VTGateService method

func (*VTGate) GetSrvKeyspace 

func (vtg *VTGate) GetSrvKeyspace(ctx context.Context, request *proto.GetSrvKeyspaceRequest, reply *topo.SrvKeyspace) (err error)

GetSrvKeyspace is the RPC version of vtgateservice.VTGateService method

func (*VTGate) Rollback 

func (vtg *VTGate) Rollback(ctx context.Context, inSession *proto.Session, noOutput *rpc.Unused) (err error)

Rollback is the RPC version of vtgateservice.VTGateService method

func (*VTGate) Rollback2 

func (vtg *VTGate) Rollback2(ctx context.Context, request *proto.RollbackRequest, reply *proto.RollbackResponse) (err error)

Rollback2 is the RPC version of vtgateservice.VTGateService method

func (*VTGate) SplitQuery 

func (vtg *VTGate) SplitQuery(ctx context.Context, request *proto.SplitQueryRequest, reply *proto.SplitQueryResult) (err error)

SplitQuery is the RPC version of vtgateservice.VTGateService method

func (*VTGate) StreamExecute 

func (vtg *VTGate) StreamExecute(ctx context.Context, request *proto.Query, sendReply func(interface{}) error) (err error)

StreamExecute is the RPC version of vtgateservice.VTGateService method

func (*VTGate) StreamExecute2 

func (vtg *VTGate) StreamExecute2(ctx context.Context, request *proto.Query, sendReply func(interface{}) error) (err error)

StreamExecute2 is the RPC version of vtgateservice.VTGateService method

func (*VTGate) StreamExecuteKeyRanges 

func (vtg *VTGate) StreamExecuteKeyRanges(ctx context.Context, request *proto.KeyRangeQuery, sendReply func(interface{}) error) (err error)

StreamExecuteKeyRanges is the RPC version of vtgateservice.VTGateService method

func (*VTGate) StreamExecuteKeyRanges2 

func (vtg *VTGate) StreamExecuteKeyRanges2(ctx context.Context, request *proto.KeyRangeQuery, sendReply func(interface{}) error) (err error)

StreamExecuteKeyRanges2 is the RPC version of vtgateservice.VTGateService method

func (*VTGate) StreamExecuteKeyspaceIds 

func (vtg *VTGate) StreamExecuteKeyspaceIds(ctx context.Context, request *proto.KeyspaceIdQuery, sendReply func(interface{}) error) (err error)

StreamExecuteKeyspaceIds is the RPC version of vtgateservice.VTGateService method

func (*VTGate) StreamExecuteKeyspaceIds2 

func (vtg *VTGate) StreamExecuteKeyspaceIds2(ctx context.Context, request *proto.KeyspaceIdQuery, sendReply func(interface{}) error) (err error)

StreamExecuteKeyspaceIds2 is the RPC version of vtgateservice.VTGateService method

func (*VTGate) StreamExecuteShard 

func (vtg *VTGate) StreamExecuteShard(ctx context.Context, request *proto.QueryShard, sendReply func(interface{}) error) (err error)

StreamExecuteShard is the RPC version of vtgateservice.VTGateService method

func (*VTGate) StreamExecuteShard2 

func (vtg *VTGate) StreamExecuteShard2(ctx context.Context, request *proto.QueryShard, sendReply func(interface{}) error) (err error)

StreamExecuteShard2 is the RPC version of vtgateservice.VTGateService method

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.