Struct PropagationScheduler 

pub struct PropagationScheduler { /* private fields */ }

Propagation scheduler

Implementations

impl PropagationScheduler

pub fn new(interests: InterestMap, topology: PropagationTopology) -> Self

Create a new scheduler

pub fn set_bandwidth_budget(&mut self, bytes_per_second: u32)

Set bandwidth budget

pub fn schedule(&self, update: &StateUpdate) -> Vec<PropagationDecision>

Decide how to propagate an update

pub fn record_send(&mut self, target: NodeId, bytes: u32)

Update bandwidth usage

pub fn reset_bandwidth(&mut self)

Reset bandwidth usage (call periodically)

pub fn has_bandwidth(&self, target: NodeId, bytes: u32) -> bool

Check if we have bandwidth for a send

Trait Implementations

impl Debug for PropagationScheduler

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

Formats the value using the given formatter.