Struct InMemoryBackend 

pub struct InMemoryBackend { /* private fields */ }

In-memory implementation of all four sync traits

Thread-safe via Arc internals. Cloning shares the same state.

Implementations

impl InMemoryBackend

pub fn new() -> Self

Create a new uninitialized backend

pub fn new_initialized() -> Self

Create a new backend that’s immediately ready for use in tests

pub async fn document_count(&self) -> usize

Get total document count across all collections

pub async fn collection_count(&self) -> usize

Get the number of collections

pub async fn clear_collection(&self, collection: &str)

Clear all documents in a collection

pub async fn set_deletion_policy( &self, collection: &str, policy: DeletionPolicy, )

Set deletion policy for a collection

Trait Implementations

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 DataSyncBackend for InMemoryBackend

fn initialize<'life0, 'async_trait>( &'life0 self, config: BackendConfig, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Initialize backend with configuration

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

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

Shutdown gracefully

fn document_store(&self) -> Arc<dyn DocumentStore>

Get reference to document store implementation

fn peer_discovery(&self) -> Arc<dyn PeerDiscovery>

Get reference to peer discovery implementation

fn sync_engine(&self) -> Arc<dyn SyncEngine>

Get reference to sync engine implementation

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

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

Check if backend is ready (initialized and not shut down)

fn backend_info(&self) -> BackendInfo

Get backend name/version for debugging

fn as_any(&self) -> &dyn Any

Get backend as Any for downcasting to concrete types

impl Default for InMemoryBackend

fn default() -> Self

Returns the “default value” for a type.

impl DocumentStore for InMemoryBackend

fn upsert<'life0, 'life1, 'async_trait>( &'life0 self, collection: &'life1 str, document: Document, ) -> Pin<Box<dyn Future<Output = Result<DocumentId>> + Send + 'async_trait>>

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

Store or update a document

fn query<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, collection: &'life1 str, query: &'life2 Query, ) -> Pin<Box<dyn Future<Output = Result<Vec<Document>>> + Send + 'async_trait>>

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

Retrieve documents matching a query

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

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

Remove a document by ID

fn observe(&self, collection: &str, query: &Query) -> Result<ChangeStream>

Register observer for live updates

fn delete<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, collection: &'life1 str, doc_id: &'life2 DocumentId, reason: Option<&'life3 str>, ) -> Pin<Box<dyn Future<Output = Result<DeleteResult>> + Send + 'async_trait>>

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

Delete a document according to collection policy (ADR-034)

fn deletion_policy(&self, collection: &str) -> DeletionPolicy

Get the deletion policy for a collection

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

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

Get all tombstones for a collection

fn apply_tombstone<'life0, 'life1, 'async_trait>( &'life0 self, tombstone: &'life1 Tombstone, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Apply a tombstone received from sync

fn get<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, collection: &'life1 str, doc_id: &'life2 DocumentId, ) -> Pin<Box<dyn Future<Output = Result<Option<Document>>> + Send + 'async_trait>>

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

Get a single document by ID

fn count<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, collection: &'life1 str, query: &'life2 Query, ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>>

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

Count documents matching a query

fn is_deleted<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, collection: &'life1 str, doc_id: &'life2 DocumentId, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Check if a document is deleted (tombstoned or soft-deleted)

impl PeerDiscovery for InMemoryBackend

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

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

Start discovery mechanism

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

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

Stop discovery

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

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

Get list of discovered peers

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

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

Manually add a peer by address

fn wait_for_peer<'life0, 'life1, 'async_trait>( &'life0 self, peer_id: &'life1 PeerId, timeout: Duration, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Wait for a specific peer to connect

fn on_peer_event(&self, callback: Box<dyn Fn(PeerEvent) + Send + Sync>)

Register callback for peer events

fn get_peer_info<'life0, 'life1, 'async_trait>( &'life0 self, peer_id: &'life1 PeerId, ) -> Pin<Box<dyn Future<Output = Result<Option<PeerInfo>>> + Send + 'async_trait>>

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

Get information about a specific peer

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

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

Check if a specific peer is currently connected

impl SyncEngine for InMemoryBackend

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

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

Start synchronization with discovered peers

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

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

Stop synchronization

fn subscribe<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, collection: &'life1 str, _query: &'life2 Query, ) -> Pin<Box<dyn Future<Output = Result<SyncSubscription>> + Send + 'async_trait>>

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

Create sync subscription for a collection

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

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

Check if sync is currently active

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

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

Set sync priority for a collection (optional)

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

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

Force a sync round (push pending changes)

fn connect_to_peer<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, endpoint_id_hex: &'life1 str, addresses: &'life2 [String], ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Connect to a peer using their EndpointId and addresses (Issue #235)