diff --git a/crates/miroir-core/src/anti_entropy.rs b/crates/miroir-core/src/anti_entropy.rs index 126f21e..e384068 100644 --- a/crates/miroir-core/src/anti_entropy.rs +++ b/crates/miroir-core/src/anti_entropy.rs @@ -19,7 +19,7 @@ use crate::cdc::ORIGIN_ANTIENTROPY; use crate::error::{MiroirError, Result}; use crate::migration::{MigrationConfig, MigrationError}; use crate::router::assign_shard_in_group; -use crate::scatter::{DeleteByIdsRequest, FetchDocumentsRequest, FetchDocumentsResponse, NodeClient, WriteRequest}; +use crate::scatter::{FetchDocumentsRequest, FetchDocumentsResponse, NodeClient, WriteRequest}; use crate::topology::{NodeId, Topology}; use serde::{Deserialize, Serialize}; use serde_json::Value; diff --git a/crates/miroir-core/src/rebalancer_worker/anti_entropy_worker.rs b/crates/miroir-core/src/rebalancer_worker/anti_entropy_worker.rs index 27d0a6e..0ea5fb7 100644 --- a/crates/miroir-core/src/rebalancer_worker/anti_entropy_worker.rs +++ b/crates/miroir-core/src/rebalancer_worker/anti_entropy_worker.rs @@ -8,7 +8,7 @@ use crate::anti_entropy::{AntiEntropyConfig, AntiEntropyReconciler}; use crate::scatter::{ - FetchDocumentsRequest, FetchDocumentsResponse, MockNodeClient, NodeClient, NodeError, + FetchDocumentsRequest, FetchDocumentsResponse, NodeClient, NodeError, PreflightRequest, PreflightResponse, SearchRequest, }; use crate::task_store::TaskStore;