Method new

opensuse-proxy-cache/src/cache.rs:243–268

(
        capacity: usize,
        content_dir: &Path,
        durable_fs: bool,
        default_backend: Backend,
        backends: Vec<Backend>,
    )

impl Cache {
    pub fn new(
        capacity: usize,
        content_dir: &Path,
        durable_fs: bool,
        default_backend: Backend,
        backends: Vec<Backend>,
    ) -> std::io::Result<Self> {
        let pri_cache = ArcDiskCache::new(capacity, content_dir, durable_fs)?;
        let (submit_tx, submit_rx) = channel(PENDING_ADDS);
        let pri_cache_cln = pri_cache.clone();

        let bloom = Mutex::new(Bloom::new_for_fp_rate(65536, 0.001));

        tokio::task::spawn_blocking(move || cache_mgr(submit_rx, pri_cache_cln));

        let pri_cache_cln = pri_cache.clone();
        tokio::task::spawn(async move { cache_stats(pri_cache_cln).await });

        Ok(Cache {
            pri_cache,
            bloom,
            default_backend,
            backends,
            submit_tx,
        })
    }

    pub fn monitor_backends(&self) -> impl Iterator<Item = &Backend> {
        std::iter::once(&self.default_backend)