Expand description
Subscription manager (RFC §13).
Phase 5 ships a lightweight implementation: every accepted envelope is
published into a tokio::sync::broadcast channel. Subscriptions filter
the live tail by type / session_id / job_id; backfill replays from
the event log. Rich filter authorisation (PLAN.md §A4.10) is reserved
for a follow-up phase.
Structs§
- Filtered
Receiver - Receiver that yields envelopes matching a
SubscriptionFilter. - Subscription
Manager - Map of active subscriptions, keyed by
SubscriptionId.
Functions§
- matches
- True if
envelopesatisfies the filter (AND across fields, OR within list-valued fields).