appcore-sync-sqlite 0.1.0-alpha.2

Bounded SQLite persistence provider for AppCore synchronization state.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

# Workflow intermédiaire et borné

```rust
use appcore_core::NodeId;
use appcore_sync::{ReplicationLog, SyncCheckpointStore, SyncMessage, SyncOutbox};
use appcore_sync_sqlite::{SqliteSyncConfig, SqliteSyncStore};

fn main() -> Result<(), Box<dyn std::error::Error>> {
    let config = SqliteSyncConfig::new("runtime/sync.db")
        .with_max_outbox_entries(1_024)
        .with_max_connections(8);
    let store = SqliteSyncStore::open(config)?;
    let mut log = store.replication_log();
    log.append_with_sequence(b"evenement-runtime-opaque".to_vec(), 1)?;

    let message = SyncMessage::new_simple(
        NodeId::new("node-a")?,
        1,
        log.events_page(0, 128)?,
    );
    let outbox = store.outbox();
    if outbox.try_enqueue(message, 1_024)? {
        store.checkpoint_store().set_last_sequence("peer-a", 1)?;
    }
    store.online_backup("runtime/sync-backup.db")?;
    Ok(())
}
```