Struct BoundedPendingBuffer 

pub struct BoundedPendingBuffer { /* private fields */ }

A bounded buffer for pending peer data with automatic expiration

Implementations

impl BoundedPendingBuffer

pub fn new( max_bytes_per_peer: usize, max_messages_per_peer: usize, ttl: Duration, ) -> Self

Create a new bounded pending buffer

pub fn push( &mut self, peer_id: &PeerId, data: Vec<u8>, ) -> Result<(), PendingBufferError>

Push data for a peer, dropping oldest if limits exceeded

pub fn pop(&mut self, peer_id: &PeerId) -> Option<Vec<u8>>

Pop the oldest pending data for a peer

pub fn pop_any(&mut self) -> Option<(PeerId, Vec<u8>)>

Pop oldest data from any peer (returns peer_id and data)

pub fn peek_oldest(&self, peer_id: &PeerId) -> Option<&[u8]>

Peek at the oldest entry without removing

pub fn message_count(&self, peer_id: &PeerId) -> usize

Get message count for a peer

pub fn total_bytes(&self, peer_id: &PeerId) -> usize

Get total bytes for a peer

pub fn clear_peer(&mut self, peer_id: &PeerId)

Clear all pending data for a peer

pub fn is_empty(&self) -> bool

Check if buffer is empty

pub fn cleanup_expired(&mut self)

Remove expired entries across all peers

pub fn stats(&self) -> PendingBufferStats

Get buffer statistics

pub fn iter_peers(&self) -> impl Iterator<Item = &PeerId>

Iterate over peers with pending data (for recv() compatibility)

Trait Implementations

impl Debug for BoundedPendingBuffer

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

Formats the value using the given formatter.

impl Default for BoundedPendingBuffer

fn default() -> Self

Returns the “default value” for a type.