Struct PeerMessageBatcher 

pub struct PeerMessageBatcher {
    pub pending: HashMap<String, Vec<BatchMessage>>,
    pub config: BatchConfig,
    pub stats: BatcherStats,
    pub next_id: u64,
    pub tick: u64,
}

Batches outbound messages per-peer and flushes them when thresholds are met.

Fields

pending: HashMap<String, Vec<BatchMessage>>

Per-peer pending message queues.

config: BatchConfig

Batching configuration.

stats: BatcherStats

Running statistics.

next_id: u64

Next message ID to assign.

tick: u64

Current logical tick counter.

Implementations

impl PeerMessageBatcher

pub fn new(config: BatchConfig) -> Self

Create a new batcher with the supplied configuration.

pub fn push(&mut self, peer_id: String, payload: Vec<u8>) -> Option<BatchFlush>

Push a message for peer_id.

Assigns a monotonic msg_id and records enqueued_at = tick, then appends to the peer’s queue. If either the size or count threshold is exceeded after appending, the peer’s queue is immediately flushed and the resulting BatchFlush is returned. Otherwise None is returned and the message stays in the queue until the next flush trigger.

pub fn tick_advance(&mut self) -> Vec<BatchFlush>

Advance the logical tick counter by one and check age thresholds.

For each peer whose oldest pending message has been waiting for at least max_age_ticks ticks, the queue is flushed with AgeThreshold.

Returns all flushes that were triggered.

pub fn flush_peer(&mut self, peer_id: &str) -> Option<BatchFlush>

Force-flush a specific peer’s pending messages with ManualFlush.

Returns None if the peer has no pending messages.

pub fn flush_all(&mut self) -> Vec<BatchFlush>

Force-flush every peer that has pending messages with ManualFlush.

pub fn stats(&self) -> &BatcherStats

Return a reference to the current statistics.