Method new

src/app_context.rs:20–47

(config: Config, args: CosdataArgs)

impl AppContext {
    pub fn new(config: Config, args: CosdataArgs) -> Result<Self, WaCustomError> {
        let config = Arc::new(config);
        let threadpool = Arc::new(
            rayon::ThreadPoolBuilder::new()
                .num_threads(config.thread_pool.pool_size)
                .build()
                .expect("Failed to build thread pool"),
        );
        let ain_env = get_app_env(config.clone(), threadpool.clone(), args)?;

        let collections_path = get_data_path().join("collections");
        std::fs::create_dir_all(&collections_path)
            .map_err(|e| WaCustomError::FsError(e.to_string()))?;

        let collection_cache_manager = Arc::new(CollectionCacheManager::new(
            Arc::from(collections_path),
            config.cache.max_collections,
            config.cache.eviction_probability,
            ain_env.clone(),
        ));

        Ok(Self {
            config,
            ain_env,
            threadpool,
            collection_cache_manager,
        })
    }
}

use crate::models::collection_cache::CollectionCacheExt;