Struct SqliteReplicator 

pub struct SqliteReplicator { /* private fields */ }

SQLite WAL-based replicator to S3

Monitors a SQLite database’s WAL file and replicates changes to S3 for persistence and disaster recovery.

Implementations

impl SqliteReplicator

pub async fn new( config: SqliteReplicatorConfig, s3_config: &LayerStorageConfig, ) -> Result<Self>

Create a new SQLite replicator

Arguments

• config - Replicator configuration
• s3_config - S3/Layer storage configuration for credentials and endpoint

Errors

Returns an error if the cache directory cannot be created or if S3 client initialization fails.

pub async fn start(&self) -> Result<()>

Start the replicator background tasks

This spawns background tasks for:

• WAL file monitoring and change detection
• Cache upload worker (handles retries)
• Periodic snapshot creation

Errors

Returns an error if the WAL monitor cannot be started (e.g., database file doesn’t exist).

pub async fn flush(&self) -> Result<()>

Force flush all pending changes to S3

Call this before shutdown to ensure all changes are persisted. This will:

1. Create a final snapshot
2. Upload all pending cache entries
3. Wait for uploads to complete

Errors

Returns an error if the final snapshot or upload fails.

pub async fn restore(&self) -> Result<bool>

Restore database from S3

Downloads the latest snapshot and any subsequent WAL segments from S3, then applies them to reconstruct the database.

Returns

• Ok(true) if a backup was found and restored
• Ok(false) if no backup was found in S3
• Err(_) if restore failed

Errors

Returns an error if downloading the snapshot or WAL segments fails, or if applying them to reconstruct the database fails.

pub fn status(&self) -> ReplicationStatus

Get current replication status