Struct DataFabricPipeline 

pub struct DataFabricPipeline { /* private fields */ }

The data fabric pipeline.

Implementations

impl DataFabricPipeline

pub fn new( archetype: CompanyArchetype, generator_config: GeneratorConfig, pipeline_config: PipelineConfig, ) -> Self

Create a new pipeline.

pub fn subscribe(&self) -> Receiver<PipelineEvent>

Subscribe to pipeline events.

pub fn network_snapshot(&self) -> NetworkSnapshot

Get the current network snapshot.

pub fn network(&self) -> &AccountingNetwork

Get the full network (for analysis).

pub fn network_mut(&mut self) -> &mut AccountingNetwork

Get mutable network access.

pub fn stats(&self) -> &PipelineStats

Get current statistics.

pub fn is_running(&self) -> bool

Check if pipeline is running.

pub fn is_paused(&self) -> bool

Check if pipeline is paused.

pub fn tick(&mut self) -> Vec<TransactionFlow>

Process one batch of data. Returns the generated flows.

pub fn pause(&mut self)

Pause the pipeline.

pub fn resume(&mut self)

Resume the pipeline.

pub fn stop(&mut self)

Stop the pipeline.

pub fn reset(&mut self)

Reset the pipeline (clear network and stats).