gorpcvtgateservice

Documentation

Overview

Package gorpcvtgateservice provides to go rpc glue for vtgate

Index

• type VTGate
  • func (vtg *VTGate) Begin(ctx *rpcproto.Context, noInput *rpc.UnusedRequest, outSession *proto.Session) error
  • func (vtg *VTGate) Commit(ctx *rpcproto.Context, inSession *proto.Session, noOutput *rpc.UnusedResponse) error
  • func (vtg *VTGate) ExecuteBatchKeyspaceIds(ctx *rpcproto.Context, batchQuery *proto.KeyspaceIdBatchQuery, ...) error
  • func (vtg *VTGate) ExecuteBatchShard(ctx *rpcproto.Context, batchQuery *proto.BatchQueryShard, ...) error
  • func (vtg *VTGate) ExecuteEntityIds(ctx *rpcproto.Context, query *proto.EntityIdsQuery, reply *proto.QueryResult) error
  • func (vtg *VTGate) ExecuteKeyRanges(ctx *rpcproto.Context, query *proto.KeyRangeQuery, reply *proto.QueryResult) error
  • func (vtg *VTGate) ExecuteKeyspaceIds(ctx *rpcproto.Context, query *proto.KeyspaceIdQuery, reply *proto.QueryResult) error
  • func (vtg *VTGate) ExecuteShard(ctx *rpcproto.Context, query *proto.QueryShard, reply *proto.QueryResult) error
  • func (vtg *VTGate) GetMRSplits(ctx *rpcproto.Context, req *proto.GetMRSplitsRequest, ...) error
  • func (vtg *VTGate) Rollback(ctx *rpcproto.Context, inSession *proto.Session, noOutput *rpc.UnusedResponse) error
  • func (vtg *VTGate) StreamExecuteKeyRanges(ctx *rpcproto.Context, query *proto.KeyRangeQuery, ...) error
  • func (vtg *VTGate) StreamExecuteKeyspaceIds(ctx *rpcproto.Context, query *proto.KeyspaceIdQuery, ...) error
  • func (vtg *VTGate) StreamExecuteShard(ctx *rpcproto.Context, query *proto.QueryShard, ...) error

Types

type VTGate

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

func (*VTGate) Begin

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

func (*VTGate) Commit

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

func (*VTGate) ExecuteBatchKeyspaceIds

func (vtg *VTGate) ExecuteBatchKeyspaceIds(ctx *rpcproto.Context, batchQuery *proto.KeyspaceIdBatchQuery, reply *proto.QueryResultList) error

func (*VTGate) ExecuteBatchShard

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

func (*VTGate) ExecuteEntityIds

func (vtg *VTGate) ExecuteEntityIds(ctx *rpcproto.Context, query *proto.EntityIdsQuery, reply *proto.QueryResult) error

func (*VTGate) ExecuteKeyRanges

func (vtg *VTGate) ExecuteKeyRanges(ctx *rpcproto.Context, query *proto.KeyRangeQuery, reply *proto.QueryResult) error

func (*VTGate) ExecuteKeyspaceIds

func (vtg *VTGate) ExecuteKeyspaceIds(ctx *rpcproto.Context, query *proto.KeyspaceIdQuery, reply *proto.QueryResult) error

func (*VTGate) ExecuteShard

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

func (*VTGate) GetMRSplits

func (vtg *VTGate) GetMRSplits(ctx *rpcproto.Context, req *proto.GetMRSplitsRequest, reply *proto.GetMRSplitsResult) error

func (*VTGate) Rollback

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

func (*VTGate) StreamExecuteKeyRanges

func (vtg *VTGate) StreamExecuteKeyRanges(ctx *rpcproto.Context, query *proto.KeyRangeQuery, sendReply func(interface{}) error) error

func (*VTGate) StreamExecuteKeyspaceIds

func (vtg *VTGate) StreamExecuteKeyspaceIds(ctx *rpcproto.Context, query *proto.KeyspaceIdQuery, sendReply func(interface{}) error) error

func (*VTGate) StreamExecuteShard

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