public static interface SchemaServiceGrpc.AsyncServiceService 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> |