Struct StorageManager

pub struct StorageManager {
    pub config: StorageConfig,
    /* private fields */
}

Storage manager that coordinates file operations

Fields

config: StorageConfig

Storage configuration settings

Implementations

impl StorageManager

pub async fn new(config: StorageConfig) -> Result<Self>

Create a new storage manager

pub fn get_file_roller(&self) -> Option<Arc<FileRoller>>

Get FileRoller instance

pub async fn get_writer( &self, exchange: &str, symbol: &str, data_type: &str, ) -> Result<Arc<FileWriter>>

Get or create a file writer for the given parameters

pub async fn write_trade(&self, trade: &TradeRecord) -> Result<()>

Write trade data

pub async fn write_orderbook(&self, orderbook: &OrderBookRecord) -> Result<()>

Write orderbook data

pub async fn get_stats(&self) -> StorageStats

Get storage statistics

pub fn get_file_rotation_stats( &self, ) -> Option<FxHashMap<String, ActiveFileInfo>>

Get file rotation statistics

pub async fn list_files( &self, exchange: Option<&str>, symbol: Option<&str>, data_type: Option<&str>, start_date: Option<SimpleDate>, end_date: Option<SimpleDate>, ) -> Result<Vec<FileInfo>>

List files for a given date range

Trait Implementations

impl Debug for StorageManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.