Struct SubscriptionManager 

pub struct SubscriptionManager { /* private fields */ }

Registry for multiple CDC subscriptions.

Assigns monotonically increasing IDs and provides lookup, creation, and removal of Subscription instances.

Implementations

impl SubscriptionManager

pub fn new() -> Self

Create an empty subscription manager.

pub fn subscribe(&mut self, pattern: Option<String>) -> u64

Create a subscription starting at sequence 0 and return its ID.

pub fn subscribe_at(&mut self, pattern: Option<String>, cursor: u64) -> u64

Create a subscription beginning at cursor and return its ID.

pub fn unsubscribe(&mut self, id: u64) -> bool

Remove a subscription by ID. Returns true if it existed.

pub fn get_mut(&mut self, id: u64) -> Option<&mut Subscription>

Look up a subscription by ID, returning a mutable reference.

pub fn len(&self) -> usize

Return the number of active subscriptions.

pub fn is_empty(&self) -> bool

Return true if there are no active subscriptions.

Trait Implementations

impl Default for SubscriptionManager

fn default() -> Self

Returns the “default value” for a type.