2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
6 * ================================================================================
7 * Licensed under the Apache License, Version 2.0 (the "License");
8 * you may not use this file except in compliance with the License.
9 * You may obtain a copy of the License at
11 * http://www.apache.org/licenses/LICENSE-2.0
13 * Unless required by applicable law or agreed to in writing, software
14 * distributed under the License is distributed on an "AS IS" BASIS,
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 * See the License for the specific language governing permissions and
17 * limitations under the License.
18 * ============LICENSE_END=========================================================
21 package org.openecomp.sdc.be.config;
23 import org.openecomp.sdc.common.api.BasicConfiguration;
24 import org.openecomp.sdc.common.http.config.ExternalServiceConfig;
26 import java.util.ArrayList;
27 import java.util.HashSet;
28 import java.util.List;
32 public class DistributionEngineConfiguration extends BasicConfiguration {
34 private List<String> uebServers;
36 private String distributionNotifTopicName;
38 private String distributionStatusTopicName;
40 private Integer initRetryIntervalSec;
42 private Integer initMaxIntervalSec;
44 private ComponentArtifactTypesConfig distribNotifServiceArtifactTypes;
46 private ComponentArtifactTypesConfig distribNotifResourceArtifactTypes;
48 private String uebPublicKey;
50 private String uebSecretKey;
52 private List<String> environments;
54 private DistributionStatusTopicConfig distributionStatusTopic;
56 private CreateTopicConfig createTopic;
58 private boolean startDistributionEngine;
60 private DistributionNotificationTopicConfig distributionNotificationTopic;
62 private Integer defaultArtifactInstallationTimeout = 60;
64 private Integer currentArtifactInstallationTimeout = 120;
66 private boolean useHttpsWithDmaap;
68 private ExternalServiceConfig aaiConfig;
70 private ExternalServiceConfig msoConfig;
72 private Integer opEnvRecoveryIntervalSec;
74 private Integer allowedTimeBeforeStaleSec;
76 public static class DistribNotifServiceArtifacts {
78 private Map<String, Object> service;
79 private Map<String, Object> resource;
82 public Map<String, Object> getService() {
86 public void setService(Map<String, Object> service) {
87 this.service = service;
90 public Map<String, Object> getResource() {
94 public void setResource(Map<String, Object> resource) {
95 this.resource = resource;
100 public static class NotifArtifactTypes {
102 private List<String> info;
103 private List<String> lifecycle;
105 public List<String> getInfo() {
109 public void setInfo(List<String> info) {
113 public List<String> getLifecycle() {
117 public void setLifecycle(List<String> lifecycle) {
118 this.lifecycle = lifecycle;
123 public static class NotifArtifactTypesResource {
125 private List<ArtifcatTypeEnum> lifecycle;
127 public List<ArtifcatTypeEnum> getLifecycle() {
131 public void setLifecycle(List<ArtifcatTypeEnum> lifecycle) {
132 this.lifecycle = lifecycle;
136 public enum ArtifcatTypeEnum {
138 MURANO_PKG("MURANO-PKG"), HEAT("HEAT"), DG_XML("DG_XML");
140 private String value;
142 ArtifcatTypeEnum(String value) {
146 public String getValue() {
152 public List<String> getUebServers() {
156 public void setUebServers(List<String> uebServers) {
157 this.uebServers = uebServers;
160 public String getDistributionNotifTopicName() {
161 return distributionNotifTopicName;
164 public void setDistributionNotifTopicName(String distributionNotifTopicName) {
165 this.distributionNotifTopicName = distributionNotifTopicName;
168 public String getDistributionStatusTopicName() {
169 return distributionStatusTopicName;
172 public void setDistributionStatusTopicName(String distributionStatusTopicName) {
173 this.distributionStatusTopicName = distributionStatusTopicName;
176 public Integer getInitRetryIntervalSec() {
177 return initRetryIntervalSec;
180 public void setInitRetryIntervalSec(Integer initRetryIntervalSec) {
181 this.initRetryIntervalSec = initRetryIntervalSec;
184 public ComponentArtifactTypesConfig getDistribNotifServiceArtifactTypes() {
185 return distribNotifServiceArtifactTypes;
188 public void setDistribNotifServiceArtifactTypes(ComponentArtifactTypesConfig distribNotifServiceArtifactTypes) {
189 this.distribNotifServiceArtifactTypes = distribNotifServiceArtifactTypes;
192 public ComponentArtifactTypesConfig getDistribNotifResourceArtifactTypes() {
193 return distribNotifResourceArtifactTypes;
196 public void setDistribNotifResourceArtifactTypes(ComponentArtifactTypesConfig distribNotifResourceArtifactTypes) {
197 this.distribNotifResourceArtifactTypes = distribNotifResourceArtifactTypes;
200 public String getUebPublicKey() {
204 public void setUebPublicKey(String uebPublicKey) {
205 this.uebPublicKey = uebPublicKey;
208 public String getUebSecretKey() {
212 public void setUebSecretKey(String uebSecretKey) {
213 this.uebSecretKey = uebSecretKey;
216 public List<String> getEnvironments() {
220 public void setEnvironments(List<String> environments) {
222 Set<String> set = new HashSet<>();
223 if (environments != null) {
224 set.addAll(environments);
225 this.environments = new ArrayList<>(set);
227 this.environments = null;
232 public DistributionStatusTopicConfig getDistributionStatusTopic() {
233 return distributionStatusTopic;
236 public void setDistributionStatusTopic(DistributionStatusTopicConfig distributionStatusTopic) {
237 this.distributionStatusTopic = distributionStatusTopic;
240 public Integer getInitMaxIntervalSec() {
241 return initMaxIntervalSec;
244 public void setInitMaxIntervalSec(Integer initMaxIntervalSec) {
245 this.initMaxIntervalSec = initMaxIntervalSec;
248 public CreateTopicConfig getCreateTopic() {
252 public void setCreateTopic(CreateTopicConfig createTopic) {
253 this.createTopic = createTopic;
256 public boolean isStartDistributionEngine() {
257 return startDistributionEngine;
260 public void setStartDistributionEngine(boolean startDistributionEngine) {
261 this.startDistributionEngine = startDistributionEngine;
264 public DistributionNotificationTopicConfig getDistributionNotificationTopic() {
265 return distributionNotificationTopic;
268 public void setDistributionNotificationTopic(DistributionNotificationTopicConfig distributionNotificationTopic) {
269 this.distributionNotificationTopic = distributionNotificationTopic;
272 public int getDefaultArtifactInstallationTimeout() {
273 return defaultArtifactInstallationTimeout;
276 public void setDefaultArtifactInstallationTimeout(int defaultArtifactInstallationTimeout) {
277 this.defaultArtifactInstallationTimeout = defaultArtifactInstallationTimeout;
280 public int getCurrentArtifactInstallationTimeout() {
281 return currentArtifactInstallationTimeout;
284 public void setCurrentArtifactInstallationTimeout(int currentArtifactInstallationTimeout) {
285 this.currentArtifactInstallationTimeout = currentArtifactInstallationTimeout;
288 public boolean isUseHttpsWithDmaap() {
289 return useHttpsWithDmaap;
292 public void setUseHttpsWithDmaap(boolean useHttpsWithDmaap) {
293 this.useHttpsWithDmaap = useHttpsWithDmaap;
296 public static class CreateTopicConfig {
298 private Integer partitionCount;
299 private Integer replicationCount;
301 public Integer getPartitionCount() {
302 return partitionCount;
305 public void setPartitionCount(Integer partitionCount) {
306 this.partitionCount = partitionCount;
309 public Integer getReplicationCount() {
310 return replicationCount;
313 public void setReplicationCount(Integer replicationCount) {
314 this.replicationCount = replicationCount;
318 public String toString() {
319 return "CreateTopicConfig [partitionCount=" + partitionCount + ", replicationCount=" + replicationCount
325 public static class EnvironmentConfig {
328 private List<String> uebServers;
330 public String getName() {
334 public void setName(String name) {
338 public List<String> getUebServers() {
342 public void setUebServers(List<String> uebServers) {
343 this.uebServers = uebServers;
347 public String toString() {
348 return "EnvironmentConfig [name=" + name + ", uebServers=" + uebServers + "]";
353 public static class DistributionStatusTopicConfig {
355 private Integer pollingIntervalSec;
356 private Integer fetchTimeSec;
357 private String consumerGroup;
358 private String consumerId;
360 public Integer getPollingIntervalSec() {
361 return pollingIntervalSec;
364 public void setPollingIntervalSec(Integer pollingIntervalSec) {
365 this.pollingIntervalSec = pollingIntervalSec;
368 public Integer getFetchTimeSec() {
372 public void setFetchTimeSec(Integer fetchTimeSec) {
373 this.fetchTimeSec = fetchTimeSec;
376 public String getConsumerGroup() {
377 return consumerGroup;
380 public void setConsumerGroup(String consumerGroup) {
381 this.consumerGroup = consumerGroup;
384 public String getConsumerId() {
388 public void setConsumerId(String consumerId) {
389 this.consumerId = consumerId;
393 public String toString() {
394 return "DistributionStatusTopicConfig [pollingIntervalSec=" + pollingIntervalSec + ", fetchTimeSec="
395 + fetchTimeSec + ", consumerGroup=" + consumerGroup + ", consumerId=" + consumerId + "]";
400 public static class DistributionNotificationTopicConfig {
402 private Integer maxWaitingAfterSendingSeconds;
403 private Integer maxThreadPoolSize;
404 private Integer minThreadPoolSize;
406 public Integer getMaxWaitingAfterSendingSeconds() {
407 return maxWaitingAfterSendingSeconds;
410 public void setMaxWaitingAfterSendingSeconds(Integer maxWaitingAfterSendingSeconds) {
411 this.maxWaitingAfterSendingSeconds = maxWaitingAfterSendingSeconds;
414 public Integer getMaxThreadPoolSize() {
415 return maxThreadPoolSize;
418 public void setMaxThreadPoolSize(Integer maxThreadPoolSize) {
419 this.maxThreadPoolSize = maxThreadPoolSize;
422 public Integer getMinThreadPoolSize() {
423 return minThreadPoolSize;
426 public void setMinThreadPoolSize(Integer minThreadPoolSize) {
427 this.minThreadPoolSize = minThreadPoolSize;
431 public String toString() {
432 return "DistributionNotificationTopicConfig [maxWaitingAfterSendingSeconds=" + maxWaitingAfterSendingSeconds
433 + ", maxThreadPoolSize=" + maxThreadPoolSize + ", minThreadPoolSize=" + minThreadPoolSize + "]";
438 public static class ComponentArtifactTypesConfig {
440 private List<String> info;
441 private List<String> lifecycle;
443 public List<String> getInfo() {
447 public void setInfo(List<String> info) {
451 public List<String> getLifecycle() {
455 public void setLifecycle(List<String> lifecycle) {
456 this.lifecycle = lifecycle;
460 public String toString() {
461 return "ArtifactTypesConfig [info=" + info + ", lifecycle=" + lifecycle + "]";
466 public Integer getOpEnvRecoveryIntervalSec() {
467 return opEnvRecoveryIntervalSec;
470 public void setOpEnvRecoveryIntervalSec(Integer opEnvRecoveryIntervalSec) {
471 this.opEnvRecoveryIntervalSec = opEnvRecoveryIntervalSec;
474 public Integer getAllowedTimeBeforeStaleSec() {
475 return allowedTimeBeforeStaleSec;
478 public void setAllowedTimeBeforeStaleSec(Integer allowedTimeBeforeStaleSec) {
479 this.allowedTimeBeforeStaleSec = allowedTimeBeforeStaleSec;
482 public ExternalServiceConfig getAaiConfig() {
486 public void setAaiConfig(ExternalServiceConfig aaiConfig) {
487 this.aaiConfig = aaiConfig;
490 public ExternalServiceConfig getMsoConfig() {
494 public void setMsoConfig(ExternalServiceConfig msoConfig) {
495 this.msoConfig = msoConfig;