public static interface SchemaServiceGrpc.AsyncService
Service for doing schema-related operations.
Methods
commitSchema(CommitSchemaRequest request, StreamObserver<Schema> responseObserver)
public default void commitSchema(CommitSchemaRequest request, StreamObserver<Schema> responseObserver)
Commits a new schema revision to an existing schema.
Parameters | |
---|---|
Name | Description |
request | CommitSchemaRequest |
responseObserver | io.grpc.stub.StreamObserver<Schema> |
createSchema(CreateSchemaRequest request, StreamObserver<Schema> responseObserver)
public default void createSchema(CreateSchemaRequest request, StreamObserver<Schema> responseObserver)
Creates a schema.
Parameters | |
---|---|
Name | Description |
request | CreateSchemaRequest |
responseObserver | io.grpc.stub.StreamObserver<Schema> |
deleteSchema(DeleteSchemaRequest request, StreamObserver<Empty> responseObserver)
public default void deleteSchema(DeleteSchemaRequest request, StreamObserver<Empty> responseObserver)
Deletes a schema.
Parameters | |
---|---|
Name | Description |
request | DeleteSchemaRequest |
responseObserver | io.grpc.stub.StreamObserver<Empty> |
deleteSchemaRevision(DeleteSchemaRevisionRequest request, StreamObserver<Schema> responseObserver)
public default void deleteSchemaRevision(DeleteSchemaRevisionRequest request, StreamObserver<Schema> responseObserver)
Deletes a specific schema revision.
Parameters | |
---|---|
Name | Description |
request | DeleteSchemaRevisionRequest |
responseObserver | io.grpc.stub.StreamObserver<Schema> |
getSchema(GetSchemaRequest request, StreamObserver<Schema> responseObserver)
public default void getSchema(GetSchemaRequest request, StreamObserver<Schema> responseObserver)
Gets a schema.
Parameters | |
---|---|
Name | Description |
request | GetSchemaRequest |
responseObserver | io.grpc.stub.StreamObserver<Schema> |
listSchemaRevisions(ListSchemaRevisionsRequest request, StreamObserver<ListSchemaRevisionsResponse> responseObserver)
public default void listSchemaRevisions(ListSchemaRevisionsRequest request, StreamObserver<ListSchemaRevisionsResponse> responseObserver)
Lists all schema revisions for the named schema.
Parameters | |
---|---|
Name | Description |
request | ListSchemaRevisionsRequest |
responseObserver | io.grpc.stub.StreamObserver<ListSchemaRevisionsResponse> |
listSchemas(ListSchemasRequest request, StreamObserver<ListSchemasResponse> responseObserver)
public default void listSchemas(ListSchemasRequest request, StreamObserver<ListSchemasResponse> responseObserver)
Lists schemas in a project.
Parameters | |
---|---|
Name | Description |
request | ListSchemasRequest |
responseObserver | io.grpc.stub.StreamObserver<ListSchemasResponse> |
rollbackSchema(RollbackSchemaRequest request, StreamObserver<Schema> responseObserver)
public default void rollbackSchema(RollbackSchemaRequest request, StreamObserver<Schema> responseObserver)
Creates a new schema revision that is a copy of the provided revision_id.
Parameters | |
---|---|
Name | Description |
request | RollbackSchemaRequest |
responseObserver | io.grpc.stub.StreamObserver<Schema> |
validateMessage(ValidateMessageRequest request, StreamObserver<ValidateMessageResponse> responseObserver)
public default void validateMessage(ValidateMessageRequest request, StreamObserver<ValidateMessageResponse> responseObserver)
Validates a message against a schema.
Parameters | |
---|---|
Name | Description |
request | ValidateMessageRequest |
responseObserver | io.grpc.stub.StreamObserver<ValidateMessageResponse> |
validateSchema(ValidateSchemaRequest request, StreamObserver<ValidateSchemaResponse> responseObserver)
public default void validateSchema(ValidateSchemaRequest request, StreamObserver<ValidateSchemaResponse> responseObserver)
Validates a schema.
Parameters | |
---|---|
Name | Description |
request | ValidateSchemaRequest |
responseObserver | io.grpc.stub.StreamObserver<ValidateSchemaResponse> |