inteligr8/SearchServices
1
0
Fork 0
mirror of https://github.com/Alfresco/SearchServices.git synced 2025-09-17 14:21:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

SEARCH-1681 creating a loop to go through instances and shards

Browse Source
This commit is contained in:
Keerat
2020-02-13 14:36:37 +00:00
parent e22bb2966d
commit 6cb9b47fbb
1 changed files with 46 additions and 43 deletions
Download Patch File Download Diff File Expand all files Collapse all files

89
e2e-test/src/test/java/org/alfresco/test/search/functional/searchServices/search/ShardInfoTest.java
View File

@@ -20,6 +20,7 @@ import static org.testng.Assert.assertNotNull;
import static org.testng.Assert.assertTrue; import static org.testng.Assert.assertTrue;
import java.util.Arrays; import java.util.Arrays;
import java.util.Iterator;
import java.util.List; import java.util.List;
import java.util.Set; import java.util.Set;
import java.util.stream.Collectors; import java.util.stream.Collectors;
@@ -155,56 +156,58 @@ public class ShardInfoTest extends AbstractE2EFunctionalTest
for (RestShardInfoModel shardInfoModel : entries) for (RestShardInfoModel shardInfoModel : entries)
{ {
RestShardInfoModel model = shardInfoModel.getModel(); RestShardInfoModel model = shardInfoModel.getModel();
assertEquals(model.getTemplate(), "rerank"); assertEquals(model.getTemplate(), "rerank", "Template is not rerank, template found: "+ model.getTemplate());
assertEquals(model.getMode(), "MASTER"); assertEquals(model.getMode(), "MASTER", "Mode is not MASTER, mode found: "+ model.getMode());
assertTrue(model.getHasContent()); assertTrue(model.getHasContent(), "There is no content on the shards");
assertTrue(model.getNumberOfShards()>=2); assertTrue(model.getNumberOfShards()>=2, "Number of shards is not equal to or greater than 2");
List<String> shardingMethods = Arrays.asList("DB_ID", "DB_ID_RANGE", "EXPLICIT_ID", "ACL_ID", "MOD_ACL_ID", "DATE", "PROPERTY"); List<String> shardingMethods = Arrays.asList("DB_ID", "DB_ID_RANGE", "EXPLICIT_ID", "ACL_ID", "MOD_ACL_ID", "DATE", "PROPERTY");
String shardingMethod = model.getShardMethod(); String shardingMethod = model.getShardMethod();
assertTrue(shardingMethods.contains(shardingMethod), "Unexpected Sharding Method Found: " + shardingMethod); assertTrue(shardingMethods.contains(shardingMethod), "Unexpected Sharding Method Found: " + shardingMethod);
List<RestShardModel> shards = model.getShards(); List<RestShardModel> shards = model.getShards();
assertNotNull(shards, "Unexpected number of shards found:" + shards); assertNotNull(shards);
RestShardModel shard = shards.iterator().next(); for (RestShardModel shardInstance : shards)
assertNotNull(shard);
List<RestInstanceModel> instances = shard.getInstances();
assertNotNull(instances, "Unexpected number of instances found:" + instances);
RestInstanceModel instance = instances.iterator().next();
assertNotNull(instance);
assertTrue(baseUrls.contains(instance.getBaseUrl()));
assertEquals(instance.getState(), "ACTIVE");
// shardparams related checks
String shardParams = instance.getShardParams();
switch (shardingMethod)
{ {
case "MOD_ACL_ID": List<RestInstanceModel> instanceList = shardInstance.getInstances();
assertTrue(shardingMethod == "MOD_ACL_ID", "Sharding Method is not MOD_ACL_ID"); for (RestInstanceModel instanceX : instanceList)
break; {
case "ACL_ID": assertTrue(baseUrls.contains(instanceX.getBaseUrl()));
assertTrue(shardingMethod == "ACL_ID", "Sharding Method is not ACL_ID"); assertEquals(instanceX.getState(), "ACTIVE", "Shard state is not ACTIVE, shard state is: " + instanceX.getState());
break; assertNotNull(instanceX.getPort(), "There is not port found for the instance");
case "DB_ID": assertEquals(instanceX.getMode(), "MASTER", "Mode is not MASTER, mode found: "+ instanceX.getMode());
assertTrue(shardingMethod == "DB_ID", "Sharding Method is not DB_ID"); assertTrue(instanceX.getTransactionsRemaining() >= 0, "Transactions remaining is not more than 0, transactions remaining: " + instanceX.getTransactionsRemaining());
break; String shardParams = (instanceX).getShardParams();
case "DB_ID_RANGE": switch (shardingMethod)
assertTrue(shardingMethod == "DB_ID_RANGE", "Sharding Method is not DB_ID_RANGE"); {
break; case "MOD_ACL_ID":
case "DATE": assertEquals(shardingMethod = "MOD_ACL_ID", "MOD_ACL_ID", "Sharding Method is not MOD_ACL_ID");
assertTrue(shardParams.contains("shard.key="), "Unexpected shard params defined for DATE"); break;
assertTrue(shardParams.contains("shard.grouping="), "Unexpected shard grouping defined for DATE"); case "ACL_ID":
break; assertEquals(shardingMethod = "ACL_ID", "ACL_ID", "Sharding Method is not ACL_ID");
case "PROPERTY": break;
assertTrue(shardParams.contains("shard.key="), "Unexpected shard params defined for PROPERTY"); case "DB_ID":
break; assertEquals(shardingMethod = "DB_ID", "DB_ID", "Sharding Method is not DB_ID");
case "EXPLICIT_ID": break;
assertTrue(shardParams.contains("shard.key="), "Unexpected shard params defined for EXPLICIT_ID"); case "DB_ID_RANGE":
break; assertEquals(shardingMethod = "DB_ID_RANGE", "DB_ID_RANGE", "Sharding Method is not DB_ID_RANGE");
default: //assertEquals(shardParams.contains("shard.range="), "Unexpected shard params defined for DB_ID_RANGE");
throw new AssertionError("Not as expected: " + shardParams.toString()); break;
} case "DATE":
assertTrue(shardParams.contains("shard.key="), "Unexpected shard params defined for DATE");
assertTrue(shardParams.contains("shard.grouping="), "Unexpected shard grouping defined for DATE");
break;
case "PROPERTY":
assertTrue(shardParams.contains("shard.key="), "Unexpected shard params defined for PROPERTY");
break;
case "EXPLICIT_ID":
assertTrue(shardParams.contains("shard.key="), "Unexpected shard params defined for EXPLICIT_ID");
break;
default:
throw new AssertionError("Not as expected: " + shardParams.toString());
}
}
}
} }
} }
} }