Some or all of the information on this page might not apply to Cloud de Confiance by S3NS. See Differences from Google Cloud for more details.

Class SchemaServiceGrpc.SchemaServiceStub (1.142.0)

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.SchemaServiceStub

Inherited Members

io.grpc.stub.AbstractAsyncStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)

io.grpc.stub.AbstractAsyncStub.<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(java.time.Duration)

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()

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Methods

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`

Overrides

io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

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>`