Struct SubscriptionRegistry 

pub struct SubscriptionRegistry { /* private fields */ }

Subscription registry enforcing lifecycle and negotiation rules.

Implementations

impl SubscriptionRegistry

pub fn new() -> SubscriptionRegistry

pub fn subscribe(&mut self, subscription: Subscription)

Add a persistent subscription.

pub fn unsubscribe(&mut self, subscription_id: &str) -> Option<Subscription>

Unsubscribe by ID.

pub fn match_event( &self, scope: &SubscriptionScope, predicate: &SubscriptionPredicate, target_state: Option<NodeLifecycleState>, ) -> Vec<Subscription>

Match active subscriptions for an event, respecting lifecycle restrictions.

pub fn advance_cursor(&mut self, subscription_id: &str, new_cursor: u64)

Update subscription cursor upon delivery receipt.

Trait Implementations

impl Clone for SubscriptionRegistry

fn clone(&self) -> SubscriptionRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriptionRegistry

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for SubscriptionRegistry

fn default() -> SubscriptionRegistry

Returns the “default value” for a type.