Struct FileSystemBatchUpdate 

pub struct FileSystemBatchUpdate<'a, D: Pouf> { /* private fields */ }

FileSystemBatchUpdate is a special repository that is designed to write the metadata and targets to an FileSystemRepository in a single batch.

Note: FileSystemBatchUpdate::commit() must be called in order to write the metadata and targets to the FileSystemRepository. Otherwise any queued changes will be lost on drop.

Implementations

impl<D> FileSystemBatchUpdate<'_, D>

where D: Pouf,

pub async fn commit(self) -> Result<(), CommitError>

Write all the metadata and targets the FileSystemBatchUpdate to the source FileSystemRepository in a single batch operation.

Note: While this function will atomically write each file, it’s possible that this could fail with part of the files written if we experience a system error during the process.

Trait Implementations

impl<'a, D: Debug + Pouf> Debug for FileSystemBatchUpdate<'a, D>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<D> RepositoryProvider<D> for FileSystemBatchUpdate<'_, D>

where D: Pouf,

fn fetch_metadata<'a>( &'a self, meta_path: &MetadataPath, version: MetadataVersion, ) -> BoxFuture<'a, Result<Box<dyn AsyncRead + Send + Unpin + 'a>>>

Fetch signed metadata identified by meta_path, version, and D::extension().

fn fetch_target<'a>( &'a self, target_path: &TargetPath, ) -> BoxFuture<'a, Result<Box<dyn AsyncRead + Send + Unpin + 'a>>>

Fetch the given target.

impl<D> RepositoryStorage<D> for FileSystemBatchUpdate<'_, D>

where D: Pouf,

fn store_metadata<'a>( &'a self, meta_path: &MetadataPath, version: MetadataVersion, read: &'a mut (dyn AsyncRead + Send + Unpin), ) -> BoxFuture<'a, Result<()>>

Store the provided metadata in a location identified by meta_path, version, and D::extension(), overwriting any existing metadata at that location.

fn store_target<'a>( &'a self, target_path: &TargetPath, read: &'a mut (dyn AsyncRead + Send + Unpin), ) -> BoxFuture<'a, Result<()>>

Store the provided target in a location identified by target_path, overwriting any existing target at that location.