Struct BinaryCache 

pub struct BinaryCache { /* private fields */ }

On-disk cache for downloaded upgrade binaries.

Implementations

impl BinaryCache

pub fn new(cache_dir: PathBuf) -> Self

Create a new binary cache backed by the given directory.

pub fn cached_binary_path(&self, version: &str) -> PathBuf

Return the path where a cached binary for version would be stored.

pub fn get_verified(&self, version: &str) -> Option<PathBuf>

Return the cached binary path if it exists and its SHA-256 matches the stored metadata. Returns None on any mismatch or error.

pub fn store(&self, version: &str, source_path: &Path) -> Result<()>

Store a binary in the cache.

Uses a write-to-temp-then-rename strategy so that readers never observe partially written files. The metadata file is written last so that get_verified only succeeds once both files are complete.

Errors

Returns an error if the binary cannot be read or the cache files cannot be written.

pub fn acquire_download_lock(&self) -> Result<DownloadLockGuard>

Acquire an exclusive download lock and return the guard.

This prevents multiple nodes from downloading the same archive concurrently — the first acquires the lock and downloads, the rest wait and then find the binary already cached.

The lock is released when the returned guard is dropped.

Note: lock_exclusive() blocks the calling thread. Callers in async contexts should wrap this call in tokio::task::spawn_blocking.

Errors

Returns an error if the lock file cannot be created or acquired.

Trait Implementations

impl Clone for BinaryCache

fn clone(&self) -> BinaryCache

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.