grpcvtgateservice

Documentation

Overview

Package grpcvtgateservice provides the gRPC glue for vtgate

Index

• func RegisterForTest(s *grpc.Server, service vtgateservice.VTGateService)
• type VTGate
  • func (vtg *VTGate) Begin(ctx context.Context, request *vtgatepb.BeginRequest) (response *vtgatepb.BeginResponse, err error)
  • func (vtg *VTGate) Commit(ctx context.Context, request *vtgatepb.CommitRequest) (response *vtgatepb.CommitResponse, err error)
  • func (vtg *VTGate) Execute(ctx context.Context, request *vtgatepb.ExecuteRequest) (response *vtgatepb.ExecuteResponse, err error)
  • func (vtg *VTGate) ExecuteBatchKeyspaceIds(ctx context.Context, request *vtgatepb.ExecuteBatchKeyspaceIdsRequest) (response *vtgatepb.ExecuteBatchKeyspaceIdsResponse, err error)
  • func (vtg *VTGate) ExecuteBatchShards(ctx context.Context, request *vtgatepb.ExecuteBatchShardsRequest) (response *vtgatepb.ExecuteBatchShardsResponse, err error)
  • func (vtg *VTGate) ExecuteEntityIds(ctx context.Context, request *vtgatepb.ExecuteEntityIdsRequest) (response *vtgatepb.ExecuteEntityIdsResponse, err error)
  • func (vtg *VTGate) ExecuteKeyRanges(ctx context.Context, request *vtgatepb.ExecuteKeyRangesRequest) (response *vtgatepb.ExecuteKeyRangesResponse, err error)
  • func (vtg *VTGate) ExecuteKeyspaceIds(ctx context.Context, request *vtgatepb.ExecuteKeyspaceIdsRequest) (response *vtgatepb.ExecuteKeyspaceIdsResponse, err error)
  • func (vtg *VTGate) ExecuteShards(ctx context.Context, request *vtgatepb.ExecuteShardsRequest) (response *vtgatepb.ExecuteShardsResponse, err error)
  • func (vtg *VTGate) GetSrvKeyspace(ctx context.Context, request *vtgatepb.GetSrvKeyspaceRequest) (response *vtgatepb.GetSrvKeyspaceResponse, err error)
  • func (vtg *VTGate) Rollback(ctx context.Context, request *vtgatepb.RollbackRequest) (response *vtgatepb.RollbackResponse, err error)
  • func (vtg *VTGate) SplitQuery(ctx context.Context, request *vtgatepb.SplitQueryRequest) (response *vtgatepb.SplitQueryResponse, err error)
  • func (vtg *VTGate) StreamExecute(request *vtgatepb.StreamExecuteRequest, ...) (err error)
  • func (vtg *VTGate) StreamExecuteKeyRanges(request *vtgatepb.StreamExecuteKeyRangesRequest, ...) (err error)
  • func (vtg *VTGate) StreamExecuteKeyspaceIds(request *vtgatepb.StreamExecuteKeyspaceIdsRequest, ...) (err error)
  • func (vtg *VTGate) StreamExecuteShards(request *vtgatepb.StreamExecuteShardsRequest, ...) (err error)
  • func (vtg *VTGate) UpdateStream(request *vtgatepb.UpdateStreamRequest, ...) (err error)

Functions

func RegisterForTest

func RegisterForTest(s *grpc.Server, service vtgateservice.VTGateService)

RegisterForTest registers the gRPC implementation on the gRPC server. Useful for unit tests only, for real use, the init() function does the registration.

Types

type VTGate

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

VTGate is the public structure that is exported via gRPC

func (*VTGate) Begin

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

Begin is the RPC version of vtgateservice.VTGateService method

func (*VTGate) Commit

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

Commit is the RPC version of vtgateservice.VTGateService method

func (*VTGate) Execute

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

Execute is the RPC version of vtgateservice.VTGateService method

func (*VTGate) ExecuteBatchKeyspaceIds

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

ExecuteBatchKeyspaceIds is the RPC version of vtgateservice.VTGateService method

func (*VTGate) ExecuteBatchShards

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

ExecuteBatchShards is the RPC version of vtgateservice.VTGateService method

func (*VTGate) ExecuteEntityIds

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

ExecuteEntityIds is the RPC version of vtgateservice.VTGateService method

func (*VTGate) ExecuteKeyRanges

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

ExecuteKeyRanges is the RPC version of vtgateservice.VTGateService method

func (*VTGate) ExecuteKeyspaceIds

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

ExecuteKeyspaceIds is the RPC version of vtgateservice.VTGateService method

func (*VTGate) ExecuteShards

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

ExecuteShards is the RPC version of vtgateservice.VTGateService method

func (*VTGate) GetSrvKeyspace

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

GetSrvKeyspace is the RPC version of vtgateservice.VTGateService method

func (*VTGate) Rollback

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

Rollback is the RPC version of vtgateservice.VTGateService method

func (*VTGate) SplitQuery

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

SplitQuery is the RPC version of vtgateservice.VTGateService method

func (*VTGate) StreamExecute

func (vtg *VTGate) StreamExecute(request *vtgatepb.StreamExecuteRequest, stream vtgateservicepb.Vitess_StreamExecuteServer) (err error)

StreamExecute is the RPC version of vtgateservice.VTGateService method

func (*VTGate) StreamExecuteKeyRanges

func (vtg *VTGate) StreamExecuteKeyRanges(request *vtgatepb.StreamExecuteKeyRangesRequest, stream vtgateservicepb.Vitess_StreamExecuteKeyRangesServer) (err error)

StreamExecuteKeyRanges is the RPC version of vtgateservice.VTGateService method

func (*VTGate) StreamExecuteKeyspaceIds

func (vtg *VTGate) StreamExecuteKeyspaceIds(request *vtgatepb.StreamExecuteKeyspaceIdsRequest, stream vtgateservicepb.Vitess_StreamExecuteKeyspaceIdsServer) (err error)

StreamExecuteKeyspaceIds is the RPC version of vtgateservice.VTGateService method

func (*VTGate) StreamExecuteShards

func (vtg *VTGate) StreamExecuteShards(request *vtgatepb.StreamExecuteShardsRequest, stream vtgateservicepb.Vitess_StreamExecuteShardsServer) (err error)

StreamExecuteShards is the RPC version of vtgateservice.VTGateService method

func (*VTGate) UpdateStream

func (vtg *VTGate) UpdateStream(request *vtgatepb.UpdateStreamRequest, stream vtgateservicepb.Vitess_UpdateStreamServer) (err error)

UpdateStream is the RPC version of vtgateservice.VTGateService method