Documentation ¶
Index ¶
- Variables
- func RegisterDatabaseServer(s grpc.ServiceRegistrar, srv DatabaseServer)
- type DatabaseClient
- type DatabaseServer
- type Database_StreamExecuteClient
- type Database_StreamExecuteServer
- type UnimplementedDatabaseServer
- func (UnimplementedDatabaseServer) CloseSession(context.Context, *v1alpha1.CloseSessionRequest) (*v1alpha1.CloseSessionResponse, error)
- func (UnimplementedDatabaseServer) CreateSession(context.Context, *v1alpha1.CreateSessionRequest) (*v1alpha1.CreateSessionResponse, error)
- func (UnimplementedDatabaseServer) Execute(context.Context, *v1alpha1.ExecuteRequest) (*v1alpha1.ExecuteResponse, error)
- func (UnimplementedDatabaseServer) Prepare(context.Context, *v1alpha1.PrepareRequest) (*v1alpha1.PrepareResponse, error)
- func (UnimplementedDatabaseServer) StreamExecute(*v1alpha1.ExecuteRequest, Database_StreamExecuteServer) error
- type UnsafeDatabaseServer
Constants ¶
This section is empty.
Variables ¶
var Database_ServiceDesc = grpc.ServiceDesc{ ServiceName: "psdb.v1alpha1.Database", HandlerType: (*DatabaseServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateSession", Handler: _Database_CreateSession_Handler, }, { MethodName: "Execute", Handler: _Database_Execute_Handler, }, { MethodName: "Prepare", Handler: _Database_Prepare_Handler, }, { MethodName: "CloseSession", Handler: _Database_CloseSession_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "StreamExecute", Handler: _Database_StreamExecute_Handler, ServerStreams: true, }, }, Metadata: "psdb/v1alpha1/database.proto", }
Database_ServiceDesc is the grpc.ServiceDesc for Database service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterDatabaseServer ¶
func RegisterDatabaseServer(s grpc.ServiceRegistrar, srv DatabaseServer)
Types ¶
type DatabaseClient ¶
type DatabaseClient interface { CreateSession(ctx context.Context, in *v1alpha1.CreateSessionRequest, opts ...grpc.CallOption) (*v1alpha1.CreateSessionResponse, error) Execute(ctx context.Context, in *v1alpha1.ExecuteRequest, opts ...grpc.CallOption) (*v1alpha1.ExecuteResponse, error) StreamExecute(ctx context.Context, in *v1alpha1.ExecuteRequest, opts ...grpc.CallOption) (Database_StreamExecuteClient, error) Prepare(ctx context.Context, in *v1alpha1.PrepareRequest, opts ...grpc.CallOption) (*v1alpha1.PrepareResponse, error) CloseSession(ctx context.Context, in *v1alpha1.CloseSessionRequest, opts ...grpc.CallOption) (*v1alpha1.CloseSessionResponse, error) }
DatabaseClient is the client API for Database 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 NewDatabaseClient ¶
func NewDatabaseClient(cc grpc.ClientConnInterface) DatabaseClient
type DatabaseServer ¶
type DatabaseServer interface { CreateSession(context.Context, *v1alpha1.CreateSessionRequest) (*v1alpha1.CreateSessionResponse, error) Execute(context.Context, *v1alpha1.ExecuteRequest) (*v1alpha1.ExecuteResponse, error) StreamExecute(*v1alpha1.ExecuteRequest, Database_StreamExecuteServer) error Prepare(context.Context, *v1alpha1.PrepareRequest) (*v1alpha1.PrepareResponse, error) CloseSession(context.Context, *v1alpha1.CloseSessionRequest) (*v1alpha1.CloseSessionResponse, error) }
DatabaseServer is the server API for Database service. All implementations should embed UnimplementedDatabaseServer for forward compatibility
type Database_StreamExecuteClient ¶
type Database_StreamExecuteClient interface { Recv() (*v1alpha1.ExecuteResponse, error) grpc.ClientStream }
type Database_StreamExecuteServer ¶
type Database_StreamExecuteServer interface { Send(*v1alpha1.ExecuteResponse) error grpc.ServerStream }
type UnimplementedDatabaseServer ¶
type UnimplementedDatabaseServer struct { }
UnimplementedDatabaseServer should be embedded to have forward compatible implementations.
func (UnimplementedDatabaseServer) CloseSession ¶
func (UnimplementedDatabaseServer) CloseSession(context.Context, *v1alpha1.CloseSessionRequest) (*v1alpha1.CloseSessionResponse, error)
func (UnimplementedDatabaseServer) CreateSession ¶
func (UnimplementedDatabaseServer) CreateSession(context.Context, *v1alpha1.CreateSessionRequest) (*v1alpha1.CreateSessionResponse, error)
func (UnimplementedDatabaseServer) Execute ¶
func (UnimplementedDatabaseServer) Execute(context.Context, *v1alpha1.ExecuteRequest) (*v1alpha1.ExecuteResponse, error)
func (UnimplementedDatabaseServer) Prepare ¶
func (UnimplementedDatabaseServer) Prepare(context.Context, *v1alpha1.PrepareRequest) (*v1alpha1.PrepareResponse, error)
func (UnimplementedDatabaseServer) StreamExecute ¶
func (UnimplementedDatabaseServer) StreamExecute(*v1alpha1.ExecuteRequest, Database_StreamExecuteServer) error
type UnsafeDatabaseServer ¶
type UnsafeDatabaseServer interface {
// contains filtered or unexported methods
}
UnsafeDatabaseServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DatabaseServer will result in compilation errors.