Enum LifecycleEvent 

pub enum LifecycleEvent<'a> {
    Registered {
        workspace: &'a WorkspaceId,
        run: &'a RunId,
        occurrence: &'a str,
        graph: &'a GraphDescription,
        parent: Option<&'a ActionContext>,
        lineage: Option<&'a RunLineage>,
    },
    ChildFinished {
        parent: &'a ActionContext,
        snapshot: &'a RunSnapshot,
    },
    ExecuteStarted {
        run: &'a RunId,
        occurrence: &'a str,
    },
    ExecuteFinished {
        snapshot: &'a RunSnapshot,
        failure: Option<&'a WorkflowFailure>,
    },
    StepStarted {
        context: &'a ActionContext,
        state: &'a WorkflowState,
        inputs: &'a Map<String, Value>,
    },
    StepFinished {
        context: &'a ActionContext,
        outcome: Option<Result<&'a ActionOutcome, &'a WorkflowFailure>>,
        checkpoint: &'a Checkpoint,
    },
    StreamStarted {
        context: &'a ActionContext,
        span: Option<&'a str>,
    },
    StreamItem {
        context: &'a ActionContext,
        span: Option<&'a str>,
        index: usize,
        result: &'a Map<String, Value>,
    },
    StreamFinished {
        context: &'a ActionContext,
        span: Option<&'a str>,
        items: usize,
        failure: Option<&'a WorkflowFailure>,
    },
    SpanStarted {
        context: &'a ActionContext,
        id: &'a str,
        name: &'a str,
        parent: Option<&'a str>,
        dependencies: &'a [String],
    },
    SpanAttribute {
        context: &'a ActionContext,
        span: Option<&'a str>,
        key: &'a str,
        value: &'a Value,
        tags: &'a Map<String, Value>,
    },
    SpanFinished {
        context: &'a ActionContext,
        id: &'a str,
    },
}

An exhaustive borrowed view of one application lifecycle event.

Variants

Registered

Registers a run and its graph with optional child or restore lineage.

Fields

workspace: &'a WorkspaceId

Workspace containing the run.

run: &'a RunId

Registered run identity.

occurrence: &'a str

Exact admitted execution occurrence.

graph: &'a GraphDescription

Graph used by the registered run.

parent: Option<&'a ActionContext>

Parent action when this is an admitted child.

lineage: Option<&'a RunLineage>

Original boundary when this is a restored run.

ChildFinished

Finishes an admitted child under its exact parent action.

Fields

parent: &'a ActionContext

Parent action that admitted this child.

snapshot: &'a RunSnapshot

Authoritative child snapshot.

ExecuteStarted

Begins one execution session.

Fields

run: &'a RunId

Run being advanced.

occurrence: &'a str

Exact admitted execution occurrence.

ExecuteFinished

Finishes one execution session.

Fields

snapshot: &'a RunSnapshot

Authoritative run snapshot at session finalization.

failure: Option<&'a WorkflowFailure>

Execution failure, when present.

StepStarted

Begins an action attempt against its committed base and resolved inputs.

Fields

context: &'a ActionContext

Identity and attempted action ordinal.

state: &'a WorkflowState

Unchanged committed base state.

inputs: &'a Map<String, Value>

Resolved transient action inputs.

StepFinished

Finalizes an attempt, including rollback with no completed outcome.

Fields

context: &'a ActionContext

Identity and attempted ordinal, including failed attempts.

outcome: Option<Result<&'a ActionOutcome, &'a WorkflowFailure>>

Committed result, exact failure, or no outcome on EOF, abort or Drop.

checkpoint: &'a Checkpoint

Committed boundary; failure retains the unchanged prior boundary.

StreamStarted

Opens partial-result observation for one action or addressed span.

Fields

context: &'a ActionContext

Action owning this stream.

span: Option<&'a str>

Addressed span, or the action root.

StreamItem

Observes one transient partial result.

Fields

context: &'a ActionContext

Action owning this stream.

span: Option<&'a str>

Addressed span, or the action root.

index: usize

Zero-based index within this stream.

result: &'a Map<String, Value>

Transient result fields; these do not commit state.

StreamFinished

Closes partial-result observation exactly once.

Fields

context: &'a ActionContext

Action owning this stream.

span: Option<&'a str>

Addressed span, or the action root.

items: usize

Number of observed partial items.

failure: Option<&'a WorkflowFailure>

Failure that closed observation, if any.

SpanStarted

Opens an explicitly addressed span within one action attempt.

Fields

context: &'a ActionContext

Action owning the span.

id: &'a str

Unique open span identity within this attempt.

name: &'a str

Display name; repeated names are permitted.

parent: Option<&'a str>

Open parent span, or the action root.

dependencies: &'a [String]

Dependency span identities in caller-authored order.

SpanAttribute

Adds an attribute to an open span or the action root.

Fields

context: &'a ActionContext

Action owning the attribute.

span: Option<&'a str>

Open span, or the action root.

key: &'a str

Attribute name.

value: &'a Value

Attribute value.

tags: &'a Map<String, Value>

Caller tags whose values are strings.

SpanFinished

Closes an addressed span.

Fields

context: &'a ActionContext

Action owning the span.

id: &'a str

Exact open span identity.

Implementations

impl LifecycleEvent<'_>

pub fn tracking_records( &self, observed_at: SystemTime, ) -> Result<Vec<Value>, AppError>

Projects this observation into the pinned rurr tracking JSON records.

This is an explicit content export: inputs, results, state and attributes may be present. The caller owns transport and samples the observation time. No record is retained and no hook is invoked. The complete encoded list is bounded to 1 MiB. Timed records require UTC years 1970 through 9999.

Execute boundaries, child completion and nonfirst partial items have no pinned wire row and return an empty list. Step completion serializes its temporary state projection through the process-global field encoders; the authoritative checkpoint remains unchanged. A step without an outcome has no pinned end-entry state and returns an input error before invoking a field encoder.

use app_kit::workflow::{LifecycleEvent, RunId};
let run: RunId = "run_8a7c251e-b5b8-4d9e-8f0b-123456789abc".parse()?;
let event = LifecycleEvent::ExecuteStarted {
run: &run, occurrence: "00000000000040008000000000000001",
};
assert!(event.tracking_records(std::time::UNIX_EPOCH)?.is_empty());

Errors

Returns InvalidInput for a step with no outcome, missing graph source, unsupported timestamp, malformed span attributes, or exceeded record bounds. Codec errors propagate from state serialization. This explicit export may contain caller content; it is separate from safe operational tracing.