Struct StageProcessorHelper 

pub struct StageProcessorHelper { /* private fields */ }

Helper utility for common stage processing patterns.

This struct provides reusable methods for the common lifecycle patterns found across stage processors, reducing code duplication.

Implementations

impl StageProcessorHelper

pub fn new(stage_name: &'static str) -> Self

Create a new stage processor helper

pub fn start_timer(&self) -> Instant

Start timing an operation

pub fn single_item_metrics( &self, start_time: Instant, success: bool, ) -> StageMetrics

Create metrics for a single item operation

pub fn batch_metrics( &self, start_time: Instant, success_count: usize, failure_count: usize, total_items: usize, parallel: bool, ) -> StageMetrics

Create metrics for batch operations

pub fn wrap_result<T>(&self, data: T, metrics: StageMetrics) -> StageResult<T>

Wrap a result with metrics