- private static Map<String, ModuleConfig> readModuleShardsConfig(final Config moduleShardsConfig) {
- List<? extends ConfigObject> moduleShardsConfigObjectList =
- moduleShardsConfig.getObjectList("module-shards");
-
- Map<String, ModuleConfig> moduleConfigMap = new HashMap<>();
- for(ConfigObject moduleShardConfigObject : moduleShardsConfigObjectList){
- String moduleName = moduleShardConfigObject.get("name").unwrapped().toString();
- ModuleConfig moduleConfig = new ModuleConfig(moduleName);
-
- List<? extends ConfigObject> shardsConfigObjectList =
- moduleShardConfigObject.toConfig().getObjectList("shards");
-
- for(ConfigObject shard : shardsConfigObjectList){
- String shardName = shard.get("name").unwrapped().toString();
- List<String> replicas = shard.toConfig().getStringList("replicas");
- moduleConfig.addShardConfig(shardName, ImmutableSet.copyOf(replicas));
- }
-
- moduleConfigMap.put(moduleName, moduleConfig);
- }
-
- return moduleConfigMap;
- }
-
- private static class ConfigObjectWrapper{
-
- private final ConfigObject configObject;
-
- ConfigObjectWrapper(final ConfigObject configObject){
- this.configObject = configObject;
- }
-
- public String stringValue(final String name){
- return configObject.get(name).unwrapped().toString();
- }