Struct FileSystemRegistryStorage

pub struct FileSystemRegistryStorage { /* private fields */ }

Represents a package storage using the local file system.

Implementations

impl FileSystemRegistryStorage

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

Attempts to lock the package 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 package 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 RegistryStorage for FileSystemRegistryStorage

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

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

Reset registry local data

fn load_checkpoint<'life0, 'life1, 'async_trait>( &'life0 self, namespace_registry: Option<&'life1 RegistryDomain>, ) -> Pin<Box<dyn Future<Output = Result<Option<SerdeEnvelope<TimestampedCheckpoint>>>> + Send + 'async_trait>>

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

Loads most recent checkpoint

fn store_checkpoint<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, namespace_registry: Option<&'life1 RegistryDomain>, ts_checkpoint: &'life2 SerdeEnvelope<TimestampedCheckpoint>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Stores most recent checkpoint

fn load_all_packages<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<IndexMap<RegistryDomain, Vec<PackageInfo>>>> + Send + 'async_trait>>

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

Loads the package information for all packages.

fn load_operator<'life0, 'life1, 'async_trait>( &'life0 self, namespace_registry: Option<&'life1 RegistryDomain>, ) -> Pin<Box<dyn Future<Output = Result<Option<OperatorInfo>>> + Send + 'async_trait>>

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

Loads the operator information from the storage.

fn store_operator<'life0, 'life1, 'async_trait>( &'life0 self, namespace_registry: Option<&'life1 RegistryDomain>, info: OperatorInfo, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Stores the operator information in the storage.

fn load_package<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, namespace_registry: Option<&'life1 RegistryDomain>, package: &'life2 PackageName, ) -> Pin<Box<dyn Future<Output = Result<Option<PackageInfo>>> + Send + 'async_trait>>

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

Loads the package information from the storage.

fn store_package<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, namespace_registry: Option<&'life1 RegistryDomain>, info: &'life2 PackageInfo, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Stores the package information in the storage.

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

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

Loads information about a pending publish operation.

fn store_publish<'life0, 'life1, 'async_trait>( &'life0 self, info: Option<&'life1 PublishInfo>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Stores information about a pending publish operation.