Struct PmRepository 

pub struct PmRepository { /* private fields */ }

Serve a repository from a local pm repository.

Implementations

impl PmRepository

pub fn builder(pm_repo_path: Utf8PathBuf) -> PmRepositoryBuilder

pub fn new(pm_repo_path: Utf8PathBuf) -> Self

Construct a PmRepository.

pub fn repo_keys(&self) -> Result<RepoKeys, ParseError>

Tries to return the pm repository [RepoKeys]. Returns an empty [RepoKeys] if the keys/ directory does not exist in the repository.

Trait Implementations

impl Debug for PmRepository

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

Formats the value using the given formatter.

impl RepoProvider for PmRepository

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 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.

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.

impl RepoStorage for PmRepository

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

Store a blob in this repository.

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

Store a delivery blob in this repository.

impl RepositoryProvider<Pouf1> for PmRepository

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 PmRepository

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.