public abstract static class SchemaServiceGrpc.SchemaServiceImplBase implements BindableService
Service for doing schema-related operations.
Implements
io.grpc.BindableServiceConstructors
SchemaServiceImplBase()
public SchemaServiceImplBase()
Methods
bindService()
public final ServerServiceDefinition bindService()
Type | Description |
io.grpc.ServerServiceDefinition |
createSchema(CreateSchemaRequest request, StreamObserver<Schema> responseObserver)
public void createSchema(CreateSchemaRequest request, StreamObserver<Schema> responseObserver)
Creates a schema.
Name | Description |
request | CreateSchemaRequest |
responseObserver | io.grpc.stub.StreamObserver<Schema> |
deleteSchema(DeleteSchemaRequest request, StreamObserver<Empty> responseObserver)
public void deleteSchema(DeleteSchemaRequest request, StreamObserver<Empty> responseObserver)
Deletes a schema.
Name | Description |
request | DeleteSchemaRequest |
responseObserver | io.grpc.stub.StreamObserver<Empty> |
getSchema(GetSchemaRequest request, StreamObserver<Schema> responseObserver)
public void getSchema(GetSchemaRequest request, StreamObserver<Schema> responseObserver)
Gets a schema.
Name | Description |
request | GetSchemaRequest |
responseObserver | io.grpc.stub.StreamObserver<Schema> |
listSchemas(ListSchemasRequest request, StreamObserver<ListSchemasResponse> responseObserver)
public void listSchemas(ListSchemasRequest request, StreamObserver<ListSchemasResponse> responseObserver)
Lists schemas in a project.
Name | Description |
request | ListSchemasRequest |
responseObserver | io.grpc.stub.StreamObserver<ListSchemasResponse> |
validateMessage(ValidateMessageRequest request, StreamObserver<ValidateMessageResponse> responseObserver)
public void validateMessage(ValidateMessageRequest request, StreamObserver<ValidateMessageResponse> responseObserver)
Validates a message against a schema.
Name | Description |
request | ValidateMessageRequest |
responseObserver | io.grpc.stub.StreamObserver<ValidateMessageResponse> |
validateSchema(ValidateSchemaRequest request, StreamObserver<ValidateSchemaResponse> responseObserver)
public void validateSchema(ValidateSchemaRequest request, StreamObserver<ValidateSchemaResponse> responseObserver)
Validates a schema.
Name | Description |
request | ValidateSchemaRequest |
responseObserver | io.grpc.stub.StreamObserver<ValidateSchemaResponse> |