Struct SubscriptionManager 

pub struct SubscriptionManager { /* private fields */ }

Manages active subscriptions

Implementations

impl SubscriptionManager

pub fn new() -> Self

Create a new subscription manager

pub fn add_book_update(&mut self, orderbook_ids: Vec<String>)

Add a book update subscription

pub fn remove_book_update(&mut self, orderbook_ids: &[String])

Remove a book update subscription

pub fn is_subscribed_book_update(&self, orderbook_id: &str) -> bool

Check if subscribed to book updates for an orderbook

pub fn add_trades(&mut self, orderbook_ids: Vec<String>)

Add a trades subscription

pub fn remove_trades(&mut self, orderbook_ids: &[String])

Remove a trades subscription

pub fn is_subscribed_trades(&self, orderbook_id: &str) -> bool

Check if subscribed to trades for an orderbook

pub fn add_user(&mut self, user: String)

Add a user subscription

pub fn remove_user(&mut self, user: &str)

Remove a user subscription

pub fn is_subscribed_user(&self, user: &str) -> bool

Check if subscribed to a user

pub fn add_price_history( &mut self, orderbook_id: String, resolution: String, include_ohlcv: bool, )

Add a price history subscription

pub fn remove_price_history(&mut self, orderbook_id: &str, resolution: &str)

Remove a price history subscription

pub fn is_subscribed_price_history( &self, orderbook_id: &str, resolution: &str, ) -> bool

Check if subscribed to price history for an orderbook/resolution

pub fn add_market(&mut self, market_pubkey: String)

Add a market subscription

pub fn remove_market(&mut self, market_pubkey: &str)

Remove a market subscription

pub fn is_subscribed_market(&self, market_pubkey: &str) -> bool

Check if subscribed to market events

pub fn get_all_subscriptions(&self) -> Vec<Subscription>

Get all subscriptions for re-subscribing after reconnect

pub fn clear(&mut self)

Clear all subscriptions

pub fn has_subscriptions(&self) -> bool

Check if there are any active subscriptions

pub fn subscription_count(&self) -> usize

Get count of active subscriptions

pub fn book_update_orderbooks(&self) -> Vec<String>

Get all subscribed orderbook IDs (for book updates)

pub fn trade_orderbooks(&self) -> Vec<String>

Get all subscribed orderbook IDs (for trades)

pub fn subscribed_users(&self) -> Vec<String>

Get all subscribed users

pub fn subscribed_markets(&self) -> Vec<String>

Get all subscribed markets

Trait Implementations

impl Debug for SubscriptionManager

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

Formats the value using the given formatter.

impl Default for SubscriptionManager

fn default() -> SubscriptionManager

Returns the “default value” for a type.