Struct Sync

pub struct Sync { /* private fields */ }

Ditto’s Sync API, obtained via ditto.sync().

See the sync module documentation for more details.

Implementations

impl Sync

pub fn subscriptions_v2(&self) -> HashSet<SyncSubscription>

Returns a snapshot of handles to all active SyncSubscriptions.

Adding or removing SyncSubscriptions from this map will not cause the underlying subscriptions to be updated.

Example

let subscription = ditto
    .sync()
    .register_subscription("SELECT * FROM cars", None)?;
let subscriptions = ditto.sync().subscriptions_v2();
assert!(subscriptions.contains(&subscription));

pub fn register_subscription_v2<Q>( &self, query: Q, ) -> Result<Arc<SyncSubscription>, DittoError>

where Q: IntoQuery, Q::Args: Serialize,

Use a DQL query to subscribe to data on other Ditto peers.

While the subscription is active, data matching this query on other peers will be synced to the local peer’s data store.

Note that dropping the SyncSubscription won’t cancel it, to do that be sure to use sync_subscription.cancel().

Example

use dittolive_ditto::prelude::*;
let query = (
    "SELECT * FROM cars WHERE color = :color",
    serde_json::json!({"color": "blue"}),
);

let sync_subscription = ditto.sync().register_subscription_v2(query)?;

// Cancel the subscription with `.cancel()`
sync_subscription.cancel();