Package com.google.cloud.pubsublite.internal (1.12.16)

Classes

AdminClientImpl

AlarmFactory.Internal

ApiResourceAggregation

BlockingPullSubscriberImpl

BufferingPullSubscriber

CheckedApiPreconditions

CloseableMonitor

Wraps a Monitor with methods that can be used with try-with-resources.

CloseableMonitor.Hold

This is meant for use in the try-with-resources pattern. It will call leave() on a Monitor when it goes out of scope. This is cannot be constructed directly, but through usage of the static utility methods above.

CursorClientImpl

CursorClientSettings

CursorClientSettings.Builder

DefaultRoutingPolicy

ExtractStatus

Lazy<T>

A thread-safe, lazily constructed instance of an object.

MoreApiFutures

ProxyService

PublishSequenceNumber

A sequence number for a published message, for implementing publish idempotency.

SerialExecutor

An executor that runs tasks sequentially.

TopicStatsClientImpl

TopicStatsClientSettings

TopicStatsClientSettings.Builder

UncheckedApiPreconditions

Interfaces

AlarmFactory

ApiBackgroundResource

BlockingPullSubscriber

CursorClient

ExtractStatus.StatusBiconsumer<K,V>

ExtractStatus.StatusConsumer<I>

ExtractStatus.StatusFunction<I,O>

Publisher<ResponseT>

A generic PubSub Lite publisher. Errors are handled out of band. Thread safe.

PullSubscriber<T>

RoutingPolicy

RoutingPolicy.Factory

SequencedPublisher<ResponseT>

A PubSub Lite publisher that requires a sequence number assigned to every message, for publish idempotency. Errors are handled out of band. Thread safe.

TopicStatsClient

Exceptions

CheckedApiException

A wrapper around an ApiException that is a checked exception to help ensure correctness of internal classes as well as ease construction of ApiExceptions. Should not be exposed in end-user interfaces.