bsonp3vtgateservice

Documentation

Overview

Package bsonp3vtgateservice provides to go rpc glue for vtgate, with BSON-encoded proto3 structs.

Index

• type VTGateP3
  • func New(vtGate vtgateservice.VTGateService) *VTGateP3
  • func (vtg *VTGateP3) Begin(ctx context.Context, request *pb.BeginRequest, response *pb.BeginResponse) (err error)
  • func (vtg *VTGateP3) Commit(ctx context.Context, request *pb.CommitRequest, response *pb.CommitResponse) (err error)
  • func (vtg *VTGateP3) Execute(ctx context.Context, request *pb.ExecuteRequest, response *pb.ExecuteResponse) (err error)
  • func (vtg *VTGateP3) ExecuteBatchKeyspaceIds(ctx context.Context, request *pb.ExecuteBatchKeyspaceIdsRequest, ...) (err error)
  • func (vtg *VTGateP3) ExecuteBatchShards(ctx context.Context, request *pb.ExecuteBatchShardsRequest, ...) (err error)
  • func (vtg *VTGateP3) ExecuteEntityIds(ctx context.Context, request *pb.ExecuteEntityIdsRequest, ...) (err error)
  • func (vtg *VTGateP3) ExecuteKeyRanges(ctx context.Context, request *pb.ExecuteKeyRangesRequest, ...) (err error)
  • func (vtg *VTGateP3) ExecuteKeyspaceIds(ctx context.Context, request *pb.ExecuteKeyspaceIdsRequest, ...) (err error)
  • func (vtg *VTGateP3) ExecuteShards(ctx context.Context, request *pb.ExecuteShardsRequest, ...) (err error)
  • func (vtg *VTGateP3) GetSrvKeyspace(ctx context.Context, request *pb.GetSrvKeyspaceRequest, ...) (err error)
  • func (vtg *VTGateP3) Rollback(ctx context.Context, request *pb.RollbackRequest, ...) (err error)
  • func (vtg *VTGateP3) SplitQuery(ctx context.Context, request *pb.SplitQueryRequest, ...) (err error)
  • func (vtg *VTGateP3) StreamExecute(ctx context.Context, request *pb.StreamExecuteRequest, ...) (err error)
  • func (vtg *VTGateP3) StreamExecuteKeyRanges(ctx context.Context, request *pb.StreamExecuteKeyRangesRequest, ...) (err error)
  • func (vtg *VTGateP3) StreamExecuteKeyspaceIds(ctx context.Context, request *pb.StreamExecuteKeyspaceIdsRequest, ...) (err error)
  • func (vtg *VTGateP3) StreamExecuteShards(ctx context.Context, request *pb.StreamExecuteShardsRequest, ...) (err error)

Types

type VTGateP3

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

VTGateP3 is the public structure that is exported via BSON RPC

func New

func New(vtGate vtgateservice.VTGateService) *VTGateP3

New returns a new VTGateP3 service

func (*VTGateP3) Begin

func (vtg *VTGateP3) Begin(ctx context.Context, request *pb.BeginRequest, response *pb.BeginResponse) (err error)

Begin is the RPC version of vtgateservice.VTGateService method

func (*VTGateP3) Commit

func (vtg *VTGateP3) Commit(ctx context.Context, request *pb.CommitRequest, response *pb.CommitResponse) (err error)

Commit is the RPC version of vtgateservice.VTGateService method

func (*VTGateP3) Execute

func (vtg *VTGateP3) Execute(ctx context.Context, request *pb.ExecuteRequest, response *pb.ExecuteResponse) (err error)

Execute is the RPC version of vtgateservice.VTGateService method

func (*VTGateP3) ExecuteBatchKeyspaceIds

func (vtg *VTGateP3) ExecuteBatchKeyspaceIds(ctx context.Context, request *pb.ExecuteBatchKeyspaceIdsRequest, response *pb.ExecuteBatchKeyspaceIdsResponse) (err error)

ExecuteBatchKeyspaceIds is the RPC version of vtgateservice.VTGateService method

func (*VTGateP3) ExecuteBatchShards

func (vtg *VTGateP3) ExecuteBatchShards(ctx context.Context, request *pb.ExecuteBatchShardsRequest, response *pb.ExecuteBatchShardsResponse) (err error)

ExecuteBatchShards is the RPC version of vtgateservice.VTGateService method

func (*VTGateP3) ExecuteEntityIds

func (vtg *VTGateP3) ExecuteEntityIds(ctx context.Context, request *pb.ExecuteEntityIdsRequest, response *pb.ExecuteEntityIdsResponse) (err error)

ExecuteEntityIds is the RPC version of vtgateservice.VTGateService method

func (*VTGateP3) ExecuteKeyRanges

func (vtg *VTGateP3) ExecuteKeyRanges(ctx context.Context, request *pb.ExecuteKeyRangesRequest, response *pb.ExecuteKeyRangesResponse) (err error)

ExecuteKeyRanges is the RPC version of vtgateservice.VTGateService method

func (*VTGateP3) ExecuteKeyspaceIds

func (vtg *VTGateP3) ExecuteKeyspaceIds(ctx context.Context, request *pb.ExecuteKeyspaceIdsRequest, response *pb.ExecuteKeyspaceIdsResponse) (err error)

ExecuteKeyspaceIds is the RPC version of vtgateservice.VTGateService method

func (*VTGateP3) ExecuteShards

func (vtg *VTGateP3) ExecuteShards(ctx context.Context, request *pb.ExecuteShardsRequest, response *pb.ExecuteShardsResponse) (err error)

ExecuteShards is the RPC version of vtgateservice.VTGateService method

func (*VTGateP3) GetSrvKeyspace

func (vtg *VTGateP3) GetSrvKeyspace(ctx context.Context, request *pb.GetSrvKeyspaceRequest, response *pb.GetSrvKeyspaceResponse) (err error)

GetSrvKeyspace is the RPC version of vtgateservice.VTGateService method

func (*VTGateP3) Rollback

func (vtg *VTGateP3) Rollback(ctx context.Context, request *pb.RollbackRequest, response *pb.RollbackResponse) (err error)

Rollback is the RPC version of vtgateservice.VTGateService method

func (*VTGateP3) SplitQuery

func (vtg *VTGateP3) SplitQuery(ctx context.Context, request *pb.SplitQueryRequest, response *pb.SplitQueryResponse) (err error)

SplitQuery is the RPC version of vtgateservice.VTGateService method

func (*VTGateP3) StreamExecute

func (vtg *VTGateP3) StreamExecute(ctx context.Context, request *pb.StreamExecuteRequest, sendReply func(interface{}) error) (err error)

StreamExecute is the RPC version of vtgateservice.VTGateService method

func (*VTGateP3) StreamExecuteKeyRanges

func (vtg *VTGateP3) StreamExecuteKeyRanges(ctx context.Context, request *pb.StreamExecuteKeyRangesRequest, sendReply func(interface{}) error) (err error)

StreamExecuteKeyRanges is the RPC version of vtgateservice.VTGateService method

func (*VTGateP3) StreamExecuteKeyspaceIds

func (vtg *VTGateP3) StreamExecuteKeyspaceIds(ctx context.Context, request *pb.StreamExecuteKeyspaceIdsRequest, sendReply func(interface{}) error) (err error)

StreamExecuteKeyspaceIds is the RPC version of vtgateservice.VTGateService method

func (*VTGateP3) StreamExecuteShards

func (vtg *VTGateP3) StreamExecuteShards(ctx context.Context, request *pb.StreamExecuteShardsRequest, sendReply func(interface{}) error) (err error)

StreamExecuteShards is the RPC version of vtgateservice.VTGateService method