Struct tvix_castore::directoryservice::Cache

pub struct Cache<DS1, DS2> {
    instance_name: String,
    near: DS1,
    far: DS2,
}

Asks near first, if not found, asks far. If found in there, returns it, and inserts it into near. Specifically, it always obtains the entire directory closure from far and inserts it into near, which is useful when far does not support accessing intermediate directories (but near does). There is no negative cache. Inserts and listings are not implemented for now.

Fields

instance_name: String

near: DS1

far: DS2

Implementations

impl<DS1, DS2> Cache<DS1, DS2>

pub fn new(instance_name: String, near: DS1, far: DS2) -> Self

Trait Implementations

impl<DS1: Clone, DS2: Clone> Clone for Cache<DS1, DS2>

fn clone(&self) -> Cache<DS1, DS2>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<DS1, DS2> DirectoryService for Cache<DS1, DS2>

where DS1: DirectoryService + Clone + 'static, DS2: DirectoryService + Clone + 'static,

fn get<'life0, 'life1, 'async_trait>( &'life0 self, digest: &'life1 B3Digest, ) -> Pin<Box<dyn Future<Output = Result<Option<Directory>, Error>> + Send + 'async_trait>>

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

Looks up a single Directory message by its digest. The returned Directory message must be valid. In case the directory is not found, Ok(None) is returned.

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

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

Uploads a single Directory message, and returns the calculated digest, or an error. An error must also be returned if the message is not valid.

fn get_recursive( &self, root_directory_digest: &B3Digest, ) -> BoxStream<'static, Result<Directory, Error>>

Looks up a closure of Directory. Ideally this would be a impl Stream<Item = Result<Directory, Error>>, and we’d be able to add a default implementation for it here, but we can’t have that yet.

fn put_multiple_start(&self) -> Box<dyn DirectoryPutter + 'static>

Allows persisting a closure of Directory, which is a graph of connected Directory messages.