Package com.google.pubsub.v1
Class SchemaServiceGrpc.SchemaServiceFutureStub
- java.lang.Object
-
- io.grpc.stub.AbstractStub<S>
-
- io.grpc.stub.AbstractFutureStub<SchemaServiceGrpc.SchemaServiceFutureStub>
-
- com.google.pubsub.v1.SchemaServiceGrpc.SchemaServiceFutureStub
-
- Enclosing class:
- SchemaServiceGrpc
public static final class SchemaServiceGrpc.SchemaServiceFutureStub extends io.grpc.stub.AbstractFutureStub<SchemaServiceGrpc.SchemaServiceFutureStub>
A stub to allow clients to do ListenableFuture-style rpc calls to service SchemaService.Service for doing schema-related operations.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected SchemaServiceGrpc.SchemaServiceFutureStub
build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
com.google.common.util.concurrent.ListenableFuture<Schema>
commitSchema(CommitSchemaRequest request)
Commits a new schema revision to an existing schema.com.google.common.util.concurrent.ListenableFuture<Schema>
createSchema(CreateSchemaRequest request)
Creates a schema.com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
deleteSchema(DeleteSchemaRequest request)
Deletes a schema.com.google.common.util.concurrent.ListenableFuture<Schema>
deleteSchemaRevision(DeleteSchemaRevisionRequest request)
Deletes a specific schema revision.com.google.common.util.concurrent.ListenableFuture<Schema>
getSchema(GetSchemaRequest request)
Gets a schema.com.google.common.util.concurrent.ListenableFuture<ListSchemaRevisionsResponse>
listSchemaRevisions(ListSchemaRevisionsRequest request)
Lists all schema revisions for the named schema.com.google.common.util.concurrent.ListenableFuture<ListSchemasResponse>
listSchemas(ListSchemasRequest request)
Lists schemas in a project.com.google.common.util.concurrent.ListenableFuture<Schema>
rollbackSchema(RollbackSchemaRequest request)
Creates a new schema revision that is a copy of the provided revision_id.com.google.common.util.concurrent.ListenableFuture<ValidateMessageResponse>
validateMessage(ValidateMessageRequest request)
Validates a message against a schema.com.google.common.util.concurrent.ListenableFuture<ValidateSchemaResponse>
validateSchema(ValidateSchemaRequest request)
Validates a schema.
-
-
-
Method Detail
-
build
protected SchemaServiceGrpc.SchemaServiceFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
- Specified by:
build
in classio.grpc.stub.AbstractStub<SchemaServiceGrpc.SchemaServiceFutureStub>
-
createSchema
public com.google.common.util.concurrent.ListenableFuture<Schema> createSchema(CreateSchemaRequest request)
Creates a schema.
-
getSchema
public com.google.common.util.concurrent.ListenableFuture<Schema> getSchema(GetSchemaRequest request)
Gets a schema.
-
listSchemas
public com.google.common.util.concurrent.ListenableFuture<ListSchemasResponse> listSchemas(ListSchemasRequest request)
Lists schemas in a project.
-
listSchemaRevisions
public com.google.common.util.concurrent.ListenableFuture<ListSchemaRevisionsResponse> listSchemaRevisions(ListSchemaRevisionsRequest request)
Lists all schema revisions for the named schema.
-
commitSchema
public com.google.common.util.concurrent.ListenableFuture<Schema> commitSchema(CommitSchemaRequest request)
Commits a new schema revision to an existing schema.
-
rollbackSchema
public com.google.common.util.concurrent.ListenableFuture<Schema> rollbackSchema(RollbackSchemaRequest request)
Creates a new schema revision that is a copy of the provided revision_id.
-
deleteSchemaRevision
public com.google.common.util.concurrent.ListenableFuture<Schema> deleteSchemaRevision(DeleteSchemaRevisionRequest request)
Deletes a specific schema revision.
-
deleteSchema
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> deleteSchema(DeleteSchemaRequest request)
Deletes a schema.
-
validateSchema
public com.google.common.util.concurrent.ListenableFuture<ValidateSchemaResponse> validateSchema(ValidateSchemaRequest request)
Validates a schema.
-
validateMessage
public com.google.common.util.concurrent.ListenableFuture<ValidateMessageResponse> validateMessage(ValidateMessageRequest request)
Validates a message against a schema.
-
-