go-vitess.v1: gopkg.in/src-d/go-vitess.v1/vt/vtgate/grpcvtgateservice Index | Files

package grpcvtgateservice

import "gopkg.in/src-d/go-vitess.v1/vt/vtgate/grpcvtgateservice"

Package grpcvtgateservice provides the gRPC glue for vtgate

Index

Package Files

server.go

func RegisterForTest Uses

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.

type VTGate Uses

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

VTGate is the public structure that is exported via gRPC

func (*VTGate) Begin Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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 Uses

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

UpdateStream is the RPC version of vtgateservice.VTGateService method

Package grpcvtgateservice imports 18 packages (graph). Updated 2019-06-13. Refresh now. Tools for package owners.