Function hot_split_plan

nodedb-cluster/src/rebalance_scheduler.rs:353–366

()

    #[test]
    fn hot_split_plan() {
        let mut topo = ClusterTopology::new();
        let addr1: SocketAddr = "127.0.0.1:9000".parse().unwrap();
        let addr2: SocketAddr = "127.0.0.1:9001".parse().unwrap();
        topo.add_node(NodeInfo::new(1, addr1, NodeState::Active));
        topo.add_node(NodeInfo::new(2, addr2, NodeState::Active));

        // uniform(2, ...) creates data groups 1 and 2 (+ metadata group 0).
        let routing = RoutingTable::uniform(2, &[1, 2], 1);
        let moves = plan_hot_split(1, &routing, &topo).unwrap();
        // Data group 1 has 512 vShards → split moves up to 256.
        assert!(!moves.is_empty());
        assert!(moves.len() <= 512);
    }
}