Struct WalEntry 

pub struct WalEntry {
    pub sequence: u64,
    pub entry_type: WalEntryType,
    pub timestamp_ms: u64,
    pub record_id: String,
    pub record_data: Option<WalRecordData>,
    pub outcome: Option<f64>,
    pub checksum: u32,
}

A single WAL entry.

Each entry is self-contained with all information needed to replay it.

Fields

sequence: u64

Monotonically increasing sequence number

entry_type: WalEntryType

Entry type

timestamp_ms: u64

Timestamp (Unix epoch millis)

record_id: String

Record ID (for all entry types)

record_data: Option<WalRecordData>

Full record data (for Insert)

outcome: Option<f64>

Outcome value (for UpdateStats)

checksum: u32

CRC32 checksum for integrity

Implementations

impl WalEntry

pub fn insert(sequence: u64, record: &MemoryRecord) -> Self

Create a new Insert entry.

pub fn update_stats(sequence: u64, record_id: &RecordId, outcome: f64) -> Self

Create a new UpdateStats entry.

pub fn delete(sequence: u64, record_id: &RecordId) -> Self

Create a new Delete entry.

pub fn checkpoint(sequence: u64) -> Self

Create a checkpoint marker.

pub fn verify_checksum(&self) -> bool

Verify the checksum.

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

Serialize to bytes using rkyv.

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

Deserialize from bytes.

Errors

Returns error if deserialization fails or checksum is invalid.

Trait Implementations

impl Archive for WalEntry

where u64: Archive, WalEntryType: Archive, String: Archive, Option<WalRecordData>: Archive, Option<f64>: Archive, u32: Archive,

type Archived = ArchivedWalEntry

The archived representation of this type.

type Resolver = WalEntryResolver

The resolver for this type. It must contain all the additional information from serializing needed to make the archived type from the normal type.

unsafe fn resolve( &self, pos: usize, resolver: Self::Resolver, out: *mut Self::Archived, )

Creates the archived version of this value at the given position and writes it to the given output.

impl Clone for WalEntry

fn clone(&self) -> WalEntry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WalEntry

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

Formats the value using the given formatter.

impl<__D: Fallible + ?Sized> Deserialize<WalEntry, __D> for Archived<WalEntry>

where u64: Archive, Archived<u64>: Deserialize<u64, __D>, WalEntryType: Archive, Archived<WalEntryType>: Deserialize<WalEntryType, __D>, String: Archive, Archived<String>: Deserialize<String, __D>, Option<WalRecordData>: Archive, Archived<Option<WalRecordData>>: Deserialize<Option<WalRecordData>, __D>, Option<f64>: Archive, Archived<Option<f64>>: Deserialize<Option<f64>, __D>, u32: Archive, Archived<u32>: Deserialize<u32, __D>,

fn deserialize(&self, deserializer: &mut __D) -> Result<WalEntry, __D::Error>

Deserializes using the given deserializer

impl<__S: Fallible + ?Sized> Serialize<__S> for WalEntry

where u64: Serialize<__S>, WalEntryType: Serialize<__S>, String: Serialize<__S>, Option<WalRecordData>: Serialize<__S>, Option<f64>: Serialize<__S>, u32: Serialize<__S>,

fn serialize(&self, serializer: &mut __S) -> Result<Self::Resolver, __S::Error>

Writes the dependencies for the object and returns a resolver that can create the archived type.