Struct LiteApplyEngine 

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

Adapts NodeDB-Lite’s array engine state to the ApplyEngine trait.

All fields are Arc-wrapped so their interior mutability can satisfy the trait’s &mut self methods without requiring &mut LiteApplyEngine. We implement ApplyEngine for &LiteApplyEngine<S> — a mutable reference to a shared reference — which allows apply_op(&mut engine_ref, &op) where engine_ref: &LiteApplyEngine<S> without any additional allocation.

Outbound loop avoidance

Operations applied here go directly through ArrayEngineState methods, which sit below NodeDbLite::array_put_cell. The ArrayOutbound hook is therefore never triggered, making the receive path loop-free by construction.

Implementations

impl<S: StorageEngine> LiteApplyEngine<S>

pub async fn new( storage: Arc<S>, array_state: Arc<Mutex<ArrayEngineState>>, schemas: Arc<SchemaRegistry<S>>, op_log: Arc<KvOpLogStore<S>>, ) -> Self

Construct from the component parts shared with NodeDbLite.

pub fn last_applied_hlc(&self, array: &str) -> Option<Hlc>

Return the highest HLC applied for array, or None if no ops applied.

Trait Implementations

impl<S: StorageEngine> ApplyEngine for &LiteApplyEngine<S>

Implement ApplyEngine on a borrowed LiteApplyEngine<S>.

Because all state lives behind Arc / Arc<tokio::sync::Mutex<...>>, a shared reference carries enough indirection to perform all mutations. The trait requires &mut self (E = &LiteApplyEngine<S>), and &mut E is merely a rebindable outer reference that we never actually need to mutate.

apply_put and apply_erase call async ArrayEngineState methods via block_in_place + blocking_lock, which is safe inside a multi_thread Tokio runtime.

fn invalidate_tile( &mut self, _array: &str, _coord: &[CoordValue], ) -> ArrayResult<()>

No-op: the Lite array engine reads from the durable memtable + segments after each write, so there is no separate read cache that would need explicit invalidation. If a tile read-cache is introduced later, this hook is the right place to drop overlapping entries.

fn schema_hlc(&self, array: &str) -> ArrayResult<Option<Hlc>>

Return the current schema HLC for array, or None if the array is not known to this replica.

fn already_seen(&self, array: &str, hlc: Hlc) -> ArrayResult<bool>

Return true if hlc has already been applied to array.

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

Apply a Put op to the engine.

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

Apply a Delete op to the engine.

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

Apply an Erase op to the engine.