Struct ConcentrationPipeline 

pub struct ConcentrationPipeline { /* private fields */ }

Ordered, deterministic execution of zero or more ConcentrationPass instances. Each pass receives a dedicated ChaCha8 substream so adding or removing a pass does not perturb the RNG state of any other pass.

Implementations

impl ConcentrationPipeline

pub fn from_config( cfg: &ConcentrationConfig, ) -> Result<Self, ConcentrationPipelineError>

Build a pipeline from config. Returns an empty pipeline if cfg.enabled == false or no passes are configured. Returns Err(ConcentrationPipelineError) if a configured pass fails to construct (e.g. Phase-2 AccountPairSubstitutionPass can’t read its PMF file).

pub fn run( &self, entries: &mut [JournalEntry], seed: u64, ) -> Vec<ConcentrationStats>

Execute every pass in order, each with its own ChaCha8 substream derived deterministically from seed. Returns one ConcentrationStats per pass in execution order.

pub fn is_active(&self) -> bool

True iff the pipeline has at least one configured pass.

pub fn len(&self) -> usize

Number of configured passes (for tests / observability).

pub fn is_empty(&self) -> bool

True iff zero passes are configured.