Struct tvix_castore::directoryservice::simple_putter::SimplePutter

pub struct SimplePutter<DS: DirectoryService> {
    directory_service: DS,
    directory_validator: Option<DirectoryGraph<LeavesToRootValidator>>,
}

This is an implementation of DirectoryPutter that simply inserts individual Directory messages one by one, on close, after they successfully validated.

Fields

directory_service: DS

directory_validator: Option<DirectoryGraph<LeavesToRootValidator>>

Implementations

impl<DS: DirectoryService> SimplePutter<DS>

pub fn new(directory_service: DS) -> Self

Trait Implementations

impl<DS: DirectoryService + 'static> DirectoryPutter for SimplePutter<DS>

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

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

Put a individual Directory into the store. Error semantics and behaviour is up to the specific implementation of this trait. Due to bursting, the returned error might refer to an object previously sent via put.

fn close<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<B3Digest, Error>> + Send + 'async_trait>>

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

Close the stream, and wait for any errors. If there’s been any invalid Directory message uploaded, and error must be returned.