Struct CanaryController 

pub struct CanaryController { /* private fields */ }

The per-generation canary analysis controller (DW-091). Compiled once per config generation from the canary_analysis blocks on service splits and AI model aliases; shared via Arc from the dataplane generation. record_outcome runs on the response path and evaluate runs on the background CanaryRunner loop.

Implementations

impl CanaryController

pub fn new() -> Self

New empty controller (no canary groups). The fast path: record_outcome and evaluate are no-ops.

pub fn compile(gateway: &Gateway, obs: Option<Arc<Observability>>) -> Self

Compile the controller from a gateway’s service splits and AI model aliases. Only services/aliases with an enabled canary_analysis block contribute a group. The observability handle wires the metric families; pass None for direct unit-test construction (metrics are then a no-op).

pub fn compile_with_clock( gateway: &Gateway, obs: Option<Arc<Observability>>, now_secs: fn() -> u64, ) -> Self

Self::compile with a caller-supplied second clock (Unix epoch). Intended for tests that need to advance time deterministically (the same pattern as AdaptiveController::compile_with_clock); production keeps the system clock via Self::compile.

pub fn is_empty(&self) -> bool

Whether any canary group is compiled in at all (the fast path: configs with no canary_analysis skip the per-request record_outcome entirely).

pub fn record_outcome( &self, group_name: &str, is_canary: bool, status: u16, latency_ms: f64, )

Record one upstream outcome for group_name (DW-091): increment the appropriate side’s request/error counters and add the latency sample. A no-op when the group has no canary_analysis. is_canary selects the side (true = canary, false = baseline); status is the upstream HTTP status (5xx counts as an error); latency_ms is the upstream round-trip in milliseconds.

pub fn evaluate(&self) -> Vec<CanaryAction>

Evaluate all groups and return the actions the runner should apply. Each action carries the recommended new canary weight. The runner applies them and emits events; the controller’s last_adjustment and current_canary_weight are updated by Self::note_applied.

pub fn note_applied(&self, action: &CanaryAction)

Note that an action was successfully applied (the runner calls this after apply_*_weights returns true). Updates the group’s last_adjustment and current_canary_weight, and records the promotion/rollback metric.

pub fn current_canary_weight(&self, group: &str) -> Option<u64>

The current transient canary weight for a group (tests / diagnostics). Returns None when the group does not exist.

pub fn total_weight(&self, group: &str) -> Option<u64>

The total weight for a group (tests / diagnostics).

Trait Implementations

impl Debug for CanaryController

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

Formats the value using the given formatter.

impl Default for CanaryController

fn default() -> Self

Returns the “default value” for a type.