canic-core 0.100.13

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::index::config
//!
//! Responsibility: resolve configured index pool definitions.
//! Does not own: configuration storage, index mutation, or endpoint defaults.
//! Boundary: maps missing index configuration into workflow errors.

use crate::{
    InternalError,
    config::schema::IndexPool,
    ops::config::ConfigOps,
    workflow::placement::index::{
        PlacementIndexWorkflow,
        state::{PlacementIndexWorkflowError, available_pool_names},
    },
};

impl PlacementIndexWorkflow {
    // Resolve the configured pool definition for the current index-bearing parent.
    pub(super) fn get_index_pool_cfg(pool: &str) -> Result<IndexPool, InternalError> {
        let index =
            ConfigOps::current_index_config()?.ok_or(PlacementIndexWorkflowError::IndexDisabled)?;
        let available = available_pool_names(&index);

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