Struct SwimScheduler 

pub struct SwimScheduler { /* private fields */ }

Fixed-interval SWIM probe scheduler.

Broadcasts a hello at every interval. Unlike BackoffScheduler it never increases its interval after a successful exchange. Topology changes (trigger()) cause an immediate probe on the next tick, after which the regular period resumes.

Implementations

impl SwimScheduler

pub fn new(interval: Duration) -> Self

Create a scheduler firing every interval.

Sends an immediate probe on the first tick to bootstrap the neighbor table.

pub fn from_discovery_config(cfg: &DiscoveryConfig) -> Self

Build from a DiscoveryConfig, using hello_interval_base as the fixed SWIM protocol period T.

Trait Implementations

impl NeighborProbeStrategy for SwimScheduler

fn on_tick(&mut self, now: Instant) -> Vec<ProbeRequest>

Advance the scheduler’s clock to now.

fn on_probe_success(&mut self, _rtt: Duration)

A probe response was received with the given round-trip time.

fn on_probe_timeout(&mut self)

A probe timed out (no response within probe_timeout).

fn trigger(&mut self, event: TriggerEvent)

An external topology event occurred.