Struct ProgressTracker 

pub struct ProgressTracker {
    pub total_steps: usize,
    pub step_durations: Vec<u64>,
}

Tracks workflow progress and provides status information

Fields

total_steps: usize

Total number of steps in the workflow

step_durations: Vec<u64>

Step durations in milliseconds (for estimation)

Implementations

impl ProgressTracker

pub fn new(total_steps: usize) -> Self

Create a new progress tracker

pub fn record_step_duration(&mut self, duration_ms: u64)

Record a step duration

pub fn calculate_progress(&self, completed_steps: usize) -> u32

Calculate progress percentage (0-100)

pub fn estimate_completion_time( &self, state: &WorkflowState, now: DateTime<Utc>, ) -> Option<DateTime<Utc>>

Estimate completion time based on step durations

pub fn generate_status_report( &self, state: &WorkflowState, now: DateTime<Utc>, ) -> StatusReport

Generate a status report

pub fn get_average_step_duration(&self) -> Option<u64>

Get average step duration in milliseconds

pub fn get_min_step_duration(&self) -> Option<u64>

Get minimum step duration in milliseconds

pub fn get_max_step_duration(&self) -> Option<u64>

Get maximum step duration in milliseconds

Trait Implementations

impl Clone for ProgressTracker

fn clone(&self) -> ProgressTracker

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProgressTracker

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ProgressTracker

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ProgressTracker

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.