Struct DataPipeline

pub struct DataPipeline { /* private fields */ }

Data pipeline that processes market data events and stores them

Implementations

impl DataPipeline

pub fn new(config: PipelineConfig, storage_manager: Arc<StorageManager>) -> Self

Create a new data pipeline

pub async fn start( &mut self, event_receiver: Receiver<MarketDataEvent>, ) -> Result<()>

Start the pipeline processing

pub async fn stop(&mut self) -> Result<()>

Stop the pipeline processing

pub fn get_stats(&self) -> PipelineStats

Get current pipeline statistics

pub fn reset_stats(&self)

Reset pipeline statistics

Trait Implementations

impl Debug for DataPipeline

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

Formats the value using the given formatter.

impl Drop for DataPipeline

fn drop(&mut self)

Executes the destructor for this type.