Struct KvOpLogStore 

pub struct KvOpLogStore<S: StorageEngine> { /* private fields */ }

Storage-backed append-only operation log for the array CRDT sync subsystem.

Generic over any StorageEngine implementation. Bridges the sync OpLog trait into async storage via tokio::task::block_in_place.

See the module-level documentation for the composite key layout.

Implementations

impl<S: StorageEngine> KvOpLogStore<S>

pub fn new(storage: Arc<S>) -> Self

Wrap an existing storage backend.

Trait Implementations

impl<S: StorageEngine> OpLog for KvOpLogStore<S>

fn append(&self, op: &ArrayOp) -> ArrayResult<()>

Append an operation to the log.

Idempotent: re-appending the same (array, hlc) overwrites the stored bytes with identical bytes — a semantic no-op.

fn scan_from<'a>(&'a self, from: Hlc) -> ArrayResult<OpIter<'a>>

Return all ops with hlc >= from, across all arrays, in composite-key order (array name, then HLC).

All matching entries are collected upfront so the storage handle is not held across the returned iterator lifetime.

fn scan_range<'a>( &'a self, array: &str, from: Hlc, to: Hlc, ) -> ArrayResult<OpIter<'a>>

Return ops for array with from <= hlc <= to, in HLC order.

Reads only the keys in [make_key(array, from), make_key(array, to)]. Hlc::to_bytes is big-endian in Ord field order, so key order equals HLC order inside one array prefix.

fn len(&self) -> ArrayResult<u64>

Return the total number of ops across all arrays.

fn drop_below(&self, hlc: Hlc) -> ArrayResult<u64>

Delete all ops with hlc < hlc and return the count deleted.

fn is_empty(&self) -> Result<bool, ArrayError>

Return true if the log contains no ops in any array.