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.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.
createSchema(CreateSchemaRequest request)
public Schema createSchema(CreateSchemaRequest request)
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.
getSchema(GetSchemaRequest request)
public Schema getSchema(GetSchemaRequest request)
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.
validateMessage(ValidateMessageRequest request)
public ValidateMessageResponse validateMessage(ValidateMessageRequest request)
Validates a message against a schema.
validateSchema(ValidateSchemaRequest request)
public ValidateSchemaResponse validateSchema(ValidateSchemaRequest request)