Documentation ¶
Index ¶
- Constants
- func NewQueryHandler(svc QueryHandler, opts ...connect.HandlerOption) (string, http.Handler)
- type QueryClient
- type QueryHandler
- type UnimplementedQueryHandler
- func (UnimplementedQueryHandler) Begin(context.Context, *connect.Request[dev.BeginRequest]) (*connect.Response[dev.BeginResponse], error)
- func (UnimplementedQueryHandler) BeginExecute(context.Context, *connect.Request[dev.BeginExecuteRequest]) (*connect.Response[dev.BeginExecuteResponse], error)
- func (UnimplementedQueryHandler) BeginStreamExecute(context.Context, *connect.Request[dev.BeginStreamExecuteRequest], ...) error
- func (UnimplementedQueryHandler) Commit(context.Context, *connect.Request[dev.CommitRequest]) (*connect.Response[dev.CommitResponse], error)
- func (UnimplementedQueryHandler) CommitPrepared(context.Context, *connect.Request[dev.CommitPreparedRequest]) (*connect.Response[dev.CommitPreparedResponse], error)
- func (UnimplementedQueryHandler) ConcludeTransaction(context.Context, *connect.Request[dev.ConcludeTransactionRequest]) (*connect.Response[dev.ConcludeTransactionResponse], error)
- func (UnimplementedQueryHandler) CreateTransaction(context.Context, *connect.Request[dev.CreateTransactionRequest]) (*connect.Response[dev.CreateTransactionResponse], error)
- func (UnimplementedQueryHandler) Execute(context.Context, *connect.Request[dev.ExecuteRequest]) (*connect.Response[dev.ExecuteResponse], error)
- func (UnimplementedQueryHandler) GetSchema(context.Context, *connect.Request[dev.GetSchemaRequest], ...) error
- func (UnimplementedQueryHandler) MessageAck(context.Context, *connect.Request[dev.MessageAckRequest]) (*connect.Response[dev.MessageAckResponse], error)
- func (UnimplementedQueryHandler) MessageStream(context.Context, *connect.Request[dev.MessageStreamRequest], ...) error
- func (UnimplementedQueryHandler) Prepare(context.Context, *connect.Request[dev.PrepareRequest]) (*connect.Response[dev.PrepareResponse], error)
- func (UnimplementedQueryHandler) ReadTransaction(context.Context, *connect.Request[dev.ReadTransactionRequest]) (*connect.Response[dev.ReadTransactionResponse], error)
- func (UnimplementedQueryHandler) Release(context.Context, *connect.Request[dev.ReleaseRequest]) (*connect.Response[dev.ReleaseResponse], error)
- func (UnimplementedQueryHandler) ReserveBeginExecute(context.Context, *connect.Request[dev.ReserveBeginExecuteRequest]) (*connect.Response[dev.ReserveBeginExecuteResponse], error)
- func (UnimplementedQueryHandler) ReserveBeginStreamExecute(context.Context, *connect.Request[dev.ReserveBeginStreamExecuteRequest], ...) error
- func (UnimplementedQueryHandler) ReserveExecute(context.Context, *connect.Request[dev.ReserveExecuteRequest]) (*connect.Response[dev.ReserveExecuteResponse], error)
- func (UnimplementedQueryHandler) ReserveStreamExecute(context.Context, *connect.Request[dev.ReserveStreamExecuteRequest], ...) error
- func (UnimplementedQueryHandler) Rollback(context.Context, *connect.Request[dev.RollbackRequest]) (*connect.Response[dev.RollbackResponse], error)
- func (UnimplementedQueryHandler) RollbackPrepared(context.Context, *connect.Request[dev.RollbackPreparedRequest]) (*connect.Response[dev.RollbackPreparedResponse], error)
- func (UnimplementedQueryHandler) SetRollback(context.Context, *connect.Request[dev.SetRollbackRequest]) (*connect.Response[dev.SetRollbackResponse], error)
- func (UnimplementedQueryHandler) StartCommit(context.Context, *connect.Request[dev.StartCommitRequest]) (*connect.Response[dev.StartCommitResponse], error)
- func (UnimplementedQueryHandler) StreamExecute(context.Context, *connect.Request[dev.StreamExecuteRequest], ...) error
- func (UnimplementedQueryHandler) StreamHealth(context.Context, *connect.Request[dev.StreamHealthRequest], ...) error
- func (UnimplementedQueryHandler) VStream(context.Context, *connect.Request[dev1.VStreamRequest], ...) error
- func (UnimplementedQueryHandler) VStreamResults(context.Context, *connect.Request[dev1.VStreamResultsRequest], ...) error
- func (UnimplementedQueryHandler) VStreamRows(context.Context, *connect.Request[dev1.VStreamRowsRequest], ...) error
- func (UnimplementedQueryHandler) VStreamTables(context.Context, *connect.Request[dev1.VStreamTablesRequest], ...) error
Constants ¶
const ( // QueryExecuteProcedure is the fully-qualified name of the Query's Execute RPC. QueryExecuteProcedure = "/queryservice.Query/Execute" // QueryStreamExecuteProcedure is the fully-qualified name of the Query's StreamExecute RPC. QueryStreamExecuteProcedure = "/queryservice.Query/StreamExecute" // QueryBeginProcedure is the fully-qualified name of the Query's Begin RPC. QueryBeginProcedure = "/queryservice.Query/Begin" // QueryCommitProcedure is the fully-qualified name of the Query's Commit RPC. QueryCommitProcedure = "/queryservice.Query/Commit" // QueryRollbackProcedure is the fully-qualified name of the Query's Rollback RPC. QueryRollbackProcedure = "/queryservice.Query/Rollback" // QueryPrepareProcedure is the fully-qualified name of the Query's Prepare RPC. QueryPrepareProcedure = "/queryservice.Query/Prepare" // QueryCommitPreparedProcedure is the fully-qualified name of the Query's CommitPrepared RPC. QueryCommitPreparedProcedure = "/queryservice.Query/CommitPrepared" // QueryRollbackPreparedProcedure is the fully-qualified name of the Query's RollbackPrepared RPC. QueryRollbackPreparedProcedure = "/queryservice.Query/RollbackPrepared" // QueryCreateTransactionProcedure is the fully-qualified name of the Query's CreateTransaction RPC. QueryCreateTransactionProcedure = "/queryservice.Query/CreateTransaction" // QueryStartCommitProcedure is the fully-qualified name of the Query's StartCommit RPC. QueryStartCommitProcedure = "/queryservice.Query/StartCommit" // QuerySetRollbackProcedure is the fully-qualified name of the Query's SetRollback RPC. QuerySetRollbackProcedure = "/queryservice.Query/SetRollback" // QueryConcludeTransactionProcedure is the fully-qualified name of the Query's ConcludeTransaction // RPC. QueryConcludeTransactionProcedure = "/queryservice.Query/ConcludeTransaction" // QueryReadTransactionProcedure is the fully-qualified name of the Query's ReadTransaction RPC. QueryReadTransactionProcedure = "/queryservice.Query/ReadTransaction" // QueryBeginExecuteProcedure is the fully-qualified name of the Query's BeginExecute RPC. QueryBeginExecuteProcedure = "/queryservice.Query/BeginExecute" // QueryBeginStreamExecuteProcedure is the fully-qualified name of the Query's BeginStreamExecute // RPC. QueryBeginStreamExecuteProcedure = "/queryservice.Query/BeginStreamExecute" // QueryMessageStreamProcedure is the fully-qualified name of the Query's MessageStream RPC. QueryMessageStreamProcedure = "/queryservice.Query/MessageStream" // QueryMessageAckProcedure is the fully-qualified name of the Query's MessageAck RPC. QueryMessageAckProcedure = "/queryservice.Query/MessageAck" // QueryReserveExecuteProcedure is the fully-qualified name of the Query's ReserveExecute RPC. QueryReserveExecuteProcedure = "/queryservice.Query/ReserveExecute" // QueryReserveBeginExecuteProcedure is the fully-qualified name of the Query's ReserveBeginExecute // RPC. QueryReserveBeginExecuteProcedure = "/queryservice.Query/ReserveBeginExecute" // QueryReserveStreamExecuteProcedure is the fully-qualified name of the Query's // ReserveStreamExecute RPC. QueryReserveStreamExecuteProcedure = "/queryservice.Query/ReserveStreamExecute" // QueryReserveBeginStreamExecuteProcedure is the fully-qualified name of the Query's // ReserveBeginStreamExecute RPC. QueryReserveBeginStreamExecuteProcedure = "/queryservice.Query/ReserveBeginStreamExecute" // QueryReleaseProcedure is the fully-qualified name of the Query's Release RPC. QueryReleaseProcedure = "/queryservice.Query/Release" // QueryStreamHealthProcedure is the fully-qualified name of the Query's StreamHealth RPC. QueryStreamHealthProcedure = "/queryservice.Query/StreamHealth" // QueryVStreamProcedure is the fully-qualified name of the Query's VStream RPC. QueryVStreamProcedure = "/queryservice.Query/VStream" // QueryVStreamRowsProcedure is the fully-qualified name of the Query's VStreamRows RPC. QueryVStreamRowsProcedure = "/queryservice.Query/VStreamRows" // QueryVStreamTablesProcedure is the fully-qualified name of the Query's VStreamTables RPC. QueryVStreamTablesProcedure = "/queryservice.Query/VStreamTables" // QueryVStreamResultsProcedure is the fully-qualified name of the Query's VStreamResults RPC. QueryVStreamResultsProcedure = "/queryservice.Query/VStreamResults" // QueryGetSchemaProcedure is the fully-qualified name of the Query's GetSchema RPC. QueryGetSchemaProcedure = "/queryservice.Query/GetSchema" )
These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.
Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.
const (
// QueryName is the fully-qualified name of the Query service.
QueryName = "queryservice.Query"
)
Variables ¶
This section is empty.
Functions ¶
func NewQueryHandler ¶
func NewQueryHandler(svc QueryHandler, opts ...connect.HandlerOption) (string, http.Handler)
NewQueryHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.
By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.
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(context.Context, *connect.Request[dev.ExecuteRequest]) (*connect.Response[dev.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(context.Context, *connect.Request[dev.StreamExecuteRequest]) (*connect.ServerStreamForClient[dev.StreamExecuteResponse], error) // Begin a transaction. Begin(context.Context, *connect.Request[dev.BeginRequest]) (*connect.Response[dev.BeginResponse], error) // Commit a transaction. Commit(context.Context, *connect.Request[dev.CommitRequest]) (*connect.Response[dev.CommitResponse], error) // Rollback a transaction. Rollback(context.Context, *connect.Request[dev.RollbackRequest]) (*connect.Response[dev.RollbackResponse], error) // Prepare preares a transaction. Prepare(context.Context, *connect.Request[dev.PrepareRequest]) (*connect.Response[dev.PrepareResponse], error) // CommitPrepared commits a prepared transaction. CommitPrepared(context.Context, *connect.Request[dev.CommitPreparedRequest]) (*connect.Response[dev.CommitPreparedResponse], error) // RollbackPrepared rolls back a prepared transaction. RollbackPrepared(context.Context, *connect.Request[dev.RollbackPreparedRequest]) (*connect.Response[dev.RollbackPreparedResponse], error) // CreateTransaction creates the metadata for a 2pc transaction. CreateTransaction(context.Context, *connect.Request[dev.CreateTransactionRequest]) (*connect.Response[dev.CreateTransactionResponse], error) // StartCommit initiates a commit for a 2pc transaction. StartCommit(context.Context, *connect.Request[dev.StartCommitRequest]) (*connect.Response[dev.StartCommitResponse], error) // SetRollback marks the 2pc transaction for rollback. SetRollback(context.Context, *connect.Request[dev.SetRollbackRequest]) (*connect.Response[dev.SetRollbackResponse], error) // ConcludeTransaction marks the 2pc transaction as resolved. ConcludeTransaction(context.Context, *connect.Request[dev.ConcludeTransactionRequest]) (*connect.Response[dev.ConcludeTransactionResponse], error) // ReadTransaction returns the 2pc transaction info. ReadTransaction(context.Context, *connect.Request[dev.ReadTransactionRequest]) (*connect.Response[dev.ReadTransactionResponse], error) // BeginExecute executes a begin and the specified SQL query. BeginExecute(context.Context, *connect.Request[dev.BeginExecuteRequest]) (*connect.Response[dev.BeginExecuteResponse], error) // BeginStreamExecute executes a begin and the specified SQL query. BeginStreamExecute(context.Context, *connect.Request[dev.BeginStreamExecuteRequest]) (*connect.ServerStreamForClient[dev.BeginStreamExecuteResponse], error) // MessageStream streams messages from a message table. MessageStream(context.Context, *connect.Request[dev.MessageStreamRequest]) (*connect.ServerStreamForClient[dev.MessageStreamResponse], error) // MessageAck acks messages for a table. MessageAck(context.Context, *connect.Request[dev.MessageAckRequest]) (*connect.Response[dev.MessageAckResponse], error) // ReserveExecute executes a query on a reserved connection ReserveExecute(context.Context, *connect.Request[dev.ReserveExecuteRequest]) (*connect.Response[dev.ReserveExecuteResponse], error) // ReserveBeginExecute starts a transaction and executes a query in the transaction on a reserved connection ReserveBeginExecute(context.Context, *connect.Request[dev.ReserveBeginExecuteRequest]) (*connect.Response[dev.ReserveBeginExecuteResponse], error) // ReserveStreamExecute executes a streaming query on a reserved connection ReserveStreamExecute(context.Context, *connect.Request[dev.ReserveStreamExecuteRequest]) (*connect.ServerStreamForClient[dev.ReserveStreamExecuteResponse], error) // ReserveBeginStreamExecute starts a transaction and executes a streaming query in the transaction on a reserved connection ReserveBeginStreamExecute(context.Context, *connect.Request[dev.ReserveBeginStreamExecuteRequest]) (*connect.ServerStreamForClient[dev.ReserveBeginStreamExecuteResponse], error) // Release releases the connection Release(context.Context, *connect.Request[dev.ReleaseRequest]) (*connect.Response[dev.ReleaseResponse], error) // StreamHealth runs a streaming RPC to the tablet, that returns the // current health of the tablet on a regular basis. StreamHealth(context.Context, *connect.Request[dev.StreamHealthRequest]) (*connect.ServerStreamForClient[dev.StreamHealthResponse], error) // VStream streams vreplication events. VStream(context.Context, *connect.Request[dev1.VStreamRequest]) (*connect.ServerStreamForClient[dev1.VStreamResponse], error) // VStreamRows streams rows from the specified starting point. VStreamRows(context.Context, *connect.Request[dev1.VStreamRowsRequest]) (*connect.ServerStreamForClient[dev1.VStreamRowsResponse], error) // VStreamTables streams rows from the specified starting point. VStreamTables(context.Context, *connect.Request[dev1.VStreamTablesRequest]) (*connect.ServerStreamForClient[dev1.VStreamTablesResponse], error) // VStreamResults streams results along with the gtid of the snapshot. VStreamResults(context.Context, *connect.Request[dev1.VStreamResultsRequest]) (*connect.ServerStreamForClient[dev1.VStreamResultsResponse], error) // GetSchema returns the schema information. GetSchema(context.Context, *connect.Request[dev.GetSchemaRequest]) (*connect.ServerStreamForClient[dev.GetSchemaResponse], error) }
QueryClient is a client for the queryservice.Query service.
func NewQueryClient ¶
func NewQueryClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) QueryClient
NewQueryClient constructs a client for the queryservice.Query service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.
The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).
type QueryHandler ¶
type QueryHandler interface { // Execute executes the specified SQL query (might be in a // transaction context, if Query.transaction_id is set). Execute(context.Context, *connect.Request[dev.ExecuteRequest]) (*connect.Response[dev.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(context.Context, *connect.Request[dev.StreamExecuteRequest], *connect.ServerStream[dev.StreamExecuteResponse]) error // Begin a transaction. Begin(context.Context, *connect.Request[dev.BeginRequest]) (*connect.Response[dev.BeginResponse], error) // Commit a transaction. Commit(context.Context, *connect.Request[dev.CommitRequest]) (*connect.Response[dev.CommitResponse], error) // Rollback a transaction. Rollback(context.Context, *connect.Request[dev.RollbackRequest]) (*connect.Response[dev.RollbackResponse], error) // Prepare preares a transaction. Prepare(context.Context, *connect.Request[dev.PrepareRequest]) (*connect.Response[dev.PrepareResponse], error) // CommitPrepared commits a prepared transaction. CommitPrepared(context.Context, *connect.Request[dev.CommitPreparedRequest]) (*connect.Response[dev.CommitPreparedResponse], error) // RollbackPrepared rolls back a prepared transaction. RollbackPrepared(context.Context, *connect.Request[dev.RollbackPreparedRequest]) (*connect.Response[dev.RollbackPreparedResponse], error) // CreateTransaction creates the metadata for a 2pc transaction. CreateTransaction(context.Context, *connect.Request[dev.CreateTransactionRequest]) (*connect.Response[dev.CreateTransactionResponse], error) // StartCommit initiates a commit for a 2pc transaction. StartCommit(context.Context, *connect.Request[dev.StartCommitRequest]) (*connect.Response[dev.StartCommitResponse], error) // SetRollback marks the 2pc transaction for rollback. SetRollback(context.Context, *connect.Request[dev.SetRollbackRequest]) (*connect.Response[dev.SetRollbackResponse], error) // ConcludeTransaction marks the 2pc transaction as resolved. ConcludeTransaction(context.Context, *connect.Request[dev.ConcludeTransactionRequest]) (*connect.Response[dev.ConcludeTransactionResponse], error) // ReadTransaction returns the 2pc transaction info. ReadTransaction(context.Context, *connect.Request[dev.ReadTransactionRequest]) (*connect.Response[dev.ReadTransactionResponse], error) // BeginExecute executes a begin and the specified SQL query. BeginExecute(context.Context, *connect.Request[dev.BeginExecuteRequest]) (*connect.Response[dev.BeginExecuteResponse], error) // BeginStreamExecute executes a begin and the specified SQL query. BeginStreamExecute(context.Context, *connect.Request[dev.BeginStreamExecuteRequest], *connect.ServerStream[dev.BeginStreamExecuteResponse]) error // MessageStream streams messages from a message table. MessageStream(context.Context, *connect.Request[dev.MessageStreamRequest], *connect.ServerStream[dev.MessageStreamResponse]) error // MessageAck acks messages for a table. MessageAck(context.Context, *connect.Request[dev.MessageAckRequest]) (*connect.Response[dev.MessageAckResponse], error) // ReserveExecute executes a query on a reserved connection ReserveExecute(context.Context, *connect.Request[dev.ReserveExecuteRequest]) (*connect.Response[dev.ReserveExecuteResponse], error) // ReserveBeginExecute starts a transaction and executes a query in the transaction on a reserved connection ReserveBeginExecute(context.Context, *connect.Request[dev.ReserveBeginExecuteRequest]) (*connect.Response[dev.ReserveBeginExecuteResponse], error) // ReserveStreamExecute executes a streaming query on a reserved connection ReserveStreamExecute(context.Context, *connect.Request[dev.ReserveStreamExecuteRequest], *connect.ServerStream[dev.ReserveStreamExecuteResponse]) error // ReserveBeginStreamExecute starts a transaction and executes a streaming query in the transaction on a reserved connection ReserveBeginStreamExecute(context.Context, *connect.Request[dev.ReserveBeginStreamExecuteRequest], *connect.ServerStream[dev.ReserveBeginStreamExecuteResponse]) error // Release releases the connection Release(context.Context, *connect.Request[dev.ReleaseRequest]) (*connect.Response[dev.ReleaseResponse], error) // StreamHealth runs a streaming RPC to the tablet, that returns the // current health of the tablet on a regular basis. StreamHealth(context.Context, *connect.Request[dev.StreamHealthRequest], *connect.ServerStream[dev.StreamHealthResponse]) error // VStream streams vreplication events. VStream(context.Context, *connect.Request[dev1.VStreamRequest], *connect.ServerStream[dev1.VStreamResponse]) error // VStreamRows streams rows from the specified starting point. VStreamRows(context.Context, *connect.Request[dev1.VStreamRowsRequest], *connect.ServerStream[dev1.VStreamRowsResponse]) error // VStreamTables streams rows from the specified starting point. VStreamTables(context.Context, *connect.Request[dev1.VStreamTablesRequest], *connect.ServerStream[dev1.VStreamTablesResponse]) error // VStreamResults streams results along with the gtid of the snapshot. VStreamResults(context.Context, *connect.Request[dev1.VStreamResultsRequest], *connect.ServerStream[dev1.VStreamResultsResponse]) error // GetSchema returns the schema information. GetSchema(context.Context, *connect.Request[dev.GetSchemaRequest], *connect.ServerStream[dev.GetSchemaResponse]) error }
QueryHandler is an implementation of the queryservice.Query service.
type UnimplementedQueryHandler ¶
type UnimplementedQueryHandler struct{}
UnimplementedQueryHandler returns CodeUnimplemented from all methods.
func (UnimplementedQueryHandler) Begin ¶
func (UnimplementedQueryHandler) Begin(context.Context, *connect.Request[dev.BeginRequest]) (*connect.Response[dev.BeginResponse], error)
func (UnimplementedQueryHandler) BeginExecute ¶
func (UnimplementedQueryHandler) BeginExecute(context.Context, *connect.Request[dev.BeginExecuteRequest]) (*connect.Response[dev.BeginExecuteResponse], error)
func (UnimplementedQueryHandler) BeginStreamExecute ¶
func (UnimplementedQueryHandler) BeginStreamExecute(context.Context, *connect.Request[dev.BeginStreamExecuteRequest], *connect.ServerStream[dev.BeginStreamExecuteResponse]) error
func (UnimplementedQueryHandler) Commit ¶
func (UnimplementedQueryHandler) Commit(context.Context, *connect.Request[dev.CommitRequest]) (*connect.Response[dev.CommitResponse], error)
func (UnimplementedQueryHandler) CommitPrepared ¶
func (UnimplementedQueryHandler) CommitPrepared(context.Context, *connect.Request[dev.CommitPreparedRequest]) (*connect.Response[dev.CommitPreparedResponse], error)
func (UnimplementedQueryHandler) ConcludeTransaction ¶
func (UnimplementedQueryHandler) ConcludeTransaction(context.Context, *connect.Request[dev.ConcludeTransactionRequest]) (*connect.Response[dev.ConcludeTransactionResponse], error)
func (UnimplementedQueryHandler) CreateTransaction ¶
func (UnimplementedQueryHandler) CreateTransaction(context.Context, *connect.Request[dev.CreateTransactionRequest]) (*connect.Response[dev.CreateTransactionResponse], error)
func (UnimplementedQueryHandler) Execute ¶
func (UnimplementedQueryHandler) Execute(context.Context, *connect.Request[dev.ExecuteRequest]) (*connect.Response[dev.ExecuteResponse], error)
func (UnimplementedQueryHandler) GetSchema ¶
func (UnimplementedQueryHandler) GetSchema(context.Context, *connect.Request[dev.GetSchemaRequest], *connect.ServerStream[dev.GetSchemaResponse]) error
func (UnimplementedQueryHandler) MessageAck ¶
func (UnimplementedQueryHandler) MessageAck(context.Context, *connect.Request[dev.MessageAckRequest]) (*connect.Response[dev.MessageAckResponse], error)
func (UnimplementedQueryHandler) MessageStream ¶
func (UnimplementedQueryHandler) MessageStream(context.Context, *connect.Request[dev.MessageStreamRequest], *connect.ServerStream[dev.MessageStreamResponse]) error
func (UnimplementedQueryHandler) Prepare ¶
func (UnimplementedQueryHandler) Prepare(context.Context, *connect.Request[dev.PrepareRequest]) (*connect.Response[dev.PrepareResponse], error)
func (UnimplementedQueryHandler) ReadTransaction ¶
func (UnimplementedQueryHandler) ReadTransaction(context.Context, *connect.Request[dev.ReadTransactionRequest]) (*connect.Response[dev.ReadTransactionResponse], error)
func (UnimplementedQueryHandler) Release ¶
func (UnimplementedQueryHandler) Release(context.Context, *connect.Request[dev.ReleaseRequest]) (*connect.Response[dev.ReleaseResponse], error)
func (UnimplementedQueryHandler) ReserveBeginExecute ¶
func (UnimplementedQueryHandler) ReserveBeginExecute(context.Context, *connect.Request[dev.ReserveBeginExecuteRequest]) (*connect.Response[dev.ReserveBeginExecuteResponse], error)
func (UnimplementedQueryHandler) ReserveBeginStreamExecute ¶
func (UnimplementedQueryHandler) ReserveBeginStreamExecute(context.Context, *connect.Request[dev.ReserveBeginStreamExecuteRequest], *connect.ServerStream[dev.ReserveBeginStreamExecuteResponse]) error
func (UnimplementedQueryHandler) ReserveExecute ¶
func (UnimplementedQueryHandler) ReserveExecute(context.Context, *connect.Request[dev.ReserveExecuteRequest]) (*connect.Response[dev.ReserveExecuteResponse], error)
func (UnimplementedQueryHandler) ReserveStreamExecute ¶
func (UnimplementedQueryHandler) ReserveStreamExecute(context.Context, *connect.Request[dev.ReserveStreamExecuteRequest], *connect.ServerStream[dev.ReserveStreamExecuteResponse]) error
func (UnimplementedQueryHandler) Rollback ¶
func (UnimplementedQueryHandler) Rollback(context.Context, *connect.Request[dev.RollbackRequest]) (*connect.Response[dev.RollbackResponse], error)
func (UnimplementedQueryHandler) RollbackPrepared ¶
func (UnimplementedQueryHandler) RollbackPrepared(context.Context, *connect.Request[dev.RollbackPreparedRequest]) (*connect.Response[dev.RollbackPreparedResponse], error)
func (UnimplementedQueryHandler) SetRollback ¶
func (UnimplementedQueryHandler) SetRollback(context.Context, *connect.Request[dev.SetRollbackRequest]) (*connect.Response[dev.SetRollbackResponse], error)
func (UnimplementedQueryHandler) StartCommit ¶
func (UnimplementedQueryHandler) StartCommit(context.Context, *connect.Request[dev.StartCommitRequest]) (*connect.Response[dev.StartCommitResponse], error)
func (UnimplementedQueryHandler) StreamExecute ¶
func (UnimplementedQueryHandler) StreamExecute(context.Context, *connect.Request[dev.StreamExecuteRequest], *connect.ServerStream[dev.StreamExecuteResponse]) error
func (UnimplementedQueryHandler) StreamHealth ¶
func (UnimplementedQueryHandler) StreamHealth(context.Context, *connect.Request[dev.StreamHealthRequest], *connect.ServerStream[dev.StreamHealthResponse]) error
func (UnimplementedQueryHandler) VStream ¶
func (UnimplementedQueryHandler) VStream(context.Context, *connect.Request[dev1.VStreamRequest], *connect.ServerStream[dev1.VStreamResponse]) error
func (UnimplementedQueryHandler) VStreamResults ¶
func (UnimplementedQueryHandler) VStreamResults(context.Context, *connect.Request[dev1.VStreamResultsRequest], *connect.ServerStream[dev1.VStreamResultsResponse]) error
func (UnimplementedQueryHandler) VStreamRows ¶
func (UnimplementedQueryHandler) VStreamRows(context.Context, *connect.Request[dev1.VStreamRowsRequest], *connect.ServerStream[dev1.VStreamRowsResponse]) error
func (UnimplementedQueryHandler) VStreamTables ¶
func (UnimplementedQueryHandler) VStreamTables(context.Context, *connect.Request[dev1.VStreamTablesRequest], *connect.ServerStream[dev1.VStreamTablesResponse]) error