Struct FileSystemContentStorage

pub struct FileSystemContentStorage { /* private fields */ }

Represents a content storage using the local file system.

Implementations

impl FileSystemContentStorage

pub fn try_lock(base_dir: impl Into<PathBuf>) -> Result<Option<Self>>

Attempts to lock the content storage.

The base directory will be created if it does not exist.

If the lock cannot be acquired, Ok(None) is returned.

pub fn lock(base_dir: impl Into<PathBuf>) -> Result<Self>

Locks a new content storage at the given base directory.

The base directory will be created if it does not exist.

If the lock cannot be immediately acquired, this function will block.

Trait Implementations

impl ContentStorage for FileSystemContentStorage

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

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

Clear content local data

fn content_location(&self, digest: &AnyHash) -> Option<PathBuf>

Gets the location of the content associated with the given digest if it exists as a file on disk.

fn load_content<'life0, 'life1, 'async_trait>( &'life0 self, digest: &'life1 AnyHash, ) -> Pin<Box<dyn Future<Output = Result<Option<Pin<Box<dyn Stream<Item = Result<Bytes>> + Send + Sync>>>>> + Send + 'async_trait>>

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

Loads the content associated with the given digest as a stream.

fn store_content<'life0, 'life1, 'async_trait>( &'life0 self, stream: Pin<Box<dyn Stream<Item = Result<Bytes>> + Send + Sync>>, expected_digest: Option<&'life1 AnyHash>, ) -> Pin<Box<dyn Future<Output = Result<AnyHash>> + Send + 'async_trait>>

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

Stores the given stream as content.