Struct PubSubManager 

pub struct PubSubManager {
    clients: Arc<DashMap<Uuid, Client>>,
    channel_subscribers: Arc<DashMap<String, Vec<Uuid>>>,
}

Fields

clients: Arc<DashMap<Uuid, Client>>

channel_subscribers: Arc<DashMap<String, Vec<Uuid>>>

Implementations

impl PubSubManager

pub fn new() -> Self

pub fn add_client( &self, client_id: Uuid, sender: UnboundedSender<Arc<WsMessage>>, authenticated: bool, wallet_address: Option<WalletAddress>, )

pub fn authenticate_client( &self, client_id: Uuid, wallet_address: WalletAddress, ) -> Result<(), String>

Set the wallet address on a connected client (message-based auth).

pub fn remove_client(&self, client_id: Uuid)

pub fn subscribe( &self, client_id: Uuid, channel: String, symbols: Option<Vec<String>>, expiry: Option<String>, option_type: Option<String>, ) -> Result<(), String>

pub fn unsubscribe( &self, client_id: Uuid, channel: String, symbols: Option<Vec<String>>, expiry: Option<String>, option_type: Option<String>, ) -> Result<(), String>

pub fn publish_to_channel(&self, channel: &str, message: WsMessage)

pub async fn active_channels_with_prefix(&self, prefix: &str) -> Vec<String>

pub fn send_to_client(&self, client_id: Uuid, message: WsMessage)

pub fn publish_orderbook_update(&self, update: WsOrderbookUpdate)

pub fn publish_order_update(&self, order: WsOrderMessage)

pub fn publish_fill(&self, fill: WsFillUpdate)

pub fn publish_market_update(&self, update: WsMarketUpdate)

pub fn publish_trade(&self, trade: WsTradeUpdate)

pub fn publish_options_chain_update(&self, update: WsOptionsChainUpdate)

pub fn publish_index_prices(&self, update: WsIndexPriceUpdate)

pub fn publish_indicative_market_data(&self, update: WsIndicativeMarketData)

pub fn publish_position_expired(&self, expired: WsPositionExpired)

pub fn publish_liquidation_state_change( &self, state_change: WsLiquidationStateChange, )

pub async fn publish_competition_update(&self, update: WsCompetitionUpdate)

pub async fn publish_competition_pnl_summary( &self, summary: WsCompetitionPnlSummary, )

pub async fn publish_competition_final_stats( &self, final_stats: WsCompetitionFinalStats, )

pub async fn publish_competition_rank_change( &self, update: WsCompetitionRankChange, )

pub async fn publish_competition_gap_update( &self, update: WsCompetitionGapUpdate, )

pub async fn publish_competition_final_standing( &self, update: WsCompetitionFinalStanding, )

pub fn publish_rfq_quotes(&self, quotes: WsRfqQuotes)

pub async fn subscribed_wallets(&self, channel: &str) -> Vec<WalletAddress>

Return wallets subscribed to the given channel (authenticated wallets only).

Trait Implementations

impl Clone for PubSubManager

fn clone(&self) -> PubSubManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for PubSubManager

fn default() -> Self

Returns the “default value” for a type.

impl RfqWebsocketPublisher for PubSubManager

fn publish_indicative_market_data(&self, update: WsIndicativeMarketData)

fn publish_rfq_quotes(&self, quotes: WsRfqQuotes)

fn publish_to_channel(&self, channel: &str, message: WsMessage)