Struct EdgeRegistry 

pub struct EdgeRegistry { /* private fields */ }

Home-side edge registry. Cheap to clone via Arc.

Implementations

impl EdgeRegistry

pub fn new(max_edges: usize, liveness_window: Duration) -> Self

pub fn register( &self, edge_id: &str, region: &str, base_url: &str, now_iso: &str, ) -> Result<Receiver<InvalidationEvent>, RegistryError>

Register a new edge. Returns the receiver the SSE handler holds open. Caller is responsible for keeping the receiver alive — when it drops, the next broadcast prunes the edge.

The channel is bounded: a slow edge that doesn’t drain fast enough back-pressures into the broadcast call (which is async). Default capacity 64 events lets bursts ride through without dropping.

pub fn unregister(&self, edge_id: &str) -> bool

Remove an edge — used when the home decides to evict (manual unregister, or cleanup during shutdown).

pub async fn broadcast(&self, ev: InvalidationEvent) -> (u32, u32)

Broadcast an invalidation to every subscribed edge. Edges whose channel has closed (receiver dropped) are pruned. Returns (sent, pruned).

pub fn list(&self) -> Vec<EdgeNode>

Read-only snapshot of currently-registered edges. Used by the admin UI / /api/edge endpoint.

pub fn count(&self) -> usize

pub fn prune_stale(&self) -> u32

Garbage-collect edges that haven’t been seen within liveness_window. Returns the count pruned.

Trait Implementations

impl Clone for EdgeRegistry

fn clone(&self) -> EdgeRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.