grpcvtgateservice

package
v1.0.10 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 17, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Overview

Package grpcvtgateservice provides the gRPC glue for vtgate

Index

Constants

This section is empty.

Variables

This section is empty.

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) ExecuteBatch

func (vtg *VTGate) ExecuteBatch(ctx context.Context, request *vtgatepb.ExecuteBatchRequest) (response *vtgatepb.ExecuteBatchResponse, err error)

ExecuteBatch 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) MessageAck

func (vtg *VTGate) MessageAck(ctx context.Context, request *vtgatepb.MessageAckRequest) (response *querypb.MessageAckResponse, err error)

MessageAck is the RPC version of vtgateservice.VTGateService method

func (*VTGate) MessageAckKeyspaceIds

func (vtg *VTGate) MessageAckKeyspaceIds(ctx context.Context, request *vtgatepb.MessageAckKeyspaceIdsRequest) (response *querypb.MessageAckResponse, err error)

MessageAckKeyspaceIds routes Message Acks using the associated keyspace ids.

func (*VTGate) MessageStream

func (vtg *VTGate) MessageStream(request *vtgatepb.MessageStreamRequest, stream vtgateservicepb.Vitess_MessageStreamServer) (err error)

MessageStream is the RPC version of vtgateservice.VTGateService method

func (*VTGate) ResolveTransaction

func (vtg *VTGate) ResolveTransaction(ctx context.Context, request *vtgatepb.ResolveTransactionRequest) (response *vtgatepb.ResolveTransactionResponse, err error)

ResolveTransaction 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL