Struct PipelineTracker 

pub struct PipelineTracker { /* private fields */ }

Tracks progress through a multi-stage pipeline.

Implementations

impl PipelineTracker

pub fn new(stages: Vec<String>) -> PipelineTracker

Create a new pipeline tracker with the given stages.

pub fn current_stage(&self) -> Option<&str>

Get the current stage name.

pub fn next_stage(&self) -> Option<&str>

Get the next stage name.

pub fn advance(&mut self, elapsed_us: u64) -> bool

Advance to the next stage, recording timing for the completed stage.

pub fn record_items(&mut self, count: u64)

Record items processed in current stage.

pub fn is_complete(&self) -> bool

Check if pipeline is complete.

pub fn total_time_us(&self) -> u64

Get total pipeline timing.

pub fn stage_timing(&self, stage: &str) -> Option<u64>

Get timing for a specific stage.

pub fn reset(&mut self)

Reset pipeline for new processing.

Trait Implementations

impl Clone for PipelineTracker

fn clone(&self) -> PipelineTracker

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PipelineTracker

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

Formats the value using the given formatter.