Struct InMemoryBackend 

pub struct InMemoryBackend { /* private fields */ }

Thread-safe async in-memory cache backend.

Uses DashMap for lock-free concurrent access with fine-grained per-key sharding. No async locks required - operations are non-blocking. Automatically handles TTL expiration on access.

Example

use cache_kit::backend::{InMemoryBackend, CacheBackend};
use std::time::Duration;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let backend = InMemoryBackend::new();

    // Store data
    backend.set("key1", b"value".to_vec(), None).await?;

    // Retrieve data
    let value = backend.get("key1").await?;
    assert!(value.is_some());

    // Store with TTL
    backend.set("key2", b"expires".to_vec(), Some(Duration::from_secs(300))).await?;

    Ok(())
}

Implementations

impl InMemoryBackend

pub fn new() -> Self

Create a new in-memory cache backend.

pub async fn len(&self) -> usize

Get the current number of entries in cache.

pub async fn is_empty(&self) -> bool

Check if cache is empty.

pub async fn stats(&self) -> CacheStats

Get memory statistics.

pub async fn log_stats(&self)

Print cache statistics to debug log.

Trait Implementations

impl CacheBackend for InMemoryBackend

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

Retrieve value from cache by key.

async fn set( &self, key: &str, value: Vec<u8>, ttl: Option<Duration>, ) -> Result<()>

Store value in cache with optional TTL.

async fn delete(&self, key: &str) -> Result<()>

Remove value from cache.

async fn exists(&self, key: &str) -> Result<bool>

Check if key exists in cache (optional optimization).

async fn mget(&self, keys: &[&str]) -> Result<Vec<Option<Vec<u8>>>>

Bulk get operation (optional optimization).

async fn mdelete(&self, keys: &[&str]) -> Result<()>

Bulk delete operation (optional optimization).

async fn health_check(&self) -> Result<bool>

Health check - verify backend is accessible.

async fn clear_all(&self) -> Result<()>

Optional: Clear all cache (use with caution).

impl Clone for InMemoryBackend

fn clone(&self) -> InMemoryBackend

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for InMemoryBackend

fn default() -> Self

Returns the “default value” for a type.