Package com.google.cloud.pubsublite.internal.wire

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

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

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.

SubscriberFactory

SubscriberResetHandler