* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
private Map<String, String> users;
private Map<String, Object> neo4j;
private ElasticSearchConfig elasticSearch;
- private String titanCfgFile;
- private String titanMigrationKeySpaceCfgFile;
- private Boolean titanInMemoryGraph;
+ private String janusGraphCfgFile;
+ private String janusGraphMigrationKeySpaceCfgFile;
+ private Boolean janusGraphInMemoryGraph;
private int startMigrationFrom;
- private Long titanLockTimeout;
- private Long titanReconnectIntervalInSeconds;
+ private Long janusGraphLockTimeout;
+ private Long janusGraphReconnectIntervalInSeconds;
private List<String> healthStatusExclude;
- private Long titanHealthCheckReadTimeout;
+ private Long janusGraphHealthCheckReadTimeout;
private Long esReconnectIntervalInSeconds;
private Long uebHealthCheckReconnectIntervalInSeconds;
private Long uebHealthCheckReadTimeout;
private Map<String, String> genericAssetNodeTypes;
private String appVersion;
- private String artifactGeneratorConfig;
public String getAutoHealingOwner() {
return autoHealingOwner;
private Map<String, List<String>> resourcesForUpgrade;
private DmaapConsumerConfiguration dmaapConsumerConfiguration;
- private boolean skipUpgradeFailedVfs;
- private boolean skipUpgradeVSPs;
+ private boolean skipUpgradeFailedVfs;
+ private boolean skipUpgradeVSPs;
private DmeConfiguration dmeConfiguration;
private boolean supportAllottedResourcesAndProxy;
public void setDmeConfiguration(DmeConfiguration dmeConfiguration) {
this.dmeConfiguration = dmeConfiguration;
}
- public void setSkipUpgradeVSPs(boolean skipUpgradeVSPs) { this.skipUpgradeVSPs = skipUpgradeVSPs; }
- public boolean getSkipUpgradeVSPsFlag() { return skipUpgradeVSPs; }
+ public void setSkipUpgradeVSPs(boolean skipUpgradeVSPs) {
+ this.skipUpgradeVSPs = skipUpgradeVSPs;
+ }
+
+ public boolean getSkipUpgradeVSPsFlag() {
+ return skipUpgradeVSPs;
+ }
public boolean getSkipUpgradeFailedVfs() {
return skipUpgradeFailedVfs;
this.appVersion = appVersion;
}
- public String getArtifactGeneratorConfig() {
- return artifactGeneratorConfig;
- }
-
- public void setArtifactGeneratorConfig(String artifactGeneratorConfig) {
- this.artifactGeneratorConfig = artifactGeneratorConfig;
- }
-
private String workloadContext;
private EnvironmentContext environmentContext;
+ private List<GabConfig> gabConfig;
+
public Map<String, String> getGenericAssetNodeTypes() {
return genericAssetNodeTypes;
}
this.elasticSearch = elasticSearch;
}
- public String getTitanCfgFile() {
- return titanCfgFile;
+ public String getJanusGraphCfgFile() {
+ return janusGraphCfgFile;
}
- public void setTitanCfgFile(String titanCfgFile) {
- this.titanCfgFile = titanCfgFile;
+ public void setJanusGraphCfgFile(String janusGraphCfgFile) {
+ this.janusGraphCfgFile = janusGraphCfgFile;
}
- public String getTitanMigrationKeySpaceCfgFile() {
- return titanMigrationKeySpaceCfgFile;
+ public String getJanusGraphMigrationKeySpaceCfgFile() {
+ return janusGraphMigrationKeySpaceCfgFile;
}
- public void setTitanMigrationKeySpaceCfgFile(String titanMigrationKeySpaceCfgFile) {
- this.titanMigrationKeySpaceCfgFile = titanMigrationKeySpaceCfgFile;
+ public void setJanusGraphMigrationKeySpaceCfgFile(String janusGraphMigrationKeySpaceCfgFile) {
+ this.janusGraphMigrationKeySpaceCfgFile = janusGraphMigrationKeySpaceCfgFile;
}
- public Boolean getTitanInMemoryGraph() {
- return titanInMemoryGraph;
+ public Boolean getJanusGraphInMemoryGraph() {
+ return janusGraphInMemoryGraph;
}
- public void setTitanInMemoryGraph(Boolean titanInMemoryGraph) {
- this.titanInMemoryGraph = titanInMemoryGraph;
+ public void setJanusGraphInMemoryGraph(Boolean janusGraphInMemoryGraph) {
+ this.janusGraphInMemoryGraph = janusGraphInMemoryGraph;
}
public int getStartMigrationFrom() {
this.startMigrationFrom = startMigrationFrom;
}
- public Long getTitanLockTimeout() {
- return titanLockTimeout;
+ public Long getJanusGraphLockTimeout() {
+ return janusGraphLockTimeout;
}
- public void setTitanLockTimeout(Long titanLockTimeout) {
- this.titanLockTimeout = titanLockTimeout;
+ public void setJanusGraphLockTimeout(Long janusGraphLockTimeout) {
+ this.janusGraphLockTimeout = janusGraphLockTimeout;
}
- public Long getTitanHealthCheckReadTimeout() {
- return titanHealthCheckReadTimeout;
+ public Long getJanusGraphHealthCheckReadTimeout() {
+ return janusGraphHealthCheckReadTimeout;
}
- public Long getTitanHealthCheckReadTimeout(long defaultVal) {
- return titanHealthCheckReadTimeout == null ? defaultVal : titanHealthCheckReadTimeout;
+ public Long getJanusGraphHealthCheckReadTimeout(long defaultVal) {
+ return janusGraphHealthCheckReadTimeout == null ? defaultVal : janusGraphHealthCheckReadTimeout;
}
- public void setTitanHealthCheckReadTimeout(Long titanHealthCheckReadTimeout) {
- this.titanHealthCheckReadTimeout = titanHealthCheckReadTimeout;
+ public void setJanusGraphHealthCheckReadTimeout(Long janusGraphHealthCheckReadTimeout) {
+ this.janusGraphHealthCheckReadTimeout = janusGraphHealthCheckReadTimeout;
}
- public Long getTitanReconnectIntervalInSeconds() {
- return titanReconnectIntervalInSeconds;
+ public Long getJanusGraphReconnectIntervalInSeconds() {
+ return janusGraphReconnectIntervalInSeconds;
}
- public Long getTitanReconnectIntervalInSeconds(long defaultVal) {
- return titanReconnectIntervalInSeconds == null ? defaultVal : titanReconnectIntervalInSeconds;
+ public Long getJanusGraphReconnectIntervalInSeconds(long defaultVal) {
+ return janusGraphReconnectIntervalInSeconds == null ? defaultVal : janusGraphReconnectIntervalInSeconds;
}
- public void setTitanReconnectIntervalInSeconds(Long titanReconnectIntervalInSeconds) {
- this.titanReconnectIntervalInSeconds = titanReconnectIntervalInSeconds;
+ public void setJanusGraphReconnectIntervalInSeconds(Long janusGraphReconnectIntervalInSeconds) {
+ this.janusGraphReconnectIntervalInSeconds = janusGraphReconnectIntervalInSeconds;
}
public Long getEsReconnectIntervalInSeconds() {
this.environmentContext = environmentContext;
}
+ public List<GabConfig> getGabConfig() {
+ return gabConfig;
+ }
+
+ public void setGabConfig(List<GabConfig> gabConfig) {
+ this.gabConfig = gabConfig;
+ }
+
public static class ElasticSearchConfig {
- List<IndicesTimeFrequencyEntry> indicesTimeFrequency;
+ private List<IndicesTimeFrequencyEntry> indicesTimeFrequency;
public List<IndicesTimeFrequencyEntry> getIndicesTimeFrequency() {
return indicesTimeFrequency;
public static class IndicesTimeFrequencyEntry {
- String indexPrefix;
- String creationPeriod;
+ private String indexPrefix;
+ private String creationPeriod;
public String getIndexPrefix() {
return indexPrefix;
}
public static class CassandrConfig {
+ private static final Integer CASSANDRA_DEFAULT_PORT = 9042;
- List<String> cassandraHosts;
- String localDataCenter;
- Long reconnectTimeout;
- Integer socketReadTimeout;
- Integer socketConnectTimeout;
- List<KeyspaceConfig> keySpaces;
- boolean authenticate;
- String username;
- String password;
- boolean ssl;
- String truststorePath;
- String truststorePassword;
+ private List<String> cassandraHosts;
+ private Integer cassandraPort;
+ private String localDataCenter;
+ private Long reconnectTimeout;
+ private Integer socketReadTimeout;
+ private Integer socketConnectTimeout;
+ private List<KeyspaceConfig> keySpaces;
+ private boolean authenticate;
+ private String username;
+ private String password;
+ private boolean ssl;
+ private String truststorePath;
+ private String truststorePassword;
+
+ public Integer getCassandraPort() {
+ return cassandraPort != null ? cassandraPort : Configuration.CassandrConfig.CASSANDRA_DEFAULT_PORT;
+ }
+
+ public void setCassandraPort(Integer cassandraPort) {
+ this.cassandraPort = cassandraPort;
+ }
public String getLocalDataCenter() {
return localDataCenter;
this.reconnectTimeout = reconnectTimeout;
}
- public Integer getSocketReadTimeout() { return socketReadTimeout; }
+ public Integer getSocketReadTimeout() {
+ return socketReadTimeout;
+ }
- public void setSocketReadTimeout(Integer socketReadTimeout) { this.socketReadTimeout = socketReadTimeout;}
+ public void setSocketReadTimeout(Integer socketReadTimeout) {
+ this.socketReadTimeout = socketReadTimeout;
+ }
- public Integer getSocketConnectTimeout() { return socketConnectTimeout;}
+ public Integer getSocketConnectTimeout() {
+ return socketConnectTimeout;
+ }
- public void setSocketConnectTimeout(Integer socketConnectTimeout) { this.socketConnectTimeout = socketConnectTimeout; }
+ public void setSocketConnectTimeout(Integer socketConnectTimeout) {
+ this.socketConnectTimeout = socketConnectTimeout;
+ }
public List<String> getCassandraHosts() {
return cassandraHosts;
public static class KeyspaceConfig {
- String name;
- String replicationStrategy;
- List<String> replicationInfo;
+ private String name;
+ private String replicationStrategy;
+ private List<String> replicationInfo;
public String getName() {
return name;
public static class SwitchoverDetectorConfig {
- String gBeFqdn;
- String gFeFqdn;
- String beVip;
- String feVip;
- int beResolveAttempts;
- int feResolveAttempts;
- Boolean enabled;
- long interval;
- String changePriorityUser;
- String changePriorityPassword;
- String publishNetworkUrl;
- String publishNetworkBody;
- Map<String, GroupInfo> groups;
+ private String gBeFqdn;
+ private String gFeFqdn;
+ private String beVip;
+ private String feVip;
+ private int beResolveAttempts;
+ private int feResolveAttempts;
+ private Boolean enabled;
+ private long interval;
+ private String changePriorityUser;
+ private String changePriorityPassword;
+ private String publishNetworkUrl;
+ private String publishNetworkBody;
+ private Map<String, GroupInfo> groups;
public String getgBeFqdn() {
return gBeFqdn;
public static class GroupInfo {
- String changePriorityUrl;
- String changePriorityBody;
+ private String changePriorityUrl;
+ private String changePriorityBody;
public String getChangePriorityUrl() {
return changePriorityUrl;
public static class BeMonitoringConfig {
- Boolean enabled;
- Boolean isProxy;
- Integer probeIntervalInSeconds;
+ private Boolean enabled;
+ private Boolean isProxy;
+ private Integer probeIntervalInSeconds;
public Boolean getEnabled() {
return enabled;
public static class ArtifactTypeConfig {
- List<String> acceptedTypes;
- List<String> validForResourceTypes;
+ private List<String> acceptedTypes;
+ private List<String> validForResourceTypes;
public List<String> getValidForResourceTypes() {
return validForResourceTypes;
public static class OnboardingConfig {
- String protocol = "http";
- String host;
- Integer port;
- String downloadCsarUri;
- String healthCheckUri;
+ private String protocol = "http";
+ private String host;
+ private Integer port;
+ private String downloadCsarUri;
+ private String healthCheckUri;
public String getProtocol() {
return protocol;
public static class DcaeConfig {
- String protocol = "http";
- String host;
- Integer port;
- String healthCheckUri;
+ private String protocol = "http";
+ private String host;
+ private Integer port;
+ private String healthCheckUri;
public String getProtocol() {
return protocol;
public static class ApplicationL1CacheConfig {
- ApplicationL1CacheInfo datatypes;
+ private ApplicationL1CacheInfo datatypes;
public ApplicationL1CacheInfo getDatatypes() {
return datatypes;
public static class ApplicationL2CacheConfig {
- boolean enabled;
- ApplicationL1CacheCatalogInfo catalogL1Cache;
+ private boolean enabled;
+ private ApplicationL1CacheCatalogInfo catalogL1Cache;
- QueueInfo queue;
+ private QueueInfo queue;
public boolean isEnabled() {
return enabled;
public static class ApplicationL1CacheInfo {
- Boolean enabled;
- Integer firstRunDelay;
- Integer pollIntervalInSec;
+ private Boolean enabled;
+ private Integer firstRunDelay;
+ private Integer pollIntervalInSec;
public Boolean getEnabled() {
return enabled;
public static class ApplicationL1CacheCatalogInfo {
- Boolean enabled;
- Integer resourcesSizeInCache;
- Integer servicesSizeInCache;
- Integer productsSizeInCache;
+ private Boolean enabled;
+ private Integer resourcesSizeInCache;
+ private Integer servicesSizeInCache;
+ private Integer productsSizeInCache;
public Boolean getEnabled() {
return enabled;
}
public static class QueueInfo {
- Integer numberOfCacheWorkers;
- Integer waitOnShutDownInMinutes;
- Integer syncIntervalInSecondes;
+ private Integer numberOfCacheWorkers;
+ private Integer waitOnShutDownInMinutes;
+ private Integer syncIntervalInSecondes;
public Integer getWaitOnShutDownInMinutes() {
return waitOnShutDownInMinutes;
public static class EnvironmentContext {
- String defaultValue;
- List<String> validValues;
+ private String defaultValue;
+ private List<String> validValues;
public String getDefaultValue() {
return defaultValue;
}
-
public CleanComponentsConfiguration getCleanComponentsConfiguration() {
return cleanComponentsConfiguration;
}
.append(format("Released: %s%n", released)).append(format("Supported protocols: %s%n", protocols))
.append(format("Users: %s%n", users)).append(format("Neo4j: %s%n", neo4j))
.append(format("ElasticSearch: %s%n", elasticSearch))
- .append(format("Titan Cfg File: %s%n", titanCfgFile))
- .append(format("Titan In memory: %s%n", titanInMemoryGraph))
- .append(format("Titan lock timeout: %s%n", titanLockTimeout))
- .append(format("Titan reconnect interval seconds: %s%n", titanReconnectIntervalInSeconds))
+ .append(format("JanusGraph Cfg File: %s%n", janusGraphCfgFile))
+ .append(format("JanusGraph In memory: %s%n", janusGraphInMemoryGraph))
+ .append(format("JanusGraph lock timeout: %s%n", janusGraphLockTimeout))
+ .append(format("JanusGraph reconnect interval seconds: %s%n",
+ janusGraphReconnectIntervalInSeconds))
.append(format("excludeResourceCategory: %s%n", excludeResourceCategory))
.append(format("informationalResourceArtifacts: %s%n", informationalResourceArtifacts))
.append(format("deploymentResourceArtifacts: %s%n", deploymentResourceArtifacts))
.append(format("Service Api Artifacts: %s%n", serviceApiArtifacts))
.append(format("heat env artifact header: %s%n", heatEnvArtifactHeader))
.append(format("heat env artifact footer: %s%n", heatEnvArtifactFooter))
- .append(format("onboarding: %s%n", onboarding))
- .append(format("tosca conformance level: %s%n", toscaConformanceLevel))
- .toString();
+ .append(format("onboarding: %s%n", onboarding))
+ .append(format("tosca conformance level: %s%n", toscaConformanceLevel))
+ .toString();
}
public List<String> getUnLoggedUrls() {
public static class VfModuleProperty {
private String forBaseModule;
private String forNonBaseModule;
+
public String getForBaseModule() {
return forBaseModule;
}
+
public void setForBaseModule(String forBaseModule) {
this.forBaseModule = forBaseModule;
}
+
public String getForNonBaseModule() {
return forNonBaseModule;
}
+
public void setForNonBaseModule(String forNonBaseModule) {
this.forNonBaseModule = forNonBaseModule;
}
}
@SuppressWarnings("unchecked")
- public static <K,V> Map<K,V> safeGetCapsInsensitiveMap(Map<K,V> map) {
+ public static <K, V> Map<K, V> safeGetCapsInsensitiveMap(Map<K, V> map) {
return map == null ? emptyMap() : new CaseInsensitiveMap(map);
}
this.healthStatusExclude = healthStatusExclude;
}
+
+ public static class PathsAndNamesDefinition {
+ private String friendlyName;
+ private String path;
+ private String searchable;
+
+ public String getFriendlyName() {
+ return friendlyName;
+ }
+
+ public String getPath() {
+ return path;
+ }
+
+ public String getSearchable() {
+ return searchable;
+ }
+
+ public void setFriendlyName(String friendlyName) {
+ this.friendlyName = friendlyName;
+ }
+
+ public void setPath(String path) {
+ this.path = path;
+ }
+
+ public void setSearchable(String searchable) {
+ this.searchable = searchable;
+ }
+ }
+
+ public static class GabConfig {
+ private String artifactType;
+ private List<PathsAndNamesDefinition> pathsAndNamesDefinitions;
+
+ public String getArtifactType() {
+ return artifactType;
+ }
+
+ public List<PathsAndNamesDefinition> getPathsAndNamesDefinitions() {
+ return pathsAndNamesDefinitions;
+ }
+
+ public void setArtifactType(String artifactType) {
+ this.artifactType = artifactType;
+ }
+
+ public void setPathsAndNamesDefinitions(List<PathsAndNamesDefinition> pathsAndNamesDefinitions) {
+ this.pathsAndNamesDefinitions = pathsAndNamesDefinitions;
+ }
+ }
}
Code Review / sdc.git / blobdiff