Struct RetryPolicy 

pub struct RetryPolicy {
    pub max_retries: u32,
    pub base_delay: Duration,
    pub max_delay: Duration,
    pub jitter: f64,
}

Declarative backoff policy governing automatic retry of failed node executions.

Domain-free port of the shape battle-tested in the reference consumer (llm-net’s graph/retry.rs): exponential backoff from base_delay to a max_delay ceiling with symmetric jitter to prevent lockstep retries across parallel fan-outs.

Fields

max_retries: u32

How many times a failed execution is re-attempted after the initial failure. 0 disables retry entirely.

base_delay: Duration

The initial backoff delay, doubled per attempt.

max_delay: Duration

The hard ceiling for any single backoff delay.

jitter: f64

Symmetric randomization factor applied to each delay (e.g. 0.25 = ±25%).

Implementations

impl RetryPolicy

pub const fn none() -> Self

A policy that never retries: the first failure propagates.

pub const fn with_max_retries(self, max_retries: u32) -> Self

Overrides the retry budget.

pub const fn with_base_delay(self, base_delay: Duration) -> Self

Overrides the initial backoff delay.

pub const fn with_max_delay(self, max_delay: Duration) -> Self

Overrides the backoff ceiling.

pub const fn with_jitter(self, jitter: f64) -> Self

Overrides the jitter factor (0.0 disables randomization).

pub fn backoff(&self, attempt: u32) -> Duration

Computes the backoff delay for the given (zero-based) retry attempt: min(base * 2^attempt, max) * (1 ± jitter).

Trait Implementations

impl Clone for RetryPolicy

fn clone(&self) -> Self

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

The recommended default: 3 retries, 500ms → 8s exponential backoff, ±25% jitter.

impl<'de> Deserialize<'de> for RetryPolicy

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for RetryPolicy

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for RetryPolicy

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for RetryPolicy