Package com.google.cloud.pubsublite.internal.wire (1.13.8)

This package is not the recommended entry point to using this client library!

For this library, we recommend using com.google.cloud.pubsublite.cloudpubsub for new applications.

Settings Classes

Settings classes can be used to configure credentials, endpoints, and retry settings for a Client.

Settings	Description
com.google.cloud.pubsublite.internal.wire.AssignerSettings
com.google.cloud.pubsublite.internal.wire.CommitterSettings
com.google.cloud.pubsublite.internal.wire.PartitionCountWatchingPublisherSettings

Classes

Class	Description
com.google.cloud.pubsublite.internal.wire.ApiExceptionPublisher
com.google.cloud.pubsublite.internal.wire.ApiServiceUtils
com.google.cloud.pubsublite.internal.wire.AssignerImpl
com.google.cloud.pubsublite.internal.wire.AssignerSettings.Builder
com.google.cloud.pubsublite.internal.wire.BatchingCommitter
com.google.cloud.pubsublite.internal.wire.CommitterImpl
com.google.cloud.pubsublite.internal.wire.CommitterSettings.Builder
com.google.cloud.pubsublite.internal.wire.ConnectedAssignerImpl
com.google.cloud.pubsublite.internal.wire.ConnectedCommitterImpl
com.google.cloud.pubsublite.internal.wire.NextOffsetTracker
com.google.cloud.pubsublite.internal.wire.PartitionCountWatcherImpl
com.google.cloud.pubsublite.internal.wire.PartitionCountWatcherImpl.Factory
com.google.cloud.pubsublite.internal.wire.PartitionCountWatchingPublisher
com.google.cloud.pubsublite.internal.wire.PartitionCountWatchingPublisherSettings.Builder
com.google.cloud.pubsublite.internal.wire.Predicates
com.google.cloud.pubsublite.internal.wire.PublisherBuilder	A builder for a PubSub Lite Publisher. Basic usage: `Publisher<Offset> publisher = PublisherBuilder.builder()`
com.google.cloud.pubsublite.internal.wire.PublisherBuilder.Builder
com.google.cloud.pubsublite.internal.wire.PublisherImpl
com.google.cloud.pubsublite.internal.wire.PubsubContext	A context for identifying clients based on basic properties.
com.google.cloud.pubsublite.internal.wire.PubsubContext.Framework	A unique string representing the unambiguous name of a framework in SCREAMING_SNAKE_CASE. Setting this value will be used to track framework popularity in internal metrics.
com.google.cloud.pubsublite.internal.wire.ResetSignal
com.google.cloud.pubsublite.internal.wire.RoutingMetadata
com.google.cloud.pubsublite.internal.wire.RoutingPublisher
com.google.cloud.pubsublite.internal.wire.RoutingPublisherBuilder
com.google.cloud.pubsublite.internal.wire.RoutingPublisherBuilder.Builder
com.google.cloud.pubsublite.internal.wire.SequenceAssigningPublisher	A publisher that assigns sequence numbers to messages and delegates to an underlying SequencedPublisher.
com.google.cloud.pubsublite.internal.wire.ServiceClients
com.google.cloud.pubsublite.internal.wire.SingleConnection	A SingleConnection handles the state for a stream with an initial connection request that may only be sent once and needs to wait for a response before sending other requests.
com.google.cloud.pubsublite.internal.wire.SinglePartitionPublisher
com.google.cloud.pubsublite.internal.wire.SinglePartitionPublisherBuilder
com.google.cloud.pubsublite.internal.wire.SinglePartitionPublisherBuilder.Builder
com.google.cloud.pubsublite.internal.wire.StreamFactories
com.google.cloud.pubsublite.internal.wire.SubscriberBuilder
com.google.cloud.pubsublite.internal.wire.SubscriberBuilder.Builder
com.google.cloud.pubsublite.internal.wire.SubscriberImpl
com.google.cloud.pubsublite.internal.wire.SystemExecutors
com.google.cloud.pubsublite.internal.wire.UuidBuilder	Utilities for generating and converting 128-bit UUIDs.

Interfaces

Interface	Description
com.google.cloud.pubsublite.internal.wire.Assigner	An Assigner is responsible for handling partition assignments for a subscribing client.
com.google.cloud.pubsublite.internal.wire.AssignerFactory
com.google.cloud.pubsublite.internal.wire.Committer
com.google.cloud.pubsublite.internal.wire.ConnectedAssigner
com.google.cloud.pubsublite.internal.wire.PartitionAssignmentReceiver	A receiver for partition assignments. All updates to reflect the assignment should be performed inline.
com.google.cloud.pubsublite.internal.wire.PartitionCountWatcher
com.google.cloud.pubsublite.internal.wire.PartitionCountWatcher.Factory
com.google.cloud.pubsublite.internal.wire.PartitionPublisherFactory
com.google.cloud.pubsublite.internal.wire.RetryingConnectionObserver
com.google.cloud.pubsublite.internal.wire.SingleConnectionFactory
com.google.cloud.pubsublite.internal.wire.StreamFactories.CursorStreamFactory
com.google.cloud.pubsublite.internal.wire.StreamFactories.PublishStreamFactory
com.google.cloud.pubsublite.internal.wire.StreamFactories.SubscribeStreamFactory
com.google.cloud.pubsublite.internal.wire.StreamFactory
com.google.cloud.pubsublite.internal.wire.Subscriber	A generic PubSub Lite subscriber. Errors are handled out of band. Messages are sent out of band. Thread safe.
com.google.cloud.pubsublite.internal.wire.SubscriberFactory
com.google.cloud.pubsublite.internal.wire.SubscriberResetHandler