Struct ThrottleGovernor 

pub struct ThrottleGovernor { /* private fields */ }

The per-phase governor: window bookkeeping over the activity’s cumulative attempt counters plus the resolved control handle.

Implementations

impl ThrottleGovernor

pub fn from_spec( spec: &ThrottleSpec, component: Option<&Arc<RwLock<Component>>>, phase_name: &str, authored_concurrency: usize, authored_rate: Option<f64>, ) -> Option<Self>

Resolve the governor from the phase’s declared spec against the attached component (where Activity::attach_component declared the controls). Returns None — with a logged warning, never silently — when the named control is not declared (e.g. control: rate on a phase without rate:).

Construction immediately publishes the slow-start offer to the control (push-on-set), so the phase OPENS at start, not at the authored ceiling; the caller also reads Self::initial_concurrency to spawn the fiber pool at the same offer.

pub fn initial_concurrency(&self) -> Option<usize>

The fiber count the activity should OPEN with when this governor walks concurrency — the slow-start offer, not the authored ceiling. None when the governor walks rate (the pool spawns at the authored concurrency; the rate limiter carries the slow-start instead).

pub fn tick(&mut self, attempt_success: u64, attempt_failure: u64)

Called every activity-loop pass with the CUMULATIVE attempt counters; acts at most once per window. The control write is push-on-set (spawned, confirmed-apply) — the loop never blocks.