Struct cxmr_snapshots_index::SnapshotIndex

pub struct SnapshotIndex { /* fields omitted */ }

Snapshots index.

Methods

impl SnapshotIndex

pub fn new_default<P: AsRef<Path>>(path: P) -> Result<Self, Error>

Creates new genome store with default options.

pub fn new<P: AsRef<Path>>(path: P, options: Options) -> Result<Self, Error>

Creates new genome store from RocksDB options.

pub async fn index<'_, '_>(&'_ mut self, path: &'_ str) -> Result<(), Error>

Inserts new snapshots into index.

pub async fn load<'_>(&'_ mut self) -> Result<(), Error>

Loads snapshots index into memory.

pub async fn markets<'_>(&'_ self) -> Result<Vec<Market>, Error>

Returns all indexed markets in index.

pub async fn market<'_, '_>(
    &'_ self,
    market: &'_ Market
) -> Result<Option<Vec<Metadata>>, Error>

Returns all indexed market snapshots.

pub async fn markets_stats<'_>(
    &'_ self
) -> Result<Vec<(Market, MarketStats)>, Error>

Returns all indexed markets in index with events amount.

pub async fn open_snapshot<'_, '_>(
    &'_ self,
    market: &'_ Market,
    timestamp: u64,
    interval: u64
) -> Result<Snapshot, Error>

Opens snapshot file and reads events.

pub async fn open_snapshot_cached<'_>(
    &'_ self,
    market: Market,
    timestamp: u64,
    interval: u64,
    __arg4: SnapshotCache
) -> Result<SharedSnapshot, Error>

Opens snapshot file and reads events.

pub async fn compact<'_>(&'_ self) -> Result<(), Error>

Compacts database.

Trait Implementations

impl Clone for SnapshotIndex

fn clone(&self) -> SnapshotIndex

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.