Struct tvix_castore::directoryservice::redb::RedbDirectoryService

pub struct RedbDirectoryService {
    db: Arc<Database>,
}

Fields

db: Arc<Database>

Implementations

impl RedbDirectoryService

pub async fn new(path: PathBuf) -> Result<Self, Error>

Constructs a new instance using the specified filesystem path for storage.

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

Constructs a new instance using the in-memory backend.

Trait Implementations

impl Clone for RedbDirectoryService

fn clone(&self) -> RedbDirectoryService

Returns a copy of the value.

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

Performs copy-assignment from source.

impl DirectoryService for RedbDirectoryService

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>

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