Struct ControllerDriver 

pub struct ControllerDriver { /* private fields */ }

Shared, live bridge between a pure AdaptiveController and the running transfer backends.

The controller is &mut and deterministic; this wrapper owns it behind a Mutex (tick is infrequent, so contention is negligible) and adds the impure parts the controller deliberately omits: a real monotonic clock, a live CpuSampler + RSS sampler, the manifest’s p95 object size, and the application of each Decision to the shared AdaptiveGate (concurrency) and — for the network backends — a rate-limiter setter + display Meter.

Both transfer paths use it identically:

• every completed/failed op calls record_op with its measured OpSample;
• a lightweight driver (a tokio interval task for the async path, a std::thread for the rayon path) periodically calls tick, which samples CPU/RSS, advances the controller, resizes the gate, and reports the new limit/rate.

The driver is Clone (the controller, gate, sampler and the rate/limit appliers are all shared via Arc).

Implementations

impl ControllerDriver

pub fn new( policy: AdaptivePolicy, gate: AdaptiveGate, p95_obj_size: u64, rate_applier: Option<Arc<dyn Fn(Option<u64>) + Send + Sync>>, meter: Option<Arc<Meter>>, ) -> Self

Builds a driver around a fresh controller for policy, the shared gate, the manifest’s p95_obj_size, an optional rate_applier (the backend’s live rate-limit setter; None for the rate-less local store), and an optional display meter.

pub fn record_op(&self, sample: OpSample)

Records one completed/failed op into the shared controller.

pub fn tick(&self) -> Decision

Advances the controller one interval: samples CPU/RSS, ticks with the injected monotonic clock + p95 object size, then applies the resulting Decision to the gate (concurrency), the rate applier (byte-rate), and the display meter. Returns the decision for tests/inspection.

Trait Implementations

impl Clone for ControllerDriver

fn clone(&self) -> ControllerDriver

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ControllerDriver

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

Formats the value using the given formatter.