Struct SourceTracker 

pub struct SourceTracker { /* private fields */ }

Tracks per-provider SourceHealth so the scheduler prefers healthy sources and backs off failed ones (bounded exponential backoff), without ever permanently banning a source that might recover.

Implementations

impl SourceTracker

pub fn new(base_backoff: Duration, max_backoff: Duration) -> Self

A tracker with the given base + max backoff (backoff doubles per consecutive failure, capped).

pub fn is_available(&self, peer_id: &str, now: Instant) -> bool

Whether peer_id is schedulable at now (not inside a backoff window).

pub fn record_success(&mut self, peer_id: &str)

Record a successful range served by peer_id (clears failures + backoff).

pub fn record_failure(&mut self, peer_id: &str, now: Instant)

Record a failure by peer_id at now and set its (capped-exponential) backoff window.

pub fn served(&self, peer_id: &str) -> u64

The number of successfully-served ranges recorded for peer_id.

pub fn failures(&self, peer_id: &str) -> u32

The consecutive-failure count recorded for peer_id.

Trait Implementations

impl Debug for SourceTracker

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

Formats the value using the given formatter.

impl Default for SourceTracker

fn default() -> SourceTracker

Returns the “default value” for a type.