Struct JoinBuffer 

pub struct JoinBuffer { /* private fields */ }

Exchange records waiting for their decision (3.7.3), keyed by attempt id, and a bounded memory of attempts already exported so a late record is counted at once.

Implementations

impl JoinBuffer

pub fn new(max: usize, ttl_ms: u64) -> Self

pub fn expire(&mut self, now_ms: u64) -> u64

Remove expired records; how many records (not attempts).

pub fn insert(&mut self, x: ExchangeRecord, now_ms: u64) -> Joined

pub fn take( &mut self, attempt_ids: &[&str], ) -> BTreeMap<String, Arc<ExchangeRecord>>

Take the records of attempt_ids, and remember them as exported.

Trait Implementations

impl Debug for JoinBuffer

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

Formats the value using the given formatter.