Struct DaemonAwareCacheClient 

pub struct DaemonAwareCacheClient { /* private fields */ }

A StorageBackend that prefers a node-local daemon and falls through to a direct remote backend when the daemon can’t be reached. See the module docs for the exact per-method contract.

Implementations

impl DaemonAwareCacheClient

pub fn new( socket_path: Option<PathBuf>, remote: Arc<dyn StorageBackend>, ) -> Self

socket_path = None makes this client behave identically to calling remote directly — the byte-for-byte Phase 2 fallback path, useful for callers that want the daemon-aware type without unconditionally trying to connect.

Trait Implementations

impl StorageBackend for DaemonAwareCacheClient

fn get_narinfo<'life0, 'life1, 'async_trait>( &'life0 self, hash: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, CacheError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieve narinfo text by store path hash.

fn put_narinfo<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, hash: &'life1 str, content: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), CacheError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Store narinfo text keyed by store path hash.

fn get_nar<'life0, 'life1, 'async_trait>( &'life0 self, path: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>, CacheError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieve a NAR blob by its relative path.

fn put_nar<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, path: &'life1 str, data: &'life2 [u8], ) -> Pin<Box<dyn Future<Output = Result<(), CacheError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Store a NAR blob at the given relative path.

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, hash: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), CacheError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Delete a store path’s narinfo and associated NAR blob.

fn list_narinfos<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, CacheError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List all stored narinfo hashes.

fn wipe_all<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<usize, CacheError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Clear EVERY narinfo and NAR blob from this backend (all tiers, for a TieredBackend). Returns the number of narinfos removed.