Struct FlowController 

pub struct FlowController { /* private fields */ }

Sliding window flow controller.

Tracks in-flight packets and controls send rate based on window size. Supports acknowledgements, retransmission detection, and RTT estimation.

Implementations

impl FlowController

pub fn new(window_size: usize) -> Self

Create a new flow controller with the given window size.

pub fn with_rto(window_size: usize, rto_ms: u64) -> Self

Create a flow controller with a custom retransmission timeout.

pub fn can_send(&self) -> bool

Returns true if the window has space to send another packet.

pub fn available_slots(&self) -> usize

Returns how many more packets can be sent right now.

pub fn window_size(&self) -> usize

Returns the current window size.

pub fn set_window_size(&mut self, size: usize)

Dynamically adjust the window size.

pub fn in_flight_count(&self) -> usize

Returns the number of packets currently in flight.

pub fn oldest_unacked_sequence(&self) -> Option<u64>

Returns the sequence number of the oldest unacknowledged sent packet, or None if there are no packets in flight.

pub fn on_send(&mut self, sequence: u64) -> bool

Register a packet as sent.

Returns false if the window is full.

pub fn on_ack(&mut self, sequence: u64) -> bool

Register a packet as acknowledged.

Updates RTT estimate. Returns true if the packet was found.

pub fn timed_out_packets(&mut self) -> Vec<u64>

Returns all in-flight packets that have exceeded the retransmission timeout.

Resets sent_at for each timed-out packet.

pub fn srtt(&self) -> Option<Duration>

Returns the current smoothed RTT estimate.

pub fn rto(&self) -> Duration

Returns the current retransmission timeout.

pub fn total_sent(&self) -> u64

Returns total packets sent.

pub fn total_acked(&self) -> u64

Returns total packets acknowledged.

pub fn total_lost(&self) -> u64

Returns total packets detected as lost.

pub fn loss_rate(&self) -> f64

Returns the packet loss rate as a value between 0.0 and 1.0.

pub fn is_acked(&self, sequence: u64) -> bool

Returns true if a sequence number has been acknowledged.

pub fn reset(&mut self)

Reset all state.

Trait Implementations

impl Default for FlowController

fn default() -> Self

Returns the “default value” for a type.