Struct RetryPolicy 

pub struct RetryPolicy { /* private fields */ }

Backoff policy for retrying transient RPC failures (Unavailable, DeadlineExceeded, and Aborted, which map to ClientError::Transport, plus ResourceExhausted, which maps to Overloaded; a Cancelled RPC also maps to Transport but is not retried).

Applies to enqueue, ack, nack, extend, and get-server-info — but not to reserve, which is a long poll. The default policy performs no retries (max_attempts == 1); opt in by building one up and passing it to SeppClientBuilder::retry_policy.

Retried enqueues can duplicate jobs that carry no idempotency key. To limit that hazard, an enqueue request in which any job lacks an idempotency key is not retried on the ambiguous-commit codes DeadlineExceeded and Aborted — the server may have already committed the batch — while Unavailable and ResourceExhausted (the request was rejected or never ran) stay retryable. When every job in the request carries an idempotency key, the server dedupes replays and the full transient set is retried.

use std::time::Duration;
use sepp_rs::client::RetryPolicy;

let policy = RetryPolicy::default()
    .with_max_attempts(5)
    .with_initial_backoff(Duration::from_millis(50))
    .with_max_backoff(Duration::from_secs(5));

Implementations

impl RetryPolicy

pub fn with_max_attempts(self, n: u32) -> Self

Sets the total number of attempts (including the first). Values below 1 are clamped to 1, so 1 means “no retries”.

pub fn with_initial_backoff(self, d: Duration) -> Self

Sets the backoff before the first retry. Each subsequent retry multiplies this by with_multiplier, capped at with_max_backoff.

pub fn with_max_backoff(self, d: Duration) -> Self

Caps the backoff between retries.

pub fn with_multiplier(self, m: f64) -> Self

Sets the exponential growth factor for the backoff. Values below 1.0 are clamped to 1.0 (constant backoff).

pub fn without_jitter(self) -> Self

Disables jitter. By default each delay is randomized within [0.5, 1.0) of its computed value to avoid thundering herds.

pub fn max_attempts(&self) -> u32

Returns the configured number of attempts.

Trait Implementations

impl Clone for RetryPolicy

fn clone(&self) -> RetryPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RetryPolicy

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

Formats the value using the given formatter.

impl Default for RetryPolicy

fn default() -> Self

Returns the “default value” for a type.