+ assertEquals("DatastoreSnapshot shard names", Set.of(expShardNames), shardNames);
+ }
+
+ @Test
+ public void testGetPrefixShardRole() throws Exception {
+ String name = "testGetPrefixShardRole";
+ String moduleShardsConfig = "module-shards-default-member-1.conf";
+
+ final MemberNode member1 = MemberNode.builder(memberNodes).akkaConfig("Member1").testName(name)
+ .moduleShardsConfig(moduleShardsConfig).build();
+
+ member1.kit().waitUntilLeader(member1.configDataStore().getActorUtils(), "default");
+ }
+
+ @Test
+ public void testModuleShardLeaderMovement() throws Exception {
+ String name = "testModuleShardLeaderMovement";
+ String moduleShardsConfig = "module-shards-member1.conf";
+
+ final MemberNode member1 = MemberNode.builder(memberNodes).akkaConfig("Member1").testName(name)
+ .waitForShardLeader("cars").moduleShardsConfig(moduleShardsConfig).build();
+ final MemberNode replicaNode2 = MemberNode.builder(memberNodes).akkaConfig("Member2").testName(name)
+ .moduleShardsConfig(moduleShardsConfig).build();
+ final MemberNode replicaNode3 = MemberNode.builder(memberNodes).akkaConfig("Member3").testName(name)
+ .moduleShardsConfig(moduleShardsConfig).build();
+
+ member1.waitForMembersUp("member-2", "member-3");
+ replicaNode2.waitForMembersUp("member-1");
+ replicaNode3.waitForMembersUp("member-1", "member-2");
+
+ doAddShardReplica(replicaNode2, "cars", "member-1");
+ doAddShardReplica(replicaNode3, "cars", "member-1", "member-2");
+
+ verifyRaftPeersPresent(member1.configDataStore(), "cars", "member-2", "member-3");
+
+ verifyRaftPeersPresent(replicaNode2.configDataStore(), "cars", "member-1", "member-3");
+
+ verifyRaftPeersPresent(replicaNode3.configDataStore(), "cars", "member-1", "member-2");
+
+ doMakeShardLeaderLocal(member1, "cars", "member-1");
+ verifyRaftState(replicaNode2.configDataStore(), "cars",
+ raftState -> assertThat(raftState.getLeader(),containsString("member-1")));
+ verifyRaftState(replicaNode3.configDataStore(), "cars",
+ raftState -> assertThat(raftState.getLeader(),containsString("member-1")));
+
+ doMakeShardLeaderLocal(replicaNode2, "cars", "member-2");
+ verifyRaftState(member1.configDataStore(), "cars",
+ raftState -> assertThat(raftState.getLeader(),containsString("member-2")));
+ verifyRaftState(replicaNode3.configDataStore(), "cars",
+ raftState -> assertThat(raftState.getLeader(),containsString("member-2")));
+
+ replicaNode2.waitForMembersUp("member-3");
+ doMakeShardLeaderLocal(replicaNode3, "cars", "member-3");