Struct AdaptiveController 

pub struct AdaptiveController { /* private fields */ }

The adaptive control brain.

PURE and deterministic: it never calls std::time::Instant::now or the snapdir_core::resources samplers. All time and metrics are injected via tick; per-op feedback via record_op. Given the same inputs it always produces the same Decisions.

Implementations

impl AdaptiveController

pub fn new(policy: AdaptivePolicy) -> Self

Builds a controller from a policy. The limit starts at 2 (slow-start seed), clamped to the policy ceiling.

pub fn current_limit(&self) -> usize

The current concurrency limit (clamped to [1, ceiling]).

pub fn record_op(&mut self, sample: OpSample)

Records one completed (or failed) operation, updating the running EWMAs and the congestion marker. Call between ticks; the accumulated samples are folded into the goodput/rtt estimates at the next tick.

pub fn tick( &mut self, now: MonoTime, cpu_pct: Option<f64>, _rss: Option<u64>, p95_obj_size: u64, ) -> Decision

Applies the control law for one interval and returns the next Decision. now is the injected monotonic time, cpu_pct/rss are best-effort system samples (None ⇒ unknown ⇒ that guardrail is skipped), and p95_obj_size is the recent 95th-percentile object size used by the memory-budget guardrail.

The controller never reads a real clock or sampler; all of these are supplied by the (later) wiring gate.

Trait Implementations

impl Debug for AdaptiveController

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.