replay_diagnostics

Deterministic replay and time-travel diagnostics contracts for M42.

Types

Flow

Replay trace flow.

pub type Flow {
  RuntimeFlow
  SessionFlow
  PipelineFlow
}

Constructors

```
RuntimeFlow
```
```
SessionFlow
```
```
PipelineFlow
```

InvestigationWorkflow

Investigation workflow integration.

pub type InvestigationWorkflow {
  FaultWorkflow
  EtlWorkflow
}

Constructors

```
FaultWorkflow
```
```
EtlWorkflow
```

ReplayTrace

Replay trace bundle.

pub type ReplayTrace {
  ReplayTrace(
    trace_id: String,
    flow: Flow,
    seed: String,
    events: List(TraceEvent),
  )
}

Constructors

ReplayTrace(
  trace_id: String,
  flow: Flow,
  seed: String,
  events: List(TraceEvent),
)

Snapshot

Time-travel snapshot extracted from a trace.

pub type Snapshot {
  Snapshot(
    trace_id: String,
    flow: Flow,
    index: Int,
    at_ms: Int,
    label: String,
    state_signature: String,
  )
}

Constructors

Snapshot(
  trace_id: String,
  flow: Flow,
  index: Int,
  at_ms: Int,
  label: String,
  state_signature: String,
)

TraceEvent

One time-indexed replay event.

pub type TraceEvent {
  TraceEvent(
    index: Int,
    at_ms: Int,
    label: String,
    state_signature: String,
  )
}

Constructors

TraceEvent(
  index: Int,
  at_ms: Int,
  label: String,
  state_signature: String,
)

Values

etl_investigation_ready

pub fn etl_investigation_ready(trace: ReplayTrace) -> Bool

ETL-investigation workflow readiness.

events

pub fn events(trace: ReplayTrace) -> List(TraceEvent)

Trace events accessor.

fault_investigation_ready

pub fn fault_investigation_ready(trace: ReplayTrace) -> Bool

Fault-investigation workflow readiness.

first_fault_snapshot

pub fn first_fault_snapshot(
  trace: ReplayTrace,
) -> option.Option(Snapshot)

First fault snapshot for triage.

flow

pub fn flow(trace: ReplayTrace) -> Flow

Flow accessor.

flow_label

pub fn flow_label(flow: Flow) -> String

Flow label.

investigation_signature

pub fn investigation_signature(
  workflow: InvestigationWorkflow,
  trace: ReplayTrace,
) -> String

Investigation signature bound to one trace.

latest_snapshot

pub fn latest_snapshot(
  trace: ReplayTrace,
) -> option.Option(Snapshot)

Latest snapshot when present.

pipeline_etl_trace

pub fn pipeline_etl_trace(seed: String) -> ReplayTrace

Deterministic pipeline replay/ETL trace.

runtime_fault_trace

pub fn runtime_fault_trace(seed: String) -> ReplayTrace

Deterministic runtime fault trace.

session_fault_trace

pub fn session_fault_trace(seed: String) -> ReplayTrace

Deterministic session fault/recovery trace.

snapshot_at

pub fn snapshot_at(
  trace: ReplayTrace,
  index: Int,
) -> Result(Snapshot, String)

Extract one time-indexed snapshot.

snapshot_label

pub fn snapshot_label(snapshot: Snapshot) -> String

Snapshot label.

timeline_signature

pub fn timeline_signature(trace: ReplayTrace) -> String

Stable timeline signature.

trace_id

pub fn trace_id(trace: ReplayTrace) -> String

Trace id accessor.

trace_signature

pub fn trace_signature(trace: ReplayTrace) -> String

Stable full trace signature.