Struct PhasePollContext 

pub struct PhasePollContext {
    pub kernel: Arc<ScopeKernel>,
    pub interval: Duration,
    pub deadline: Instant,
    pub started_at: Instant,
    pub metric_name: Option<String>,
    pub max_error_retries: u32,
    pub on_timeout: PhasePollTimeoutPolicy,
    pub require: Vec<String>,
    pub require_grace: Instant,
}

Runtime context for SRD-75 phase-level poll. Carried on Activity when the phase declares a poll: block; consumed by the fiber loop after each source-exhaustion event to decide whether to terminate (predicate satisfied or timeout) or rewind and run another iteration.

Fields

kernel: Arc<ScopeKernel>

Handle to the phase scope kernel. After each iteration the fiber loop resolves crate::wrappers::condition::UNTIL_BINDING through CycleWires over the per-fiber kernel — the same call an op-level poll: makes — and ends the loop when it reads truthy per crate::wrappers::condition::is_truthy. lookup would not do: the predicate is a DYNAMIC binding fed by per-iteration capture writes, so it has to be pulled or it returns the last-evaluated value forever.

interval: Duration

Sleep between iterations (after a predicate check returns “not done”).

deadline: Instant

Wall-clock cap on the whole poll loop. Computed at run-phase entry as Instant::now() + timeout_ms.

started_at: Instant

Instant the loop started — used to compute the elapsed-time value emitted under metric_name (if set) on successful completion.

metric_name: Option<String>

Optional named metric to emit on successful loop completion (predicate fired). Value is the elapsed wall-clock decoded per the existing _ns / _us / _ms / _s / _m / _h suffix convention. None ⇒ no metric written.

max_error_retries: u32

Tolerated consecutive retryable inner-op errors before the loop propagates the error. Mirrors the per-op PollingDispenser max_error_retries semantics. Default 0 (strict).

on_timeout: PhasePollTimeoutPolicy

What to do when the deadline fires without satisfying the predicate. SRD-75 §“on_timeout”:

• Error (default) — set the activity’s stop_flag + stop_reason. The phase returns an error; the scenario walker’s error-routing policy decides whether sibling phases continue.
• Abort — additionally call session_signals::request_stop() so the whole scenario terminates. The workload-author declares the predicate’s satisfaction as a precondition for any downstream phase being meaningful; a stuck synchronizer invalidates the rest of the run.

require: Vec<String>

SRD-75 (C5) — strict-gate selectors: each must resolve to a registered instrument before the gate’s predicate is trusted. While any selector is unresolved the gate HOLDS (the predicate is not consulted — an unregistered family reads 0.0, which could satisfy a >=-shaped predicate spuriously); past Self::require_grace an unresolved selector is a hard poll_require failure.

require_grace: Instant

Grace deadline for Self::require resolution: the first poll interval after loop start (late registration is normal — a producing daemon registers its instruments as it spins up).

Trait Implementations

impl Clone for PhasePollContext

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.