Struct PeerFlowControl 

pub struct PeerFlowControl { /* private fields */ }

Window-based flow control manager for multiple peers.

Tracks per-peer send windows, automatically creates windows for new peers, and provides grow/shrink operations for adaptive congestion control.

Implementations

impl PeerFlowControl

pub fn new(config: FlowControlConfig) -> Self

Create a new PeerFlowControl with the given configuration.

pub fn can_send(&self, peer_id: &str, bytes: u64) -> bool

Check whether bytes can be sent to peer_id without exceeding the window. Returns true even if the peer has no window yet (it would be auto-created on send).

pub fn send(&mut self, peer_id: &str, bytes: u64) -> Result<(), String>

Record bytes as sent to peer_id.

Auto-creates a window for new peers. Returns an error if sending bytes would exceed the peer’s window size and increments the stall counter.

pub fn ack(&mut self, peer_id: &str, bytes: u64)

Acknowledge bytes from peer_id, reducing bytes in flight.

If the peer has no window this is a no-op. The in-flight counter is clamped to zero (will not underflow).

pub fn grow_window(&mut self, peer_id: &str)

Grow the window for peer_id by growth_factor, clamped to max_window.

No-op if the peer has no window.

pub fn shrink_window(&mut self, peer_id: &str)

Shrink the window for peer_id by shrink_factor, clamped to min_window.

No-op if the peer has no window.

pub fn get_window(&self, peer_id: &str) -> Option<&FlowWindow>

Get a reference to the flow window for peer_id, if it exists.

pub fn utilization(&self, peer_id: &str) -> Option<f64>

Compute the utilization ratio (bytes_in_flight / window_size) for peer_id. Returns None if the peer has no window.

pub fn remove_peer(&mut self, peer_id: &str) -> bool

Remove the flow window for peer_id. Returns true if the peer was present.

pub fn peer_count(&self) -> usize

Return the number of peers with active flow windows.

pub fn stats(&self) -> FlowControlStats

Compute aggregate statistics across all peers.