Struct tvix_store::pathinfoservice::LruPathInfoService

pub struct LruPathInfoService {
    instance_name: String,
    lru: Arc<RwLock<LruCache<[u8; 20], PathInfo>>>,
}

Fields

instance_name: String

lru: Arc<RwLock<LruCache<[u8; 20], PathInfo>>>

Implementations

impl LruPathInfoService

pub fn with_capacity(instance_name: String, capacity: NonZeroUsize) -> Self

Trait Implementations

impl PathInfoService for LruPathInfoService

fn get<'life0, 'async_trait>( &'life0 self, digest: [u8; 20], ) -> Pin<Box<dyn Future<Output = Result<Option<PathInfo>, Error>> + Send + 'async_trait>>

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

Retrieve a PathInfo message by the output digest.

fn put<'life0, 'async_trait>( &'life0 self, path_info: PathInfo, ) -> Pin<Box<dyn Future<Output = Result<PathInfo, Error>> + Send + 'async_trait>>

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

Store a PathInfo message. Implementations MUST call validate and reject invalid messages.

fn list(&self) -> BoxStream<'static, Result<PathInfo, Error>>

Iterate over all PathInfo objects in the store. Implementations can decide to disallow listing.

fn nar_calculation_service(&self) -> Option<Box<dyn NarCalculationService>>

Returns a (more) suitable NarCalculationService. This can be used to offload NAR calculation to the remote side.