Struct WriteAggregator 

pub struct WriteAggregator { /* private fields */ }

Counts acks against a target derived from a crate::WriteConsistency and cluster_size.

Implementations

impl WriteAggregator

pub fn new(target: usize) -> Self

pub fn ack(&mut self)

pub fn nack(&mut self)

pub fn is_satisfied(&self) -> bool

True when enough positive acks have arrived.

pub fn is_failed(&self, cluster_size: usize) -> bool

True when so many negative acks have arrived that the target can no longer be reached.

pub fn received(&self) -> usize

pub fn target(&self) -> usize

Trait Implementations

impl Debug for WriteAggregator

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

Formats the value using the given formatter.