Package io.deephaven.proto.schema.grpc
Interface SchemaApiGrpc.AsyncService
- All Known Implementing Classes:
SchemaApiGrpc.SchemaApiImplBase,SchemaServiceImpl
- Enclosing class:
- SchemaApiGrpc
public static interface SchemaApiGrpc.AsyncService
Remoting for the Schema Service.
-
Method Summary
Modifier and TypeMethodDescriptiondefault voidabout(AboutRequest request, io.grpc.stub.StreamObserver<AboutReply> responseObserver) return a string with information about the server side contextdefault voidauthenticate(AuthRequest request, io.grpc.stub.StreamObserver<AuthReply> responseObserver) Authenticate using the AuthToken in the AuthRequest.default voidcontainsNamespace(NamespaceRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.BoolValue> responseObserver) default voidcontainsSchema(SchemaRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.BoolValue> responseObserver) rpc listSchemas(SchemasRequest) returns (stream StringReply) {}default voidcreateNamespace(NamespaceRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.BoolValue> responseObserver) default voidgetImportSources(ImportSourcesRequest request, io.grpc.stub.StreamObserver<ImportSourcesResponse> responseObserver) default voidgetNamespaceSet(NamespaceRequest request, io.grpc.stub.StreamObserver<NamespaceSetReply> responseObserver) default voidgetSchema(SchemaRequest request, io.grpc.stub.StreamObserver<SchemaReply> responseObserver) default voidgetSchemas(SchemasRequest request, io.grpc.stub.StreamObserver<SchemaReply> responseObserver) default voidlistAllTables(ListAllTablesRequest request, io.grpc.stub.StreamObserver<TableNameReply> responseObserver) default voidlistNamespaces(NamespaceSetRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.StringValue> responseObserver) rpc NamespaceSet getNamespaceSet(@NotNull String namespace) throws IllegalArgumentException;default voidlistTableNames(NamespaceRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.StringValue> responseObserver) default voidputSchema(SchemaRequest request, io.grpc.stub.StreamObserver<SchemaReply> responseObserver) TODO: there's a choice to make - mimic the SchemaService API, or provide building blocks e.g.default voidremoveNamespace(NamespaceRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.BoolValue> responseObserver)
-
Method Details
-
about
return a string with information about the server side context
-
authenticate
default void authenticate(AuthRequest request, io.grpc.stub.StreamObserver<AuthReply> responseObserver) Authenticate using the AuthToken in the AuthRequest. This can be used to remove authentication. The client will hold on to this authenticated context for subsequent calls.
-
putSchema
default void putSchema(SchemaRequest request, io.grpc.stub.StreamObserver<SchemaReply> responseObserver) TODO: there's a choice to make - mimic the SchemaService API, or provide building blocks e.g. putSchema with SchemaRequest that differentiates between add and update
-
getSchema
default void getSchema(SchemaRequest request, io.grpc.stub.StreamObserver<SchemaReply> responseObserver) -
getSchemas
default void getSchemas(SchemasRequest request, io.grpc.stub.StreamObserver<SchemaReply> responseObserver) -
containsSchema
default void containsSchema(SchemaRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.BoolValue> responseObserver) rpc listSchemas(SchemasRequest) returns (stream StringReply) {} -
getNamespaceSet
default void getNamespaceSet(NamespaceRequest request, io.grpc.stub.StreamObserver<NamespaceSetReply> responseObserver) -
listNamespaces
default void listNamespaces(NamespaceSetRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.StringValue> responseObserver) rpc NamespaceSet getNamespaceSet(@NotNull String namespace) throws IllegalArgumentException; -
listTableNames
default void listTableNames(NamespaceRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.StringValue> responseObserver) -
listAllTables
default void listAllTables(ListAllTablesRequest request, io.grpc.stub.StreamObserver<TableNameReply> responseObserver) -
containsNamespace
default void containsNamespace(NamespaceRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.BoolValue> responseObserver) -
createNamespace
default void createNamespace(NamespaceRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.BoolValue> responseObserver) -
removeNamespace
default void removeNamespace(NamespaceRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.BoolValue> responseObserver) -
getImportSources
default void getImportSources(ImportSourcesRequest request, io.grpc.stub.StreamObserver<ImportSourcesResponse> responseObserver)
-