Struct MessageBuffer 

pub struct MessageBuffer { /* private fields */ }

Node-wide bounded receive buffer shared by all delivery profiles.

Implementations

impl MessageBuffer

pub fn new( max_buffer_bytes: usize, warning_threshold: f32, limited_threshold: f32, ) -> Self

pub fn push( &mut self, profile: MessageProfile, payload: Vec<u8>, ) -> Result<(), BufferError>

pub fn pop(&mut self) -> Option<BufferedMessage>

pub fn max_buffer_bytes(&self) -> usize

pub fn used_bytes(&self) -> usize

pub fn backpressure_level(&self) -> BackpressureLevel

pub fn bytes_for(&self, profile: MessageProfile) -> usize

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

Trait Implementations

impl Debug for MessageBuffer

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

Formats the value using the given formatter.