Struct CacheManager 

pub struct CacheManager {
    pub root: PathBuf,
    pub pyroduct: Option<Dependency>,
    pub author: String,
}

Fields

root: PathBuf

pyroduct: Option<Dependency>

author: String

Implementations

impl CacheManager

pub async fn new( root: &Path, pyroduct: Option<Dependency>, author: String, ) -> Result<Self, CacheError>

pub async fn from_env() -> Result<Self, CacheError>

pub async fn init(&self) -> Result<(), CacheError>

pub async fn purge(&self) -> Result<(), CacheError>

pub async fn purge_capabilities(&self) -> Result<(), CacheError>

pub async fn purge_modules(&self) -> Result<(), CacheError>

pub async fn list_available_capabilities( &self, ) -> Result<Vec<(String, String, String)>, CacheError>

pub fn capabilities_base_dir(&self) -> PathBuf

pub fn capabilities_dir( &self, author: &str, name: &str, version: &str, ) -> PathBuf

pub fn interface_dir(&self, author: &str, name: &str, version: &str) -> PathBuf

pub fn modules_base_dir(&self) -> PathBuf

pub fn module_dir(&self, author: &str, name: &str, version: &str) -> PathBuf

pub async fn list_available_modules( &self, ) -> Result<Vec<(String, String, String)>, CacheError>

pub fn interfaces_base_dir(&self) -> PathBuf

pub async fn capability_interface_spec( &self, author: &str, name: &str, version: &str, ) -> Result<String, CacheError>

pub async fn capability_binary_path( &self, author: &str, name: &str, version: &str, ) -> Result<PathBuf, CacheError>

pub async fn capability_config_spec( &self, author: &str, name: &str, version: &str, ) -> Result<Option<String>, CacheError>

pub async fn remove_module( &self, author: &str, name: &str, version: &str, ) -> Result<(), CacheError>

pub async fn get_named_binary( &self, author: &str, package: &str, version: &str, ) -> Result<PlaybookBinary, CacheError>

pub async fn get_named_source( &self, author: &str, package: &str, version: &str, ) -> Result<PlaybookSource, CacheError>

pub async fn write_artifacts( &self, artifacts: &Artifacts, ) -> Result<(), CacheError>

pub async fn load_playbook( &self, playbook: PlaybookIdent, remotes: HashMap<CapabilityIdent, RemoteAddress>, log_dir: impl AsRef<Path>, input_dir: impl AsRef<Path>, output_dir: impl AsRef<Path>, num_workers: usize, ) -> Result<LoadedPlaybook, CacheError>

pub fn convert_anon_playbook(&self, playbook: AnonPlaybook) -> PlaybookSource