Struct RepeatingRegistry 

pub struct RepeatingRegistry { /* private fields */ }

The registry sweep as a declared pair of queriers (#37) — for callers that re-run the sweep (--watch topic list, doctor’s second pass, a GUI refresh). One-shot callers keep fleet_registry.

Two queriers, not one: the wildcard-producer fan-out plus @catalog by name (a * never matches a verbatim origin, D4 — the two cannot double-count; same reasoning as fleet_registry).

Implementations

impl RepeatingRegistry

pub async fn declare(fleet: &Fleet<'_>, timeout: Duration) -> Result<Self>

pub async fn fetch(&self) -> Result<Vec<(RegistrySlice, String)>>

One sweep: every parsed slice with its raw TOML.

Drops the answering origin. fetch_by_origin is the same sweep keeping it, and is what a caller asking which host wants (#385).

pub async fn fetch_by_origin(&self) -> Result<Vec<ServedSlice>>

One sweep, attributed: every parsed slice with the origin that served it and its raw TOML (#385).

A reply that does not parse is logged and skipped, never fatal — one malformed producer must not blind the tool to every other producer’s slice. Nothing is deduplicated: a fleet mid-rollout serving three versions of one producer yields three entries, and that disagreement is the finding.

pub async fn undeclare(self) -> Result<()>

Undeclare both queriers, acknowledged.

Both, even when the first refuses (#346): the wildcard sweep and the @catalog ask are one teardown, and leaving the second declared because the first would not go is the half-torn-down state crate::Monitor::shutdown refuses. Failures are reported together.