grpcvtgateservice

package
v0.19.4 Latest Latest
Warning

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

Go to latest
Published: May 8, 2024 License: Apache-2.0 Imports: 18 Imported by: 3

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 {
	vtgateservicepb.UnimplementedVitessServer
	// contains filtered or unexported fields
}

VTGate is the public structure that is exported via gRPC

func (*VTGate) CloseSession added in v0.11.0

func (vtg *VTGate) CloseSession(ctx context.Context, request *vtgatepb.CloseSessionRequest) (response *vtgatepb.CloseSessionResponse, err error)

CloseSession 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) Prepare added in v0.11.0

func (vtg *VTGate) Prepare(ctx context.Context, request *vtgatepb.PrepareRequest) (response *vtgatepb.PrepareResponse, err error)

Prepare 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) 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) VStream

func (vtg *VTGate) VStream(request *vtgatepb.VStreamRequest, stream vtgateservicepb.Vitess_VStreamServer) (err error)

VStream 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