diff options
Diffstat (limited to 'src/state.rs')
| -rw-r--r-- | src/state.rs | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/state.rs b/src/state.rs index 0f981e6..20285a0 100644 --- a/src/state.rs +++ b/src/state.rs @@ -12,8 +12,8 @@ use tokio::sync::{broadcast, mpsc, watch, Mutex, RwLock}; use tokio::time::Instant; use tracing::{debug, error, warn}; -use crate::compaction::{Compaction, Host, PeerSummary}; use crate::document::replica::{Epoch, Replica}; +use crate::remake::{Host, PeerSummary, RemakeState}; use crate::swarm::sync::{ChangeSet, SyncEvent}; use crate::transport; use crate::transport::firewall::Firewall; @@ -298,8 +298,8 @@ pub(crate) struct AppState { pub(crate) timing: Timing, - /// Per-node compaction state (prebuilt snapshots, switch status, archive). - pub(crate) compaction: Arc<Compaction>, + /// Per-node remake state (prebuilt snapshots, switch status, archive). + pub(crate) remake: Arc<RemakeState>, /// While rejoining a newer epoch, the previous document, served read-only (and /// marked stale) instead of answering 503. @@ -621,10 +621,10 @@ pub(crate) fn unix_millis() -> u64 { .unwrap_or(0) } -/// The node as seen by the compaction module. +/// The node as seen by the remake module. impl Host for AppState { - fn compaction(&self) -> &Compaction { - &self.compaction + fn remake(&self) -> &RemakeState { + &self.remake } fn node_id(&self) -> String { |