Struct FileSystemRepository 

pub struct FileSystemRepository { /* private fields */ }

Serve a repository from the file system.

Implementations

impl FileSystemRepository

pub fn builder( metadata_repo_path: Utf8PathBuf, blob_repo_path: Utf8PathBuf, ) -> FileSystemRepositoryBuilder

Construct a FileSystemRepositoryBuilder.

pub fn new(metadata_repo_path: Utf8PathBuf, blob_repo_path: Utf8PathBuf) -> Self

Construct a FileSystemRepository.

pub fn blob_repo_path(&self) -> &Utf8PathBuf

Trait Implementations

impl Debug for FileSystemRepository

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

Formats the value using the given formatter.

impl RepoProvider for FileSystemRepository

fn aliases(&self) -> &BTreeSet<String>

Get the repository aliases.

fn fetch_metadata_range<'a>( &'a self, resource_path: &str, range: Range, ) -> BoxFuture<'a, Result<Resource, Error>>

Fetch a metadata Resource from this repository.

fn fetch_blob_range<'a>( &'a self, resource_path: &str, range: Range, ) -> BoxFuture<'a, Result<Resource, Error>>

Fetch a blob Resource from this repository.

fn blob_modification_time<'a>( &'a self, path: &str, ) -> BoxFuture<'a, Result<Option<SystemTime>>>

Get the modification time of a blob in this repository if available.

fn blob_type(&self) -> DeliveryBlobType

Get the type of delivery blobs in this repository.

fn supports_watch(&self) -> bool

Whether or not the backend supports watching for file changes.

fn watch(&self) -> Result<BoxStream<'static, ()>>

Returns a stream which sends a unit value every time the given path is modified.

impl RepoStorage for FileSystemRepository

fn store_blob<'a>( &'a self, hash: &Hash, len: u64, src: &Utf8Path, ) -> BoxFuture<'a, Result<()>>

Store a blob in this repository.

fn store_delivery_blob<'a>( &'a self, hash: &Hash, src: &Utf8Path, delivery_blob_type: DeliveryBlobType, ) -> BoxFuture<'a, Result<()>>

Store a delivery blob in this repository.

impl RepositoryProvider<Pouf1> for FileSystemRepository

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 RepositoryStorage<Pouf1> for FileSystemRepository

fn store_metadata<'a>( &'a self, meta_path: &MetadataPath, version: MetadataVersion, metadata: &'a mut (dyn AsyncRead + Send + Unpin + 'a), ) -> 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, target: &'a mut (dyn AsyncRead + Send + Unpin + 'a), ) -> BoxFuture<'a, Result<()>>

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