rsmarketstore

MarketStore 的 Rust 驱动

rsmarketstore 可以从 MarketStore 查询和 [写入 待定] 金融时间序列数据

如何安装

cargo add rsmarketstore

示例

// Connect
let agent = Agent::connect(
    Uri::from_static("http://localhost:5995").into()).await;

// Query
agent
    .query(QueryParams {
        symbols: vec!["NIFTY 50".to_string()],
        timeframe: marketstore::MIN,
        attrgroup: "OHLCV".to_string(),
        ..Default::default()
    })
    .await?

// timeframes
let FiveMins = 5 * marketstore::MIN;
let FifteenMin = 15 * marketstore::MIN;

let TwoHours = 2 * marketstore::HOUR;

// stream
    let (stream, receiver) = stream::connect::<Candle>("ws://localhost:5993/ws")
        .await
        .unwrap();

    stream.subscribe(vec!["NIFTY 50".into()]).await?;
    receiver
        .for_each(|msg| async move {
            println!("{:#?}", msg);
        })
        .await;

Serde 与 Protobuf

源代码位于 examples/ohlcv

# Run
cargo run --example ohlcv --features=serde

流

源代码位于 examples/stream

# Run
cargo run --example stream --features=stream