Struct tvix_castore::directoryservice::memory::MemoryDirectoryService

pub struct MemoryDirectoryService {
    instance_name: String,
    db: Arc<RwLock<HashMap<B3Digest, Directory>>>,
}

Fields

instance_name: String

db: Arc<RwLock<HashMap<B3Digest, Directory>>>

Trait Implementations

impl Clone for MemoryDirectoryService

fn clone(&self) -> MemoryDirectoryService

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for MemoryDirectoryService

fn default() -> MemoryDirectoryService

Returns the “default value” for a type.

impl DirectoryService for MemoryDirectoryService

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>

where Self: Clone,

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