Skip to main content

CandleStore

quantforge::ports

Trait CandleStore 

Source 
pub trait CandleStore: Send + Sync {
    // Required methods
    fn init(&self) -> Result<(), StorageError>;
    fn upsert_candles(
        &self,
        market: &MarketId,
        candles: &[Candle],
    ) -> Result<usize, StorageError>;
    fn load_candles(
        &self,
        market: &MarketId,
        query: CandleQuery,
    ) -> Result<Vec<Candle>, StorageError>;
    fn load_recent_candles(
        &self,
        market: &MarketId,
        limit: usize,
    ) -> Result<Vec<Candle>, StorageError>;
    fn max_open_time_ms(
        &self,
        market: &MarketId,
    ) -> Result<Option<TimestampMs>, StorageError>;
}

Required Methods§

Source

fn init(&self) -> Result<(), StorageError>

Source

fn upsert_candles( &self, market: &MarketId, candles: &[Candle], ) -> Result<usize, StorageError>

Source

fn load_candles( &self, market: &MarketId, query: CandleQuery, ) -> Result<Vec<Candle>, StorageError>

Source

fn load_recent_candles( &self, market: &MarketId, limit: usize, ) -> Result<Vec<Candle>, StorageError>

Source

fn max_open_time_ms( &self, market: &MarketId, ) -> Result<Option<TimestampMs>, StorageError>

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§