+/*
+ * Copyright (c) 2015 Brocade Communications Systems, Inc. and others. All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+package org.opendaylight.controller.cluster.datastore.config;
+
+import com.google.common.collect.ImmutableSet;
+import com.typesafe.config.Config;
+import com.typesafe.config.ConfigFactory;
+import com.typesafe.config.ConfigObject;
+import java.io.File;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import org.opendaylight.controller.cluster.datastore.shardstrategy.ShardStrategyFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * Implementation of ModuleShardConfigProvider that reads the module and shard configuration from files.
+ *
+ * @author Thomas Pantelis
+ */
+public class FileModuleShardConfigProvider implements ModuleShardConfigProvider {
+ private static final Logger LOG = LoggerFactory.getLogger(FileModuleShardConfigProvider.class);
+
+ private final String moduleShardsConfigPath;
+ private final String modulesConfigPath;
+
+ public FileModuleShardConfigProvider(String moduleShardsConfigPath, String modulesConfigPath) {
+ this.moduleShardsConfigPath = moduleShardsConfigPath;
+ this.modulesConfigPath = modulesConfigPath;
+ }
+
+ @Override
+ public Map<String, ModuleConfig> retrieveModuleConfigs(Configuration configuration) {
+ File moduleShardsFile = new File("./configuration/initial/" + moduleShardsConfigPath);
+ File modulesFile = new File("./configuration/initial/" + modulesConfigPath);
+
+ Config moduleShardsConfig = null;
+ if(moduleShardsFile.exists()) {
+ LOG.info("module shards config file exists - reading config from it");
+ moduleShardsConfig = ConfigFactory.parseFile(moduleShardsFile);
+ } else {
+ LOG.warn("module shards configuration read from resource");
+ moduleShardsConfig = ConfigFactory.load(moduleShardsConfigPath);
+ }
+
+ Config modulesConfig = null;
+ if(modulesFile.exists()) {
+ LOG.info("modules config file exists - reading config from it");
+ modulesConfig = ConfigFactory.parseFile(modulesFile);
+ } else {
+ LOG.warn("modules configuration read from resource");
+ modulesConfig = ConfigFactory.load(modulesConfigPath);
+ }
+
+ Map<String, ModuleConfig> moduleConfigMap = readModuleShardsConfig(moduleShardsConfig);
+ readModulesConfig(modulesConfig, moduleConfigMap, configuration);
+
+ return moduleConfigMap;
+ }
+
+ private void readModulesConfig(final Config modulesConfig, Map<String, ModuleConfig> moduleConfigMap,
+ Configuration configuration) {
+ List<? extends ConfigObject> modulesConfigObjectList = modulesConfig.getObjectList("modules");
+
+ for(ConfigObject o : modulesConfigObjectList){
+ ConfigObjectWrapper w = new ConfigObjectWrapper(o);
+
+ String moduleName = w.stringValue("name");
+ ModuleConfig moduleConfig = moduleConfigMap.get(moduleName);
+ if(moduleConfig == null) {
+ moduleConfig = new ModuleConfig(moduleName);
+ moduleConfigMap.put(moduleName, moduleConfig);
+ }
+
+ moduleConfig.setNameSpace(w.stringValue("namespace"));
+ moduleConfig.setShardStrategy(ShardStrategyFactory.newShardStrategyInstance(moduleName,
+ w.stringValue("shard-strategy"), configuration));
+ }
+ }
+
+ 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();
+ }
+ }
+}
Code Review / controller.git / commitdiff