Versions in this module Expand all Collapse all v0 v0.16.3 Nov 29, 2024 Changes in this version + func RegisterVitessServer(s *grpc.Server, srv VitessServer) + type UnimplementedVitessServer struct + func (*UnimplementedVitessServer) Begin(ctx context.Context, req *vtgate.BeginRequest) (*vtgate.BeginResponse, error) + func (*UnimplementedVitessServer) Commit(ctx context.Context, req *vtgate.CommitRequest) (*vtgate.CommitResponse, error) + func (*UnimplementedVitessServer) Execute(ctx context.Context, req *vtgate.ExecuteRequest) (*vtgate.ExecuteResponse, error) + func (*UnimplementedVitessServer) ExecuteBatch(ctx context.Context, req *vtgate.ExecuteBatchRequest) (*vtgate.ExecuteBatchResponse, error) + func (*UnimplementedVitessServer) ExecuteBatchKeyspaceIds(ctx context.Context, req *vtgate.ExecuteBatchKeyspaceIdsRequest) (*vtgate.ExecuteBatchKeyspaceIdsResponse, error) + func (*UnimplementedVitessServer) ExecuteBatchShards(ctx context.Context, req *vtgate.ExecuteBatchShardsRequest) (*vtgate.ExecuteBatchShardsResponse, error) + func (*UnimplementedVitessServer) ExecuteEntityIds(ctx context.Context, req *vtgate.ExecuteEntityIdsRequest) (*vtgate.ExecuteEntityIdsResponse, error) + func (*UnimplementedVitessServer) ExecuteKeyRanges(ctx context.Context, req *vtgate.ExecuteKeyRangesRequest) (*vtgate.ExecuteKeyRangesResponse, error) + func (*UnimplementedVitessServer) ExecuteKeyspaceIds(ctx context.Context, req *vtgate.ExecuteKeyspaceIdsRequest) (*vtgate.ExecuteKeyspaceIdsResponse, error) + func (*UnimplementedVitessServer) ExecuteShards(ctx context.Context, req *vtgate.ExecuteShardsRequest) (*vtgate.ExecuteShardsResponse, error) + func (*UnimplementedVitessServer) GetSrvKeyspace(ctx context.Context, req *vtgate.GetSrvKeyspaceRequest) (*vtgate.GetSrvKeyspaceResponse, error) + func (*UnimplementedVitessServer) MessageAck(ctx context.Context, req *vtgate.MessageAckRequest) (*query.MessageAckResponse, error) + func (*UnimplementedVitessServer) MessageAckKeyspaceIds(ctx context.Context, req *vtgate.MessageAckKeyspaceIdsRequest) (*query.MessageAckResponse, error) + func (*UnimplementedVitessServer) MessageStream(req *vtgate.MessageStreamRequest, srv Vitess_MessageStreamServer) error + func (*UnimplementedVitessServer) ResolveTransaction(ctx context.Context, req *vtgate.ResolveTransactionRequest) (*vtgate.ResolveTransactionResponse, error) + func (*UnimplementedVitessServer) Rollback(ctx context.Context, req *vtgate.RollbackRequest) (*vtgate.RollbackResponse, error) + func (*UnimplementedVitessServer) StreamExecute(req *vtgate.StreamExecuteRequest, srv Vitess_StreamExecuteServer) error + func (*UnimplementedVitessServer) StreamExecuteKeyRanges(req *vtgate.StreamExecuteKeyRangesRequest, ...) error + func (*UnimplementedVitessServer) StreamExecuteKeyspaceIds(req *vtgate.StreamExecuteKeyspaceIdsRequest, ...) error + func (*UnimplementedVitessServer) StreamExecuteShards(req *vtgate.StreamExecuteShardsRequest, srv Vitess_StreamExecuteShardsServer) error + func (*UnimplementedVitessServer) VStream(req *vtgate.VStreamRequest, srv Vitess_VStreamServer) error + type VitessClient interface + Begin func(ctx context.Context, in *vtgate.BeginRequest, opts ...grpc.CallOption) (*vtgate.BeginResponse, error) + Commit func(ctx context.Context, in *vtgate.CommitRequest, opts ...grpc.CallOption) (*vtgate.CommitResponse, error) + Execute func(ctx context.Context, in *vtgate.ExecuteRequest, opts ...grpc.CallOption) (*vtgate.ExecuteResponse, error) + ExecuteBatch func(ctx context.Context, in *vtgate.ExecuteBatchRequest, opts ...grpc.CallOption) (*vtgate.ExecuteBatchResponse, error) + ExecuteBatchKeyspaceIds func(ctx context.Context, in *vtgate.ExecuteBatchKeyspaceIdsRequest, ...) (*vtgate.ExecuteBatchKeyspaceIdsResponse, error) + ExecuteBatchShards func(ctx context.Context, in *vtgate.ExecuteBatchShardsRequest, ...) (*vtgate.ExecuteBatchShardsResponse, error) + ExecuteEntityIds func(ctx context.Context, in *vtgate.ExecuteEntityIdsRequest, ...) (*vtgate.ExecuteEntityIdsResponse, error) + ExecuteKeyRanges func(ctx context.Context, in *vtgate.ExecuteKeyRangesRequest, ...) (*vtgate.ExecuteKeyRangesResponse, error) + ExecuteKeyspaceIds func(ctx context.Context, in *vtgate.ExecuteKeyspaceIdsRequest, ...) (*vtgate.ExecuteKeyspaceIdsResponse, error) + ExecuteShards func(ctx context.Context, in *vtgate.ExecuteShardsRequest, opts ...grpc.CallOption) (*vtgate.ExecuteShardsResponse, error) + GetSrvKeyspace func(ctx context.Context, in *vtgate.GetSrvKeyspaceRequest, opts ...grpc.CallOption) (*vtgate.GetSrvKeyspaceResponse, error) + MessageAck func(ctx context.Context, in *vtgate.MessageAckRequest, opts ...grpc.CallOption) (*query.MessageAckResponse, error) + MessageAckKeyspaceIds func(ctx context.Context, in *vtgate.MessageAckKeyspaceIdsRequest, ...) (*query.MessageAckResponse, error) + MessageStream func(ctx context.Context, in *vtgate.MessageStreamRequest, opts ...grpc.CallOption) (Vitess_MessageStreamClient, error) + ResolveTransaction func(ctx context.Context, in *vtgate.ResolveTransactionRequest, ...) (*vtgate.ResolveTransactionResponse, error) + Rollback func(ctx context.Context, in *vtgate.RollbackRequest, opts ...grpc.CallOption) (*vtgate.RollbackResponse, error) + StreamExecute func(ctx context.Context, in *vtgate.StreamExecuteRequest, opts ...grpc.CallOption) (Vitess_StreamExecuteClient, error) + StreamExecuteKeyRanges func(ctx context.Context, in *vtgate.StreamExecuteKeyRangesRequest, ...) (Vitess_StreamExecuteKeyRangesClient, error) + StreamExecuteKeyspaceIds func(ctx context.Context, in *vtgate.StreamExecuteKeyspaceIdsRequest, ...) (Vitess_StreamExecuteKeyspaceIdsClient, error) + StreamExecuteShards func(ctx context.Context, in *vtgate.StreamExecuteShardsRequest, ...) (Vitess_StreamExecuteShardsClient, error) + VStream func(ctx context.Context, in *vtgate.VStreamRequest, opts ...grpc.CallOption) (Vitess_VStreamClient, error) + func NewVitessClient(cc *grpc.ClientConn) VitessClient + type VitessServer interface + Begin func(context.Context, *vtgate.BeginRequest) (*vtgate.BeginResponse, error) + Commit func(context.Context, *vtgate.CommitRequest) (*vtgate.CommitResponse, error) + Execute func(context.Context, *vtgate.ExecuteRequest) (*vtgate.ExecuteResponse, error) + ExecuteBatch func(context.Context, *vtgate.ExecuteBatchRequest) (*vtgate.ExecuteBatchResponse, error) + ExecuteBatchKeyspaceIds func(context.Context, *vtgate.ExecuteBatchKeyspaceIdsRequest) (*vtgate.ExecuteBatchKeyspaceIdsResponse, error) + ExecuteBatchShards func(context.Context, *vtgate.ExecuteBatchShardsRequest) (*vtgate.ExecuteBatchShardsResponse, error) + ExecuteEntityIds func(context.Context, *vtgate.ExecuteEntityIdsRequest) (*vtgate.ExecuteEntityIdsResponse, error) + ExecuteKeyRanges func(context.Context, *vtgate.ExecuteKeyRangesRequest) (*vtgate.ExecuteKeyRangesResponse, error) + ExecuteKeyspaceIds func(context.Context, *vtgate.ExecuteKeyspaceIdsRequest) (*vtgate.ExecuteKeyspaceIdsResponse, error) + ExecuteShards func(context.Context, *vtgate.ExecuteShardsRequest) (*vtgate.ExecuteShardsResponse, error) + GetSrvKeyspace func(context.Context, *vtgate.GetSrvKeyspaceRequest) (*vtgate.GetSrvKeyspaceResponse, error) + MessageAck func(context.Context, *vtgate.MessageAckRequest) (*query.MessageAckResponse, error) + MessageAckKeyspaceIds func(context.Context, *vtgate.MessageAckKeyspaceIdsRequest) (*query.MessageAckResponse, error) + MessageStream func(*vtgate.MessageStreamRequest, Vitess_MessageStreamServer) error + ResolveTransaction func(context.Context, *vtgate.ResolveTransactionRequest) (*vtgate.ResolveTransactionResponse, error) + Rollback func(context.Context, *vtgate.RollbackRequest) (*vtgate.RollbackResponse, error) + StreamExecute func(*vtgate.StreamExecuteRequest, Vitess_StreamExecuteServer) error + StreamExecuteKeyRanges func(*vtgate.StreamExecuteKeyRangesRequest, Vitess_StreamExecuteKeyRangesServer) error + StreamExecuteKeyspaceIds func(*vtgate.StreamExecuteKeyspaceIdsRequest, Vitess_StreamExecuteKeyspaceIdsServer) error + StreamExecuteShards func(*vtgate.StreamExecuteShardsRequest, Vitess_StreamExecuteShardsServer) error + VStream func(*vtgate.VStreamRequest, Vitess_VStreamServer) error + type Vitess_MessageStreamClient interface + Recv func() (*query.MessageStreamResponse, error) + type Vitess_MessageStreamServer interface + Send func(*query.MessageStreamResponse) error + type Vitess_StreamExecuteClient interface + Recv func() (*vtgate.StreamExecuteResponse, error) + type Vitess_StreamExecuteKeyRangesClient interface + Recv func() (*vtgate.StreamExecuteKeyRangesResponse, error) + type Vitess_StreamExecuteKeyRangesServer interface + Send func(*vtgate.StreamExecuteKeyRangesResponse) error + type Vitess_StreamExecuteKeyspaceIdsClient interface + Recv func() (*vtgate.StreamExecuteKeyspaceIdsResponse, error) + type Vitess_StreamExecuteKeyspaceIdsServer interface + Send func(*vtgate.StreamExecuteKeyspaceIdsResponse) error + type Vitess_StreamExecuteServer interface + Send func(*vtgate.StreamExecuteResponse) error + type Vitess_StreamExecuteShardsClient interface + Recv func() (*vtgate.StreamExecuteShardsResponse, error) + type Vitess_StreamExecuteShardsServer interface + Send func(*vtgate.StreamExecuteShardsResponse) error + type Vitess_VStreamClient interface + Recv func() (*vtgate.VStreamResponse, error) + type Vitess_VStreamServer interface + Send func(*vtgate.VStreamResponse) error
Go to main page