Method init_epoch

syncer/src/cache.rs:183–214

Helper to initialize the cache for a given epoch.

(&mut self, epoch: Epoch)

    /// Helper to initialize the cache for a given epoch.
    async fn init_epoch(&mut self, epoch: Epoch) {
        let verified_blocks = self
            .init_archive(epoch, "verified", self.block_codec_config.clone())
            .await;
        let notarized_blocks = self
            .init_archive(epoch, "notarized", self.block_codec_config.clone())
            .await;
        let notarizations = self
            .init_archive(
                epoch,
                "notarizations",
                S::certificate_codec_config_unbounded(),
            )
            .await;
        let finalizations = self
            .init_archive(
                epoch,
                "finalizations",
                S::certificate_codec_config_unbounded(),
            )
            .await;
        let existing = self.caches.insert(
            epoch,
            Cache {
                verified_blocks,
                notarized_blocks,
                notarizations,
                finalizations,
            },
        );
        assert!(existing.is_none(), "cache already exists for epoch {epoch}");
    }

    /// Helper to initialize an archive.
    async fn init_archive<T: CodecShared>(