Module coordinator 

Sync engine coordinator.

The SyncEngine is the main orchestrator that ties together all components:

• L1 in-memory cache with eviction
• L2 Redis cache with batch writes
• L3 MySQL/SQLite archive with WAL durability
• Cuckoo filters for existence checks
• Merkle trees for sync verification

Lifecycle

Created → Connecting → DrainingWal → SyncingRedis → WarmingUp → Ready → Running → ShuttingDown

Example

use sync_engine::{SyncEngine, SyncEngineConfig, SyncItem, EngineState};
use serde_json::json;
use tokio::sync::watch;

let config = SyncEngineConfig::default();
let (_tx, rx) = watch::channel(config.clone());
let mut engine = SyncEngine::new(config, rx);

assert_eq!(engine.state(), EngineState::Created);

// engine.start().await.expect("Start failed");
// assert!(engine.is_ready());

Structs

BatchResult

Result of a batch operation.

HealthCheck

Comprehensive health status of the sync engine.

MerkleDiff

Result of comparing merkle trees between two nodes.

SearchResult

Search result with metadata

SyncEngine

Main sync engine coordinator.

Enums

EngineState

Engine lifecycle state.

ItemStatus

Sync status of an item across storage tiers.

SearchSource

Where search results came from

SearchTier

Search tier strategy