as-rust/exchanges/src/response_base.rs

/**交易所返回数据处理之后，同意保存格式，为了内部其他接口调用*/
#[derive(Debug, Clone)]
pub struct ResponseData {
    pub label: String,
    pub code: String,
    pub message: String,
    pub channel: String,
    pub data: String,
    pub time: i64,       //数据接受的时间
    pub reach_time: i64, //远程数据时间 弃用
    pub data_type: String // 數據類型, 例如 bybit 深度信息：snapshot（全量）,delta（增量）
}

impl ResponseData {
    pub fn new(label: String, code: String, message: String, data: String) -> ResponseData {
        ResponseData { label, code, message, data, channel: "".to_string(), time: 0, reach_time: 0 , data_type: String::new()}
    }
    pub fn error(label: String, message: String) -> ResponseData {
        ResponseData {
            label,
            code: "-1".to_string(),
            message: format!("{}", &message),
            data: "".to_string(),
            channel: "".to_string(),
            time: 0,
            reach_time: 0,
            data_type: String::new()
        }
    }

    pub fn to_string(&self) -> String {
        format!("{:?}", self)
    }
}