public static final class SchemaServiceGrpc.SchemaServiceBlockingStub extends AbstractBlockingStub<SchemaServiceGrpc.SchemaServiceBlockingStub>
A stub to allow clients to do synchronous rpc calls to service SchemaService.
Service for doing schema-related operations.
Inheritance
java.lang.Object >
io.grpc.stub.AbstractStub >
io.grpc.stub.AbstractBlockingStub >
SchemaServiceGrpc.SchemaServiceBlockingStub
Inherited Members
io.grpc.stub.AbstractBlockingStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)
io.grpc.stub.AbstractBlockingStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel,io.grpc.CallOptions)
io.grpc.stub.AbstractStub.<T>withOption(io.grpc.CallOptions.Key<T>,T)
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)
io.grpc.stub.AbstractStub.getCallOptions()
io.grpc.stub.AbstractStub.getChannel()
io.grpc.stub.AbstractStub.withCallCredentials(io.grpc.CallCredentials)
io.grpc.stub.AbstractStub.withChannel(io.grpc.Channel)
io.grpc.stub.AbstractStub.withCompression(java.lang.String)
io.grpc.stub.AbstractStub.withDeadline(io.grpc.Deadline)
io.grpc.stub.AbstractStub.withDeadlineAfter(long,java.util.concurrent.TimeUnit)
io.grpc.stub.AbstractStub.withExecutor(java.util.concurrent.Executor)
io.grpc.stub.AbstractStub.withInterceptors(io.grpc.ClientInterceptor...)
io.grpc.stub.AbstractStub.withMaxInboundMessageSize(int)
io.grpc.stub.AbstractStub.withMaxOutboundMessageSize(int)
io.grpc.stub.AbstractStub.withOnReadyThreshold(int)
io.grpc.stub.AbstractStub.withWaitForReady()
Methods
build(Channel channel, CallOptions callOptions)
protected SchemaServiceGrpc.SchemaServiceBlockingStub build(Channel channel, CallOptions callOptions)
Parameters |
Name |
Description |
channel |
io.grpc.Channel
|
callOptions |
io.grpc.CallOptions
|
Overrides
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)
commitSchema(CommitSchemaRequest request)
public Schema commitSchema(CommitSchemaRequest request)
Commits a new schema revision to an existing schema.
Returns |
Type |
Description |
Schema |
|
createSchema(CreateSchemaRequest request)
public Schema createSchema(CreateSchemaRequest request)
Returns |
Type |
Description |
Schema |
|
deleteSchema(DeleteSchemaRequest request)
public Empty deleteSchema(DeleteSchemaRequest request)
Returns |
Type |
Description |
Empty |
|
deleteSchemaRevision(DeleteSchemaRevisionRequest request)
public Schema deleteSchemaRevision(DeleteSchemaRevisionRequest request)
Deletes a specific schema revision.
Returns |
Type |
Description |
Schema |
|
getSchema(GetSchemaRequest request)
public Schema getSchema(GetSchemaRequest request)
Returns |
Type |
Description |
Schema |
|
listSchemaRevisions(ListSchemaRevisionsRequest request)
public ListSchemaRevisionsResponse listSchemaRevisions(ListSchemaRevisionsRequest request)
Lists all schema revisions for the named schema.
listSchemas(ListSchemasRequest request)
public ListSchemasResponse listSchemas(ListSchemasRequest request)
Lists schemas in a project.
rollbackSchema(RollbackSchemaRequest request)
public Schema rollbackSchema(RollbackSchemaRequest request)
Creates a new schema revision that is a copy of the provided revision_id.
Returns |
Type |
Description |
Schema |
|
validateMessage(ValidateMessageRequest request)
public ValidateMessageResponse validateMessage(ValidateMessageRequest request)
Validates a message against a schema.
validateSchema(ValidateSchemaRequest request)
public ValidateSchemaResponse validateSchema(ValidateSchemaRequest request)