grpcvtgateservice

package

v0.16.3 Latest Latest Go to latest Published: Nov 29, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/katechun/vitess

Links

Open Source Insights

Documentation ¶

Overview ¶

Package grpcvtgateservice provides the gRPC glue for vtgate

Index ¶

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

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

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

VStream is the RPC version of vtgateservice.VTGateService method

Source Files ¶

View all Source files

server.go

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