Struct PipelineCoordinator 

pub struct PipelineCoordinator { /* private fields */ }

Pipeline coordinator managing all processing stages.

Implementations

impl PipelineCoordinator

pub fn new(sector: SectorTemplate, config: PipelineConfig) -> Self

Create a new pipeline coordinator.

pub fn with_conformance_model(self, model: ProcessModel) -> Self

Set reference model for conformance checking.

pub fn create_result_channel(&mut self) -> Receiver<PipelineMessage>

Create result channel.

pub fn stats(&self) -> &PipelineStats

Get current statistics.

pub fn analytics(&self) -> &AnalyticsEngine

Get analytics engine.

pub fn analytics_mut(&mut self) -> &mut AnalyticsEngine

Get mutable analytics engine.

pub fn current_dfg(&self) -> &DFGGraph

Get current DFG graph.

pub fn current_patterns(&self) -> &[GpuPatternMatch]

Get current detected patterns.

pub fn current_partial_orders(&self) -> &[GpuPartialOrderTrace]

Get current partial orders.

pub fn current_conformance(&self) -> Option<&ConformanceCheckResult>

Get current conformance results.

pub fn variations(&self) -> &HashMap<String, ProcessVariation>

Get process variations.

pub fn dfg_gpu_status(&self) -> GpuStatus

Get GPU status for DFG kernel.

pub fn pattern_gpu_status(&self) -> GpuStatus

Get GPU status for pattern detection kernel.

pub fn is_dfg_using_gpu(&self) -> bool

Check if DFG kernel is using GPU.

pub fn is_pattern_using_gpu(&self) -> bool

Check if pattern kernel is using GPU.

pub fn gpu_stats(&self) -> GpuStatsReport

Get combined GPU stats.

pub fn handle_control(&mut self, msg: ControlMessage)

Handle control message.

pub fn tick(&mut self) -> Option<ProcessedBatch>

Process a single tick (generate + process batch).

pub fn reset(&mut self)

Reset all state.

pub fn set_sector(&mut self, sector: SectorTemplate)

Change sector.

pub fn pipeline(&self) -> &ProcessingPipeline

Get pipeline reference.

pub fn pipeline_mut(&mut self) -> &mut ProcessingPipeline

Get mutable pipeline reference.