Enum WalTelemetryEvent 

pub enum WalTelemetryEvent {
    FrameAppended {
        frame_count: u32,
        bytes_written: u64,
        is_commit: bool,
        timestamp_ns: u64,
    },
    ReplayStarted {
        valid_frames: usize,
        replayable_frames: usize,
        timestamp_ns: u64,
    },
    ReplayCompleted {
        frames_replayed: usize,
        duration_us: u64,
        timestamp_ns: u64,
    },
    CheckpointStarted {
        mode: CheckpointMode,
        frames_to_backfill: u32,
        timestamp_ns: u64,
    },
    CheckpointCompleted {
        mode: CheckpointMode,
        frames_backfilled: u32,
        wal_reset: bool,
        duration_us: u64,
        timestamp_ns: u64,
    },
    WalReset {
        new_checkpoint_seq: u32,
        timestamp_ns: u64,
    },
    ChecksumFailure {
        frame_index: usize,
        kind: ChecksumFailureKind,
        action: RecoveryAction,
        timestamp_ns: u64,
    },
    ChainValidated {
        total_frames: usize,
        valid: bool,
        first_invalid_frame: Option<usize>,
        reason: Option<WalChainInvalidReason>,
        timestamp_ns: u64,
    },
    FecRepairAttempted {
        outcome: WalFecRepairOutcome,
        symbols_available: usize,
        duration_us: u64,
        timestamp_ns: u64,
    },
    GroupCommitFlushed {
        batch_size: u32,
        total_frames: u32,
        latency_us: u64,
        timestamp_ns: u64,
    },
}

Structured telemetry event emitted by WAL operations.

Each variant captures the minimal context needed to diagnose the operation in post-mortem analysis or real-time dashboards.

Variants

FrameAppended

One or more frames appended to the WAL.

Fields

frame_count: u32

Number of frames written in this batch.

bytes_written: u64

Total bytes written (frame headers + page data).

is_commit: bool

Whether the last frame in the batch is a commit frame.

timestamp_ns: u64

Monotonic timestamp in nanoseconds.

ReplayStarted

WAL chain replay started during open or recovery.

Fields

valid_frames: usize

Total valid frames found in the WAL chain.

replayable_frames: usize

Frames eligible for replay (up to last commit boundary).

timestamp_ns: u64

Monotonic timestamp in nanoseconds.

ReplayCompleted

WAL chain replay completed.

Fields

frames_replayed: usize

Frames successfully replayed to the page cache.

duration_us: u64

Duration of replay in microseconds.

timestamp_ns: u64

Monotonic timestamp in nanoseconds.

CheckpointStarted

Checkpoint operation started.

Fields

mode: CheckpointMode

Checkpoint mode requested.

frames_to_backfill: u32

Frames eligible for backfill.

timestamp_ns: u64

Monotonic timestamp in nanoseconds.

CheckpointCompleted

Checkpoint operation completed.

Fields

mode: CheckpointMode

Checkpoint mode that was executed.

frames_backfilled: u32

Frames actually backfilled to the database file.

wal_reset: bool

Whether the WAL was reset after checkpoint.

duration_us: u64

Duration of checkpoint in microseconds.

timestamp_ns: u64

Monotonic timestamp in nanoseconds.

WalReset

WAL file reset (post-checkpoint truncation or restart).

Fields

new_checkpoint_seq: u32

New checkpoint sequence number after reset.

timestamp_ns: u64

Monotonic timestamp in nanoseconds.

ChecksumFailure

Checksum failure detected during chain validation or frame read.

Fields

frame_index: usize

Zero-based frame index where the failure occurred.

kind: ChecksumFailureKind

Classification of the checksum failure.

action: RecoveryAction

Recovery action selected for this failure.

timestamp_ns: u64

Monotonic timestamp in nanoseconds.

ChainValidated

WAL chain validation completed (during open or recovery).

Fields

total_frames: usize

Total frames examined.

valid: bool

Whether the chain is fully valid.

first_invalid_frame: Option<usize>

First invalid frame index, if any.

reason: Option<WalChainInvalidReason>

Reason for invalidity, if applicable.

timestamp_ns: u64

Monotonic timestamp in nanoseconds.

FecRepairAttempted

FEC repair attempted for a corrupted commit group.

Fields

outcome: WalFecRepairOutcome

Outcome of the repair attempt.

symbols_available: usize

Number of repair symbols available.

duration_us: u64

Duration of the repair attempt in microseconds.

timestamp_ns: u64

Monotonic timestamp in nanoseconds.

GroupCommitFlushed

Group commit flush completed.

Fields

batch_size: u32

Number of transactions in this group.

total_frames: u32

Total frames written in the group.

latency_us: u64

Flush latency in microseconds.

timestamp_ns: u64

Monotonic timestamp in nanoseconds.

Implementations

impl WalTelemetryEvent

pub fn timestamp_ns(&self) -> u64

Extract the monotonic timestamp from any event variant.

pub fn kind_str(&self) -> &'static str

Short classification label for this event kind.

Trait Implementations

impl Clone for WalTelemetryEvent

fn clone(&self) -> WalTelemetryEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WalTelemetryEvent

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

Formats the value using the given formatter.

impl Eq for WalTelemetryEvent

impl PartialEq for WalTelemetryEvent

fn eq(&self, other: &WalTelemetryEvent) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for WalTelemetryEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for WalTelemetryEvent