Enum AuditEvent 

pub enum AuditEvent {
    Observe {
        timestamp: DateTime<Utc>,
        query: String,
        symbol_count: usize,
    },
    Constrain {
        timestamp: DateTime<Utc>,
        policy_count: usize,
        violations: usize,
    },
    Plan {
        timestamp: DateTime<Utc>,
        step_count: usize,
        estimated_files: usize,
    },
    Mutate {
        timestamp: DateTime<Utc>,
        files_modified: Vec<String>,
    },
    Verify {
        timestamp: DateTime<Utc>,
        passed: bool,
        diagnostic_count: usize,
    },
    Commit {
        timestamp: DateTime<Utc>,
        transaction_id: String,
    },
    Rollback {
        timestamp: DateTime<Utc>,
        reason: String,
        phase: String,
    },
    WorkflowStarted {
        timestamp: DateTime<Utc>,
        workflow_id: String,
        task_count: usize,
    },
    WorkflowTaskStarted {
        timestamp: DateTime<Utc>,
        workflow_id: String,
        task_id: String,
        task_name: String,
    },
    WorkflowTaskCompleted {
        timestamp: DateTime<Utc>,
        workflow_id: String,
        task_id: String,
        task_name: String,
        result: String,
    },
    WorkflowTaskFailed {
        timestamp: DateTime<Utc>,
        workflow_id: String,
        task_id: String,
        task_name: String,
        error: String,
    },
    WorkflowCompleted {
        timestamp: DateTime<Utc>,
        workflow_id: String,
        total_tasks: usize,
        completed_tasks: usize,
    },
    WorkflowTaskRolledBack {
        timestamp: DateTime<Utc>,
        workflow_id: String,
        task_id: String,
        compensation: String,
    },
    WorkflowRolledBack {
        timestamp: DateTime<Utc>,
        workflow_id: String,
        reason: String,
        rolled_back_tasks: Vec<String>,
    },
    WorkflowCancelled {
        timestamp: DateTime<Utc>,
        workflow_id: String,
    },
    WorkflowTaskTimedOut {
        timestamp: DateTime<Utc>,
        workflow_id: String,
        task_id: String,
        task_name: String,
        timeout_secs: u64,
    },
    WorkflowToolFallback {
        timestamp: DateTime<Utc>,
        workflow_id: String,
        task_id: String,
        tool_name: String,
        error: String,
        fallback_action: String,
    },
    WorkflowTaskParallelStarted {
        timestamp: DateTime<Utc>,
        workflow_id: String,
        layer_index: usize,
        task_count: usize,
    },
    WorkflowTaskParallelCompleted {
        timestamp: DateTime<Utc>,
        workflow_id: String,
        layer_index: usize,
        task_count: usize,
    },
    WorkflowDeadlockCheck {
        timestamp: DateTime<Utc>,
        workflow_id: String,
        has_cycles: bool,
        warnings: Vec<String>,
    },
    WorkflowDeadlockTimeout {
        timestamp: DateTime<Utc>,
        workflow_id: String,
        layer_index: usize,
        timeout_secs: u64,
    },
}

Audit event for phase transitions.

Each event captures the timestamp and phase-specific data for complete transaction reconstruction.

Variants

Observe

Observation phase - gather context from graph

Fields

timestamp: DateTime<Utc>

query: String

symbol_count: usize

Constrain

Constraint phase - apply policy rules

Fields

timestamp: DateTime<Utc>

policy_count: usize

violations: usize

Plan

Plan phase - generate execution steps

Fields

timestamp: DateTime<Utc>

step_count: usize

estimated_files: usize

Mutate

Mutate phase - apply changes

Fields

timestamp: DateTime<Utc>

files_modified: Vec<String>

Verify

Verify phase - validate results

Fields

timestamp: DateTime<Utc>

passed: bool

diagnostic_count: usize

Commit

Commit phase - finalize transaction

Fields

timestamp: DateTime<Utc>

transaction_id: String

Rollback

Rollback occurred with reason

Fields

timestamp: DateTime<Utc>

reason: String

phase: String

WorkflowStarted

Workflow execution started

Fields

timestamp: DateTime<Utc>

workflow_id: String

task_count: usize

WorkflowTaskStarted

Workflow task started

Fields

timestamp: DateTime<Utc>

workflow_id: String

task_id: String

task_name: String

WorkflowTaskCompleted

Workflow task completed

Fields

timestamp: DateTime<Utc>

workflow_id: String

task_id: String

task_name: String

result: String

WorkflowTaskFailed

Workflow task failed

Fields

timestamp: DateTime<Utc>

workflow_id: String

task_id: String

task_name: String

error: String

WorkflowCompleted

Workflow execution completed

Fields

timestamp: DateTime<Utc>

workflow_id: String

total_tasks: usize

completed_tasks: usize

WorkflowTaskRolledBack

Workflow task rolled back

Fields

timestamp: DateTime<Utc>

workflow_id: String

task_id: String

compensation: String

WorkflowRolledBack

Workflow rolled back

Fields

timestamp: DateTime<Utc>

workflow_id: String

reason: String

rolled_back_tasks: Vec<String>

WorkflowCancelled

Workflow cancelled

Fields

timestamp: DateTime<Utc>

workflow_id: String

WorkflowTaskTimedOut

Workflow task timed out

Fields

timestamp: DateTime<Utc>

workflow_id: String

task_id: String

task_name: String

timeout_secs: u64

WorkflowToolFallback

Workflow tool fallback activated

Fields

timestamp: DateTime<Utc>

workflow_id: String

task_id: String

tool_name: String

error: String

fallback_action: String

WorkflowTaskParallelStarted

Parallel task layer started

Fields

timestamp: DateTime<Utc>

workflow_id: String

layer_index: usize

task_count: usize

WorkflowTaskParallelCompleted

Parallel task layer completed

Fields

timestamp: DateTime<Utc>

workflow_id: String

layer_index: usize

task_count: usize

WorkflowDeadlockCheck

Workflow deadlock check completed

Fields

timestamp: DateTime<Utc>

workflow_id: String

has_cycles: bool

warnings: Vec<String>

WorkflowDeadlockTimeout

Workflow deadlock timeout occurred

Fields

timestamp: DateTime<Utc>

workflow_id: String

layer_index: usize

timeout_secs: u64

Trait Implementations

impl Clone for AuditEvent

fn clone(&self) -> AuditEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AuditEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AuditEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for AuditEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.