gorpcvtgateservice

Documentation

Overview

Package gorpcvtgateservice provides to go rpc glue for vtgate

Index

• type VTGate
  • func (vtg *VTGate) Begin(context *rpcproto.Context, noInput *rpc.UnusedRequest, ...) error
  • func (vtg *VTGate) Commit(context *rpcproto.Context, inSession *proto.Session, ...) error
  • func (vtg *VTGate) ExecuteBatchShard(context *rpcproto.Context, batchQuery *proto.BatchQueryShard, ...) error
  • func (vtg *VTGate) ExecuteShard(context *rpcproto.Context, query *proto.QueryShard, reply *proto.QueryResult) error
  • func (vtg *VTGate) Rollback(context *rpcproto.Context, inSession *proto.Session, ...) error
  • func (vtg *VTGate) StreamExecuteKeyRange(context *rpcproto.Context, query *proto.StreamQueryKeyRange, ...) error
  • func (vtg *VTGate) StreamExecuteShard(context *rpcproto.Context, query *proto.QueryShard, ...) error

Types

type VTGate

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

func (*VTGate) Begin

func (vtg *VTGate) Begin(context *rpcproto.Context, noInput *rpc.UnusedRequest, outSession *proto.Session) error

func (*VTGate) Commit

func (vtg *VTGate) Commit(context *rpcproto.Context, inSession *proto.Session, noOutput *rpc.UnusedResponse) error

func (*VTGate) ExecuteBatchShard

func (vtg *VTGate) ExecuteBatchShard(context *rpcproto.Context, batchQuery *proto.BatchQueryShard, reply *proto.QueryResultList) error

func (*VTGate) ExecuteShard

func (vtg *VTGate) ExecuteShard(context *rpcproto.Context, query *proto.QueryShard, reply *proto.QueryResult) error

func (*VTGate) Rollback

func (vtg *VTGate) Rollback(context *rpcproto.Context, inSession *proto.Session, noOutput *rpc.UnusedResponse) error

func (*VTGate) StreamExecuteKeyRange

func (vtg *VTGate) StreamExecuteKeyRange(context *rpcproto.Context, query *proto.StreamQueryKeyRange, sendReply func(interface{}) error) error

func (*VTGate) StreamExecuteShard

func (vtg *VTGate) StreamExecuteShard(context *rpcproto.Context, query *proto.QueryShard, sendReply func(interface{}) error) error