Struct AuditTrail 

pub struct AuditTrail {
    pub workflow_id: Arc<str>,
    pub task_id: Arc<str>,
    pub timestamp: DateTime<Utc>,
    pub changes: Vec<Change>,
    pub status: usize,
    pub loop_counter: Option<i64>,
    pub element_index: Option<usize>,
}

Fields

workflow_id: Arc<str>

task_id: Arc<str>

timestamp: DateTime<Utc>

changes: Vec<Change>

status: usize

loop_counter: Option<i64>

Loop counter value for the sweep that produced this entry, for workflows carrying a crate::engine::workflow::LoopConfig; None otherwise.

The counter rather than a sweep ordinal: increment >= 1 makes it strictly increasing, so it identifies the iteration and carries the business meaning — in the per-item pattern it is the array index this entry refers to. Recorded even when the loop leaves its counter unnamed, since the engine tracks the value either way.

Skipped when None, so a non-looping workflow’s audit JSON is byte-identical to what it was before loops existed.

element_index: Option<usize>

Index of the element this entry records, for a task carrying a crate::engine::for_each::ForEach; None otherwise. A fan-out records one entry per element, in element order.

Also None on the single entry an empty or unevaluable over records, since no element was involved. Skipped when None, so an ordinary task’s audit JSON is unchanged.

Trait Implementations

impl Clone for AuditTrail

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AuditTrail

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AuditTrail

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for AuditTrail

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

where __S: Serializer,

Serialize this value into the given Serde serializer.