Struct tvix_store::pathinfoservice::memory::MemoryPathInfoService

pub struct MemoryPathInfoService {
    instance_name: String,
    db: Arc<RwLock<HashMap<[u8; 20], PathInfo>>>,
}

Fields

instance_name: String

db: Arc<RwLock<HashMap<[u8; 20], PathInfo>>>

Trait Implementations

impl Default for MemoryPathInfoService

fn default() -> MemoryPathInfoService

Returns the “default value” for a type.

impl PathInfoService for MemoryPathInfoService

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.