Enum ProgressUpdate 

pub enum ProgressUpdate {
    Started {
        job_id: Uuid,
        job_type: JobType,
        total_steps: usize,
        total_workspaces: usize,
        timestamp: DateTime<Utc>,
    },
    Completed {
        job_id: Uuid,
        duration_ms: u64,
        timestamp: DateTime<Utc>,
    },
    Failed {
        job_id: Uuid,
        error: String,
        timestamp: DateTime<Utc>,
    },
    WorkspaceStarted {
        job_id: Uuid,
        workspace: String,
        timestamp: DateTime<Utc>,
    },
    WorkspaceCompleted {
        job_id: Uuid,
        workspace: String,
        duration_ms: u64,
        timestamp: DateTime<Utc>,
    },
    StepStarted {
        job_id: Uuid,
        step_name: String,
        workspace: String,
        phase: ExecutionPhase,
        timestamp: DateTime<Utc>,
    },
    StepCompleted {
        job_id: Uuid,
        step_name: String,
        workspace: String,
        phase: ExecutionPhase,
        rows: usize,
        duration_ms: u64,
        timestamp: DateTime<Utc>,
    },
    StepFailed {
        job_id: Uuid,
        step_name: String,
        workspace: String,
        phase: ExecutionPhase,
        error: String,
        timestamp: DateTime<Utc>,
    },
    StepSkipped {
        job_id: Uuid,
        step_name: String,
        workspace: String,
        phase: ExecutionPhase,
        reason: String,
        timestamp: DateTime<Utc>,
    },
    VariablesExtracted {
        job_id: Uuid,
        step_name: String,
        workspace: String,
        variables: Vec<String>,
        timestamp: DateTime<Utc>,
    },
    ConditionEvaluated {
        job_id: Uuid,
        step_name: String,
        condition: String,
        result: bool,
        timestamp: DateTime<Utc>,
    },
    ForeachProgress {
        job_id: Uuid,
        step_name: String,
        workspace: String,
        current: usize,
        total: usize,
        timestamp: DateTime<Utc>,
    },
    HttpExecuted {
        job_id: Uuid,
        step_name: String,
        url: String,
        status: u16,
        duration_ms: u64,
        timestamp: DateTime<Utc>,
    },
    Debug {
        job_id: Uuid,
        message: String,
        timestamp: DateTime<Utc>,
    },
}

Progress update message sent during execution

Variants

Started

Execution has started

Fields

job_id: Uuid

job_type: JobType

total_steps: usize

total_workspaces: usize

timestamp: DateTime<Utc>

Completed

Execution completed successfully

Fields

job_id: Uuid

duration_ms: u64

timestamp: DateTime<Utc>

Failed

Execution failed

Fields

job_id: Uuid

error: String

timestamp: DateTime<Utc>

WorkspaceStarted

Workspace execution started

Fields

job_id: Uuid

workspace: String

timestamp: DateTime<Utc>

WorkspaceCompleted

Workspace execution completed

Fields

job_id: Uuid

workspace: String

duration_ms: u64

timestamp: DateTime<Utc>

StepStarted

A step/query has started

Fields

job_id: Uuid

step_name: String

workspace: String

phase: ExecutionPhase

timestamp: DateTime<Utc>

StepCompleted

A step/query completed successfully

Fields

job_id: Uuid

step_name: String

workspace: String

phase: ExecutionPhase

rows: usize

duration_ms: u64

timestamp: DateTime<Utc>

StepFailed

A step/query failed

Fields

job_id: Uuid

step_name: String

workspace: String

phase: ExecutionPhase

error: String

timestamp: DateTime<Utc>

StepSkipped

A step was skipped (condition not met, dependency failed, etc.)

Fields

job_id: Uuid

step_name: String

workspace: String

phase: ExecutionPhase

reason: String

timestamp: DateTime<Utc>

VariablesExtracted

Variables extracted from a step (investigation only)

Fields

job_id: Uuid

step_name: String

workspace: String

variables: Vec<String>

timestamp: DateTime<Utc>

ConditionEvaluated

Condition evaluated (investigation only)

Fields

job_id: Uuid

step_name: String

condition: String

result: bool

timestamp: DateTime<Utc>

ForeachProgress

Foreach iteration progress (investigation only)

Fields

job_id: Uuid

step_name: String

workspace: String

current: usize

total: usize

timestamp: DateTime<Utc>

HttpExecuted

HTTP step executed (investigation only)

Fields

job_id: Uuid

step_name: String

url: String

status: u16

duration_ms: u64

timestamp: DateTime<Utc>

Debug

Debug message (only when verbose mode is enabled)

Fields

job_id: Uuid

message: String

timestamp: DateTime<Utc>

Implementations

impl ProgressUpdate

pub fn job_id(&self) -> Uuid

Get the job ID from any progress update

pub fn timestamp(&self) -> DateTime<Utc>

Get the timestamp from any progress update

pub fn is_error(&self) -> bool

Check if this is an error event

pub fn debug(job_id: Uuid, message: impl Into<String>) -> Self

Create a debug message

Trait Implementations

impl Clone for ProgressUpdate

fn clone(&self) -> ProgressUpdate

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProgressUpdate

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ProgressUpdate

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ProgressUpdate

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

where __S: Serializer,

Serialize this value into the given Serde serializer.