Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterQueryServer(s grpc.ServiceRegistrar, srv QueryServer)
- type QueryClient
- type QueryServer
- type Query_BeginStreamExecuteClient
- type Query_BeginStreamExecuteServer
- type Query_GetSchemaClient
- type Query_GetSchemaServer
- type Query_MessageStreamClient
- type Query_MessageStreamServer
- type Query_ReserveBeginStreamExecuteClient
- type Query_ReserveBeginStreamExecuteServer
- type Query_ReserveStreamExecuteClient
- type Query_ReserveStreamExecuteServer
- type Query_StreamExecuteClient
- type Query_StreamExecuteServer
- type Query_StreamHealthClient
- type Query_StreamHealthServer
- type Query_VStreamClient
- type Query_VStreamResultsClient
- type Query_VStreamResultsServer
- type Query_VStreamRowsClient
- type Query_VStreamRowsServer
- type Query_VStreamServer
- type UnimplementedQueryServer
- func (UnimplementedQueryServer) Begin(context.Context, *v16.BeginRequest) (*v16.BeginResponse, error)
- func (UnimplementedQueryServer) BeginExecute(context.Context, *v16.BeginExecuteRequest) (*v16.BeginExecuteResponse, error)
- func (UnimplementedQueryServer) BeginStreamExecute(*v16.BeginStreamExecuteRequest, Query_BeginStreamExecuteServer) error
- func (UnimplementedQueryServer) Commit(context.Context, *v16.CommitRequest) (*v16.CommitResponse, error)
- func (UnimplementedQueryServer) CommitPrepared(context.Context, *v16.CommitPreparedRequest) (*v16.CommitPreparedResponse, error)
- func (UnimplementedQueryServer) ConcludeTransaction(context.Context, *v16.ConcludeTransactionRequest) (*v16.ConcludeTransactionResponse, error)
- func (UnimplementedQueryServer) CreateTransaction(context.Context, *v16.CreateTransactionRequest) (*v16.CreateTransactionResponse, error)
- func (UnimplementedQueryServer) Execute(context.Context, *v16.ExecuteRequest) (*v16.ExecuteResponse, error)
- func (UnimplementedQueryServer) GetSchema(*v16.GetSchemaRequest, Query_GetSchemaServer) error
- func (UnimplementedQueryServer) MessageAck(context.Context, *v16.MessageAckRequest) (*v16.MessageAckResponse, error)
- func (UnimplementedQueryServer) MessageStream(*v16.MessageStreamRequest, Query_MessageStreamServer) error
- func (UnimplementedQueryServer) Prepare(context.Context, *v16.PrepareRequest) (*v16.PrepareResponse, error)
- func (UnimplementedQueryServer) ReadTransaction(context.Context, *v16.ReadTransactionRequest) (*v16.ReadTransactionResponse, error)
- func (UnimplementedQueryServer) Release(context.Context, *v16.ReleaseRequest) (*v16.ReleaseResponse, error)
- func (UnimplementedQueryServer) ReserveBeginExecute(context.Context, *v16.ReserveBeginExecuteRequest) (*v16.ReserveBeginExecuteResponse, error)
- func (UnimplementedQueryServer) ReserveBeginStreamExecute(*v16.ReserveBeginStreamExecuteRequest, Query_ReserveBeginStreamExecuteServer) error
- func (UnimplementedQueryServer) ReserveExecute(context.Context, *v16.ReserveExecuteRequest) (*v16.ReserveExecuteResponse, error)
- func (UnimplementedQueryServer) ReserveStreamExecute(*v16.ReserveStreamExecuteRequest, Query_ReserveStreamExecuteServer) error
- func (UnimplementedQueryServer) Rollback(context.Context, *v16.RollbackRequest) (*v16.RollbackResponse, error)
- func (UnimplementedQueryServer) RollbackPrepared(context.Context, *v16.RollbackPreparedRequest) (*v16.RollbackPreparedResponse, error)
- func (UnimplementedQueryServer) SetRollback(context.Context, *v16.SetRollbackRequest) (*v16.SetRollbackResponse, error)
- func (UnimplementedQueryServer) StartCommit(context.Context, *v16.StartCommitRequest) (*v16.StartCommitResponse, error)
- func (UnimplementedQueryServer) StreamExecute(*v16.StreamExecuteRequest, Query_StreamExecuteServer) error
- func (UnimplementedQueryServer) StreamHealth(*v16.StreamHealthRequest, Query_StreamHealthServer) error
- func (UnimplementedQueryServer) VStream(*v161.VStreamRequest, Query_VStreamServer) error
- func (UnimplementedQueryServer) VStreamResults(*v161.VStreamResultsRequest, Query_VStreamResultsServer) error
- func (UnimplementedQueryServer) VStreamRows(*v161.VStreamRowsRequest, Query_VStreamRowsServer) error
- type UnsafeQueryServer
Constants ¶
const ( Query_Execute_FullMethodName = "/vitess.queryservice.v16.Query/Execute" Query_StreamExecute_FullMethodName = "/vitess.queryservice.v16.Query/StreamExecute" Query_Begin_FullMethodName = "/vitess.queryservice.v16.Query/Begin" Query_Commit_FullMethodName = "/vitess.queryservice.v16.Query/Commit" Query_Rollback_FullMethodName = "/vitess.queryservice.v16.Query/Rollback" Query_Prepare_FullMethodName = "/vitess.queryservice.v16.Query/Prepare" Query_CommitPrepared_FullMethodName = "/vitess.queryservice.v16.Query/CommitPrepared" Query_RollbackPrepared_FullMethodName = "/vitess.queryservice.v16.Query/RollbackPrepared" Query_CreateTransaction_FullMethodName = "/vitess.queryservice.v16.Query/CreateTransaction" Query_StartCommit_FullMethodName = "/vitess.queryservice.v16.Query/StartCommit" Query_SetRollback_FullMethodName = "/vitess.queryservice.v16.Query/SetRollback" Query_ConcludeTransaction_FullMethodName = "/vitess.queryservice.v16.Query/ConcludeTransaction" Query_ReadTransaction_FullMethodName = "/vitess.queryservice.v16.Query/ReadTransaction" Query_BeginExecute_FullMethodName = "/vitess.queryservice.v16.Query/BeginExecute" Query_BeginStreamExecute_FullMethodName = "/vitess.queryservice.v16.Query/BeginStreamExecute" Query_MessageStream_FullMethodName = "/vitess.queryservice.v16.Query/MessageStream" Query_MessageAck_FullMethodName = "/vitess.queryservice.v16.Query/MessageAck" Query_ReserveExecute_FullMethodName = "/vitess.queryservice.v16.Query/ReserveExecute" Query_ReserveBeginExecute_FullMethodName = "/vitess.queryservice.v16.Query/ReserveBeginExecute" Query_ReserveStreamExecute_FullMethodName = "/vitess.queryservice.v16.Query/ReserveStreamExecute" Query_ReserveBeginStreamExecute_FullMethodName = "/vitess.queryservice.v16.Query/ReserveBeginStreamExecute" Query_Release_FullMethodName = "/vitess.queryservice.v16.Query/Release" Query_StreamHealth_FullMethodName = "/vitess.queryservice.v16.Query/StreamHealth" Query_VStream_FullMethodName = "/vitess.queryservice.v16.Query/VStream" Query_VStreamRows_FullMethodName = "/vitess.queryservice.v16.Query/VStreamRows" Query_VStreamResults_FullMethodName = "/vitess.queryservice.v16.Query/VStreamResults" Query_GetSchema_FullMethodName = "/vitess.queryservice.v16.Query/GetSchema" )
Variables ¶
var Query_ServiceDesc = grpc.ServiceDesc{ ServiceName: "vitess.queryservice.v16.Query", HandlerType: (*QueryServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Execute", Handler: _Query_Execute_Handler, }, { MethodName: "Begin", Handler: _Query_Begin_Handler, }, { MethodName: "Commit", Handler: _Query_Commit_Handler, }, { MethodName: "Rollback", Handler: _Query_Rollback_Handler, }, { MethodName: "Prepare", Handler: _Query_Prepare_Handler, }, { MethodName: "CommitPrepared", Handler: _Query_CommitPrepared_Handler, }, { MethodName: "RollbackPrepared", Handler: _Query_RollbackPrepared_Handler, }, { MethodName: "CreateTransaction", Handler: _Query_CreateTransaction_Handler, }, { MethodName: "StartCommit", Handler: _Query_StartCommit_Handler, }, { MethodName: "SetRollback", Handler: _Query_SetRollback_Handler, }, { MethodName: "ConcludeTransaction", Handler: _Query_ConcludeTransaction_Handler, }, { MethodName: "ReadTransaction", Handler: _Query_ReadTransaction_Handler, }, { MethodName: "BeginExecute", Handler: _Query_BeginExecute_Handler, }, { MethodName: "MessageAck", Handler: _Query_MessageAck_Handler, }, { MethodName: "ReserveExecute", Handler: _Query_ReserveExecute_Handler, }, { MethodName: "ReserveBeginExecute", Handler: _Query_ReserveBeginExecute_Handler, }, { MethodName: "Release", Handler: _Query_Release_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "StreamExecute", Handler: _Query_StreamExecute_Handler, ServerStreams: true, }, { StreamName: "BeginStreamExecute", Handler: _Query_BeginStreamExecute_Handler, ServerStreams: true, }, { StreamName: "MessageStream", Handler: _Query_MessageStream_Handler, ServerStreams: true, }, { StreamName: "ReserveStreamExecute", Handler: _Query_ReserveStreamExecute_Handler, ServerStreams: true, }, { StreamName: "ReserveBeginStreamExecute", Handler: _Query_ReserveBeginStreamExecute_Handler, ServerStreams: true, }, { StreamName: "StreamHealth", Handler: _Query_StreamHealth_Handler, ServerStreams: true, }, { StreamName: "VStream", Handler: _Query_VStream_Handler, ServerStreams: true, }, { StreamName: "VStreamRows", Handler: _Query_VStreamRows_Handler, ServerStreams: true, }, { StreamName: "VStreamResults", Handler: _Query_VStreamResults_Handler, ServerStreams: true, }, { StreamName: "GetSchema", Handler: _Query_GetSchema_Handler, ServerStreams: true, }, }, Metadata: "vitess/queryservice/v16/queryservice.proto", }
Query_ServiceDesc is the grpc.ServiceDesc for Query service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterQueryServer ¶
func RegisterQueryServer(s grpc.ServiceRegistrar, srv QueryServer)
Types ¶
type QueryClient ¶
type QueryClient interface { // Execute executes the specified SQL query (might be in a // transaction context, if Query.transaction_id is set). Execute(ctx context.Context, in *v16.ExecuteRequest, opts ...grpc.CallOption) (*v16.ExecuteResponse, error) // StreamExecute executes a streaming query. Use this method if the // query returns a large number of rows. The first QueryResult will // contain the Fields, subsequent QueryResult messages will contain // the rows. StreamExecute(ctx context.Context, in *v16.StreamExecuteRequest, opts ...grpc.CallOption) (Query_StreamExecuteClient, error) // Begin a transaction. Begin(ctx context.Context, in *v16.BeginRequest, opts ...grpc.CallOption) (*v16.BeginResponse, error) // Commit a transaction. Commit(ctx context.Context, in *v16.CommitRequest, opts ...grpc.CallOption) (*v16.CommitResponse, error) // Rollback a transaction. Rollback(ctx context.Context, in *v16.RollbackRequest, opts ...grpc.CallOption) (*v16.RollbackResponse, error) // Prepare preares a transaction. Prepare(ctx context.Context, in *v16.PrepareRequest, opts ...grpc.CallOption) (*v16.PrepareResponse, error) // CommitPrepared commits a prepared transaction. CommitPrepared(ctx context.Context, in *v16.CommitPreparedRequest, opts ...grpc.CallOption) (*v16.CommitPreparedResponse, error) // RollbackPrepared rolls back a prepared transaction. RollbackPrepared(ctx context.Context, in *v16.RollbackPreparedRequest, opts ...grpc.CallOption) (*v16.RollbackPreparedResponse, error) // CreateTransaction creates the metadata for a 2pc transaction. CreateTransaction(ctx context.Context, in *v16.CreateTransactionRequest, opts ...grpc.CallOption) (*v16.CreateTransactionResponse, error) // StartCommit initiates a commit for a 2pc transaction. StartCommit(ctx context.Context, in *v16.StartCommitRequest, opts ...grpc.CallOption) (*v16.StartCommitResponse, error) // SetRollback marks the 2pc transaction for rollback. SetRollback(ctx context.Context, in *v16.SetRollbackRequest, opts ...grpc.CallOption) (*v16.SetRollbackResponse, error) // ConcludeTransaction marks the 2pc transaction as resolved. ConcludeTransaction(ctx context.Context, in *v16.ConcludeTransactionRequest, opts ...grpc.CallOption) (*v16.ConcludeTransactionResponse, error) // ReadTransaction returns the 2pc transaction info. ReadTransaction(ctx context.Context, in *v16.ReadTransactionRequest, opts ...grpc.CallOption) (*v16.ReadTransactionResponse, error) // BeginExecute executes a begin and the specified SQL query. BeginExecute(ctx context.Context, in *v16.BeginExecuteRequest, opts ...grpc.CallOption) (*v16.BeginExecuteResponse, error) // BeginStreamExecute executes a begin and the specified SQL query. BeginStreamExecute(ctx context.Context, in *v16.BeginStreamExecuteRequest, opts ...grpc.CallOption) (Query_BeginStreamExecuteClient, error) // MessageStream streams messages from a message table. MessageStream(ctx context.Context, in *v16.MessageStreamRequest, opts ...grpc.CallOption) (Query_MessageStreamClient, error) // MessageAck acks messages for a table. MessageAck(ctx context.Context, in *v16.MessageAckRequest, opts ...grpc.CallOption) (*v16.MessageAckResponse, error) // ReserveExecute executes a query on a reserved connection ReserveExecute(ctx context.Context, in *v16.ReserveExecuteRequest, opts ...grpc.CallOption) (*v16.ReserveExecuteResponse, error) // ReserveBeginExecute starts a transaction and executes a query in the transaction on a reserved connection ReserveBeginExecute(ctx context.Context, in *v16.ReserveBeginExecuteRequest, opts ...grpc.CallOption) (*v16.ReserveBeginExecuteResponse, error) // ReserveStreamExecute executes a streaming query on a reserved connection ReserveStreamExecute(ctx context.Context, in *v16.ReserveStreamExecuteRequest, opts ...grpc.CallOption) (Query_ReserveStreamExecuteClient, error) // ReserveBeginStreamExecute starts a transaction and executes a streaming query in the transaction on a reserved connection ReserveBeginStreamExecute(ctx context.Context, in *v16.ReserveBeginStreamExecuteRequest, opts ...grpc.CallOption) (Query_ReserveBeginStreamExecuteClient, error) // Release releases the connection Release(ctx context.Context, in *v16.ReleaseRequest, opts ...grpc.CallOption) (*v16.ReleaseResponse, error) // StreamHealth runs a streaming RPC to the tablet, that returns the // current health of the tablet on a regular basis. StreamHealth(ctx context.Context, in *v16.StreamHealthRequest, opts ...grpc.CallOption) (Query_StreamHealthClient, error) // VStream streams vreplication events. VStream(ctx context.Context, in *v161.VStreamRequest, opts ...grpc.CallOption) (Query_VStreamClient, error) // VStreamRows streams rows from the specified starting point. VStreamRows(ctx context.Context, in *v161.VStreamRowsRequest, opts ...grpc.CallOption) (Query_VStreamRowsClient, error) // VStreamResults streams results along with the gtid of the snapshot. VStreamResults(ctx context.Context, in *v161.VStreamResultsRequest, opts ...grpc.CallOption) (Query_VStreamResultsClient, error) // GetSchema returns the schema information. GetSchema(ctx context.Context, in *v16.GetSchemaRequest, opts ...grpc.CallOption) (Query_GetSchemaClient, error) }
QueryClient is the client API for Query service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewQueryClient ¶
func NewQueryClient(cc grpc.ClientConnInterface) QueryClient
type QueryServer ¶
type QueryServer interface { // Execute executes the specified SQL query (might be in a // transaction context, if Query.transaction_id is set). Execute(context.Context, *v16.ExecuteRequest) (*v16.ExecuteResponse, error) // StreamExecute executes a streaming query. Use this method if the // query returns a large number of rows. The first QueryResult will // contain the Fields, subsequent QueryResult messages will contain // the rows. StreamExecute(*v16.StreamExecuteRequest, Query_StreamExecuteServer) error // Begin a transaction. Begin(context.Context, *v16.BeginRequest) (*v16.BeginResponse, error) // Commit a transaction. Commit(context.Context, *v16.CommitRequest) (*v16.CommitResponse, error) // Rollback a transaction. Rollback(context.Context, *v16.RollbackRequest) (*v16.RollbackResponse, error) // Prepare preares a transaction. Prepare(context.Context, *v16.PrepareRequest) (*v16.PrepareResponse, error) // CommitPrepared commits a prepared transaction. CommitPrepared(context.Context, *v16.CommitPreparedRequest) (*v16.CommitPreparedResponse, error) // RollbackPrepared rolls back a prepared transaction. RollbackPrepared(context.Context, *v16.RollbackPreparedRequest) (*v16.RollbackPreparedResponse, error) // CreateTransaction creates the metadata for a 2pc transaction. CreateTransaction(context.Context, *v16.CreateTransactionRequest) (*v16.CreateTransactionResponse, error) // StartCommit initiates a commit for a 2pc transaction. StartCommit(context.Context, *v16.StartCommitRequest) (*v16.StartCommitResponse, error) // SetRollback marks the 2pc transaction for rollback. SetRollback(context.Context, *v16.SetRollbackRequest) (*v16.SetRollbackResponse, error) // ConcludeTransaction marks the 2pc transaction as resolved. ConcludeTransaction(context.Context, *v16.ConcludeTransactionRequest) (*v16.ConcludeTransactionResponse, error) // ReadTransaction returns the 2pc transaction info. ReadTransaction(context.Context, *v16.ReadTransactionRequest) (*v16.ReadTransactionResponse, error) // BeginExecute executes a begin and the specified SQL query. BeginExecute(context.Context, *v16.BeginExecuteRequest) (*v16.BeginExecuteResponse, error) // BeginStreamExecute executes a begin and the specified SQL query. BeginStreamExecute(*v16.BeginStreamExecuteRequest, Query_BeginStreamExecuteServer) error // MessageStream streams messages from a message table. MessageStream(*v16.MessageStreamRequest, Query_MessageStreamServer) error // MessageAck acks messages for a table. MessageAck(context.Context, *v16.MessageAckRequest) (*v16.MessageAckResponse, error) // ReserveExecute executes a query on a reserved connection ReserveExecute(context.Context, *v16.ReserveExecuteRequest) (*v16.ReserveExecuteResponse, error) // ReserveBeginExecute starts a transaction and executes a query in the transaction on a reserved connection ReserveBeginExecute(context.Context, *v16.ReserveBeginExecuteRequest) (*v16.ReserveBeginExecuteResponse, error) // ReserveStreamExecute executes a streaming query on a reserved connection ReserveStreamExecute(*v16.ReserveStreamExecuteRequest, Query_ReserveStreamExecuteServer) error // ReserveBeginStreamExecute starts a transaction and executes a streaming query in the transaction on a reserved connection ReserveBeginStreamExecute(*v16.ReserveBeginStreamExecuteRequest, Query_ReserveBeginStreamExecuteServer) error // Release releases the connection Release(context.Context, *v16.ReleaseRequest) (*v16.ReleaseResponse, error) // StreamHealth runs a streaming RPC to the tablet, that returns the // current health of the tablet on a regular basis. StreamHealth(*v16.StreamHealthRequest, Query_StreamHealthServer) error // VStream streams vreplication events. VStream(*v161.VStreamRequest, Query_VStreamServer) error // VStreamRows streams rows from the specified starting point. VStreamRows(*v161.VStreamRowsRequest, Query_VStreamRowsServer) error // VStreamResults streams results along with the gtid of the snapshot. VStreamResults(*v161.VStreamResultsRequest, Query_VStreamResultsServer) error // GetSchema returns the schema information. GetSchema(*v16.GetSchemaRequest, Query_GetSchemaServer) error }
QueryServer is the server API for Query service. All implementations should embed UnimplementedQueryServer for forward compatibility
type Query_BeginStreamExecuteClient ¶
type Query_BeginStreamExecuteClient interface { Recv() (*v16.BeginStreamExecuteResponse, error) grpc.ClientStream }
type Query_BeginStreamExecuteServer ¶
type Query_BeginStreamExecuteServer interface { Send(*v16.BeginStreamExecuteResponse) error grpc.ServerStream }
type Query_GetSchemaClient ¶
type Query_GetSchemaClient interface { Recv() (*v16.GetSchemaResponse, error) grpc.ClientStream }
type Query_GetSchemaServer ¶
type Query_GetSchemaServer interface { Send(*v16.GetSchemaResponse) error grpc.ServerStream }
type Query_MessageStreamClient ¶
type Query_MessageStreamClient interface { Recv() (*v16.MessageStreamResponse, error) grpc.ClientStream }
type Query_MessageStreamServer ¶
type Query_MessageStreamServer interface { Send(*v16.MessageStreamResponse) error grpc.ServerStream }
type Query_ReserveBeginStreamExecuteClient ¶
type Query_ReserveBeginStreamExecuteClient interface { Recv() (*v16.ReserveBeginStreamExecuteResponse, error) grpc.ClientStream }
type Query_ReserveBeginStreamExecuteServer ¶
type Query_ReserveBeginStreamExecuteServer interface { Send(*v16.ReserveBeginStreamExecuteResponse) error grpc.ServerStream }
type Query_ReserveStreamExecuteClient ¶
type Query_ReserveStreamExecuteClient interface { Recv() (*v16.ReserveStreamExecuteResponse, error) grpc.ClientStream }
type Query_ReserveStreamExecuteServer ¶
type Query_ReserveStreamExecuteServer interface { Send(*v16.ReserveStreamExecuteResponse) error grpc.ServerStream }
type Query_StreamExecuteClient ¶
type Query_StreamExecuteClient interface { Recv() (*v16.StreamExecuteResponse, error) grpc.ClientStream }
type Query_StreamExecuteServer ¶
type Query_StreamExecuteServer interface { Send(*v16.StreamExecuteResponse) error grpc.ServerStream }
type Query_StreamHealthClient ¶
type Query_StreamHealthClient interface { Recv() (*v16.StreamHealthResponse, error) grpc.ClientStream }
type Query_StreamHealthServer ¶
type Query_StreamHealthServer interface { Send(*v16.StreamHealthResponse) error grpc.ServerStream }
type Query_VStreamClient ¶
type Query_VStreamClient interface { Recv() (*v161.VStreamResponse, error) grpc.ClientStream }
type Query_VStreamResultsClient ¶
type Query_VStreamResultsClient interface { Recv() (*v161.VStreamResultsResponse, error) grpc.ClientStream }
type Query_VStreamResultsServer ¶
type Query_VStreamResultsServer interface { Send(*v161.VStreamResultsResponse) error grpc.ServerStream }
type Query_VStreamRowsClient ¶
type Query_VStreamRowsClient interface { Recv() (*v161.VStreamRowsResponse, error) grpc.ClientStream }
type Query_VStreamRowsServer ¶
type Query_VStreamRowsServer interface { Send(*v161.VStreamRowsResponse) error grpc.ServerStream }
type Query_VStreamServer ¶
type Query_VStreamServer interface { Send(*v161.VStreamResponse) error grpc.ServerStream }
type UnimplementedQueryServer ¶
type UnimplementedQueryServer struct { }
UnimplementedQueryServer should be embedded to have forward compatible implementations.
func (UnimplementedQueryServer) Begin ¶
func (UnimplementedQueryServer) Begin(context.Context, *v16.BeginRequest) (*v16.BeginResponse, error)
func (UnimplementedQueryServer) BeginExecute ¶
func (UnimplementedQueryServer) BeginExecute(context.Context, *v16.BeginExecuteRequest) (*v16.BeginExecuteResponse, error)
func (UnimplementedQueryServer) BeginStreamExecute ¶
func (UnimplementedQueryServer) BeginStreamExecute(*v16.BeginStreamExecuteRequest, Query_BeginStreamExecuteServer) error
func (UnimplementedQueryServer) Commit ¶
func (UnimplementedQueryServer) Commit(context.Context, *v16.CommitRequest) (*v16.CommitResponse, error)
func (UnimplementedQueryServer) CommitPrepared ¶
func (UnimplementedQueryServer) CommitPrepared(context.Context, *v16.CommitPreparedRequest) (*v16.CommitPreparedResponse, error)
func (UnimplementedQueryServer) ConcludeTransaction ¶
func (UnimplementedQueryServer) ConcludeTransaction(context.Context, *v16.ConcludeTransactionRequest) (*v16.ConcludeTransactionResponse, error)
func (UnimplementedQueryServer) CreateTransaction ¶
func (UnimplementedQueryServer) CreateTransaction(context.Context, *v16.CreateTransactionRequest) (*v16.CreateTransactionResponse, error)
func (UnimplementedQueryServer) Execute ¶
func (UnimplementedQueryServer) Execute(context.Context, *v16.ExecuteRequest) (*v16.ExecuteResponse, error)
func (UnimplementedQueryServer) GetSchema ¶
func (UnimplementedQueryServer) GetSchema(*v16.GetSchemaRequest, Query_GetSchemaServer) error
func (UnimplementedQueryServer) MessageAck ¶
func (UnimplementedQueryServer) MessageAck(context.Context, *v16.MessageAckRequest) (*v16.MessageAckResponse, error)
func (UnimplementedQueryServer) MessageStream ¶
func (UnimplementedQueryServer) MessageStream(*v16.MessageStreamRequest, Query_MessageStreamServer) error
func (UnimplementedQueryServer) Prepare ¶
func (UnimplementedQueryServer) Prepare(context.Context, *v16.PrepareRequest) (*v16.PrepareResponse, error)
func (UnimplementedQueryServer) ReadTransaction ¶
func (UnimplementedQueryServer) ReadTransaction(context.Context, *v16.ReadTransactionRequest) (*v16.ReadTransactionResponse, error)
func (UnimplementedQueryServer) Release ¶
func (UnimplementedQueryServer) Release(context.Context, *v16.ReleaseRequest) (*v16.ReleaseResponse, error)
func (UnimplementedQueryServer) ReserveBeginExecute ¶
func (UnimplementedQueryServer) ReserveBeginExecute(context.Context, *v16.ReserveBeginExecuteRequest) (*v16.ReserveBeginExecuteResponse, error)
func (UnimplementedQueryServer) ReserveBeginStreamExecute ¶
func (UnimplementedQueryServer) ReserveBeginStreamExecute(*v16.ReserveBeginStreamExecuteRequest, Query_ReserveBeginStreamExecuteServer) error
func (UnimplementedQueryServer) ReserveExecute ¶
func (UnimplementedQueryServer) ReserveExecute(context.Context, *v16.ReserveExecuteRequest) (*v16.ReserveExecuteResponse, error)
func (UnimplementedQueryServer) ReserveStreamExecute ¶
func (UnimplementedQueryServer) ReserveStreamExecute(*v16.ReserveStreamExecuteRequest, Query_ReserveStreamExecuteServer) error
func (UnimplementedQueryServer) Rollback ¶
func (UnimplementedQueryServer) Rollback(context.Context, *v16.RollbackRequest) (*v16.RollbackResponse, error)
func (UnimplementedQueryServer) RollbackPrepared ¶
func (UnimplementedQueryServer) RollbackPrepared(context.Context, *v16.RollbackPreparedRequest) (*v16.RollbackPreparedResponse, error)
func (UnimplementedQueryServer) SetRollback ¶
func (UnimplementedQueryServer) SetRollback(context.Context, *v16.SetRollbackRequest) (*v16.SetRollbackResponse, error)
func (UnimplementedQueryServer) StartCommit ¶
func (UnimplementedQueryServer) StartCommit(context.Context, *v16.StartCommitRequest) (*v16.StartCommitResponse, error)
func (UnimplementedQueryServer) StreamExecute ¶
func (UnimplementedQueryServer) StreamExecute(*v16.StreamExecuteRequest, Query_StreamExecuteServer) error
func (UnimplementedQueryServer) StreamHealth ¶
func (UnimplementedQueryServer) StreamHealth(*v16.StreamHealthRequest, Query_StreamHealthServer) error
func (UnimplementedQueryServer) VStream ¶
func (UnimplementedQueryServer) VStream(*v161.VStreamRequest, Query_VStreamServer) error
func (UnimplementedQueryServer) VStreamResults ¶
func (UnimplementedQueryServer) VStreamResults(*v161.VStreamResultsRequest, Query_VStreamResultsServer) error
func (UnimplementedQueryServer) VStreamRows ¶
func (UnimplementedQueryServer) VStreamRows(*v161.VStreamRowsRequest, Query_VStreamRowsServer) error
type UnsafeQueryServer ¶
type UnsafeQueryServer interface {
// contains filtered or unexported methods
}
UnsafeQueryServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to QueryServer will result in compilation errors.