Google Cloud Pub/Sub C++ Client  1.31.1
A C++ Client Library for Google Cloud Pub/Sub
Namespaces | Classes | Typedefs | Functions
google::cloud::pubsub Namespace Reference

Contains all the Cloud Pubsub C++ client types and functions. More...

Namespaces

 v1
 The inlined, versioned namespace for the Cloud Pubsub C++ client APIs.
 

Classes

class  AckHandler
 Defines the interface to acknowledge and reject messages. More...
 
class  Publisher
 Publish messages to the Cloud Pub/Sub service. More...
 
class  Subscriber
 Receive messages from the Cloud Pub/Sub service. More...
 
class  SubscriptionAdminClient
 Performs subscription administrative operations in Cloud Pub/Sub. More...
 
class  TopicAdminClient
 Performs topic admin operations in Cloud Pub/Sub. More...
 
struct  ConnectionOptionsTraits
 The Cloud Pub/Sub connection traits. More...
 
class  PublisherConnection
 A connection to the Cloud Pub/Sub service to publish events. More...
 
class  PublisherOptions
 Configuration options for a Publisher. More...
 
class  Message
 The C++ representation for a Cloud Pub/Sub messages. More...
 
class  MessageBuilder
 Constructs Message objects. More...
 
class  SubscriberConnection
 A connection to the Cloud Pub/Sub service to receive events. More...
 
class  Subscription
 Objects of this class identify a Cloud Pub/Sub subscription. More...
 
class  SnapshotBuilder
 Build a request to create a Cloud Pub/Sub snapshot. More...
 
class  SubscriptionAdminConnection
 A connection to Cloud Pub/Sub for subscription-related administrative operations. More...
 
class  PushConfigBuilder
 Helper class to create google::pubsub::v1::PushConfig protos. More...
 
class  SubscriptionBuilder
 Create a Cloud Pub/Sub subscription configuration. More...
 
class  Snapshot
 Objects of this class identify a Cloud Pub/Sub snapshot. More...
 
class  TopicAdminConnection
 A connection to Cloud Pub/Sub for topic-related administrative operations. More...
 
class  TopicBuilder
 Builds requests to create or update a Cloud Pub/Sub topic. More...
 
class  SubscriberOptions
 Configure how a Subscriber handles incoming messages. More...
 
class  Topic
 Objects of this class identify a Cloud Pub/Sub topic. More...
 
class  SchemaAdminClient
 Performs schema admin operations in Cloud Pub/Sub. More...
 
class  Schema
 Objects of this class identify a Cloud Pub/Sub schema. More...
 
class  SchemaAdminConnection
 A connection to Cloud Pub/Sub for schema-related administrative operations. More...
 
class  MockSchemaAdminConnection
 A googlemock-based mock for [pubsub::SchemaAdminConnection][mocked-link]. More...
 

Typedefs

using ConnectionOptions = ::google::cloud::ConnectionOptions< ConnectionOptionsTraits >
 Configure a connection for Cloud Pub/Sub services. More...
 
using PubsubMessageDataType = std::decay< decltype(std::declval< google::pubsub::v1::PubsubMessage >().data())>::type
 Defines the type for message data. More...
 
using ListSubscriptionsRange = google::cloud::internal::PaginationRange< google::pubsub::v1::Subscription >
 An input range to stream Cloud Pub/Sub subscriptions. More...
 
using ListSnapshotsRange = google::cloud::internal::PaginationRange< google::pubsub::v1::Snapshot >
 An input range to stream Cloud Pub/Sub snapshots. More...
 
using ListTopicsRange = google::cloud::internal::PaginationRange< google::pubsub::v1::Topic >
 An input range to stream Cloud Pub/Sub topics. More...
 
using ListTopicSubscriptionsRange = google::cloud::internal::PaginationRange< std::string >
 An input range to stream the Cloud Pub/Sub subscriptions of a topic. More...
 
using ListTopicSnapshotsRange = google::cloud::internal::PaginationRange< std::string >
 An input range to stream the Cloud Pub/Sub snapshots of a topic. More...
 
using BackoffPolicy = ::google::cloud::internal::BackoffPolicy
 The base class for backoff policies. More...
 
using ExponentialBackoffPolicy = google::cloud::internal::ExponentialBackoffPolicy
 A truncated exponential backoff policy with randomized periods. More...
 
using RetryPolicy = ::google::cloud::internal::TraitBasedRetryPolicy< pubsub_internal::RetryTraits >
 The base class for retry policies. More...
 
using LimitedTimeRetryPolicy = ::google::cloud::internal::LimitedTimeRetryPolicy< pubsub_internal::RetryTraits >
 A retry policy that limits based on time. More...
 
using LimitedErrorCountRetryPolicy = google::cloud::internal::LimitedErrorCountRetryPolicy< pubsub_internal::RetryTraits >
 A retry policy that limits the number of times a request can fail. More...
 
using ApplicationCallback = std::function< void(Message, AckHandler)>
 Defines the interface for application-level callbacks. More...
 
using ListSchemasRange = google::cloud::internal::PaginationRange< google::pubsub::v1::Schema >
 An input range to stream Cloud Pub/Sub schemas. More...
 
using seconds = std::chrono::seconds
 

Functions

std::shared_ptr< PublisherConnectionMakePublisherConnection (Topic topic, PublisherOptions options, ConnectionOptions connection_options={}, std::unique_ptr< RetryPolicy const > retry_policy={}, std::unique_ptr< BackoffPolicy const > backoff_policy={})
 Creates a new PublisherConnection object to work with Publisher. More...
 
std::shared_ptr< SubscriberConnectionMakeSubscriberConnection (Subscription subscription, SubscriberOptions options={}, ConnectionOptions connection_options={}, std::unique_ptr< pubsub::RetryPolicy const > retry_policy={}, std::unique_ptr< pubsub::BackoffPolicy const > backoff_policy={})
 Creates a new SubscriberConnection object to work with Subscriber. More...
 
std::shared_ptr< SubscriptionAdminConnectionMakeSubscriptionAdminConnection (ConnectionOptions const &options=ConnectionOptions(), std::unique_ptr< pubsub::RetryPolicy const > retry_policy={}, std::unique_ptr< pubsub::BackoffPolicy const > backoff_policy={})
 Returns an SubscriberConnection object to work with Cloud Pub/Sub subscriber APIs. More...
 
std::shared_ptr< TopicAdminConnectionMakeTopicAdminConnection (ConnectionOptions const &options=ConnectionOptions(), std::unique_ptr< pubsub::RetryPolicy const > retry_policy={}, std::unique_ptr< pubsub::BackoffPolicy const > backoff_policy={})
 Creates a new TopicAdminConnection object to work with TopicAdminClient. More...
 
bool operator== (Message const &a, Message const &b)
 
std::ostream & operator<< (std::ostream &os, Message const &rhs)
 
bool operator== (Schema const &a, Schema const &b)
 
std::ostream & operator<< (std::ostream &os, Schema const &rhs)
 
std::shared_ptr< SchemaAdminConnectionMakeSchemaAdminConnection (pubsub::ConnectionOptions const &options=pubsub::ConnectionOptions(), std::unique_ptr< pubsub::RetryPolicy const > retry_policy={}, std::unique_ptr< pubsub::BackoffPolicy const > backoff_policy={})
 Creates a new SchemaAdminConnection object to work with SchemaAdminClient. More...
 
bool operator== (Snapshot const &a, Snapshot const &b)
 
std::ostream & operator<< (std::ostream &os, Snapshot const &rhs)
 
bool operator== (Subscription const &a, Subscription const &b)
 
std::ostream & operator<< (std::ostream &os, Subscription const &rhs)
 
bool operator== (Topic const &a, Topic const &b)
 
std::ostream & operator<< (std::ostream &os, Topic const &rhs)
 

Detailed Description

Contains all the Cloud Pubsub C++ client types and functions.