Skip to main content
Documentation
close
Get Started
Get Started with Google Cloud
Product List
Cloud Customer Care
Featured Products
Agent Platform
Apigee API Management
BigQuery
Compute Engine
Cloud CDN
Cloud Run
Cloud Storage
Cloud SQL
Gemini Enterprise
Google Kubernetes Engine
Looker
Cross-product Tools
Access and resources management
Costs and usage management
Infrastructure as code
SDK, languages, frameworks, and tools
Technology Areas
AI and ML
Application development
Application hosting
Compute
Data analytics and pipelines
Databases
Distributed, hybrid, and multicloud
Industry solutions
Migration
Networking
Observability and monitoring
Security
Storage
/
Console
English
Deutsch
Español – América Latina
Français
Português – Brasil
中文 – 简体
日本語
한국어
Sign in
Google Cloud SDK
C++
Client libraries
Start free
Overview
Guides
Reference
Samples
Documentation
More
Overview
Guides
Reference
Samples
Console
Overview
Library reference docs
Cloud Pub/Sub C++ Client Library
In-Depth Topics
Environment Variables
Error Handling
Override Retry, Backoff, and Idempotency Policies
Override pubsub::SchemaServiceClient Retry Policies
Testing your Cloud Pub/Sub publisher application with googlemock
Override the default endpoint
Override the authentication configuration
Override the default universe domain
Override Publisher Default Universe Domain
Override Subscriber Default Universe Domain
Override BlockingPublisher Default Universe Domain
Override TopicAdminClient Default Universe Domain
Override SubscriptionAdminClient Default Universe Domain
Override SchemaServiceClient Default Universe Domain
Testing your Cloud Pub/Sub subscriber application with googlemock
Modules
Pub/Sub Client Library Configuration Options
Namespaces
google::cloud::pubsub
Overview
Classes
AckHandler
Overview
Constructors
Impl
Overview
Functions
virtual ack()
virtual nack()
virtual delivery_attempt() const
virtual ack_id()
virtual subscription() const
AckHandler(AckHandler &&)
AckHandler(std::unique_ptr< Impl >)
Operators
operator=(AckHandler &&)
Functions
ack() &&
nack() &&
delivery_attempt() const
BigQueryConfigBuilder
Overview
Constructors
BigQueryConfigBuilder()
Functions
set_table(std::string) &
set_table(std::string) &&
set_table(std::string const &, std::string const &, std::string const &) &
set_table(std::string const &, std::string const &, std::string const &) &&
set_use_topic_schema(bool) &
set_use_topic_schema(bool) &&
set_write_metadata(bool) &
set_write_metadata(bool) &&
set_drop_unknown_fields(bool) &
set_drop_unknown_fields(bool) &&
BlockingPublisher
Overview
Constructors
BlockingPublisher(std::shared_ptr< BlockingPublisherConnection >, Options)
BlockingPublisher(BlockingPublisher const &)
BlockingPublisher(BlockingPublisher &&)
Operators
operator=(BlockingPublisher const &)
operator=(BlockingPublisher &&)
operator==(BlockingPublisher const &, BlockingPublisher const &)
operator!=(BlockingPublisher const &, BlockingPublisher const &)
Functions
Publish(Topic, Message, Options)
BlockingPublisherConnection
Overview
Constructors
PublishParams
Overview
Functions
virtual Publish(PublishParams)
virtual options()
CloudStorageConfigBuilder
Overview
Constructors
CloudStorageConfigBuilder()
Functions
set_bucket(std::string) &
set_bucket(std::string) &&
set_filename_prefix(std::string) &
set_filename_prefix(std::string) &&
set_filename_suffix(std::string) &
set_filename_suffix(std::string) &&
set_avro_config(google::pubsub::v1::CloudStorageConfig::AvroConfig) &
set_avro_config(google::pubsub::v1::CloudStorageConfig::AvroConfig) &&
set_max_duration(std::chrono::duration< Rep, Period >) &
set_max_duration(std::chrono::duration< Rep, Period >) &&
set_max_duration(google::protobuf::Duration const &) &
set_max_duration(google::protobuf::Duration const &) &&
set_max_bytes(int) &
set_max_bytes(int) &&
static MakeAvroConfig(bool)
ExactlyOnceAckHandler
Overview
Constructors
Impl
Overview
Functions
virtual ack()
virtual nack()
virtual delivery_attempt() const
virtual ack_id()
virtual subscription() const
ExactlyOnceAckHandler(ExactlyOnceAckHandler &&)
ExactlyOnceAckHandler(std::unique_ptr< Impl >)
Operators
operator=(ExactlyOnceAckHandler &&)
Functions
ack() &&
nack() &&
delivery_attempt() const
LimitedErrorCountRetryPolicy
Overview
Constructors
LimitedErrorCountRetryPolicy(int)
LimitedErrorCountRetryPolicy(LimitedErrorCountRetryPolicy &&)
LimitedErrorCountRetryPolicy(LimitedErrorCountRetryPolicy const &)
Functions
maximum_failures() const
virtual OnFailure(Status const &)
virtual IsExhausted() const
virtual IsPermanentFailure(Status const &) const
virtual clone() const
