Struct WalRecord 

pub struct WalRecord {
    pub record_type: WalRecordType,
    pub trace_id: TraceId,
    pub node_id: NodeId,
    pub timestamp_ns: u64,
    pub output_offset: ArenaOffset,
    pub output_size: u32,
    pub schema_hash: u64,
    pub error_message: Option<String>,
    pub iteration: u32,
    pub metadata: Option<String>,
}

A single WAL record.

Fields

record_type: WalRecordType

Type of this record.

trace_id: TraceId

The trace this record belongs to.

node_id: NodeId

The node this record is about (if applicable).

timestamp_ns: u64

Timestamp (Unix epoch nanoseconds).

output_offset: ArenaOffset

Arena offset for output data (if applicable).

output_size: u32

Output size in bytes.

schema_hash: u64

Schema version hash.

error_message: Option<String>

Error message (if applicable).

iteration: u32

Loop iteration number (for loop records).

metadata: Option<String>

Additional metadata (JSON-encoded).

Implementations

impl WalRecord

pub fn trace_start(trace_id: TraceId) -> Self

Create a trace start record.

pub fn node_start(trace_id: TraceId, node_id: NodeId) -> Self

Create a node start record.

pub fn node_done( trace_id: TraceId, node_id: NodeId, output_offset: ArenaOffset, output_size: u32, schema_hash: u64, ) -> Self

Create a node done record.

pub fn node_error( trace_id: TraceId, node_id: NodeId, error: impl ToString, ) -> Self

Create a node error record.

pub fn trace_complete(trace_id: TraceId) -> Self

Create a trace complete record.

pub fn trace_failed(trace_id: TraceId, error: impl ToString) -> Self

Create a trace failed record.

pub fn trace_suspended(trace_id: TraceId, node_id: NodeId) -> Self

Create a trace suspended record.

pub fn trace_resumed(trace_id: TraceId) -> Self

Create a trace resumed record (for crash recovery or wait resumption).

pub fn loop_iteration( trace_id: TraceId, node_id: NodeId, iteration: u32, ) -> Self

Create a loop iteration record.

pub fn with_metadata(self, metadata: impl ToString) -> Self

Set metadata on this record.

pub fn to_bytes(&self) -> Result<Vec<u8>>

Serialize the record to bytes.

pub fn from_bytes(bytes: &[u8]) -> Result<Self>

Deserialize a record from bytes.

pub fn serialized_size(&self) -> usize

Get the total serialized size of this record.

Trait Implementations

impl Clone for WalRecord

fn clone(&self) -> WalRecord

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WalRecord

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

Formats the value using the given formatter.