Struct BackoffTable 

pub struct BackoffTable { /* private fields */ }

Per-peer exponential backoff table.

Implementations

impl BackoffTable

pub fn new() -> Self

Construct a fresh table using the spec’s default schedule (10 ms base, 60 s cap).

pub fn with_schedule(base_ns: u64, max_delay_ns: u64) -> Self

Construct a table with a custom exponential schedule.

pub fn record_failure(&mut self, peer: PeerId, now_ns: u64)

Record a failure for peer observed at now_ns. Increments the attempt counter + schedules the next retry.

pub fn record_remote_advisory( &mut self, peer: PeerId, now_ns: u64, min_backoff_ns: u64, )

Record a remotely-advised back-off for peer per the backpressure protocol at docs/internal/superpowers/specs/2026-06-23-backpressure-runtime.md §5.2. Unlike Self::record_failure, the advisory sets next_retry_ns = now_ns + min_backoff_ns directly instead of applying the local exponential schedule - the receiver knows best how long the sender should pause.

Bumps the attempt counter so a subsequent local record_failure resumes the exponential schedule at the next step. Caps min_backoff_ns at max_delay_ns so a pathological remote advisory cannot pin the peer indefinitely.

pub fn record_success(&mut self, peer: PeerId)

Record a success for peer; clears any tracked failure state. Subsequent should_retry returns true immediately.

pub fn should_retry(&self, peer: PeerId, now_ns: u64) -> bool

Whether a retry to peer is permitted at now_ns. Peers with no recorded failures retry immediately.

pub fn state(&self, peer: PeerId) -> Option<BackoffState>

Inspect the recorded state for peer. Returns None when no failures have been recorded.

pub fn len(&self) -> usize

Number of peers currently being tracked.

pub fn is_empty(&self) -> bool

Whether any peer is currently backing off.

pub fn iter(&self) -> impl Iterator<Item = (PeerId, BackoffState)> + '_

Iterate (PeerId, BackoffState) for snapshot capture. .

pub fn restore_state(&mut self, peer: PeerId, state: BackoffState)

Restore one peer’s backoff state directly. Used by Node::restore to re-seed peers from a FrameworkSnapshot::backoff_table entry without going through the failure-counting path.

Trait Implementations

impl Default for BackoffTable

fn default() -> Self

Returns the “default value” for a type.