Struct WalRecord 

pub struct WalRecord {
    pub header: RecordHeader,
    pub payload: Vec<u8>,
}

A complete WAL record: header + payload.

Fields

header: RecordHeader

payload: Vec<u8>

Implementations

impl WalRecord

pub fn new( record_type: u16, lsn: u64, tenant_id: u32, vshard_id: u16, payload: Vec<u8>, encryption_key: Option<&WalEncryptionKey>, ) -> Result<Self>

Create a new WAL record with computed CRC32C.

If encryption_key is provided, the payload is encrypted before CRC computation. The ciphertext includes a 16-byte auth tag.

pub fn decrypt_payload( &self, epoch: &[u8; 4], encryption_key: Option<&WalEncryptionKey>, ) -> Result<Vec<u8>>

Decrypt the payload if the record is encrypted.

epoch is the encryption epoch from the WAL segment header. Returns the plaintext payload. If not encrypted, returns the payload as-is.

pub fn decrypt_payload_ring( &self, epoch: &[u8; 4], ring: Option<&KeyRing>, ) -> Result<Vec<u8>>

Decrypt the payload using a key ring (supports dual-key rotation).

epoch is the encryption epoch from the WAL segment header. Tries the current key first, then falls back to the previous key. Returns the plaintext payload. If not encrypted, returns the payload as-is.

pub fn is_encrypted(&self) -> bool

Whether this record’s payload is encrypted.

pub fn logical_record_type(&self) -> u16

Get the logical record type (with encryption flag stripped).

pub fn verify_checksum(&self) -> Result<()>

Verify the CRC32C checksum.

pub fn wire_size(&self) -> usize

Total size on disk: header + payload.

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.