Struct IndexedDbStorage 

pub struct IndexedDbStorage { /* private fields */ }

IndexedDB storage implementation with real browser storage

Implementations

impl IndexedDbStorage

pub fn new(db_name: String, store_name: String) -> Self

Create a new IndexedDB storage instance

pub async fn initialize(&mut self) -> Result<(), StorageError>

Initialize the IndexedDB database

pub fn is_indexeddb_available(&self) -> bool

Check if IndexedDB is available and working

pub async fn get_stats(&self) -> Result<StorageStats, StorageError>

Get storage statistics

pub async fn store_delta( &mut self, collection_id: &str, delta: &[u8], replica_id: &str, operation_type: &str, ) -> Result<(), StorageError>

Store a CRDT delta

pub async fn get_deltas( &mut self, collection_id: &str, from_timestamp: Option<u64>, to_timestamp: Option<u64>, ) -> Result<Vec<DeltaRecord>, StorageError>

Get CRDT deltas for a collection

pub async fn store_metadata( &mut self, metadata: &CollectionMetadata, ) -> Result<(), StorageError>

Store collection metadata

pub async fn get_metadata( &mut self, collection_id: &str, ) -> Result<Option<CollectionMetadata>, StorageError>

Get collection metadata

pub async fn list_collections( &mut self, ) -> Result<Vec<CollectionMetadata>, StorageError>

List all collections

pub async fn store_peer(&mut self, peer: &PeerInfo) -> Result<(), StorageError>

Store peer information

pub async fn get_peer( &mut self, peer_id: &str, ) -> Result<Option<PeerInfo>, StorageError>

Get peer information

pub async fn list_peers(&mut self) -> Result<Vec<PeerInfo>, StorageError>

List all peers

pub async fn cleanup_old_deltas( &mut self, collection_id: &str, keep_count: usize, ) -> Result<(), StorageError>

Clean up old deltas

pub async fn clear_all(&mut self) -> Result<(), StorageError>

Clear all data

Trait Implementations

impl Clone for IndexedDbStorage

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl LocalStorage for IndexedDbStorage

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

where T: 'async_trait + Serialize + Send + Sync, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Store a value with the given key

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

where T: 'async_trait + DeserializeOwned + Send + Sync, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieve a value by key

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

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

Remove a value by key

fn keys<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, StorageError>> + Send + 'async_trait>>

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

Get all keys

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

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

Check if a key exists

fn len<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<usize, StorageError>> + Send + 'async_trait>>

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

Get the number of stored items

fn is_empty<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<bool, StorageError>> + Send + 'async_trait>>

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

Check if storage is empty

fn clear<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

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

Clear all stored data