Struct PushDispatcher 

pub struct PushDispatcher { /* private fields */ }

推送分发器

Implementations

impl PushDispatcher

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

Send one quote first-push to the target physical connection.

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

Direct first-push with the ordinary quote route identity required by the shared KLine cursor.

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

Fan out one ordinary quote event without KLine section metadata.

pub async fn push_qot_with_kline_section( &self, security_key: &str, sub_type: i32, rehab_type: i32, proto_id: u32, body: Vec<u8>, kline_trade_section: Option<KlineTradeSection>, )

Fan out one canonical quote event. kline_trade_section is internal route metadata used only for C++-compatible native connection filtering.

impl PushDispatcher

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

创建推送分发器。connections 和 subscriptions 由 super::listener::ApiServer 共享；外部 sink / metrics 可通过 Self::with_metrics / Self::with_external_sink 后续注入。

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

设置监控指标引用

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

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

pub fn with_startup_readiness(self, startup_readiness: StartupReadiness) -> Self

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

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

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

Direct async delivery; generation is checked in the physical tx lookup.

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，对齐使用 InitConnect.recvNotify。