Interface SchemaApiGrpc.AsyncService

All Known Implementing Classes:
SchemaApiGrpc.SchemaApiImplBase, SchemaServiceImpl
Enclosing class:
SchemaApiGrpc

public static interface SchemaApiGrpc.AsyncService
 Remoting for the Schema Service.
 
  • Method Details

    • about

      default void about(AboutRequest request, io.grpc.stub.StreamObserver<AboutReply> responseObserver)
       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)