canic-core 0.70.7

Canic — a canister orchestration and management toolkit for the Internet Computer
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

//! Module: workflow::placement::directory::config
//!
//! Responsibility: resolve configured directory pool definitions.
//! Does not own: configuration storage, directory mutation, or endpoint defaults.
//! Boundary: maps missing directory configuration into workflow errors.

use crate::{
    InternalError,
    config::schema::DirectoryPool,
    ops::config::ConfigOps,
    workflow::placement::directory::{
        DirectoryWorkflow,
        state::{DirectoryWorkflowError, available_pool_names},
    },
};

impl DirectoryWorkflow {
    // Resolve the configured pool definition for the current directory-bearing parent.
    pub(super) fn get_directory_pool_cfg(pool: &str) -> Result<DirectoryPool, InternalError> {
        let directory = ConfigOps::current_directory_config()?
            .ok_or(DirectoryWorkflowError::DirectoryDisabled)?;
        let available = available_pool_names(&directory);

        directory
            .pools
            .get(pool)
            .cloned()
            .ok_or_else(|| DirectoryWorkflowError::UnknownPool {
                requested: pool.to_string(),
                available,
            })
            .map_err(InternalError::from)
    }
}