ubiquisync-core 0.0.3

Core protocol types and sync engine for Ubiquisync — conflict-free sync of structured data over commodity cloud storage or a dedicated server.
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

//! Synchronization traits: the read/write faces of a replica and the cursors
//! they exchange.
//!
//! - [`LogProcessor`] — write side: `apply` an entry at `(peer, index)`.
//!   Multi-writer, idempotent.
//! - [`LogSource`] — read side: `read_since` to pull, `cursors` /
//!   `watch_cursors` to publish progress.
//!
//! A store that is both is a [`Replica`] (the SQL oplog). A file log reads any
//! origin but writes only its own ([`FileLogSink`]), so it's a
//! [`FileLogReplica`] — the type-level form of "only the originating device
//! writes its own log". Both faces speak [`PeerCursors`], a per-origin version
//! vector. The convergence drivers that consume these traits come later.

mod cursors;
mod error;
mod file_log;
mod processor;
mod replica;
mod source;

pub use cursors::{CursorStream, CursorsEvent, HasCursors, PeerCursors};
pub use error::SyncError;
pub use file_log::{FileLogPuller, FileLogReplica, FileLogSink};
pub use processor::{Applied, LogProcessor};
pub use replica::Replica;
pub use source::LogSource;