mylittleindicators 0.1.2

Multi-stream financial indicators library — 559 bar indicators + 21 event primitives across 35 categories. Consumes OHLCV bars, ticks, orderbook (snapshot/delta), funding, mark price, open interest, liquidations, ticker, agg trades, and 12+ extended stream types from digdigdig3 exchange connectors.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

//! Trait for pluggable REST-based stream fetchers.
//!
//! Concrete implementations (e.g. via digdigdig3 `ExchangeHub`) are provided externally.
//! Pass an implementor via `EnrichedDataLoader::with_rest_fetcher(...)`.

use async_trait::async_trait;
use digdigdig3::{AccountType, ExchangeId};

use super::{StreamKind, TimedEvent};

/// Fetches historical events for a stream from a remote REST exchange API.
///
/// # Integration
/// Implement this trait against digdigdig3 `ExchangeHub` or any other HTTP client.
/// Then pass the implementor via `EnrichedDataLoader::with_rest_fetcher(...)`.
#[async_trait]
pub trait RestFetcher: Send + Sync {
    /// Fetch events for `exchange`/`account_type`/`symbol`/`kind` in the closed
    /// timestamp range `[from_ts, to_ts]` (milliseconds).
    ///
    /// Returns a vec of `TimedEvent`, not necessarily sorted.
    async fn fetch(
        &self,
        exchange: ExchangeId,
        account_type: AccountType,
        symbol: &str,
        kind: StreamKind,
        from_ts: i64,
        to_ts: i64,
    ) -> Result<Vec<TimedEvent>, String>;
}