Struct UpstreamRegistry 

pub struct UpstreamRegistry { /* private fields */ }

The live set of upstreams, keyed by name. Owned by Control, OUTSIDE the swapped ActiveConfig, so health state survives a reload (ADR 000017). The Mutex is contended only by reconcile (on reload) and the prober supervisor (groups) / a config build (group) — never the per-request hot path, which holds an Arc<UpstreamGroup> resolved at build time.

Implementations

impl UpstreamRegistry

pub fn new() -> Self

pub fn reconcile( &self, upstreams: &[Upstream], base_dir: &Path, ) -> Result<(), ControlError>

Reconcile the registry to upstreams (ADR 000017). Validation (duplicate name, empty addresses, the LB config — ADR 000035 — and the [upstream.tls] CA load, ADR 000042) runs FIRST against the whole list, so a bad manifest leaves the running set untouched (all-or-nothing, like the rest of a reload). Then, per upstream: build a new group whose instances reuse the existing Arc<UpstreamInstance> for any unchanged (name, address, weight) when the health policy and [upstream.tls] are unchanged (a TLS change makes prior probe results meaningless, so it re-probes from pessimistic like a health-policy change), create a fresh pessimistic instance otherwise, build the LB state (a Maglev upstream recomputes its table from the instance set), and drop upstreams no longer present. base_dir resolves each [upstream.tls] ca_path, like the [[tls]] cert paths.

pub fn group(&self, name: &str) -> Option<Arc<UpstreamGroup>>

The group named name, if present — used to resolve a route’s upstream at config-build time.

pub fn groups(&self) -> Vec<Arc<UpstreamGroup>>

A snapshot of every current group, for the health-check supervisor to probe.

Trait Implementations

impl Debug for UpstreamRegistry

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

Formats the value using the given formatter.

impl Default for UpstreamRegistry

fn default() -> UpstreamRegistry

Returns the “default value” for a type.