Struct SingleNodeEngine 

pub struct SingleNodeEngine { /* private fields */ }

Single-node key-value engine with worker threads and automatic compaction.

Implementations

impl SingleNodeEngine

pub fn new() -> Result<Self>

Creates a new engine with default configuration.

pub fn with_config(config: StoreConfig) -> Result<Self>

Creates a new engine with the specified configuration.

pub fn put(&self, key: Vec<u8>, value: Vec<u8>) -> Result<ApplyOutcome>

Inserts or updates a key-value pair.

pub fn delete(&self, key: Vec<u8>) -> Result<ApplyOutcome>

Deletes a key from the store.

pub fn len(&self) -> usize

Returns the number of keys in the store.

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

Flushes pending writes to disk.

pub fn submit_batch<I>(&self, commands: I) -> Result<Vec<ApplyOutcome>>

where I: IntoIterator<Item = Command>,

Submits a batch of commands for execution.

pub fn read_with<F, R>(&self, reader: F) -> R

where F: FnOnce(&KvState) -> R,

Executes a read operation with a consistent snapshot of the state.

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

Triggers an immediate compaction run.

pub fn get_prefix(&self, prefix: &[u8]) -> Result<Vec<(Vec<u8>, Vec<u8>)>>

Retrieves all key-value pairs with the given prefix.

pub fn into_argon2_hasher_aes_gcm_auth_service( self, master_key: [u8; 32], ) -> (Arc<SingleNodeEngine>, AuthService<Arc<SingleNodeEngine>, Argon2SecretHasher, AesGcmEncryptor>)

Wraps the engine in an Arc and constructs an AuthService configured with Argon2 hashing and AES-GCM encryption.

Trait Implementations

impl Debug for SingleNodeEngine

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

Formats the value using the given formatter.

impl Drop for SingleNodeEngine

fn drop(&mut self)

Executes the destructor for this type.

impl KvEngine for SingleNodeEngine

fn submit(&self, command: Command) -> Result<ApplyOutcome>

Submits a single command for execution.

fn submit_batch<I>(&self, commands: I) -> Result<Vec<ApplyOutcome>>

where I: IntoIterator<Item = Command>,

Submits a batch of commands for execution.

fn get(&self, key: &[u8]) -> Result<Option<Vec<u8>>>

Retrieves the value for a key if it exists.

fn get_prefix(&self, prefix: &[u8]) -> Result<Vec<(Vec<u8>, Vec<u8>)>>

Retrieves all key-value pairs with the given prefix.

impl SnapshotEngine for SingleNodeEngine

fn snapshot_state(&self) -> KvState

Returns a snapshot of the current key-value state.

fn latest_version(&self) -> u64

Returns the latest version number in the store.