@Test
public void testAddMemberReplicaForShard() {
configuration.addMemberReplicaForShard("people-1", MEMBER_2);
String shardName = configuration.getShardNameForModule("people");
assertEquals("ModuleShardName", "people-1", shardName);
ShardStrategy shardStrategy = configuration.getStrategyForModule("people");
assertEquals("ModuleStrategy", ModuleShardStrategy.class, shardStrategy.getClass());
Collection<MemberName> members = configuration.getMembersFromShardName("people-1");
assertEquals("Members", ImmutableSortedSet.of(MEMBER_1, MEMBER_2),
ImmutableSortedSet.copyOf(members));
configuration.addMemberReplicaForShard("non-existent", MEMBER_2);
Set<String> shardNames = configuration.getAllShardNames();
assertEquals("ShardNames", ImmutableSortedSet.of("people-1", "cars-1", "test-1", "default"),
ImmutableSortedSet.copyOf(shardNames));
}
ConfigurationImplTest.java 文件源码
java
阅读 39
收藏 0
点赞 0
评论 0
项目:hashsdn-controller
作者:
评论列表
文章目录