Struct LocalKv 

pub struct LocalKv { /* private fields */ }

Local disk-persisted KV implementation using sled embedded database

This provides a persistent, thread-safe, disk-based key-value store that implements all KV trait features including TTL, conditional puts, and prefix scanning. Perfect for local development and testing that needs data persistence across restarts.

Implementations

impl LocalKv

pub async fn new(data_dir: PathBuf) -> Result<Self>

Create a new local KV store with the given data directory

pub fn data_dir(&self) -> &PathBuf

Get the data directory path

pub async fn len(&self) -> Result<usize>

Get the number of items currently stored (including expired items) Useful for testing

pub async fn is_empty(&self) -> Result<bool>

Check if the store is empty (including expired items) Useful for testing

pub async fn clear(&self) -> Result<()>

Clear all data from the store Useful for testing

pub async fn keys(&self) -> Result<Vec<String>>

Get all keys currently in the store (including expired ones) Useful for testing and debugging

Trait Implementations

impl Debug for LocalKv

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

Formats the value using the given formatter.

impl Kv for LocalKv

fn get<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get a value by key. Returns None if key doesn’t exist or has expired.

fn put<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, value: Vec<u8>, options: Option<PutOptions>, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Put a value with optional options. When options.if_not_exists is true, returns true if created, false if already exists. When options.if_not_exists is false or options is None, always returns true.

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Delete a key. No error if key doesn’t exist.

fn exists<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Check if a key exists without retrieving the value.

fn scan_prefix<'life0, 'life1, 'async_trait>( &'life0 self, prefix: &'life1 str, limit: Option<usize>, cursor: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<ScanResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Scan keys with a prefix, with pagination support.

impl Binding for LocalKv