Struct NoteBook 

pub struct NoteBook {
    told_paused: HashSet<String>,
    pause: Option<(i64, &'static str)>,
    resume: Option<(i64, HashSet<String>)>,
}

Which agents were told delivery paused, and which still await their resume note.

Fields

told_paused: HashSet<String>

Agents told about the current pause.

pause: Option<(i64, &'static str)>

The current pause’s note, for agents that join while it lasts.

resume: Option<(i64, HashSet<String>)>

Since when delivery is back, and the agents whose resume note waits for their first pull.

Implementations

impl NoteBook

pub fn pause( &mut self, since_ms: i64, reason: &'static str, agents: &[String], ) -> Vec<Note>

Delivery has been paused a while: a note for every agent in agents.

pub fn pause_late_joiners(&mut self, agents: &[String]) -> Vec<Note>

While a pause note stands, agents that weren’t told yet.

pub fn resumed(&mut self, at_ms: i64)

Delivery is back: every agent told about the pause gets a resume note after its first pull (see Self::fetched).

pub fn fetched( &mut self, agent: &str, delivered: usize, expired: &[ExpiredItem], ) -> Option<Note>

An agent’s pull came back with delivered messages and expired reports: its resume note, or an expiry note, or nothing.

pub fn tick(&mut self, now_ms: i64) -> Vec<Note>

Resume notes still waiting after RESUME_NOTE_GRACE_MS go out without a count.

fn flush_resume(&mut self) -> Vec<Note>

Trait Implementations

impl Debug for NoteBook

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

Formats the value using the given formatter.

impl Default for NoteBook

fn default() -> NoteBook

Returns the “default value” for a type.