Struct ApiServer 

pub struct ApiServer { /* private fields */ }

API 服务端

Implementations

impl ApiServer

pub fn new(config: ServerConfig) -> Self

pub fn set_subscriptions(&mut self, subs: Arc<SubscriptionManager>)

设置订阅管理器，用于连接断开时自动清理订阅关系

pub fn router(&self) -> &Arc<RequestRouter>

获取路由器引用（用于注册业务处理器）

pub fn connections(&self) -> &Arc<DashMap<u64, ClientConn>>

获取连接池引用（用于推送分发）

pub fn set_metrics(&mut self, metrics: Arc<GatewayMetrics>)

设置外部监控指标（共享同一个 Arc，让 bridge 和 server 使用同一份计数器）

pub fn metrics(&self) -> &Arc<GatewayMetrics>

获取监控指标引用

pub async fn run(&self) -> Result<()>

启动服务端监听

pub async fn send_response( connections: &DashMap<u64, ClientConn>, conn_id: u64, proto_id: u32, serial_no: u32, body: Vec<u8>, )

向指定连接发送响应（自动处理 AES 加密）