Struct Registry 

pub struct Registry { /* private fields */ }

The awareness roster of one application.

Implementations

impl Registry

pub fn new(config: Config) -> Arc<Registry>

pub fn value(&self) -> Value

The roster as a Beck value: Map[Str, T], actor to contribution.

pub fn watch(&self) -> Receiver<Value>

Wake on every change to it. A subscription watches this only when the program’s page reads awareness — a program that never asks must not re-render when somebody navigates.

pub fn here(&self) -> usize

How many actors are in the roster.

pub fn refused(&self) -> u64

How many joins the capacity refused, for the life of this process.

pub fn oversized(&self) -> u64

How many contributions the per-actor bound refused, for the life of this process.

pub fn join(self: &Arc<Self>, actor: &str, contribution: Value) -> Guard

Record a connection’s first contribution. The roster holds it until the guard is dropped.

A guard for crate::presence::Guard’s reason: a subscription ends by returning, by erroring or by its socket dying, and a roster that only removed an actor on the happy path would fill up with people who left hours ago.

pub fn update(&self, actor: &str, contribution: Value) -> bool

Publish a new contribution for an actor already in the roster.

Silently does nothing for an actor that is not — the capacity refused them, and a client navigating should not be a way to get in through a different door.

Returns whether the roster changed, which is what saves a re-render: the common navigation republishes the same route.