Struct SpannerRetryPolicy 

pub struct SpannerRetryPolicy { /* private fields */ }

The retry policy the Spanner client applies to RPCs that do not configure their own. It decorates/extends google_cloud_gax::retry_policy::Aip194Strict.

Like Aip194Strict, this policy retries UNAVAILABLE errors and transient failures that occur before the request reaches the service, but only for idempotent requests. In addition — because Spanner allows transport and connection errors to be retried on idempotent operations — it also retries transport/network and I/O errors that Aip194Strict would classify as permanent (such as a connection dropped after the request was sent), again only if the request is idempotent.

The policy places no limit on the number of attempts or the elapsed time. Applications that want to bound the client’s default retry behavior can decorate this policy with RetryPolicyExt instead of re-implementing its error classification:

Example

let statement = Statement::builder("SELECT * FROM Users")
    .with_retry_policy(
        SpannerRetryPolicy::new()
            .with_attempt_limit(5)
            .with_time_limit(Duration::from_secs(30)),
    )
    .build();

Implementations

impl SpannerRetryPolicy

pub fn new() -> Self

Creates a new Spanner retry policy.

Trait Implementations

impl Clone for SpannerRetryPolicy

fn clone(&self) -> SpannerRetryPolicy

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SpannerRetryPolicy

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SpannerRetryPolicy

fn default() -> Self

Returns the “default value” for a type.

impl RetryPolicy for SpannerRetryPolicy