Struct State 

pub struct State {
    pub attempts: u64,
    pub next_attempt: u64,
}

State stored alongside the consumer’s candidate fingerprint.

Fields

attempts: u64

Reserved attempts, including candidates that die immediately after commit.

next_attempt: u64

Earliest permitted retry in the consumer’s persisted time domain (seconds).

Implementations

impl State

pub fn allowed(&self, policy: Policy, now: u64) -> bool

Whether this campaign may attempt a candidate now.

pub fn reserve(&mut self, policy: Policy, now: u64)

Reserve before launching. Persist the returned state before spawning; cancellation and controller crashes must not restore the spent attempt.

pub fn exhaust(&mut self, policy: Policy)

A permanent candidate failure exhausts this fingerprint’s campaign.

pub fn next(&self, policy: Policy) -> Option<u64>

Next retry time, or None once a new candidate selection is required.

Trait Implementations

impl Clone for State

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for State

impl Debug for State

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

Formats the value using the given formatter.

impl Default for State

fn default() -> Self

Returns the “default value” for a type.