Struct AimdController 

pub struct AimdController { /* private fields */ }

Additive-increase / multiplicative-decrease controller. Pure + deterministic.

Implementations

impl AimdController

pub fn new(cfg: &AdaptiveBatchConfig, initial: usize) -> Self

Build a controller. initial is clamped into [min, max] (cold-start = the source’s actual page size when run_stream passes the first page len).

pub fn current(&self) -> usize

pub fn cooldown_active(&self) -> bool

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

p50 of the rolling latency window (ms), if any samples present.

pub fn observe(&mut self, obs: Observation) -> Option<Adjustment>

Feed one sub-batch observation; returns Some(Adjustment) when the size changed. First-match-wins: error shrink → cooldown → latency target → success growth.