Struct tvix_castore::directoryservice::sled::SledDirectoryService

pub struct SledDirectoryService {
    db: Db,
}

Fields

db: Db

Implementations

impl SledDirectoryService

pub fn new<P: AsRef<Path>>(p: P) -> Result<Self, Error>

pub fn new_temporary() -> Result<Self, Error>

Trait Implementations

impl Clone for SledDirectoryService

fn clone(&self) -> SledDirectoryService

Returns a copy of the value.

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

Performs copy-assignment from source.

impl DirectoryService for SledDirectoryService

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.