Struct CallPolicy 

pub struct CallPolicy {
    pub deadline: Option<Duration>,
    pub max_attempts: u32,
    pub base_backoff: Duration,
    pub idempotent: bool,
}

Per-call deadline and retry policy.

Retries are bounded and only ever applied where the caller has said the operation is safe to repeat — see CallPolicy::idempotent.

Fields

deadline: Option<Duration>

max_attempts: u32

base_backoff: Duration

idempotent: bool

Whether the operation may be safely repeated. Defaults to false: a blanket retry on a mutation is how one payment becomes two.

Implementations

impl CallPolicy

pub fn idempotent() -> Self

A read: safe to repeat.

pub fn from_contract(path: &str) -> Self

The policy the CONTRACT implies for one RPC path.

This replaced a hand-written per-method judgement, which was wrong in both directions: it refused to retry Upsert, Update and Delete even though the broker declares them replayable, costing availability on a transient failure the broker was happy to see again.

Deciding from the descriptor instead of a method name is the point of the operation_kind annotation. An unknown path yields the conservative default (no retries).

pub fn once() -> Self

No retries at all.

pub fn with_deadline(self, deadline: Duration) -> Self

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

Trait Implementations

impl Clone for CallPolicy

fn clone(&self) -> CallPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for CallPolicy

impl Debug for CallPolicy

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

Formats the value using the given formatter.

impl Default for CallPolicy

fn default() -> Self

Returns the “default value” for a type.