summaryrefslogtreecommitdiffstats
path: root/src/state.rs
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-10-21 03:22:55 +0200
committertv <tv@krebsco.de>2026-10-21 03:22:55 +0200
commitcc96f69204140caf02c44f95df2b1027d5073e4e (patch)
tree7acde26d4a96b2bdef1e4cf115e17c8011f5b6c6 /src/state.rs
parente176d3f240498b28b2b3a1cff58e46ef2fc6fd6c (diff)
reorganize all the modules
Diffstat (limited to 'src/state.rs')
-rw-r--r--src/state.rs8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/state.rs b/src/state.rs
index c7dbd90..cf2666c 100644
--- a/src/state.rs
+++ b/src/state.rs
@@ -13,10 +13,10 @@ use tokio::time::Instant;
use tracing::{debug, error, warn};
use crate::compaction::{Compaction, Host, PeerSummary};
-use crate::firewall::Firewall;
-use crate::replica::{Epoch, Replica};
-use crate::sync::{ChangeSet, SyncEvent};
+use crate::document::replica::{Epoch, Replica};
+use crate::swarm::sync::{ChangeSet, SyncEvent};
use crate::transport;
+use crate::transport::firewall::Firewall;
#[derive(Debug, Clone, PartialEq, Eq)]
pub(crate) enum NodeLifecycle {
@@ -539,7 +539,7 @@ impl AppState {
// Tell peers about the new epoch now instead of with the next keepalive (up to a
// keepalive interval later): sync with peers already on it resumes right away,
// and peers that never saw the commit start catching up.
- let keepalive = crate::peer::local_keepalive(self).await;
+ let keepalive = crate::swarm::peer::local_keepalive(self).await;
for (id, _) in &peers {
if let Err(error) = self
.transport