Struct SubscriptionHub 

pub struct SubscriptionHub { /* private fields */ }

The process’s subscription sources. Cheap to share behind an Arc.

Implementations

impl SubscriptionHub

pub fn new() -> Self

A hub with the default ring caps and byte budget.

pub fn with_limits(ring: RingLimits, byte_budget: usize) -> Self

A hub with explicit caps (tests use small ones).

pub fn publish(&self, source: Source, frame: Value) -> u64

Append a frame and wake that source’s subscribers. Never waits. Returns the frame’s sequence number.

pub fn note_loss(&self, source: Source, count: u64)

Record that count frames for source were lost before reaching the hub. Their sequence numbers are skipped, so any cursor that would have read them reads Read::Lagged instead.

pub fn epoch(&self) -> &str

This hub’s identity. Sequence numbers are only comparable within one epoch.

pub fn oldest_seq(&self, source: Source) -> u64

The sequence number of the oldest frame still buffered, or the next sequence number when the ring is empty.

pub fn head_seq(&self, source: Source) -> u64

The sequence number of the newest frame (0 before the first).

pub fn read(&self, source: Source, cursor: u64, max: usize) -> Read

Up to max frames at or after cursor, or the gap the cursor is in.

pub fn notifier(&self, source: Source) -> &Notify

The wakeup for source, signalled on every publish and loss.

pub fn total_bytes(&self) -> usize

Total bytes held across all rings.

pub fn attach_bus(self: &Arc<Self>, tx: &Sender<Value>)

Feed this hub from the daemon event bus: every frame into Source::Logs, observer frames into Source::Events. Idempotent: only the first call starts the pump.

Pairing credentials are dropped before they reach a ring, so they are never replayed, and the internal marker is stripped from everything else. A broadcast overrun is recorded with Self::note_loss, so subscribers see lagged, not a silent gap.

Trait Implementations

impl Default for SubscriptionHub

fn default() -> Self

Returns the “default value” for a type.