Package | Description |
---|---|
com.google.cloud.pubsub.spi.v1 |
A client to Google Cloud Pub/Sub API.
|
com.google.pubsub.v1 |
Modifier and Type | Method and Description |
---|---|
Topic |
PublisherApi.createTopic(java.lang.String name)
Creates the given topic with the given name.
|
Topic |
PublisherApi.getTopic(java.lang.String topic)
Gets the configuration of a topic.
|
Modifier and Type | Method and Description |
---|---|
ApiCallable<Topic,Topic> |
PublisherApi.createTopicCallable()
Creates the given topic with the given name.
|
ApiCallable<Topic,Topic> |
PublisherApi.createTopicCallable()
Creates the given topic with the given name.
|
SimpleCallSettings<Topic,Topic> |
PublisherSettings.createTopicSettings()
Returns the object with the settings used for calls to createTopic.
|
SimpleCallSettings<Topic,Topic> |
PublisherSettings.createTopicSettings()
Returns the object with the settings used for calls to createTopic.
|
SimpleCallSettings.Builder<Topic,Topic> |
PublisherSettings.Builder.createTopicSettings()
Returns the builder for the settings used for calls to createTopic.
|
SimpleCallSettings.Builder<Topic,Topic> |
PublisherSettings.Builder.createTopicSettings()
Returns the builder for the settings used for calls to createTopic.
|
ApiCallable<GetTopicRequest,Topic> |
PublisherApi.getTopicCallable()
Gets the configuration of a topic.
|
SimpleCallSettings<GetTopicRequest,Topic> |
PublisherSettings.getTopicSettings()
Returns the object with the settings used for calls to getTopic.
|
SimpleCallSettings.Builder<GetTopicRequest,Topic> |
PublisherSettings.Builder.getTopicSettings()
Returns the builder for the settings used for calls to getTopic.
|
PageAccessor<Topic> |
PublisherApi.listTopics(ListTopicsRequest request)
Lists matching topics.
|
PageAccessor<Topic> |
PublisherApi.listTopics(java.lang.String project)
Lists matching topics.
|
ApiCallable<ListTopicsRequest,PageAccessor<Topic>> |
PublisherApi.listTopicsPagedCallable()
Lists matching topics.
|
PageStreamingCallSettings<ListTopicsRequest,ListTopicsResponse,Topic> |
PublisherSettings.listTopicsSettings()
Returns the object with the settings used for calls to listTopics.
|
PageStreamingCallSettings.Builder<ListTopicsRequest,ListTopicsResponse,Topic> |
PublisherSettings.Builder.listTopicsSettings()
Returns the builder for the settings used for calls to listTopics.
|
Modifier and Type | Field and Description |
---|---|
static io.grpc.MethodDescriptor<Topic,Topic> |
PublisherGrpc.METHOD_CREATE_TOPIC |
static io.grpc.MethodDescriptor<Topic,Topic> |
PublisherGrpc.METHOD_CREATE_TOPIC |
static io.grpc.MethodDescriptor<GetTopicRequest,Topic> |
PublisherGrpc.METHOD_GET_TOPIC |
Modifier and Type | Method and Description |
---|---|
Topic |
Topic.Builder.build() |
Topic |
Topic.Builder.buildPartial() |
Topic |
PublisherGrpc.PublisherBlockingClient.createTopic(Topic request) |
Topic |
PublisherGrpc.PublisherBlockingStub.createTopic(Topic request) |
static Topic |
Topic.getDefaultInstance() |
Topic |
Topic.getDefaultInstanceForType() |
Topic |
Topic.Builder.getDefaultInstanceForType() |
Topic |
PublisherGrpc.PublisherBlockingClient.getTopic(GetTopicRequest request) |
Topic |
PublisherGrpc.PublisherBlockingStub.getTopic(GetTopicRequest request) |
Topic |
ListTopicsResponseOrBuilder.getTopics(int index)
The resulting topics.
|
Topic |
ListTopicsResponse.getTopics(int index)
The resulting topics.
|
Topic |
ListTopicsResponse.Builder.getTopics(int index)
The resulting topics.
|
static Topic |
Topic.parseDelimitedFrom(java.io.InputStream input) |
static Topic |
Topic.parseDelimitedFrom(java.io.InputStream input,
ExtensionRegistryLite extensionRegistry) |
static Topic |
Topic.parseFrom(byte[] data) |
static Topic |
Topic.parseFrom(byte[] data,
ExtensionRegistryLite extensionRegistry) |
static Topic |
Topic.parseFrom(ByteString data) |
static Topic |
Topic.parseFrom(ByteString data,
ExtensionRegistryLite extensionRegistry) |
static Topic |
Topic.parseFrom(CodedInputStream input) |
static Topic |
Topic.parseFrom(CodedInputStream input,
ExtensionRegistryLite extensionRegistry) |
static Topic |
Topic.parseFrom(java.io.InputStream input) |
static Topic |
Topic.parseFrom(java.io.InputStream input,
ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.common.util.concurrent.ListenableFuture<Topic> |
PublisherGrpc.PublisherFutureClient.createTopic(Topic request) |
com.google.common.util.concurrent.ListenableFuture<Topic> |
PublisherGrpc.PublisherFutureStub.createTopic(Topic request) |
Parser<Topic> |
Topic.getParserForType() |
com.google.common.util.concurrent.ListenableFuture<Topic> |
PublisherGrpc.PublisherFutureClient.getTopic(GetTopicRequest request) |
com.google.common.util.concurrent.ListenableFuture<Topic> |
PublisherGrpc.PublisherFutureStub.getTopic(GetTopicRequest request) |
java.util.List<Topic> |
ListTopicsResponseOrBuilder.getTopicsList()
The resulting topics.
|
java.util.List<Topic> |
ListTopicsResponse.getTopicsList()
The resulting topics.
|
java.util.List<Topic> |
ListTopicsResponse.Builder.getTopicsList()
The resulting topics.
|
static Parser<Topic> |
Topic.parser() |
Modifier and Type | Method and Description |
---|---|
ListTopicsResponse.Builder |
ListTopicsResponse.Builder.addTopics(int index,
Topic value)
The resulting topics.
|
ListTopicsResponse.Builder |
ListTopicsResponse.Builder.addTopics(Topic value)
The resulting topics.
|
Topic |
PublisherGrpc.PublisherBlockingClient.createTopic(Topic request) |
com.google.common.util.concurrent.ListenableFuture<Topic> |
PublisherGrpc.PublisherFutureClient.createTopic(Topic request) |
Topic |
PublisherGrpc.PublisherBlockingStub.createTopic(Topic request) |
com.google.common.util.concurrent.ListenableFuture<Topic> |
PublisherGrpc.PublisherFutureStub.createTopic(Topic request) |
void |
PublisherGrpc.Publisher.createTopic(Topic request,
io.grpc.stub.StreamObserver<Topic> responseObserver) |
void |
PublisherGrpc.PublisherStub.createTopic(Topic request,
io.grpc.stub.StreamObserver<Topic> responseObserver) |
Topic.Builder |
Topic.Builder.mergeFrom(Topic other) |
static Topic.Builder |
Topic.newBuilder(Topic prototype) |
ListTopicsResponse.Builder |
ListTopicsResponse.Builder.setTopics(int index,
Topic value)
The resulting topics.
|
Modifier and Type | Method and Description |
---|---|
ListTopicsResponse.Builder |
ListTopicsResponse.Builder.addAllTopics(java.lang.Iterable<? extends Topic> values)
The resulting topics.
|
void |
PublisherGrpc.Publisher.createTopic(Topic request,
io.grpc.stub.StreamObserver<Topic> responseObserver) |
void |
PublisherGrpc.PublisherStub.createTopic(Topic request,
io.grpc.stub.StreamObserver<Topic> responseObserver) |
void |
PublisherGrpc.Publisher.getTopic(GetTopicRequest request,
io.grpc.stub.StreamObserver<Topic> responseObserver) |
void |
PublisherGrpc.PublisherStub.getTopic(GetTopicRequest request,
io.grpc.stub.StreamObserver<Topic> responseObserver) |