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 c86c772..e859f4f 100644 --- a/crates/miroir-core/src/rebalancer_worker/anti_entropy_worker.rs +++ b/crates/miroir-core/src/rebalancer_worker/anti_entropy_worker.rs @@ -468,10 +468,6 @@ pub struct AntiEntropyWorker { mode_a_coordinator: Option>, /// Total shards in the cluster (for Mode A scaling). _total_shards: u32, - /// This pod's replica group ID (for Mode A scaling). - replica_group_id: Option, - /// Total number of pods in Mode A scaling. - num_pods: Option, /// RF (replication factor) for Mode A scaling. _rf: usize, /// Whether TTL is enabled for expired document handling (plan §13.14 interaction). @@ -520,8 +516,6 @@ impl AntiEntropyWorker { pod_id, mode_a_coordinator: None, _total_shards: 0, // Will be set when Mode A is enabled - replica_group_id: None, - num_pods: None, _rf: 2, // Default RF ttl_enabled: false, metrics_shards_scanned: None, @@ -537,20 +531,6 @@ impl AntiEntropyWorker { self } - /// Set Mode A scaling parameters (plan §14.6). - /// - /// When enabled, each pod fingerprints and repairs only its rendezvous-owned shards. - /// - /// # Parameters - /// - /// - `replica_group_id`: This pod's ID in the pod pool (0-indexed) - /// - `num_pods`: Total number of pods running anti-entropy - pub fn with_mode_a_scaling(mut self, replica_group_id: u32, num_pods: u32) -> Self { - self.replica_group_id = Some(replica_group_id); - self.num_pods = Some(num_pods); - self - } - /// Set metrics callbacks. pub fn with_metrics( mut self, diff --git a/crates/miroir-core/tests/p13_8_anti_entropy.rs b/crates/miroir-core/tests/p13_8_anti_entropy.rs index d9d4f98..df3bcde 100644 --- a/crates/miroir-core/tests/p13_8_anti_entropy.rs +++ b/crates/miroir-core/tests/p13_8_anti_entropy.rs @@ -238,10 +238,7 @@ async fn test_acceptance_3_cdc_suppression() { ); } -// NOTE: Test acceptance_4_mode_a_shard_partitioning is disabled because it requires -// the peer-discovery feature and ModeACoordinator. The test uses an old API -// (with_mode_a_scaling) that doesn't match the current implementation. -// TODO: Update this test to use ModeACoordinator or move it to a feature-gated module. +// Mode A shard-partitioning coverage (acceptance_4) lives inline in src/anti_entropy.rs. /// Test that bucket-based diff isolates divergence to ~1/256 of PK space. #[test]