Struct CongestionController 

pub struct CongestionController { /* private fields */ }

Multi-connection, multi-algorithm TCP-inspired congestion controller.

Manages per-connection congestion state and emits Decision structs that callers use to pace their sends.

Implementations

impl CongestionController

pub fn new(config: CccControllerConfig) -> Self

Create a new controller with the given configuration.

pub fn with_defaults() -> Self

Create a new controller with default configuration.

pub fn add_connection(&mut self, id: CccConnId)

Register a new connection. If the connection already exists this is a no-op.

pub fn remove_connection(&mut self, id: CccConnId) -> bool

Remove a tracked connection. Returns true if it existed.

pub fn reset_connection(&mut self, id: CccConnId) -> Result<(), &'static str>

Reset a connection to its initial state (keeps the entry).

Returns an error if the connection does not exist.

pub fn on_ack( &mut self, conn_id: CccConnId, bytes_acked: u64, rtt_ms: f64, ) -> Result<CccDecision, &'static str>

Process an ACK for bytes_acked bytes on conn_id with the measured RTT.

Returns the new Decision, or an error if conn_id is unknown.

pub fn on_loss( &mut self, conn_id: CccConnId, lost_bytes: u64, ) -> Result<CccDecision, &'static str>

Process a packet loss event on conn_id.

Applies multiplicative decrease and enters fast recovery.

pub fn on_timeout( &mut self, conn_id: CccConnId, ) -> Result<CccDecision, &'static str>

Process a retransmission timeout on conn_id.

Resets cwnd to min_cwnd, halves ssthresh, re-enters slow start.

pub fn sending_rate(&self, conn_id: CccConnId) -> Option<f64>

Current sending rate for a connection, in bytes/sec.

Returns None if the connection is unknown or RTT has not been measured.

pub fn controller_stats(&self) -> CccControllerStats

Aggregate statistics across all active connections.

pub fn connection(&self, conn_id: CccConnId) -> Option<&CccConnection>

Immutable reference to a connection, if it exists.

pub fn events(&self) -> &VecDeque<CccEvent>

Read-only view of the event log.