Struct DataManager 

pub struct DataManager { /* private fields */ }

数据管理器

管理所有 DIFF 协议数据，支持：

• 递归合并
• 版本追踪
• 路径监听

Implementations

impl DataManager

pub fn new( initial_data: HashMap<String, Value>, config: DataManagerConfig, ) -> Self

创建新的数据管理器

pub fn on_data<F>(&self, callback: F)

where F: Fn() + Send + Sync + 'static,

注册数据更新回调

pub fn merge_data(&self, source: Value, epoch_increase: bool, delete_null: bool)

合并数据（DIFF 协议核心）

参数

• source - 源数据（可以是单个对象或数组）
• epoch_increase - 是否增加版本号
• delete_null - 是否删除 null 对象

pub fn get_by_path(&self, path: &[&str]) -> Option<Value>

根据路径获取数据

pub fn is_changing(&self, path: &[&str]) -> bool

判断指定路径的数据是否在最近一次更新中发生了变化

pub fn get_epoch(&self) -> i64

获取当前版本号

pub fn set_default(&self, path: &[&str], default_value: Value) -> Option<Value>

设置默认值

pub fn watch(&self, path: Vec<String>) -> Receiver<Value>

监听指定路径的数据变化

返回一个 receiver，数据变化时会推送到这个 channel

pub fn unwatch(&self, path: &[String]) -> Result<()>

取消路径监听

pub fn convert_to_struct<T: DeserializeOwned>(&self, data: &Value) -> Result<T>

转换为结构体

pub fn get_quote_data(&self, symbol: &str) -> Result<Quote>

获取 Quote 数据

pub fn get_klines_data( &self, symbol: &str, duration: i64, view_width: usize, right_id: i64, ) -> Result<KlineSeriesData>

获取 K线数据

pub fn get_multi_klines_data( &self, symbols: &[String], duration: i64, chart_id: &str, view_width: usize, ) -> Result<MultiKlineSeriesData>

获取多合约对齐的 K线数据

pub fn get_ticks_data( &self, symbol: &str, view_width: usize, right_id: i64, ) -> Result<TickSeriesData>

获取 Tick 数据

pub fn get_account_data(&self, user_id: &str, currency: &str) -> Result<Account>

获取账户数据

pub fn get_position_data(&self, user_id: &str, symbol: &str) -> Result<Position>

获取持仓数据

pub fn get_order_data(&self, user_id: &str, order_id: &str) -> Result<Order>

获取委托单数据

pub fn get_trade_data(&self, user_id: &str, trade_id: &str) -> Result<Trade>

获取成交数据