diff options
| author | tv <tv@krebsco.de> | 2026-10-21 03:56:31 +0200 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-21 03:56:31 +0200 |
| commit | 0cdd5075c88d938117c5dbddc22a2331a8816c34 (patch) | |
| tree | 98f3f8ad2f010f9e3aa9ea88350f21af4f11bb90 /src/main.rs | |
| parent | cc96f69204140caf02c44f95df2b1027d5073e4e (diff) | |
rename compaction to remake
Diffstat (limited to 'src/main.rs')
| -rw-r--r-- | src/main.rs | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/main.rs b/src/main.rs index 5085130..e1ba7bc 100644 --- a/src/main.rs +++ b/src/main.rs @@ -19,8 +19,8 @@ use tracing::{debug, error, info, trace}; use url::Url; mod api; -mod compaction; mod document; +mod remake; mod state; mod swarm; mod transport; @@ -155,7 +155,7 @@ async fn main() -> Result<()> { initial_sync_done: Arc::new(AtomicBool::new(false)), change_events, timing: Timing::from_keepalive(Duration::from_secs(args.keepalive_secs)), - compaction: Arc::new(compaction::Compaction::default()), + remake: Arc::new(remake::RemakeState::default()), stale: Default::default(), }; @@ -189,8 +189,8 @@ async fn main() -> Result<()> { // Switches to committed epochs and catches up with newer ones. Starts before // bootstrapping: a node joining a compacted cluster can only finish its initial sync // after fetching the current epoch from a peer. - tokio::spawn(compaction::run_worker(state.clone())); - trace!("Compaction worker task spawned"); + tokio::spawn(remake::run_worker(state.clone())); + trace!("Remake worker task spawned"); bootstrap::bootstrap(&state, &seeds) .await |
