Override the default retry policies

Application developers can override the default retry and backoff policies:

  namespace gcs = ::google::cloud::storage;
 
using ::google::cloud::StatusOr;
 
[](std::string const& bucket_name, std::string const& object_name,
     std
::string const& contents) {
   
// Create a client that only gives up on the third error. The default policy
   
// is to retry for several minutes.
   
auto client =
        gcs
::Client(google::cloud::Options{}.set<gcs::RetryPolicyOption>(
            gcs
::LimitedErrorCountRetryPolicy(3).clone()));

   
StatusOr<gcs::ObjectMetadata> object_metadata =
        client
.InsertObject(bucket_name, object_name, std::move(contents),
                            gcs
::IfGenerationMatch(0));
   
if (!object_metadata) throw std::move(object_metadata).status();

    std
::cout << "The object " << object_metadata->name()
             
<< " was created in bucket " << object_metadata->bucket()
             
<< "\nFull metadata: " << *object_metadata << "\n";
 
}

The default policies are to continue retrying for up to 15 minutes, and to use truncated (at 5 minutes) exponential backoff, doubling the maximum backoff period between retries.

By default the library retries all operations, even those that are not idempotent. Application developers can override the idempotency policy to follow a more conservative approach:

  namespace gcs = ::google::cloud::storage;
 
using ::google::cloud::StatusOr;
 
[](std::string const& bucket_name, std::string const& object_name,
     std
::string const& contents) {
   
// Create a client that only retries idempotent operations, the default is
   
// to retry all operations.
   
auto client =
        gcs
::Client(google::cloud::Options{}.set<gcs::IdempotencyPolicyOption>(
            gcs
::StrictIdempotencyPolicy().clone()));
   
StatusOr<gcs::ObjectMetadata> object_metadata =
        client
.InsertObject(bucket_name, object_name, std::move(contents),
                            gcs
::IfGenerationMatch(0));
   
if (!object_metadata) throw std::move(object_metadata).status();

    std
::cout << "The object " << object_metadata->name()
             
<< " was created in bucket " << object_metadata->bucket()
             
<< "\nFull metadata: " << *object_metadata << "\n";
 
}
See Also

LimitedTimeRetryPolicy and LimitedErrorCountRetryPolicy for alternative retry policies.

See Also

ExponentialBackoffPolicy to configure different parameters for the exponential backoff policy.

See Also

AlwaysRetryIdempotencyPolicy and StrictIdempotencyPolicy for alternative idempotency policies.