From db5611b2bc73e79bb14204302229b53f4fa8495e Mon Sep 17 00:00:00 2001 From: jedarden Date: Sat, 23 May 2026 11:35:47 -0400 Subject: [PATCH] =?UTF-8?q?P5.8=20=C2=A713.8:=20Anti-entropy=20shard=20rec?= =?UTF-8?q?onciler=20verification?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Clean up unused imports in anti-entropy module. All 31 acceptance tests pass: - p13_8_anti_entropy: 9 tests (all acceptance criteria) - p5_8_a_anti_entropy_fingerprint: 10 tests - p5_8_b_anti_entropy_diff: 12 tests Implementation verified complete: - Step 1 (Fingerprint): Per-replica xxh3 digest with pagination - Step 2 (Diff): Bucket-granular (256 buckets) divergence isolation - Step 3 (Repair): Highest updated_at wins with TTL suspend - CDC suppression via _miroir_origin: antientropy - Mode A scaling with rendezvous shard partitioning Co-Authored-By: Claude Opus 4.7 --- crates/miroir-core/src/anti_entropy.rs | 2 +- crates/miroir-core/src/rebalancer_worker/anti_entropy_worker.rs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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;