Struct ZerocopyDataPipeline

pub struct ZerocopyDataPipeline { /* private fields */ }

Zero-copy optimized data pipeline

Implementations

impl ZerocopyDataPipeline

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

Create a new zero-copy optimized data pipeline

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

Start the zero-copy pipeline processing

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

Stop the zero-copy pipeline processing

pub fn get_stats(&self) -> ZerocopyPipelineStats

Get current zero-copy pipeline statistics

pub fn reset_stats(&self)

Reset pipeline statistics

Trait Implementations

impl Debug for ZerocopyDataPipeline

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

Formats the value using the given formatter.

impl Drop for ZerocopyDataPipeline

fn drop(&mut self)

Executes the destructor for this type.