Struct SledStorage 

pub struct SledStorage { /* private fields */ }

Sled-based persistent storage backend

Uses the sled embedded database for high-performance, persistent storage. This is recommended for:

• Large datasets
• High write throughput
• Production applications

Sled provides:

• ACID transactions
• High performance
• Automatic crash recovery
• Efficient storage format

Thread Safety

SledStorage is thread-safe and can be shared across threads using Arc<SledStorage>.

Example

use gun::storage::{Storage, SledStorage};
use gun::state::Node;
use std::sync::Arc;

let storage = Arc::new(SledStorage::new("./gun_data")?);
let node = Node::with_soul("user_123".to_string());
storage.put("user_123", &node).await?;

Implementations

impl SledStorage

pub fn new(path: &str) -> GunResult<Self>

Create a new SledStorage instance

Arguments

• path - Directory path where the sled database will be stored

Returns

Ok(SledStorage) if initialization succeeds, or GunError on failure.

Errors

Returns GunError::Storage if the sled database cannot be opened or created.

Trait Implementations

impl Storage for SledStorage

fn get<'life0, 'life1, 'async_trait>( &'life0 self, soul: &'life1 str, ) -> Pin<Box<dyn Future<Output = GunResult<Option<Node>>> + Send + 'async_trait>>

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

Retrieve a node by its soul (unique identifier)

fn put<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, soul: &'life1 str, node: &'life2 Node, ) -> Pin<Box<dyn Future<Output = GunResult<()>> + Send + 'async_trait>>

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

Store a node by its soul (unique identifier)

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

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

Check if a node exists in storage