Package com.google.cloud.pubsublite.cloudpubsub (1.15.0)
| GitHub Repository |
Settings Classes
Settings classes can be used to configure credentials, endpoints, and retry settings for a Client.
| Settings | Description |
|---|---|
| com.google.cloud.pubsublite.cloudpubsub.FlowControlSettings | Describes limits on bytes and messages outstanding for a single partition Pub/Sub Lite subscriber. These are hard limits enforced by the server. |
| com.google.cloud.pubsublite.cloudpubsub.PublisherSettings | Settings for instantiating a Pub/Sub Lite publisher emulating the Cloud Pub/Sub Publisher API. |
| com.google.cloud.pubsublite.cloudpubsub.SubscriberSettings | Settings for instantiating a Pub/Sub Lite subscriber emulating the Cloud Pub/Sub Subscriber API. |
Classes
| Class | Description |
|---|---|
| com.google.cloud.pubsublite.cloudpubsub.FlowControlSettings.Builder | |
| com.google.cloud.pubsublite.cloudpubsub.MessageTransforms |
MessageTransforms details how to transform message representations from Cloud Pub/Sub to Pub/Sub
Lite.
Transformers are made public to allow user code that currently uses PubsubMessages to use |
| com.google.cloud.pubsublite.cloudpubsub.PublisherSettings.Builder | |
| com.google.cloud.pubsublite.cloudpubsub.SubscriberSettings.Builder |
Interfaces
| Interface | Description |
|---|---|
| com.google.cloud.pubsublite.cloudpubsub.KeyExtractor |
A KeyExtractor can extract the Pub/Sub Lite 'key' field used for message routing from a
PubsubMessage. It will by default use the ordering_key field directly for this if it exists.
An empty ByteString implies that the message should have no ordering key. |
| com.google.cloud.pubsublite.cloudpubsub.NackHandler | A NackHandler handles when nack() is called in a user's AckReplyConsumer. Pub/Sub Lite does not have a concept of 'nack'. When nack() is called in an AckReplyConsumerr, nack(message) is called with the nacked message. |
| com.google.cloud.pubsublite.cloudpubsub.PartitionSubscriberClientSupplier | Supplies new SubscriberServiceClient instances. |
| com.google.cloud.pubsublite.cloudpubsub.Publisher | Pub/Sub Lite publishers are streaming based and can experience permanent errors. |
| com.google.cloud.pubsublite.cloudpubsub.ReassignmentHandler |
A ReassignmentHandler is called any time a new partition assignment is received from the server.
It will be called with both the previous and new assignments as decided by the backend.
The client library will not acknowledge the assignment until handleReassignment returns. The |
| com.google.cloud.pubsublite.cloudpubsub.Subscriber | A sub-interface of com.google.cloud.pubsub.v1.SubscriberInterface. |