public static final class SchemaServiceGrpc.SchemaServiceStub extends AbstractAsyncStub<SchemaServiceGrpc.SchemaServiceStub>A stub to allow clients to do asynchronous rpc calls to service SchemaService.
Service for doing schema-related operations.
Inheritance
java.lang.Object > io.grpc.stub.AbstractStub > io.grpc.stub.AbstractAsyncStub > SchemaServiceGrpc.SchemaServiceStubMethods
build(Channel channel, CallOptions callOptions)
protected SchemaServiceGrpc.SchemaServiceStub build(Channel channel, CallOptions callOptions)| Parameters | |
|---|---|
| Name | Description |
channel |
io.grpc.Channel |
callOptions |
io.grpc.CallOptions |
| Returns | |
|---|---|
| Type | Description |
SchemaServiceGrpc.SchemaServiceStub |
|
commitSchema(CommitSchemaRequest request, StreamObserver<Schema> responseObserver)
public 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 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 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 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 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 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 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 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 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 void validateSchema(ValidateSchemaRequest request, StreamObserver<ValidateSchemaResponse> responseObserver)Validates a schema.
| Parameters | |
|---|---|
| Name | Description |
request |
ValidateSchemaRequest |
responseObserver |
io.grpc.stub.StreamObserver<ValidateSchemaResponse> |