Classes
AdminServiceClient
The service that a client application uses to manage topics and subscriptions, such creating, listing, and deleting topics and subscriptions.
AdminServiceConnection
The AdminServiceConnection
object for AdminServiceClient
.
AdminServiceConnectionIdempotencyPolicy
AdminServiceLimitedErrorCountRetryPolicy
A retry policy for AdminServiceConnection
based on counting errors.
AdminServiceLimitedTimeRetryPolicy
A retry policy for AdminServiceConnection
based on elapsed time.
AdminServiceRetryPolicy
The retry policy for AdminServiceConnection
.
Topic
Objects of this class identify a Cloud Pub/Sub Lite topic.
TopicStatsServiceClient
This service allows users to get stats about messages in their topic.
TopicStatsServiceConnection
The TopicStatsServiceConnection
object for TopicStatsServiceClient
.
TopicStatsServiceConnectionIdempotencyPolicy
TopicStatsServiceLimitedErrorCountRetryPolicy
A retry policy for TopicStatsServiceConnection
based on counting errors.
TopicStatsServiceLimitedTimeRetryPolicy
A retry policy for TopicStatsServiceConnection
based on elapsed time.
TopicStatsServiceRetryPolicy
The retry policy for TopicStatsServiceConnection
.
Structs
AdminServiceBackoffPolicyOption
Use with google::cloud::Options
to configure the backoff policy.
AdminServiceConnectionIdempotencyPolicyOption
Use with google::cloud::Options
to configure which operations are retried.
AdminServicePollingPolicyOption
Use with google::cloud::Options
to configure the long-running operations polling policy.
AdminServiceRetryPolicyOption
Use with google::cloud::Options
to configure the retry policy.
MaxBatchBytesOption
Publish a batch when its size in bytes reaches this value.
MaxBatchMessagesOption
Publish a batch when it has this many messages.
MessageMetadata
This struct stores the partition and Cursor
of a published Pub/Sub Lite message.
PublishFlushAlarmPeriodOption
The interval at which Flush
will be called on single-partition Publisher
s to publish all remaining messages.
PublishMessageTransformerOption
TopicStatsServiceBackoffPolicyOption
Use with google::cloud::Options
to configure the backoff policy.
TopicStatsServiceConnectionIdempotencyPolicyOption
Use with google::cloud::Options
to configure which operations are retried.
TopicStatsServiceRetryPolicyOption
Use with google::cloud::Options
to configure the retry policy.
Functions
MakeAdminServiceConnection(Options)
A factory function to construct an object of type AdminServiceConnection
.
The returned connection object should not be used directly; instead it should be passed as an argument to the constructor of AdminServiceClient .
The optional options
argument may be used to configure aspects of the returned AdminServiceConnection
. Expected options are any of the types in the following option lists:
options
std::shared_ptr< AdminServiceConnection >
MakeDefaultAdminServiceConnectionIdempotencyPolicy()
std::unique_ptr< AdminServiceConnectionIdempotencyPolicy >
EndpointFromZone(std::string const &)
Returns the appropriate endpoint given a zone name.
Given a zone name in ${region}-[a-z] form it returns the appropriate regional endpoint to contact the Pub/Sub Lite service. Use the value returned to initialize the library via google::cloud::EndpointOption
.
zone_id
std::string const &
StatusOr< std::string >
EndpointFromRegion(std::string const &)
Returns the appropriate endpoint given a region name.
Given a region name it returns the appropriate regional endpoint to contact the Pub/Sub Lite service. Use the value returned to initialize the library via google::cloud::EndpointOption
.
region_id
std::string const &
StatusOr< std::string >
MakeMessageMetadata(std::string const &)
Parses a string into a MessageMetadata object.
The formatting of this string is not stable cross-binary.
input
std::string const &
StatusOr< MessageMetadata >
MakePublisherConnection(std::shared_ptr< AdminServiceConnection >, Topic, Options)
Creates a new PublisherConnection
object to work with Publisher
.
admin_connection
std::shared_ptr< AdminServiceConnection >
a connection to the Pub/Sub Lite Admin API. This is needed to query the number of partitions in the topic.
topic
Topic
the Cloud Pub/Sub Lite topic used by the returned PublisherConnection
.
opts
Options
The options to use for this call. Expected options are any of the types in the following option lists and in google/cloud/pubsublite/options.h .
StatusOr< std::unique_ptr< google::cloud::pubsub::PublisherConnection > >
MakePublisherConnection(Topic, Options)
Creates a new PublisherConnection
object to work with Publisher
.
topic
Topic
the Cloud Pub/Sub Lite topic used by the returned PublisherConnection
.
opts
Options
The options to use for this call. Expected options are any of the types in the following option lists and in google/cloud/pubsublite/options.h .
StatusOr< std::unique_ptr< google::cloud::pubsub::PublisherConnection > >
MakeTopicStatsServiceConnection(Options)
A factory function to construct an object of type TopicStatsServiceConnection
.
The returned connection object should not be used directly; instead it should be passed as an argument to the constructor of TopicStatsServiceClient .
The optional options
argument may be used to configure aspects of the returned TopicStatsServiceConnection
. Expected options are any of the types in the following option lists:
options
std::shared_ptr< TopicStatsServiceConnection >
MakeDefaultTopicStatsServiceConnectionIdempotencyPolicy()
std::unique_ptr< TopicStatsServiceConnectionIdempotencyPolicy >
Type Aliases
PublishMessageTransformer
std::function< StatusOr< google::cloud::pubsublite::v1::PubSubMessage >( google::cloud::pubsub::Message)>
Converts a Google Cloud Pub/Sub Message
into a Google Cloud Pub/Sub Lite protobuf PubSubMessage
.
