Struct PushDispatcher 

pub struct PushDispatcher { /* private fields */ }

推送分发器

Implementations

impl PushDispatcher

pub fn new( connections: Arc<DashMap<u64, ClientConn>>, subscriptions: Arc<SubscriptionManager>, ) -> Self

pub fn with_metrics(self, metrics: Arc<GatewayMetrics>) -> Self

设置监控指标引用

pub fn with_external_sink(self, sink: Arc<dyn ExternalPushSink>) -> Self

添加外部推送接收器（可多次调用注册多个）

pub async fn push_to_conn(&self, conn_id: u64, proto_id: u32, body: Vec<u8>)

向指定连接推送（自动处理 AES 加密）

pub async fn push_notify(&self, proto_id: u32, body: Vec<u8>)

向所有订阅了通知的连接广播（每个连接独立 AES 加密）

pub async fn push_trd_acc(&self, acc_id: u64, proto_id: u32, body: Vec<u8>)

向订阅了指定交易账户的所有连接推送

pub async fn push_broadcast(&self, proto_id: u32, body: Vec<u8>)

向所有已连接的客户端广播（到价提醒等，不需要订阅通知） C++ 检查 IsConnSubRecvNotify，对齐使用 is_subscribed_notify

pub async fn push_qot( &self, security_key: &str, sub_type: i32, proto_id: u32, body: Vec<u8>, )

向订阅了指定行情类型+股票的所有连接推送