Struct SyncEngine 

pub struct SyncEngine { /* private fields */ }

Sync engine for pulling sessions from remote sources.

Implementations

impl SyncEngine

pub fn new(data_dir: &Path) -> Self

Create a new sync engine.

Arguments

• data_dir - The cass data directory (e.g., ~/.local/share/coding-agent-search)

pub fn with_connection_timeout(self, seconds: u64) -> Self

Set the connection timeout.

pub fn with_transfer_timeout(self, seconds: u64) -> Self

Set the transfer timeout.

pub fn mirror_dir(&self, source_name: &str) -> PathBuf

Get the local mirror directory for a source.

pub fn detect_sync_method() -> SyncMethod

Detect the available sync method.

Detection order:

1. Native rsync → SyncMethod::Rsync
2. wsl rsync (Windows only) → SyncMethod::WslRsync
3. System scp available → SyncMethod::Scp
4. Last resort → SyncMethod::Sftp (ssh2-based, no native-agent integration)

On Windows the ssh2 SFTP path is intentionally avoided whenever possible because it bypasses the Windows OpenSSH agent and ~/.ssh/config, leading to “No valid authentication method found” errors even when SSH keys are properly configured. Using the system scp binary instead lets OpenSSH handle auth the same way ssh and cass sources doctor do.

pub fn sync_source( &self, source: &SourceDefinition, ) -> Result<SyncReport, SyncError>

Sync a single source.

Syncs all configured paths from the source to the local mirror directory. Individual path failures don’t abort the entire sync.

pub fn sync_all( &self, sources: impl Iterator<Item = impl Borrow<SourceDefinition>>, ) -> Vec<SyncReport>

Sync all remote sources from a config.

Continues even if individual sources fail.