#![cfg_attr(coverage_nightly, coverage(off))]
use super::*;
use crate::state::event_store::{EventStore, EventStoreConfig};
use crate::state::snapshot_store::{SnapshotConfig, SnapshotStore};
use std::sync::Arc;
use std::time::{Duration, Instant};
include!("recovery_types.rs");
include!("recovery_scheduler.rs");
pub struct RecoveryManager<S: AgentState> {
event_store: Arc<EventStore>,
snapshot_store: Arc<SnapshotStore>,
snapshot_scheduler: Arc<AdaptiveSnapshotScheduler>,
_phantom: std::marker::PhantomData<S>,
}
include!("recovery_manager.rs");
include!("recovery_parallel.rs");
include!("recovery_tests.rs");