oxigdal-sync 0.1.4

Multi-device synchronization with CRDTs, vector clocks, and operational transformation for OxiGDAL
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
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62

//! Error types for synchronization operations

use thiserror::Error;

/// Result type for synchronization operations
pub type SyncResult<T> = Result<T, SyncError>;

/// Synchronization error types
#[derive(Error, Debug)]
pub enum SyncError {
    /// Vector clock comparison resulted in concurrent/conflicting events
    #[error("Concurrent events detected: {0}")]
    ConcurrentEvents(String),

    /// Invalid operation in operational transformation
    #[error("Invalid operation: {0}")]
    InvalidOperation(String),

    /// Merkle tree verification failed
    #[error("Merkle tree verification failed: {0}")]
    MerkleVerificationFailed(String),

    /// Delta encoding/decoding error
    #[error("Delta encoding error: {0}")]
    DeltaEncodingError(String),

    /// Device coordination error
    #[error("Device coordination error: {0}")]
    CoordinationError(String),

    /// CRDT merge conflict
    #[error("CRDT merge conflict: {0}")]
    MergeConflict(String),

    /// Serialization error
    #[error("Serialization error: {0}")]
    SerializationError(String),

    /// I/O error
    #[error("I/O error: {0}")]
    IoError(#[from] std::io::Error),

    /// JSON error
    #[error("JSON error: {0}")]
    JsonError(#[from] serde_json::Error),

    /// Invalid device ID
    #[error("Invalid device ID: {0}")]
    InvalidDeviceId(String),

    /// Operation timeout
    #[error("Operation timeout: {0}")]
    Timeout(String),

    /// Network error
    #[error("Network error: {0}")]
    NetworkError(String),

    /// State inconsistency detected
    #[error("State inconsistency: {0}")]
    StateInconsistency(String),
}