Classes
ApiExceptionPublisher<T>
ApiServiceUtils
AssignerImpl
AssignerSettings
AssignerSettings.Builder
BatchingCommitter
CommitterImpl
CommitterSettings
CommitterSettings.Builder
ConnectedAssignerImpl
ConnectedCommitterImpl
NextOffsetTracker
PartitionCountWatcherImpl
PartitionCountWatcherImpl.Factory
PartitionCountWatchingPublisher
PartitionCountWatchingPublisherSettings
PartitionCountWatchingPublisherSettings.Builder
Predicates
PublisherBuilder
A builder for a PubSub Lite Publisher. Basic usage:
Publisher<Offset> publisher = PublisherBuilder.builder()
.setTopic(
TopicPath.newBuilder()
.setProject(MY_PROJECT)
.setName(MY_TOPIC)
.setLocation(CloudZone.of("us-east1-a"))
.build())
.setPartition(Partition.of(10))
.build();
A custom service client can also be set.
PublisherBuilder.Builder
PublisherImpl
PubsubContext
A context for identifying clients based on basic properties.
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.
ResetSignal
RoutingMetadata
RoutingPublisher
RoutingPublisherBuilder
RoutingPublisherBuilder.Builder
SequenceAssigningPublisher
A publisher that assigns sequence numbers to messages and delegates to an underlying SequencedPublisher.
ServiceClients
SingleConnection<StreamRequestT,StreamResponseT,ClientResponseT>
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.
SinglePartitionPublisher
SinglePartitionPublisherBuilder
SinglePartitionPublisherBuilder.Builder
StreamFactories
SubscriberBuilder
SubscriberBuilder.Builder
SubscriberImpl
SystemExecutors
UuidBuilder
Utilities for generating and converting 128-bit UUIDs.
Interfaces
Assigner
An Assigner is responsible for handling partition assignments for a subscribing client.
AssignerFactory
Committer
ConnectedAssigner
PartitionAssignmentReceiver
A receiver for partition assignments. All updates to reflect the assignment should be performed inline.
PartitionCountWatcher
PartitionCountWatcher.Factory
PartitionPublisherFactory
RetryingConnectionObserver<ClientResponseT>
SingleConnectionFactory<StreamRequestT,StreamResponseT,ClientResponseT,ConnectionT>
StreamFactories.CursorStreamFactory
StreamFactories.PublishStreamFactory
StreamFactories.SubscribeStreamFactory
StreamFactory<RequestT,ResponseT>
Subscriber
A generic PubSub Lite subscriber. Errors are handled out of band. Messages are sent out of band. Thread safe.