diff options
Diffstat (limited to 'participant')
29 files changed, 3 insertions, 6546 deletions
diff --git a/participant/participant-impl/participant-impl-dcae/pom.xml b/participant/participant-impl/participant-impl-dcae/pom.xml deleted file mode 100644 index f5fd3688c..000000000 --- a/participant/participant-impl/participant-impl-dcae/pom.xml +++ /dev/null @@ -1,51 +0,0 @@ -<!-- - ============LICENSE_START======================================================= - Copyright (C) 2021 Nordix Foundation. - ================================================================================ - 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. - See the License for the specific language governing permissions and - limitations under the License. - - SPDX-License-Identifier: Apache-2.0 - ============LICENSE_END========================================================= ---> - -<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" - xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> - <modelVersion>4.0.0</modelVersion> - - <parent> - <groupId>org.onap.policy.clamp.participant</groupId> - <artifactId>policy-clamp-participant-impl</artifactId> - <version>6.1.2-SNAPSHOT</version> - </parent> - - <artifactId>policy-clamp-participant-impl-dcae</artifactId> - <name>${project.artifactId}</name> - <description>DCAE participant, that allows DCAE to partake in control loops</description> - - <build> - <plugins> - <plugin> - <groupId>org.springframework.boot</groupId> - <artifactId>spring-boot-maven-plugin</artifactId> - <executions> - <execution> - <goals> - <goal>repackage</goal> - </goals> - <phase>package</phase> - </execution> - </executions> - </plugin> - </plugins> - </build> -</project> diff --git a/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/DcaeParticipantApplication.java b/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/DcaeParticipantApplication.java deleted file mode 100644 index 9be83bbd3..000000000 --- a/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/DcaeParticipantApplication.java +++ /dev/null @@ -1,43 +0,0 @@ -/*-
- * ============LICENSE_START=======================================================
- * Copyright (C) 2021 Nordix Foundation.
- * ================================================================================
- * 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.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- * SPDX-License-Identifier: Apache-2.0
- * ============LICENSE_END=========================================================
- */
-
-package org.onap.policy.clamp.controlloop.participant.dcae;
-
-import org.springframework.boot.SpringApplication;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.boot.context.properties.ConfigurationPropertiesScan;
-import org.springframework.context.annotation.ComponentScan;
-
-/**
- * Starter.
- *
- */
-@SpringBootApplication
-@ComponentScan({
- "org.onap.policy.clamp.controlloop.participant.dcae",
- "org.onap.policy.clamp.controlloop.participant.intermediary"
-})
-@ConfigurationPropertiesScan("org.onap.policy.clamp.controlloop.participant.dcae.main.parameters")
-public class DcaeParticipantApplication {
-
- public static void main(String[] args) {
- SpringApplication.run(DcaeParticipantApplication.class, args);
- }
-}
diff --git a/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/config/ParticipantConfig.java b/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/config/ParticipantConfig.java deleted file mode 100644 index 965c3f143..000000000 --- a/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/config/ParticipantConfig.java +++ /dev/null @@ -1,43 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2021 Nordix Foundation. - * ================================================================================ - * 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. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.clamp.controlloop.participant.dcae.config; - -import org.onap.policy.clamp.controlloop.participant.dcae.main.handler.ControlLoopElementHandler; -import org.onap.policy.clamp.controlloop.participant.intermediary.api.ParticipantIntermediaryApi; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.context.annotation.Configuration; - -@Configuration -public class ParticipantConfig { - - /** - * Register ControlLoopElementListener. - * - * @param intermediaryApi the ParticipantIntermediaryApi - * @param clElementHandler the ControlLoop Element Handler - */ - @Autowired - public void registerControlLoopElementListener(ParticipantIntermediaryApi intermediaryApi, - ControlLoopElementHandler clElementHandler) { - intermediaryApi.registerControlLoopElementListener(clElementHandler); - clElementHandler.setIntermediaryApi(intermediaryApi); - } -} diff --git a/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/httpclient/AbstractHttpClient.java b/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/httpclient/AbstractHttpClient.java deleted file mode 100644 index 43326e725..000000000 --- a/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/httpclient/AbstractHttpClient.java +++ /dev/null @@ -1,112 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2021 Nordix Foundation. - * ================================================================================ - * 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. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.clamp.controlloop.participant.dcae.httpclient; - -import java.io.Closeable; -import java.io.IOException; -import java.util.Collections; -import javax.ws.rs.client.Entity; -import javax.ws.rs.core.Response.Status; -import org.onap.policy.clamp.controlloop.common.exception.ControlLoopRuntimeException; -import org.onap.policy.clamp.controlloop.participant.dcae.model.Loop; -import org.onap.policy.common.endpoints.event.comm.bus.internal.BusTopicParams; -import org.onap.policy.common.endpoints.http.client.HttpClient; -import org.onap.policy.common.endpoints.http.client.HttpClientFactoryInstance; -import org.onap.policy.common.utils.coder.Coder; -import org.onap.policy.common.utils.coder.StandardCoder; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -public abstract class AbstractHttpClient implements Closeable { - - private static final String MSG_REQUEST_FAILED = "request to {} failed"; - - private static final Logger LOGGER = LoggerFactory.getLogger(AbstractHttpClient.class); - private final HttpClient httpclient; - public static final Coder CODER = new StandardCoder(); - - /** - * Constructor. - * - * @param restClientParameters the REST client parameters - * @throws ControlLoopRuntimeException on errors - */ - protected AbstractHttpClient(BusTopicParams restClientParameters) { - try { - httpclient = HttpClientFactoryInstance.getClientFactory().build(restClientParameters); - } catch (final Exception e) { - throw new ControlLoopRuntimeException(Status.INTERNAL_SERVER_ERROR, - restClientParameters.getClientName() + " Client failed to start", e); - } - } - - protected boolean executePut(String path, String jsonEntity, int statusCode) { - try { - var response = httpclient.put(path, Entity.json(jsonEntity), Collections.emptyMap()); - return response.getStatus() == statusCode; - } catch (Exception e) { - LOGGER.error(MSG_REQUEST_FAILED, httpclient.getName(), e); - return false; - } - } - - protected boolean executePut(String path, int statusCode) { - try { - var response = httpclient.put(path, Entity.json(""), Collections.emptyMap()); - return response.getStatus() == statusCode; - } catch (Exception e) { - LOGGER.error(MSG_REQUEST_FAILED, httpclient.getName(), e); - return false; - } - } - - protected Loop executePost(String path, int statusCode) { - try { - var response = httpclient.post(path, Entity.json(""), Collections.emptyMap()); - if (response.getStatus() != statusCode) { - return null; - } - return response.readEntity(Loop.class); - } catch (Exception e) { - LOGGER.error(MSG_REQUEST_FAILED, httpclient.getName(), e); - return null; - } - } - - protected Loop executeGet(String path, int statusCode) { - try { - var response = httpclient.get(path); - - if (response.getStatus() != statusCode) { - return null; - } - return response.readEntity(Loop.class); - } catch (Exception e) { - LOGGER.error(MSG_REQUEST_FAILED, httpclient.getName(), e); - return null; - } - } - - @Override - public void close() throws IOException { - httpclient.shutdown(); - } -} diff --git a/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/httpclient/ClampHttpClient.java b/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/httpclient/ClampHttpClient.java deleted file mode 100644 index 3d8308bc1..000000000 --- a/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/httpclient/ClampHttpClient.java +++ /dev/null @@ -1,126 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2021 Nordix Foundation. - * ================================================================================ - * Modifications Copyright (C) 2021 AT&T Intellectual Property. All rights reserved. - * ================================================================================ - * 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. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.clamp.controlloop.participant.dcae.httpclient; - -import org.apache.http.HttpStatus; -import org.onap.policy.clamp.controlloop.participant.dcae.main.parameters.ClampEndPoints; -import org.onap.policy.clamp.controlloop.participant.dcae.main.parameters.ParticipantDcaeParameters; -import org.onap.policy.clamp.controlloop.participant.dcae.model.Loop; -import org.springframework.stereotype.Component; - -@Component -public class ClampHttpClient extends AbstractHttpClient { - - private final ClampEndPoints endPoints; - public static final String STATUS_NOT_FOUND = "STATUS_NOT_FOUND"; - public static final String POLICY_NOT_FOUND = "POLICY_NOT_FOUND"; - - /** - * Constructor. - * - * @param parameters the DCAE parameters - */ - public ClampHttpClient(ParticipantDcaeParameters parameters) { - super(parameters.getClampClientParameters()); - this.endPoints = parameters.getClampClientEndPoints(); - } - - /** - * Create. - * - * @param loopName the loopName - * @param templateName the templateName - * @return the Loop object or null if error occurred - */ - public Loop create(String loopName, String templateName) { - return executePost(String.format(endPoints.getCreate(), loopName, templateName), HttpStatus.SC_OK); - } - - /** - * Deploy. - * - * @param loopName the loopName - * @return true - */ - public boolean deploy(String loopName) { - return executePut(endPoints.getDeploy() + loopName, HttpStatus.SC_ACCEPTED); - } - - /** - * Get Status. - * - * @param loopName the loopName - * @return the Loop object or null if error occurred - */ - public Loop getstatus(String loopName) { - return executeGet(endPoints.getStatus() + loopName, HttpStatus.SC_OK); - } - - /** - * Undeploy. - * - * @param loopName the loopName - * @return true - */ - public boolean undeploy(String loopName) { - return executePut(endPoints.getUndeploy() + loopName, HttpStatus.SC_ACCEPTED); - } - - /** - * Stop. - * - * @param loopName the loopName - * @return true - */ - public boolean stop(String loopName) { - return executePut(endPoints.getStop() + loopName, HttpStatus.SC_OK); - } - - /** - * Delete. - * - * @param loopName the loopName - * @return true - */ - public boolean delete(String loopName) { - return executePut(endPoints.getDelete() + loopName, HttpStatus.SC_OK); - } - - /** - * return status from Loop object. - * - * @param loop Loop - * @return status - */ - public static String getStatusCode(Loop loop) { - if (loop == null || loop.getComponents() == null || loop.getComponents().isEmpty()) { - return STATUS_NOT_FOUND; - } - var externalComponent = loop.getComponents().get("DCAE"); - if (externalComponent == null || externalComponent.getComponentState() == null) { - return STATUS_NOT_FOUND; - } - - return externalComponent.getComponentState().getStateName(); - } -} diff --git a/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/httpclient/ConsulDcaeHttpClient.java b/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/httpclient/ConsulDcaeHttpClient.java deleted file mode 100644 index 4cdcf7c7f..000000000 --- a/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/httpclient/ConsulDcaeHttpClient.java +++ /dev/null @@ -1,53 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2021 Nordix Foundation. - * ================================================================================ - * 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. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.clamp.controlloop.participant.dcae.httpclient; - -import org.apache.http.HttpStatus; -import org.onap.policy.clamp.controlloop.participant.dcae.main.parameters.ConsulEndPoints; -import org.onap.policy.clamp.controlloop.participant.dcae.main.parameters.ParticipantDcaeParameters; -import org.springframework.stereotype.Component; - -@Component -public class ConsulDcaeHttpClient extends AbstractHttpClient { - - private final ConsulEndPoints endPoints; - - /** - * Constructor. - * - * @param parameters the DCAE parameters - */ - public ConsulDcaeHttpClient(ParticipantDcaeParameters parameters) { - super(parameters.getConsulClientParameters()); - this.endPoints = parameters.getConsulClientEndPoints(); - } - - /** - * Call deploy consult. - * - * @param name the name to deploy - * @param jsonEntity the Entity - * @return true - */ - public boolean deploy(String name, String jsonEntity) { - return executePut(endPoints.getDeploy() + name, jsonEntity, HttpStatus.SC_OK); - } -} diff --git a/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/main/handler/ControlLoopElementHandler.java b/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/main/handler/ControlLoopElementHandler.java deleted file mode 100644 index ca763f119..000000000 --- a/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/main/handler/ControlLoopElementHandler.java +++ /dev/null @@ -1,207 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2021 Nordix Foundation. - * ================================================================================ - * Modifications Copyright (C) 2021 AT&T Intellectual Property. All rights reserved. - * ================================================================================ - * 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. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.clamp.controlloop.participant.dcae.main.handler; - -import java.time.Instant; -import java.util.UUID; -import java.util.concurrent.TimeUnit; -import lombok.Setter; -import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ClElementStatistics; -import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ControlLoopElement; -import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ControlLoopOrderedState; -import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ControlLoopState; -import org.onap.policy.clamp.controlloop.models.messages.dmaap.participant.ParticipantMessageType; -import org.onap.policy.clamp.controlloop.participant.dcae.httpclient.ClampHttpClient; -import org.onap.policy.clamp.controlloop.participant.dcae.httpclient.ConsulDcaeHttpClient; -import org.onap.policy.clamp.controlloop.participant.dcae.main.parameters.ParticipantDcaeParameters; -import org.onap.policy.clamp.controlloop.participant.dcae.model.Loop; -import org.onap.policy.clamp.controlloop.participant.intermediary.api.ControlLoopElementListener; -import org.onap.policy.clamp.controlloop.participant.intermediary.api.ParticipantIntermediaryApi; -import org.onap.policy.common.utils.resources.ResourceUtils; -import org.onap.policy.models.base.PfModelException; -import org.onap.policy.models.tosca.authorative.concepts.ToscaConceptIdentifier; -import org.onap.policy.models.tosca.authorative.concepts.ToscaNodeTemplate; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; -import org.springframework.stereotype.Component; - -/** - * This class handles implementation of controlLoopElement updates. - */ -@Component -public class ControlLoopElementHandler implements ControlLoopElementListener { - - private static final Logger LOGGER = LoggerFactory.getLogger(ControlLoopElementHandler.class); - private final ClampHttpClient clampClient; - private final ConsulDcaeHttpClient consulClient; - - @Setter - private ParticipantIntermediaryApi intermediaryApi; - - private static final String LOOP = "pmsh_loop"; - private static final String TEMPLATE = "LOOP_TEMPLATE_k8s_pmsh"; - private static final String POLICY = "policy"; - - private static final String BLUEPRINT_DEPLOYED = "BLUEPRINT_DEPLOYED"; - private static final String MICROSERVICE_INSTALLED_SUCCESSFULLY = "MICROSERVICE_INSTALLED_SUCCESSFULLY"; - - private int checkCount; - private int secCount; - - private String bodyConsul; - - /** - * Constructor. - * - * @param clampClient the CLAMP client - * @param consulClient the Consul client - */ - public ControlLoopElementHandler(ClampHttpClient clampClient, ConsulDcaeHttpClient consulClient, - ParticipantDcaeParameters parameters) { - this.clampClient = clampClient; - this.consulClient = consulClient; - this.checkCount = parameters.getCheckCount(); - this.secCount = parameters.getSecCount(); - bodyConsul = ResourceUtils.getResourceAsString(parameters.getJsonBodyConsulPath()); - } - - /** - * Callback method to handle a control loop element state change. - * - * @param controlLoopElementId the ID of the control loop element - * @param currentState the current state of the control loop element - * @param newState the state to which the control loop element is changing to - */ - @Override - public void controlLoopElementStateChange(ToscaConceptIdentifier controlLoopId, - UUID controlLoopElementId, ControlLoopState currentState, - ControlLoopOrderedState newState) { - switch (newState) { - case UNINITIALISED: - var loop = clampClient.getstatus(LOOP); - if (loop != null) { - clampClient.undeploy(LOOP); - intermediaryApi.updateControlLoopElementState(controlLoopId, - controlLoopElementId, newState, - ControlLoopState.UNINITIALISED, ParticipantMessageType.CONTROL_LOOP_STATE_CHANGE); - } - break; - case PASSIVE: - intermediaryApi.updateControlLoopElementState(controlLoopId, - controlLoopElementId, newState, ControlLoopState.PASSIVE, - ParticipantMessageType.CONTROL_LOOP_STATE_CHANGE); - break; - case RUNNING: - intermediaryApi.updateControlLoopElementState(controlLoopId, - controlLoopElementId, newState, ControlLoopState.RUNNING, - ParticipantMessageType.CONTROL_LOOP_STATE_CHANGE); - break; - default: - LOGGER.debug("Unknown orderedstate {}", newState); - break; - } - } - - private Loop getStatus() throws PfModelException { - var loop = clampClient.getstatus(LOOP); - if (loop == null) { - loop = clampClient.create(LOOP, TEMPLATE); - } - if (loop == null) { - throw new PfModelException(null, ""); - } - return loop; - } - - private void deploy() throws PfModelException { - if (!consulClient.deploy(POLICY, bodyConsul)) { - throw new PfModelException(null, "deploy to consul failed"); - } - if (!clampClient.deploy(LOOP)) { - throw new PfModelException(null, "deploy failed"); - } - } - - /** - * Callback method to handle an update on a control loop element. - * - * @param element the information on the control loop element - * @param nodeTemplate toscaNodeTemplate - * @throws PfModelException in case of an exception - */ - @Override - public void controlLoopElementUpdate(ToscaConceptIdentifier controlLoopId, - ControlLoopElement element, ToscaNodeTemplate nodeTemplate) - throws PfModelException { - try { - var loop = getStatus(); - - if (BLUEPRINT_DEPLOYED.equals(ClampHttpClient.getStatusCode(loop))) { - deploy(); - var deployedFlag = false; - for (var i = 0; i < checkCount; i++) { - // sleep 10 seconds - TimeUnit.SECONDS.sleep(secCount); - loop = getStatus(); - String status = ClampHttpClient.getStatusCode(loop); - if (MICROSERVICE_INSTALLED_SUCCESSFULLY.equals(status)) { - intermediaryApi.updateControlLoopElementState(controlLoopId, element.getId(), - element.getOrderedState(), ControlLoopState.PASSIVE, - ParticipantMessageType.CONTROL_LOOP_UPDATE); - deployedFlag = true; - break; - } - } - if (!deployedFlag) { - LOGGER.warn("DCAE is not deployed properly, ClElement state will be UNINITIALISED2PASSIVE"); - intermediaryApi.updateControlLoopElementState(controlLoopId, element.getId(), - element.getOrderedState(), ControlLoopState.UNINITIALISED2PASSIVE, - ParticipantMessageType.CONTROL_LOOP_UPDATE); - } - } - } catch (PfModelException e) { - throw e; - } catch (InterruptedException e) { - Thread.currentThread().interrupt(); - throw new PfModelException(null, e.getMessage(), e); - } catch (Exception e) { - throw new PfModelException(null, e.getMessage(), e); - } - } - - /** - * Handle controlLoopElement statistics. - * - * @param controlLoopElementId controlloop element id - */ - @Override - public void handleStatistics(UUID controlLoopElementId) { - var clElement = intermediaryApi.getControlLoopElement(controlLoopElementId); - if (clElement != null) { - var clElementStatistics = new ClElementStatistics(); - clElementStatistics.setControlLoopState(clElement.getState()); - clElementStatistics.setTimeStamp(Instant.now()); - intermediaryApi.updateControlLoopElementStatistics(controlLoopElementId, clElementStatistics); - } - } -} diff --git a/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/main/parameters/ClampEndPoints.java b/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/main/parameters/ClampEndPoints.java deleted file mode 100644 index 12b67ebda..000000000 --- a/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/main/parameters/ClampEndPoints.java +++ /dev/null @@ -1,55 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2021 Nordix Foundation. - * ================================================================================ - * 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. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.clamp.controlloop.participant.dcae.main.parameters; - -import javax.validation.constraints.NotBlank; -import lombok.Getter; -import lombok.Setter; -import org.springframework.validation.annotation.Validated; - -/** - * Class to hold all end points needed for clamp client. - * - */ -@Validated -@Getter -@Setter -public class ClampEndPoints { - - @NotBlank - private String status; - - @NotBlank - private String create; - - @NotBlank - private String deploy; - - @NotBlank - private String stop; - - @NotBlank - private String delete; - - @NotBlank - private String undeploy; - -} diff --git a/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/main/parameters/ConsulEndPoints.java b/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/main/parameters/ConsulEndPoints.java deleted file mode 100644 index ffbfa409c..000000000 --- a/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/main/parameters/ConsulEndPoints.java +++ /dev/null @@ -1,39 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2021 Nordix Foundation. - * ================================================================================ - * 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. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.clamp.controlloop.participant.dcae.main.parameters; - -import javax.validation.constraints.NotBlank; -import lombok.Getter; -import lombok.Setter; -import org.springframework.validation.annotation.Validated; - -/** - * Class to hold all end points needed for consul client. - * - */ -@Validated -@Getter -@Setter -public class ConsulEndPoints { - - @NotBlank - private String deploy; -} diff --git a/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/main/parameters/ParticipantDcaeParameters.java b/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/main/parameters/ParticipantDcaeParameters.java deleted file mode 100644 index 1ef9e2fdd..000000000 --- a/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/main/parameters/ParticipantDcaeParameters.java +++ /dev/null @@ -1,76 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2021 Nordix Foundation. - * ================================================================================ - * 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. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.clamp.controlloop.participant.dcae.main.parameters; - -import javax.validation.Valid; -import javax.validation.constraints.Min; -import javax.validation.constraints.NotBlank; -import javax.validation.constraints.NotNull; -import lombok.Getter; -import lombok.Setter; -import org.onap.policy.clamp.controlloop.participant.intermediary.parameters.ParticipantIntermediaryParameters; -import org.onap.policy.clamp.controlloop.participant.intermediary.parameters.ParticipantParameters; -import org.onap.policy.common.endpoints.parameters.RestClientParameters; -import org.onap.policy.common.parameters.validation.ParameterGroupConstraint; -import org.springframework.boot.context.properties.ConfigurationProperties; -import org.springframework.validation.annotation.Validated; - -/** - * Class to hold all parameters needed for the participant dcae. - * - */ -@Validated -@Getter -@Setter -@ConfigurationProperties(prefix = "participant") -public class ParticipantDcaeParameters implements ParticipantParameters { - - @NotNull - @Min(10) - private int checkCount = 10; - - @NotNull - @Min(1) - private int secCount = 10; - - @NotBlank - private String jsonBodyConsulPath; - - @NotNull - @Valid - private ClampEndPoints clampClientEndPoints; - - @NotNull - @Valid - private ConsulEndPoints consulClientEndPoints; - - @NotNull - @ParameterGroupConstraint - private RestClientParameters clampClientParameters; - - @NotNull - @ParameterGroupConstraint - private RestClientParameters consulClientParameters; - - @NotNull - @Valid - private ParticipantIntermediaryParameters intermediaryParameters; -} diff --git a/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/model/ExternalComponent.java b/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/model/ExternalComponent.java deleted file mode 100644 index 01a514f43..000000000 --- a/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/model/ExternalComponent.java +++ /dev/null @@ -1,35 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2021 Nordix Foundation. - * ================================================================================ - * 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. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.clamp.controlloop.participant.dcae.model; - -import java.io.Serializable; -import lombok.Getter; -import lombok.Setter; - -@Getter -@Setter -public class ExternalComponent implements Serializable { - - private static final long serialVersionUID = -10; - - private ExternalComponentState componentState; - -} diff --git a/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/model/ExternalComponentState.java b/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/model/ExternalComponentState.java deleted file mode 100644 index da7360a9b..000000000 --- a/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/model/ExternalComponentState.java +++ /dev/null @@ -1,34 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2021 Nordix Foundation. - * ================================================================================ - * 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. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.clamp.controlloop.participant.dcae.model; - -import java.io.Serializable; -import lombok.Getter; -import lombok.Setter; - -@Getter -@Setter -public class ExternalComponentState implements Serializable { - - private static final long serialVersionUID = -10; - - private String stateName; -} diff --git a/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/model/Loop.java b/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/model/Loop.java deleted file mode 100644 index d84270500..000000000 --- a/participant/participant-impl/participant-impl-dcae/src/main/java/org/onap/policy/clamp/controlloop/participant/dcae/model/Loop.java +++ /dev/null @@ -1,36 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2021 Nordix Foundation. - * ================================================================================ - * 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. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.clamp.controlloop.participant.dcae.model; - -import java.io.Serializable; -import java.util.HashMap; -import java.util.Map; -import lombok.Getter; -import lombok.Setter; - -@Getter -@Setter -public class Loop implements Serializable { - - private static final long serialVersionUID = -10; - - private Map<String, ExternalComponent> components = new HashMap<>(); -} diff --git a/participant/participant-impl/participant-impl-dcae/src/main/resources/config/application.yaml b/participant/participant-impl/participant-impl-dcae/src/main/resources/config/application.yaml deleted file mode 100644 index a873f76b3..000000000 --- a/participant/participant-impl/participant-impl-dcae/src/main/resources/config/application.yaml +++ /dev/null @@ -1,57 +0,0 @@ -server: - port: 8081 - -participant: - name: ControlLoopParticipantDcae - clampClientEndPoints: - status: /restservices/clds/v2/loop/getstatus/ - create: /restservices/clds/v2/loop/create/%s?templateName=%s - deploy: /restservices/clds/v2/loop/deploy/ - stop: /restservices/clds/v2/loop/stop/ - delete: /restservices/clds/v2/loop/delete/ - undeploy: /restservices/clds/v2/loop/undeploy/ - clampClientParameters: - clientName: Clamp - hostname: 0.0.0.0 - port: 8443 - userName: admin - password: password - https: true - aaf: false - consulClientEndPoints: - deploy: "/v1/kv/dcae-pmsh:" - consulClientParameters: - clientName: Consul - hostname: consul - port: 31321 - userName: admin - password: password - https: false - aaf: false - intermediaryParameters: - name: Participant parameters - reportingTimeIntervalMs: 120000 - description: Participant Description - participantId: - name: DCAEParticipant0 - version: 1.0.0 - participantType: - name: org.onap.dcae.controlloop.DCAEMicroserviceControlLoopParticipant - version: 2.3.4 - clampControlLoopTopics: - topicSources: - - - topic: POLICY-CLRUNTIME-PARTICIPANT - servers: - - ${topicServer:localhost} - topicCommInfrastructure: dmaap - fetchTimeout: 15000 - topicSinks: - - - topic: POLICY-CLRUNTIME-PARTICIPANT - servers: - - ${topicServer:localhost} - topicCommInfrastructure: dmaap - checkCount: 10 - secCount: 10 - jsonBodyConsulPath: src/main/resources/parameters/consul.json diff --git a/participant/participant-impl/participant-impl-dcae/src/main/resources/parameters/consul.json b/participant/participant-impl/participant-impl-dcae/src/main/resources/parameters/consul.json deleted file mode 100644 index 3aad78ee8..000000000 --- a/participant/participant-impl/participant-impl-dcae/src/main/resources/parameters/consul.json +++ /dev/null @@ -1,62 +0,0 @@ -{ - "subscription": { - "subscriptionName": "subscriptiona", - "administrativeState": "UNLOCKED", - "fileBasedGP": 15, - "fileLocation": "/pm/pm.xml", - "nfFilter": { - "nfNames": [ - "^pnf1.*" - ], - "modelInvariantIDs": [ - "5845y423-g654-6fju-po78-8n53154532k6", - "7129e420-d396-4efb-af02-6b83499b12f8" - ], - "modelVersionIDs": [ - "e80a6ae3-cafd-4d24-850d-e14c084a5ca9" - ] - }, - "measurementGroups": [ - { - "measurementGroup": { - "measurementTypes": [ - { - "measurementType": "countera" - }, - { - "measurementType": "counterb" - } - ], - "managedObjectDNsBasic": [ - { - "DN": "dna" - }, - { - "DN": "dnb" - } - ] - } - }, - { - "measurementGroup": { - "measurementTypes": [ - { - "measurementType": "counterc" - }, - { - "measurementType": "counterd" - } - ], - "managedObjectDNsBasic": [ - { - "DN": "dnc" - }, - { - "DN": "dnd" - } - ] - } - } - ] - } -} diff --git a/participant/participant-impl/participant-impl-dcae/src/main/resources/version.txt b/participant/participant-impl/participant-impl-dcae/src/main/resources/version.txt deleted file mode 100644 index dbd67585f..000000000 --- a/participant/participant-impl/participant-impl-dcae/src/main/resources/version.txt +++ /dev/null @@ -1,4 +0,0 @@ -ONAP Tosca defined control loop Participant -Version: ${project.version} -Built (UTC): ${maven.build.timestamp} -ONAP https://wiki.onap.org diff --git a/participant/participant-impl/participant-impl-dcae/src/test/java/org/onap/policy/clamp/controlloop/participant/dcae/endtoend/ParticipantDcaeTest.java b/participant/participant-impl/participant-impl-dcae/src/test/java/org/onap/policy/clamp/controlloop/participant/dcae/endtoend/ParticipantDcaeTest.java deleted file mode 100644 index 6e7f28735..000000000 --- a/participant/participant-impl/participant-impl-dcae/src/test/java/org/onap/policy/clamp/controlloop/participant/dcae/endtoend/ParticipantDcaeTest.java +++ /dev/null @@ -1,181 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2021 Nordix Foundation. - * ================================================================================ - * 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. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.clamp.controlloop.participant.dcae.endtoend; - -import static org.assertj.core.api.Assertions.assertThat; -import static org.junit.jupiter.api.Assertions.assertEquals; -import static org.junit.jupiter.api.Assertions.assertNotEquals; -import static org.mockserver.model.HttpRequest.request; -import static org.mockserver.model.HttpResponse.response; - -import org.junit.jupiter.api.AfterAll; -import org.junit.jupiter.api.BeforeAll; -import org.junit.jupiter.api.Test; -import org.junit.jupiter.api.extension.ExtendWith; -import org.mockserver.integration.ClientAndServer; -import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ControlLoopOrderedState; -import org.onap.policy.clamp.controlloop.models.messages.dmaap.participant.ControlLoopStateChange; -import org.onap.policy.clamp.controlloop.models.messages.dmaap.participant.ControlLoopUpdate; -import org.onap.policy.clamp.controlloop.models.messages.dmaap.participant.ParticipantUpdate; -import org.onap.policy.clamp.controlloop.participant.dcae.main.parameters.CommonTestData; -import org.onap.policy.clamp.controlloop.participant.dcae.main.rest.TestListenerUtils; -import org.onap.policy.clamp.controlloop.participant.intermediary.comm.ControlLoopStateChangeListener; -import org.onap.policy.clamp.controlloop.participant.intermediary.comm.ControlLoopUpdateListener; -import org.onap.policy.clamp.controlloop.participant.intermediary.comm.ParticipantUpdateListener; -import org.onap.policy.clamp.controlloop.participant.intermediary.handler.ParticipantHandler; -import org.onap.policy.common.endpoints.event.comm.Topic.CommInfrastructure; -import org.onap.policy.common.utils.coder.CoderException; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.boot.test.context.SpringBootTest; -import org.springframework.boot.test.context.SpringBootTest.WebEnvironment; -import org.springframework.test.context.TestPropertySource; -import org.springframework.test.context.junit.jupiter.SpringExtension; - -@ExtendWith(SpringExtension.class) -@SpringBootTest(webEnvironment = WebEnvironment.RANDOM_PORT) -@TestPropertySource(locations = {"classpath:application_test.properties"}) -class ParticipantDcaeTest { - - private static final CommInfrastructure INFRA = CommInfrastructure.NOOP; - private static final String TOPIC = "my-topic"; - private static final Object lockit = new Object(); - - private static final String LOOP = "pmsh_loop"; - private static final String BLUEPRINT_DEPLOYED = "BLUEPRINT_DEPLOYED"; - - private static ClientAndServer mockClampServer; - private static ClientAndServer mockConsulServer; - - @Autowired - private ParticipantHandler participantHandler; - - /** - * start Servers. - */ - @BeforeAll - public void startServers() { - - // Clamp - mockClampServer = ClientAndServer.startClientAndServer(8443); - - mockClampServer.when(request().withMethod("GET").withPath("/restservices/clds/v2/loop/getstatus/" + LOOP)) - .respond(response().withBody(CommonTestData.createJsonStatus(BLUEPRINT_DEPLOYED).toString()) - .withStatusCode(200)); - - mockClampServer.when(request().withMethod("PUT").withPath("/restservices/clds/v2/loop/deploy/" + LOOP)) - .respond(response().withStatusCode(202)); - - mockClampServer.when(request().withMethod("PUT").withPath("/restservices/clds/v2/loop/undeploy/" + LOOP)) - .respond(response().withStatusCode(202)); - - // Consul - mockConsulServer = ClientAndServer.startClientAndServer(31321); - - mockConsulServer.when(request().withMethod("PUT").withPath("/v1/kv/dcae-pmsh:policy")) - .respond(response().withStatusCode(200)); - ParticipantUpdate participantUpdateMsg = TestListenerUtils.createParticipantUpdateMsg(); - - synchronized (lockit) { - ParticipantUpdateListener participantUpdateListener = new ParticipantUpdateListener(participantHandler); - participantUpdateListener.onTopicEvent(INFRA, TOPIC, null, participantUpdateMsg); - } - } - - /** - * stop Server. - */ - @AfterAll - public static void stopServer() { - mockClampServer.stop(); - mockClampServer = null; - - mockConsulServer.stop(); - mockConsulServer = null; - } - - @Test - void testControlLoopStateChangeMessageListener() { - ControlLoopStateChange controlLoopStateChangeMsg = - TestListenerUtils.createControlLoopStateChangeMsg(ControlLoopOrderedState.UNINITIALISED); - controlLoopStateChangeMsg.setOrderedState(ControlLoopOrderedState.PASSIVE); - - ControlLoopStateChangeListener clStateChangeListener = new ControlLoopStateChangeListener(participantHandler); - - clStateChangeListener.onTopicEvent(INFRA, TOPIC, null, controlLoopStateChangeMsg); - assertEquals(ControlLoopOrderedState.PASSIVE, controlLoopStateChangeMsg.getOrderedState()); - - controlLoopStateChangeMsg.setOrderedState(ControlLoopOrderedState.RUNNING); - clStateChangeListener.onTopicEvent(INFRA, TOPIC, null, controlLoopStateChangeMsg); - assertEquals(ControlLoopOrderedState.RUNNING, controlLoopStateChangeMsg.getOrderedState()); - - controlLoopStateChangeMsg.setOrderedState(ControlLoopOrderedState.RUNNING); - clStateChangeListener.onTopicEvent(INFRA, TOPIC, null, controlLoopStateChangeMsg); - assertEquals(ControlLoopOrderedState.RUNNING, controlLoopStateChangeMsg.getOrderedState()); - } - - @Test - void testControlLoopUpdateListener_ParticipantIdNoMatch() throws CoderException { - ControlLoopUpdate controlLoopUpdateMsg = TestListenerUtils.createControlLoopUpdateMsg(); - controlLoopUpdateMsg.getParticipantId().setName("DummyName"); - - ControlLoopUpdateListener clUpdateListener = new ControlLoopUpdateListener(participantHandler); - clUpdateListener.onTopicEvent(INFRA, TOPIC, null, controlLoopUpdateMsg); - - // Verify the content in participantHandler - assertNotEquals(controlLoopUpdateMsg.getParticipantId().getName(), - participantHandler.getParticipantId().getName()); - } - - @Test - void testControlLoopUpdateListenerPassive() throws CoderException { - ControlLoopUpdate controlLoopUpdateMsg = TestListenerUtils.createControlLoopUpdateMsg(); - - ControlLoopUpdateListener clUpdateListener = new ControlLoopUpdateListener(participantHandler); - clUpdateListener.onTopicEvent(INFRA, TOPIC, null, controlLoopUpdateMsg); - - // Verify the content in participantHandler - assertEquals(participantHandler.getParticipantId(), controlLoopUpdateMsg.getParticipantId()); - assertEquals(1, participantHandler.getControlLoopHandler().getControlLoops().getControlLoopList().size()); - } - - @Test - void testControlLoopUpdateListenerUninitialised() throws CoderException { - ControlLoopUpdate controlLoopUpdateMsg = TestListenerUtils.createControlLoopUpdateMsg(); - - ControlLoopUpdateListener clUpdateListener = new ControlLoopUpdateListener(participantHandler); - clUpdateListener.onTopicEvent(INFRA, TOPIC, null, controlLoopUpdateMsg); - - // Verify the content in participantHandler - assertEquals(participantHandler.getParticipantId(), controlLoopUpdateMsg.getParticipantId()); - assertEquals(1, participantHandler.getControlLoopHandler().getControlLoops().getControlLoopList().size()); - } - - @Test - void testControlLoopUpdateListenerString() throws CoderException { - ControlLoopUpdate controlLoopUpdateMsg = TestListenerUtils.createControlLoopUpdateMsg(); - - assertThat(controlLoopUpdateMsg.toString()).contains("state=UNINITIALISED"); - ControlLoopUpdate copyControlLoopUpdateMsg = - TestListenerUtils.createCopyControlLoopUpdateMsg(controlLoopUpdateMsg); - assertThat(copyControlLoopUpdateMsg.toString()).contains("state=UNINITIALISED"); - assertNotEquals(controlLoopUpdateMsg, copyControlLoopUpdateMsg); - } -} diff --git a/participant/participant-impl/participant-impl-dcae/src/test/java/org/onap/policy/clamp/controlloop/participant/dcae/httpclient/ClampHttpClientTest.java b/participant/participant-impl/participant-impl-dcae/src/test/java/org/onap/policy/clamp/controlloop/participant/dcae/httpclient/ClampHttpClientTest.java deleted file mode 100644 index f3aa17655..000000000 --- a/participant/participant-impl/participant-impl-dcae/src/test/java/org/onap/policy/clamp/controlloop/participant/dcae/httpclient/ClampHttpClientTest.java +++ /dev/null @@ -1,165 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2021 Nordix Foundation. - * ================================================================================ - * 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. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.clamp.controlloop.participant.dcae.httpclient; - -import static org.assertj.core.api.Assertions.assertThat; -import static org.assertj.core.api.Assertions.fail; -import static org.junit.Assert.assertFalse; -import static org.junit.Assert.assertTrue; -import static org.mockserver.model.HttpRequest.request; -import static org.mockserver.model.HttpResponse.response; - -import javax.ws.rs.core.MediaType; -import org.junit.jupiter.api.AfterAll; -import org.junit.jupiter.api.BeforeAll; -import org.junit.jupiter.api.Test; -import org.junit.jupiter.api.extension.ExtendWith; -import org.mockserver.integration.ClientAndServer; -import org.onap.policy.clamp.controlloop.participant.dcae.main.parameters.CommonTestData; -import org.onap.policy.clamp.controlloop.participant.dcae.main.parameters.ParticipantDcaeParameters; -import org.onap.policy.clamp.controlloop.participant.dcae.model.Loop; -import org.onap.policy.common.utils.coder.Coder; -import org.onap.policy.common.utils.coder.StandardCoder; -import org.springframework.test.context.junit.jupiter.SpringExtension; - -/** - * Class to perform unit test of {@link ClampHttpClient}. - * - */ -@ExtendWith(SpringExtension.class) -class ClampHttpClientTest { - - private static final String LOOP = "pmsh_loop"; - private static final String BLUEPRINT_DEPLOYED = "BLUEPRINT_DEPLOYED"; - - private static ClientAndServer mockServer; - private static ParticipantDcaeParameters parameters; - public static final Coder CODER = new StandardCoder(); - - /** - * Set up. - */ - @BeforeAll - public static void setUp() { - CommonTestData commonTestData = new CommonTestData(); - - parameters = commonTestData.getParticipantDcaeParameters(); - - mockServer = ClientAndServer.startClientAndServer(parameters.getClampClientParameters().getPort()); - - mockServer.when(request().withMethod("GET").withPath("/restservices/clds/v2/loop/getstatus/" + LOOP)) - .respond(response().withBody(CommonTestData.createJsonStatus(BLUEPRINT_DEPLOYED)).withStatusCode(200) - .withHeader("Content-Type", MediaType.APPLICATION_JSON)); - - mockServer.when(request().withMethod("PUT").withPath("/restservices/clds/v2/loop/deploy/" + LOOP)) - .respond(response().withStatusCode(202)); - - mockServer.when(request().withMethod("PUT").withPath("/restservices/clds/v2/loop/undeploy/" + LOOP)) - .respond(response().withStatusCode(202)); - } - - @AfterAll - public static void stopServer() { - mockServer.stop(); - mockServer = null; - } - - @Test - void test_getstatus() throws Exception { - try (ClampHttpClient client = new ClampHttpClient(parameters)) { - - Loop status = client.getstatus(LOOP); - - String json = CommonTestData.createJsonStatus(BLUEPRINT_DEPLOYED); - Loop loop = CODER.convert(json, Loop.class); - - assertThat(ClampHttpClient.getStatusCode(status)).isEqualTo(ClampHttpClient.getStatusCode(loop)); - - } catch (Exception e) { - fail(e.getMessage()); - } - } - - @Test - void test_create() throws Exception { - try (ClampHttpClient client = new ClampHttpClient(parameters)) { - - assertThat(client.create(LOOP, null)).isNull(); - - } catch (Exception e) { - fail(e.getMessage()); - } - } - - @Test - void test_deploy() throws Exception { - try (ClampHttpClient client = new ClampHttpClient(parameters)) { - - assertTrue(client.deploy(LOOP)); - - } catch (Exception e) { - fail(e.getMessage()); - } - } - - @Test - void test_undeploy() throws Exception { - try (ClampHttpClient client = new ClampHttpClient(parameters)) { - - assertTrue(client.undeploy(LOOP)); - - } catch (Exception e) { - fail(e.getMessage()); - } - } - - @Test - void test_getStatusCodeNull() { - assertThat(ClampHttpClient.getStatusCode(null)).isEqualTo(ClampHttpClient.STATUS_NOT_FOUND); - } - - @Test - void test_getStatusEmptyMap() { - assertThat(ClampHttpClient.getStatusCode(new Loop())).isEqualTo(ClampHttpClient.STATUS_NOT_FOUND); - } - - @Test - void test_stop() throws Exception { - try (ClampHttpClient client = new ClampHttpClient(parameters)) { - - assertFalse(client.stop(LOOP)); - - } catch (Exception e) { - fail(e.getMessage()); - } - } - - @Test - void test_delete() throws Exception { - try (ClampHttpClient client = new ClampHttpClient(parameters)) { - - assertFalse(client.delete(LOOP)); - - } catch (Exception e) { - fail(e.getMessage()); - } - } -} diff --git a/participant/participant-impl/participant-impl-dcae/src/test/java/org/onap/policy/clamp/controlloop/participant/dcae/httpclient/ConsulDcaeHttpClientTest.java b/participant/participant-impl/participant-impl-dcae/src/test/java/org/onap/policy/clamp/controlloop/participant/dcae/httpclient/ConsulDcaeHttpClientTest.java deleted file mode 100644 index 5155fed1d..000000000 --- a/participant/participant-impl/participant-impl-dcae/src/test/java/org/onap/policy/clamp/controlloop/participant/dcae/httpclient/ConsulDcaeHttpClientTest.java +++ /dev/null @@ -1,75 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2021 Nordix Foundation. - * ================================================================================ - * 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. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.clamp.controlloop.participant.dcae.httpclient; - -import static org.junit.Assert.assertTrue; -import static org.mockserver.model.HttpRequest.request; -import static org.mockserver.model.HttpResponse.response; - -import org.assertj.core.api.Assertions; -import org.junit.jupiter.api.AfterAll; -import org.junit.jupiter.api.BeforeAll; -import org.junit.jupiter.api.Test; -import org.junit.jupiter.api.extension.ExtendWith; -import org.mockserver.integration.ClientAndServer; -import org.onap.policy.clamp.controlloop.participant.dcae.main.parameters.CommonTestData; -import org.onap.policy.clamp.controlloop.participant.dcae.main.parameters.ParticipantDcaeParameters; -import org.springframework.test.context.junit.jupiter.SpringExtension; - -/** - * Class to perform unit test of {@link ConsulDcaeHttpClient}. - * - */ -@ExtendWith(SpringExtension.class) -class ConsulDcaeHttpClientTest { - - private static ClientAndServer mockServer; - private static ParticipantDcaeParameters parameters; - - @BeforeAll - public static void startServer() { - CommonTestData commonTestData = new CommonTestData(); - - parameters = commonTestData.getParticipantDcaeParameters(); - - mockServer = ClientAndServer.startClientAndServer(parameters.getConsulClientParameters().getPort()); - - mockServer.when(request().withMethod("PUT").withPath("/v1/kv/dcae-pmsh:policy")) - .respond(response().withStatusCode(200)); - } - - @AfterAll - public static void stopServer() { - mockServer.stop(); - mockServer = null; - } - - @Test - void test_deploy() throws Exception { - try (ConsulDcaeHttpClient client = new ConsulDcaeHttpClient(parameters)) { - - assertTrue(client.deploy("policy", "")); - - } catch (Exception e) { - Assertions.fail(e.getMessage()); - } - } -} diff --git a/participant/participant-impl/participant-impl-dcae/src/test/java/org/onap/policy/clamp/controlloop/participant/dcae/main/handler/ControlLoopElementHandlerTest.java b/participant/participant-impl/participant-impl-dcae/src/test/java/org/onap/policy/clamp/controlloop/participant/dcae/main/handler/ControlLoopElementHandlerTest.java deleted file mode 100644 index 0b8d1b30f..000000000 --- a/participant/participant-impl/participant-impl-dcae/src/test/java/org/onap/policy/clamp/controlloop/participant/dcae/main/handler/ControlLoopElementHandlerTest.java +++ /dev/null @@ -1,179 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2021 Nordix Foundation. - * Modifications Copyright (C) 2021 AT&T Intellectual Property. All rights reserved. - * ================================================================================ - * 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. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.clamp.controlloop.participant.dcae.main.handler; - -import static org.assertj.core.api.Assertions.assertThat; -import static org.mockito.ArgumentMatchers.any; -import static org.mockito.Mockito.mock; -import static org.mockito.Mockito.spy; -import static org.mockito.Mockito.times; -import static org.mockito.Mockito.verify; -import static org.mockito.Mockito.when; - -import java.util.UUID; -import org.json.JSONException; -import org.junit.jupiter.api.BeforeAll; -import org.junit.jupiter.api.Test; -import org.junit.jupiter.api.extension.ExtendWith; -import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ControlLoopElement; -import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ControlLoopOrderedState; -import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ControlLoopState; -import org.onap.policy.clamp.controlloop.models.messages.dmaap.participant.ParticipantUpdate; -import org.onap.policy.clamp.controlloop.participant.dcae.httpclient.ClampHttpClient; -import org.onap.policy.clamp.controlloop.participant.dcae.httpclient.ConsulDcaeHttpClient; -import org.onap.policy.clamp.controlloop.participant.dcae.main.parameters.CommonTestData; -import org.onap.policy.clamp.controlloop.participant.dcae.main.rest.TestListenerUtils; -import org.onap.policy.clamp.controlloop.participant.dcae.model.Loop; -import org.onap.policy.clamp.controlloop.participant.intermediary.api.ParticipantIntermediaryApi; -import org.onap.policy.clamp.controlloop.participant.intermediary.comm.ParticipantUpdateListener; -import org.onap.policy.clamp.controlloop.participant.intermediary.handler.ParticipantHandler; -import org.onap.policy.common.endpoints.event.comm.Topic.CommInfrastructure; -import org.onap.policy.common.utils.coder.Coder; -import org.onap.policy.common.utils.coder.CoderException; -import org.onap.policy.common.utils.coder.StandardCoder; -import org.onap.policy.models.base.PfModelException; -import org.onap.policy.models.tosca.authorative.concepts.ToscaServiceTemplate; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.test.context.junit.jupiter.SpringExtension; - -/** - * Class to perform unit test of {@link ControlLoopElementHandler}. - * - */ -@ExtendWith(SpringExtension.class) -class ControlLoopElementHandlerTest { - - private static final String LOOP = "pmsh_loop"; - private static final String TEMPLATE = "LOOP_TEMPLATE_k8s_pmsh"; - private static final String BLUEPRINT_DEPLOYED = "BLUEPRINT_DEPLOYED"; - private static final String MICROSERVICE_INSTALLED_SUCCESSFULLY = "MICROSERVICE_INSTALLED_SUCCESSFULLY"; - - public static final Coder CODER = new StandardCoder(); - private static final Object lockit = new Object(); - private static final CommInfrastructure INFRA = CommInfrastructure.NOOP; - private static final String TOPIC = "my-topic"; - private CommonTestData commonTestData = new CommonTestData(); - - @Autowired - private ParticipantHandler participantHandler; - - /** - * Initial ParticipantUpdate message. - */ - @BeforeAll - public void sendParticipantUpdate() { - ParticipantUpdate participantUpdateMsg = TestListenerUtils.createParticipantUpdateMsg(); - - synchronized (lockit) { - ParticipantUpdateListener participantUpdateListener = new ParticipantUpdateListener(participantHandler); - participantUpdateListener.onTopicEvent(INFRA, TOPIC, null, participantUpdateMsg); - } - } - - @Test - void test_ControlLoopElementStateChange() { - ClampHttpClient clampClient = spy(mock(ClampHttpClient.class)); - ConsulDcaeHttpClient consulClient = mock(ConsulDcaeHttpClient.class); - ControlLoopElementHandler controlLoopElementHandler = - new ControlLoopElementHandler(clampClient, consulClient, commonTestData.getParticipantDcaeParameters()); - - when(clampClient.getstatus(LOOP)).thenReturn(new Loop()); - - ParticipantIntermediaryApi intermediaryApi = mock(ParticipantIntermediaryApi.class); - controlLoopElementHandler.setIntermediaryApi(intermediaryApi); - - UUID controlLoopElementId = UUID.randomUUID(); - controlLoopElementHandler.controlLoopElementStateChange(TestListenerUtils.getControlLoopId(), - controlLoopElementId, ControlLoopState.PASSIVE, - ControlLoopOrderedState.UNINITIALISED); - - verify(clampClient).undeploy(LOOP); - controlLoopElementHandler.handleStatistics(controlLoopElementId); - assertThat(intermediaryApi.getControlLoopElement(controlLoopElementId)).isNull(); - } - - @Test - void testCreate_ControlLoopElementUpdate() throws PfModelException, JSONException, CoderException { - ClampHttpClient clampClient = spy(mock(ClampHttpClient.class)); - Loop loopDeployed = CODER.convert(CommonTestData.createJsonStatus(BLUEPRINT_DEPLOYED), Loop.class); - when(clampClient.create(LOOP, TEMPLATE)).thenReturn(loopDeployed); - when(clampClient.deploy(LOOP)).thenReturn(true); - - Loop loopInstalled = - CODER.convert(CommonTestData.createJsonStatus(MICROSERVICE_INSTALLED_SUCCESSFULLY), Loop.class); - when(clampClient.getstatus(LOOP)).thenReturn(null, loopInstalled); - - ConsulDcaeHttpClient consulClient = spy(mock(ConsulDcaeHttpClient.class)); - when(consulClient.deploy(any(String.class), any(String.class))).thenReturn(true); - - ControlLoopElementHandler controlLoopElementHandler = - new ControlLoopElementHandler(clampClient, consulClient, commonTestData.getParticipantDcaeParameters()); - - ParticipantIntermediaryApi intermediaryApi = mock(ParticipantIntermediaryApi.class); - controlLoopElementHandler.setIntermediaryApi(intermediaryApi); - - ControlLoopElement element = new ControlLoopElement(); - element.setId(UUID.randomUUID()); - element.setOrderedState(ControlLoopOrderedState.PASSIVE); - - final ToscaServiceTemplate controlLoopDefinition = new ToscaServiceTemplate(); - controlLoopElementHandler.controlLoopElementUpdate(TestListenerUtils.getControlLoopId(), element, - controlLoopDefinition.getToscaTopologyTemplate().getNodeTemplates() - .get("org.onap.domain.pmsh.PMSH_DCAEMicroservice")); - - verify(clampClient).create(LOOP, TEMPLATE); - verify(consulClient).deploy(any(String.class), any(String.class)); - verify(clampClient).deploy(LOOP); - } - - @Test - void test_ControlLoopElementUpdate() throws PfModelException, JSONException, CoderException { - ClampHttpClient clampClient = spy(mock(ClampHttpClient.class)); - Loop loopDeployed = CODER.convert(CommonTestData.createJsonStatus(BLUEPRINT_DEPLOYED), Loop.class); - Loop loopInstalled = - CODER.convert(CommonTestData.createJsonStatus(MICROSERVICE_INSTALLED_SUCCESSFULLY), Loop.class); - when(clampClient.getstatus(LOOP)).thenReturn(loopDeployed, loopInstalled); - when(clampClient.deploy(LOOP)).thenReturn(true); - - ConsulDcaeHttpClient consulClient = spy(mock(ConsulDcaeHttpClient.class)); - when(consulClient.deploy(any(String.class), any(String.class))).thenReturn(true); - - ControlLoopElementHandler controlLoopElementHandler = - new ControlLoopElementHandler(clampClient, consulClient, commonTestData.getParticipantDcaeParameters()); - - ParticipantIntermediaryApi intermediaryApi = mock(ParticipantIntermediaryApi.class); - controlLoopElementHandler.setIntermediaryApi(intermediaryApi); - - ControlLoopElement element = new ControlLoopElement(); - element.setId(UUID.randomUUID()); - element.setOrderedState(ControlLoopOrderedState.PASSIVE); - - ToscaServiceTemplate controlLoopDefinition = new ToscaServiceTemplate(); - controlLoopElementHandler.controlLoopElementUpdate(TestListenerUtils.getControlLoopId(), element, - controlLoopDefinition.getToscaTopologyTemplate().getNodeTemplates() - .get("org.onap.domain.pmsh.PMSH_DCAEMicroservice")); - - verify(clampClient, times(0)).create(LOOP, TEMPLATE); - verify(consulClient).deploy(any(String.class), any(String.class)); - verify(clampClient).deploy(LOOP); - } -} diff --git a/participant/participant-impl/participant-impl-dcae/src/test/java/org/onap/policy/clamp/controlloop/participant/dcae/main/parameters/CommonTestData.java b/participant/participant-impl/participant-impl-dcae/src/test/java/org/onap/policy/clamp/controlloop/participant/dcae/main/parameters/CommonTestData.java deleted file mode 100644 index a28a6ece1..000000000 --- a/participant/participant-impl/participant-impl-dcae/src/test/java/org/onap/policy/clamp/controlloop/participant/dcae/main/parameters/CommonTestData.java +++ /dev/null @@ -1,253 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2021 Nordix Foundation. - * ================================================================================ - * 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. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.clamp.controlloop.participant.dcae.main.parameters; - -import java.io.File; -import java.io.IOException; -import java.nio.charset.StandardCharsets; -import java.nio.file.Files; -import java.util.Arrays; -import java.util.List; -import java.util.Map; -import java.util.TreeMap; -import javax.ws.rs.core.Response; -import org.onap.policy.clamp.controlloop.common.exception.ControlLoopRuntimeException; -import org.onap.policy.common.endpoints.parameters.TopicParameters; -import org.onap.policy.common.utils.coder.Coder; -import org.onap.policy.common.utils.coder.CoderException; -import org.onap.policy.common.utils.coder.StandardCoder; -import org.onap.policy.common.utils.network.NetworkUtil; -import org.onap.policy.models.tosca.authorative.concepts.ToscaConceptIdentifier; - -/** - * Class to hold/create all parameters for test cases. - */ -public class CommonTestData { - public static final String PARTICIPANT_GROUP_NAME = "ControlLoopParticipantGroup"; - public static final String DESCRIPTION = "Participant description"; - public static final long TIME_INTERVAL = 2000; - public static final List<TopicParameters> TOPIC_PARAMS = Arrays.asList(getTopicParams()); - private static final String REST_CLIENT_PASSWORD = "password"; - private static final String REST_CLIENT_USER = "admin"; - private static final String REST_CLAMP_HOST = "0.0.0.0"; - private static final String REST_CONSUL_HOST = "0.0.0.0"; - private static final boolean REST_CLAMP_HTTPS = false; - private static final boolean REST_CONSUL_HTTPS = false; - private static final boolean REST_CLIENT_AAF = false; - - public static final Coder CODER = new StandardCoder(); - - /** - * Get ParticipantDcaeParameters. - * - * @return ParticipantDcaeParameters - */ - public ParticipantDcaeParameters getParticipantDcaeParameters() { - try { - return CODER.convert(getParticipantParameterGroupMap(PARTICIPANT_GROUP_NAME), - ParticipantDcaeParameters.class); - } catch (final CoderException e) { - throw new RuntimeException("cannot create ParticipantDcaeParameters from map", e); - } - } - - /** - * Returns a property map for a ApexStarterParameterGroup map for test cases. - * - * @param name name of the parameters - * - * @return a property map suitable for constructing an object - */ - public Map<String, Object> getParticipantParameterGroupMap(final String name) { - final Map<String, Object> map = new TreeMap<>(); - - map.put("name", name); - map.put("checkCount", 10); - map.put("secCount", 10); - map.put("jsonBodyConsulPath", "src/main/resources/parameters/consul.json"); - map.put("clampClientParameters", getClampClientParametersMap(false)); - map.put("consulClientParameters", getConsulClientParametersMap(false)); - map.put("intermediaryParameters", getIntermediaryParametersMap(false)); - map.put("clampClientEndPoints", getClampClientEndPoints()); - map.put("consulClientEndPoints", getConsulClientEndPoints()); - return map; - } - - private Map<String, Object> getConsulClientEndPoints() { - final Map<String, Object> map = new TreeMap<>(); - map.put("deploy", "/v1/kv/dcae-pmsh:"); - return map; - } - - private Map<String, Object> getClampClientEndPoints() { - final Map<String, Object> map = new TreeMap<>(); - map.put("status", "/restservices/clds/v2/loop/getstatus/"); - map.put("create", "/restservices/clds/v2/loop/create/%s?templateName=%s"); - map.put("deploy", "/restservices/clds/v2/loop/deploy/"); - map.put("stop", "/restservices/clds/v2/loop/stop/"); - map.put("delete", "/restservices/clds/v2/loop/delete/"); - map.put("undeploy", "/restservices/clds/v2/loop/undeploy/"); - return map; - } - - /** - * Returns a property map for a RestServerParameters map for test cases. - * - * @param isEmpty boolean value to represent that object created should be empty or not - * @return a property map suitable for constructing an object - * @throws ControlLoopRuntimeException on errors - */ - public Map<String, Object> getClampClientParametersMap(final boolean isEmpty) { - final Map<String, Object> map = new TreeMap<>(); - map.put("clientName", "Clamp"); - map.put("https", REST_CLAMP_HTTPS); - map.put("aaf", REST_CLIENT_AAF); - - if (!isEmpty) { - map.put("hostname", REST_CLAMP_HOST); - try { - map.put("port", NetworkUtil.allocPort()); - } catch (IOException e) { - throw new ControlLoopRuntimeException(Response.Status.NOT_ACCEPTABLE, "not valid port", e); - } - map.put("userName", REST_CLIENT_USER); - map.put("password", REST_CLIENT_PASSWORD); - } - - return map; - } - - /** - * Returns a property map for a RestServerParameters map for test cases. - * - * @param isEmpty boolean value to represent that object created should be empty or not - * @return a property map suitable for constructing an object - * @throws ControlLoopRuntimeException on errors - */ - public Map<String, Object> getConsulClientParametersMap(final boolean isEmpty) { - final Map<String, Object> map = new TreeMap<>(); - map.put("clientName", "Consul"); - map.put("https", REST_CONSUL_HTTPS); - map.put("aaf", REST_CLIENT_AAF); - - if (!isEmpty) { - map.put("hostname", REST_CONSUL_HOST); - try { - map.put("port", NetworkUtil.allocPort()); - } catch (IOException e) { - throw new ControlLoopRuntimeException(Response.Status.NOT_ACCEPTABLE, "not valid port", e); - } - map.put("userName", REST_CLIENT_USER); - map.put("password", REST_CLIENT_PASSWORD); - } - - return map; - } - - /** - * Returns a property map for a intermediaryParameters map for test cases. - * - * @param isEmpty boolean value to represent that object created should be empty or not - * @return a property map suitable for constructing an object - */ - public Map<String, Object> getIntermediaryParametersMap(final boolean isEmpty) { - final Map<String, Object> map = new TreeMap<>(); - if (!isEmpty) { - map.put("name", "Participant parameters"); - map.put("reportingTimeIntervalMs", TIME_INTERVAL); - map.put("description", DESCRIPTION); - map.put("participantId", getParticipantId()); - map.put("participantType", getParticipantId()); - map.put("clampControlLoopTopics", getTopicParametersMap(false)); - } - - return map; - } - - /** - * Returns a property map for a TopicParameters map for test cases. - * - * @param isEmpty boolean value to represent that object created should be empty or not - * @return a property map suitable for constructing an object - */ - public Map<String, Object> getTopicParametersMap(final boolean isEmpty) { - final Map<String, Object> map = new TreeMap<>(); - if (!isEmpty) { - map.put("topicSources", TOPIC_PARAMS); - map.put("topicSinks", TOPIC_PARAMS); - } - return map; - } - - /** - * Returns topic parameters for test cases. - * - * @return topic parameters - */ - public static TopicParameters getTopicParams() { - final TopicParameters topicParams = new TopicParameters(); - topicParams.setTopic("POLICY-CLRUNTIME-PARTICIPANT"); - topicParams.setTopicCommInfrastructure("dmaap"); - topicParams.setServers(Arrays.asList("localhost")); - return topicParams; - } - - /** - * Returns participantId for test cases. - * - * @return participant Id - */ - public static ToscaConceptIdentifier getParticipantId() { - final ToscaConceptIdentifier participantId = new ToscaConceptIdentifier(); - participantId.setName("DCAEParticipant0"); - participantId.setVersion("1.0.0"); - return participantId; - } - - /** - * Nulls out a field within a JSON string. - * - * @param json JSON string - * @param field field to be nulled out - * @return a new JSON string with the field nulled out - */ - public String nullifyField(String json, String field) { - return json.replace(field + "\"", field + "\":null, \"" + field + "Xxx\""); - } - - /** - * Create Json response from getstatus call. - * - * @param status the status of Partecipant - * @return the JSON - * @throws ControlLoopRuntimeException on errors - */ - public static String createJsonStatus(String status) { - try { - File file = new File("src/test/resources/rest/status.json"); - String json = new String(Files.readAllBytes(file.toPath()), StandardCharsets.UTF_8); - return json.replace("${status}", status); - - } catch (IOException e) { - throw new ControlLoopRuntimeException(Response.Status.NOT_ACCEPTABLE, "cannot read json file", e); - } - } -} diff --git a/participant/participant-impl/participant-impl-dcae/src/test/java/org/onap/policy/clamp/controlloop/participant/dcae/main/parameters/ParticipantDcaeParametersTest.java b/participant/participant-impl/participant-impl-dcae/src/test/java/org/onap/policy/clamp/controlloop/participant/dcae/main/parameters/ParticipantDcaeParametersTest.java deleted file mode 100644 index b59cee756..000000000 --- a/participant/participant-impl/participant-impl-dcae/src/test/java/org/onap/policy/clamp/controlloop/participant/dcae/main/parameters/ParticipantDcaeParametersTest.java +++ /dev/null @@ -1,163 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2021 Nordix Foundation. - * ================================================================================ - * 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. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.clamp.controlloop.participant.dcae.main.parameters; - -import static org.assertj.core.api.Assertions.assertThat; - -import javax.validation.Validation; -import javax.validation.ValidatorFactory; -import org.junit.jupiter.api.Test; -import org.onap.policy.clamp.controlloop.common.exception.ControlLoopException; -import org.onap.policy.clamp.controlloop.participant.intermediary.parameters.ParticipantIntermediaryParameters; - -/** - * Class to perform unit test of {@link ParticipantDcaeParameters}. - * It will be tested the "javax.validation.constraints" - * - */ -class ParticipantDcaeParametersTest { - private CommonTestData commonTestData = new CommonTestData(); - private ValidatorFactory validatorFactory = Validation.buildDefaultValidatorFactory(); - - @Test - void testParticipantDcaeParameters() { - final ParticipantDcaeParameters participantParameters = commonTestData.getParticipantDcaeParameters(); - assertThat(validatorFactory.getValidator().validate(participantParameters)).isEmpty(); - } - - @Test - void testZeroCheckCount() { - final ParticipantDcaeParameters participantParameters = commonTestData.getParticipantDcaeParameters(); - participantParameters.setCheckCount(0); - assertThat(validatorFactory.getValidator().validate(participantParameters)).isNotEmpty(); - } - - @Test - void testNoClampClientEndPoints() { - final ParticipantDcaeParameters participantParameters = commonTestData.getParticipantDcaeParameters(); - participantParameters.setClampClientEndPoints(null); - assertThat(validatorFactory.getValidator().validate(participantParameters)).isNotEmpty(); - } - - @Test - void testNoClampClientEndPointCreate() { - final ParticipantDcaeParameters participantParameters = commonTestData.getParticipantDcaeParameters(); - participantParameters.getClampClientEndPoints().setCreate(null); - assertThat(validatorFactory.getValidator().validate(participantParameters)).isNotEmpty(); - } - - @Test - void testNoClampClientEndPointDelete() { - final ParticipantDcaeParameters participantParameters = commonTestData.getParticipantDcaeParameters(); - participantParameters.getClampClientEndPoints().setDelete(null); - assertThat(validatorFactory.getValidator().validate(participantParameters)).isNotEmpty(); - } - - @Test - void testNoClampClientEndPointDeploy() { - final ParticipantDcaeParameters participantParameters = commonTestData.getParticipantDcaeParameters(); - participantParameters.getClampClientEndPoints().setDeploy(null); - assertThat(validatorFactory.getValidator().validate(participantParameters)).isNotEmpty(); - } - - @Test - void testNoClampClientEndPointStatus() { - final ParticipantDcaeParameters participantParameters = commonTestData.getParticipantDcaeParameters(); - participantParameters.getClampClientEndPoints().setStatus(null); - assertThat(validatorFactory.getValidator().validate(participantParameters)).isNotEmpty(); - } - - @Test - void testNoClampClientEndPointStop() { - final ParticipantDcaeParameters participantParameters = commonTestData.getParticipantDcaeParameters(); - participantParameters.getClampClientEndPoints().setStop(null); - assertThat(validatorFactory.getValidator().validate(participantParameters)).isNotEmpty(); - } - - @Test - void testNoClampClientEndPointUndeploy() { - final ParticipantDcaeParameters participantParameters = commonTestData.getParticipantDcaeParameters(); - participantParameters.getClampClientEndPoints().setUndeploy(null); - assertThat(validatorFactory.getValidator().validate(participantParameters)).isNotEmpty(); - } - - @Test - void testNoClampClientParameters() { - final ParticipantDcaeParameters participantParameters = commonTestData.getParticipantDcaeParameters(); - participantParameters.setClampClientParameters(null); - assertThat(validatorFactory.getValidator().validate(participantParameters)).isNotEmpty(); - } - - @Test - void testNoHostname() { - final ParticipantDcaeParameters participantParameters = commonTestData.getParticipantDcaeParameters(); - participantParameters.getClampClientParameters().setHostname(null); - assertThat(validatorFactory.getValidator().validate(participantParameters)).isNotEmpty(); - } - - @Test - void testNoTopicSinks() throws ControlLoopException { - final ParticipantDcaeParameters participantParameters = commonTestData.getParticipantDcaeParameters(); - - ParticipantIntermediaryParameters intermediaryParameters = participantParameters.getIntermediaryParameters(); - intermediaryParameters.getClampControlLoopTopics().setTopicSinks(null); - - assertThat(validatorFactory.getValidator().validate(participantParameters)).isNotEmpty(); - } - - @Test - void testNoTopicSources() throws ControlLoopException { - final ParticipantDcaeParameters participantParameters = commonTestData.getParticipantDcaeParameters(); - - ParticipantIntermediaryParameters intermediaryParameters = participantParameters.getIntermediaryParameters(); - intermediaryParameters.getClampControlLoopTopics().setTopicSources(null); - - assertThat(validatorFactory.getValidator().validate(participantParameters)).isNotEmpty(); - } - - @Test - void testNoConsulClientParameters() { - final ParticipantDcaeParameters participantParameters = commonTestData.getParticipantDcaeParameters(); - participantParameters.setConsulClientParameters(null); - assertThat(validatorFactory.getValidator().validate(participantParameters)).isNotEmpty(); - } - - @Test - void testNoConsulHostname() { - final ParticipantDcaeParameters participantParameters = commonTestData.getParticipantDcaeParameters(); - participantParameters.getConsulClientParameters().setHostname(null); - assertThat(validatorFactory.getValidator().validate(participantParameters)).isNotEmpty(); - } - - @Test - void testNoIntermediaryParameters() { - final ParticipantDcaeParameters participantParameters = commonTestData.getParticipantDcaeParameters(); - participantParameters.setIntermediaryParameters(null); - assertThat(validatorFactory.getValidator().validate(participantParameters)).isNotEmpty(); - } - - @Test - void testNoParticipantId() { - final ParticipantDcaeParameters participantParameters = commonTestData.getParticipantDcaeParameters(); - participantParameters.getIntermediaryParameters().setParticipantId(null); - assertThat(validatorFactory.getValidator().validate(participantParameters)).isNotEmpty(); - } -} diff --git a/participant/participant-impl/participant-impl-dcae/src/test/java/org/onap/policy/clamp/controlloop/participant/dcae/main/rest/TestListenerUtils.java b/participant/participant-impl/participant-impl-dcae/src/test/java/org/onap/policy/clamp/controlloop/participant/dcae/main/rest/TestListenerUtils.java deleted file mode 100644 index df49f7c49..000000000 --- a/participant/participant-impl/participant-impl-dcae/src/test/java/org/onap/policy/clamp/controlloop/participant/dcae/main/rest/TestListenerUtils.java +++ /dev/null @@ -1,332 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2021 Nordix Foundation. - * ================================================================================ - * 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. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.clamp.controlloop.participant.dcae.main.rest; - -import java.io.File; -import java.time.Instant; -import java.util.ArrayList; -import java.util.LinkedHashMap; -import java.util.List; -import java.util.Map; -import java.util.UUID; -import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ControlLoop; -import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ControlLoopElement; -import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ControlLoopElementDefinition; -import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ControlLoopOrderedState; -import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ControlLoopState; -import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ParticipantDefinition; -import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ParticipantUpdates; -import org.onap.policy.clamp.controlloop.models.messages.dmaap.participant.ControlLoopStateChange; -import org.onap.policy.clamp.controlloop.models.messages.dmaap.participant.ControlLoopUpdate; -import org.onap.policy.clamp.controlloop.models.messages.dmaap.participant.ParticipantUpdate; -import org.onap.policy.common.utils.coder.Coder; -import org.onap.policy.common.utils.coder.CoderException; -import org.onap.policy.common.utils.coder.StandardCoder; -import org.onap.policy.common.utils.coder.YamlJsonTranslator; -import org.onap.policy.common.utils.resources.ResourceUtils; -import org.onap.policy.models.tosca.authorative.concepts.ToscaConceptIdentifier; -import org.onap.policy.models.tosca.authorative.concepts.ToscaNodeTemplate; -import org.onap.policy.models.tosca.authorative.concepts.ToscaServiceTemplate; - -public class TestListenerUtils { - - private static final YamlJsonTranslator yamlTranslator = new YamlJsonTranslator(); - private static final Coder CODER = new StandardCoder(); - private static final String TOSCA_TEMPLATE_YAML = "examples/controlloop/PMSubscriptionHandling.yaml"; - private static final String CONTROL_LOOP_ELEMENT = "org.onap.policy.clamp.controlloop.ControlLoopElement"; - - /** - * Method to create a controlLoop from a yaml file. - * - * @return ControlLoop controlloop - */ - public static ControlLoop createControlLoop() { - ControlLoop controlLoop = new ControlLoop(); - Map<UUID, ControlLoopElement> elements = new LinkedHashMap<>(); - ToscaServiceTemplate toscaServiceTemplate = testControlLoopRead(); - Map<String, ToscaNodeTemplate> nodeTemplatesMap = - toscaServiceTemplate.getToscaTopologyTemplate().getNodeTemplates(); - for (Map.Entry<String, ToscaNodeTemplate> toscaInputEntry : nodeTemplatesMap.entrySet()) { - ControlLoopElement clElement = new ControlLoopElement(); - clElement.setId(UUID.randomUUID()); - - ToscaConceptIdentifier clElementParticipantId = new ToscaConceptIdentifier(); - clElementParticipantId.setName(toscaInputEntry.getKey()); - clElementParticipantId.setVersion(toscaInputEntry.getValue().getVersion()); - clElement.setParticipantId(clElementParticipantId); - - clElement.setDefinition(clElementParticipantId); - clElement.setState(ControlLoopState.UNINITIALISED); - clElement.setDescription(toscaInputEntry.getValue().getDescription()); - clElement.setOrderedState(ControlLoopOrderedState.UNINITIALISED); - elements.put(clElement.getId(), clElement); - } - controlLoop.setElements(elements); - controlLoop.setName("PMSHInstance0"); - controlLoop.setVersion("1.0.0"); - - ToscaConceptIdentifier definition = new ToscaConceptIdentifier(); - definition.setName("PMSHInstance0"); - definition.setVersion("1.0.0"); - controlLoop.setDefinition(definition); - - return controlLoop; - } - - /** - * Method to create ControlLoopStateChange message from the arguments passed. - * - * @param controlLoopOrderedState controlLoopOrderedState - * - * @return ControlLoopStateChange message - */ - public static ControlLoopStateChange createControlLoopStateChangeMsg( - final ControlLoopOrderedState controlLoopOrderedState) { - final ControlLoopStateChange clStateChangeMsg = new ControlLoopStateChange(); - - ToscaConceptIdentifier controlLoopId = new ToscaConceptIdentifier(); - controlLoopId.setName("PMSHInstance0"); - controlLoopId.setVersion("1.0.0"); - - ToscaConceptIdentifier participantId = new ToscaConceptIdentifier(); - participantId.setName("DCAEParticipant0"); - participantId.setVersion("1.0.0"); - - clStateChangeMsg.setControlLoopId(controlLoopId); - clStateChangeMsg.setParticipantId(participantId); - clStateChangeMsg.setTimestamp(Instant.now()); - clStateChangeMsg.setOrderedState(controlLoopOrderedState); - - return clStateChangeMsg; - } - - /** - * Method to create ControlLoopUpdateMsg. - * - * @return ControlLoopUpdate message - */ - public static ControlLoopUpdate createControlLoopUpdateMsg() { - final ControlLoopUpdate clUpdateMsg = new ControlLoopUpdate(); - ToscaConceptIdentifier controlLoopId = - new ToscaConceptIdentifier("PMSHInstance0", "1.0.0"); - ToscaConceptIdentifier participantId = - new ToscaConceptIdentifier("org.onap.PM_Policy", "0.0.0"); - - clUpdateMsg.setControlLoopId(controlLoopId); - clUpdateMsg.setParticipantId(participantId); - clUpdateMsg.setMessageId(UUID.randomUUID()); - clUpdateMsg.setTimestamp(Instant.now()); - - Map<UUID, ControlLoopElement> elements = new LinkedHashMap<>(); - ToscaServiceTemplate toscaServiceTemplate = testControlLoopRead(); - Map<String, ToscaNodeTemplate> nodeTemplatesMap = - toscaServiceTemplate.getToscaTopologyTemplate().getNodeTemplates(); - for (Map.Entry<String, ToscaNodeTemplate> toscaInputEntry : nodeTemplatesMap.entrySet()) { - if (checkIfNodeTemplateIsControlLoopElement(toscaInputEntry.getValue(), toscaServiceTemplate)) { - ControlLoopElement clElement = new ControlLoopElement(); - clElement.setId(UUID.randomUUID()); - ToscaConceptIdentifier clParticipantType; - try { - clParticipantType = CODER.decode( - toscaInputEntry.getValue().getProperties().get("participantType").toString(), - ToscaConceptIdentifier.class); - } catch (CoderException e) { - throw new RuntimeException("cannot get ParticipantType from toscaNodeTemplate", e); - } - - clElement.setParticipantId(clParticipantType); - clElement.setParticipantType(clParticipantType); - - clElement.setDefinition(new ToscaConceptIdentifier(toscaInputEntry.getKey(), - toscaInputEntry.getValue().getVersion())); - clElement.setState(ControlLoopState.UNINITIALISED); - clElement.setDescription(toscaInputEntry.getValue().getDescription()); - clElement.setOrderedState(ControlLoopOrderedState.PASSIVE); - elements.put(clElement.getId(), clElement); - } - } - - List<ParticipantUpdates> participantUpdates = new ArrayList<>(); - for (ControlLoopElement element : elements.values()) { - prepareParticipantUpdateForControlLoop(element, participantUpdates); - } - clUpdateMsg.setParticipantUpdatesList(participantUpdates); - return clUpdateMsg; - } - - private static boolean checkIfNodeTemplateIsControlLoopElement(ToscaNodeTemplate nodeTemplate, - ToscaServiceTemplate toscaServiceTemplate) { - if (nodeTemplate.getType().contains(CONTROL_LOOP_ELEMENT)) { - return true; - } else { - var nodeType = toscaServiceTemplate.getNodeTypes().get(nodeTemplate.getType()); - if (nodeType != null) { - var derivedFrom = nodeType.getDerivedFrom(); - if (derivedFrom != null) { - return derivedFrom.contains(CONTROL_LOOP_ELEMENT) ? true : false; - } - } - } - return false; - } - - private static void prepareParticipantUpdateForControlLoop(ControlLoopElement clElement, - List<ParticipantUpdates> participantUpdates) { - if (participantUpdates.isEmpty()) { - participantUpdates.add(getControlLoopElementList(clElement)); - } else { - boolean participantExists = false; - for (ParticipantUpdates participantUpdate : participantUpdates) { - if (participantUpdate.getParticipantId().equals(clElement.getParticipantId())) { - participantUpdate.getControlLoopElementList().add(clElement); - participantExists = true; - } - } - if (!participantExists) { - participantUpdates.add(getControlLoopElementList(clElement)); - } - } - } - - private static ParticipantUpdates getControlLoopElementList(ControlLoopElement clElement) { - ParticipantUpdates participantUpdate = new ParticipantUpdates(); - List<ControlLoopElement> controlLoopElementList = new ArrayList<>(); - participantUpdate.setParticipantId(clElement.getParticipantId()); - controlLoopElementList.add(clElement); - participantUpdate.setControlLoopElementList(controlLoopElementList); - return participantUpdate; - } - - /** - * Method to create participantUpdateMsg. - * - * @return ParticipantUpdate message - */ - public static ParticipantUpdate createParticipantUpdateMsg() { - final ParticipantUpdate participantUpdateMsg = new ParticipantUpdate(); - ToscaConceptIdentifier participantId = new ToscaConceptIdentifier("org.onap.PM_Policy", "1.0.0"); - ToscaConceptIdentifier participantType = new ToscaConceptIdentifier( - "org.onap.policy.controlloop.PolicyControlLoopParticipant", "2.3.1"); - - participantUpdateMsg.setParticipantId(participantId); - participantUpdateMsg.setTimestamp(Instant.now()); - participantUpdateMsg.setParticipantType(participantType); - participantUpdateMsg.setTimestamp(Instant.ofEpochMilli(3000)); - participantUpdateMsg.setMessageId(UUID.randomUUID()); - - ToscaServiceTemplate toscaServiceTemplate = testControlLoopRead(); - - List<ParticipantDefinition> participantDefinitionUpdates = new ArrayList<>(); - for (Map.Entry<String, ToscaNodeTemplate> toscaInputEntry : - toscaServiceTemplate.getToscaTopologyTemplate().getNodeTemplates().entrySet()) { - if (checkIfNodeTemplateIsControlLoopElement(toscaInputEntry.getValue(), toscaServiceTemplate)) { - ToscaConceptIdentifier clParticipantType; - try { - clParticipantType = CODER.decode( - toscaInputEntry.getValue().getProperties().get("participantType").toString(), - ToscaConceptIdentifier.class); - } catch (CoderException e) { - throw new RuntimeException("cannot get ParticipantType from toscaNodeTemplate", e); - } - prepareParticipantDefinitionUpdate(clParticipantType, toscaInputEntry.getKey(), - toscaInputEntry.getValue(), participantDefinitionUpdates); - } - } - - participantUpdateMsg.setParticipantDefinitionUpdates(participantDefinitionUpdates); - return participantUpdateMsg; - } - - private static void prepareParticipantDefinitionUpdate(ToscaConceptIdentifier clParticipantType, String entryKey, - ToscaNodeTemplate entryValue, List<ParticipantDefinition> participantDefinitionUpdates) { - - var clDefinition = new ControlLoopElementDefinition(); - clDefinition.setClElementDefinitionId(new ToscaConceptIdentifier( - entryKey, entryValue.getVersion())); - clDefinition.setControlLoopElementToscaNodeTemplate(entryValue); - List<ControlLoopElementDefinition> controlLoopElementDefinitionList = new ArrayList<>(); - - if (participantDefinitionUpdates.isEmpty()) { - participantDefinitionUpdates.add(getParticipantDefinition(clDefinition, clParticipantType, - controlLoopElementDefinitionList)); - } else { - boolean participantExists = false; - for (ParticipantDefinition participantDefinitionUpdate : participantDefinitionUpdates) { - if (participantDefinitionUpdate.getParticipantType().equals(clParticipantType)) { - participantDefinitionUpdate.getControlLoopElementDefinitionList().add(clDefinition); - participantExists = true; - } - } - if (!participantExists) { - participantDefinitionUpdates.add(getParticipantDefinition(clDefinition, clParticipantType, - controlLoopElementDefinitionList)); - } - } - } - - private static ParticipantDefinition getParticipantDefinition(ControlLoopElementDefinition clDefinition, - ToscaConceptIdentifier clParticipantType, - List<ControlLoopElementDefinition> controlLoopElementDefinitionList) { - ParticipantDefinition participantDefinition = new ParticipantDefinition(); - participantDefinition.setParticipantType(clParticipantType); - controlLoopElementDefinitionList.add(clDefinition); - participantDefinition.setControlLoopElementDefinitionList(controlLoopElementDefinitionList); - return participantDefinition; - } - - public static ToscaConceptIdentifier getControlLoopId() { - return new ToscaConceptIdentifier("PMSHInstance0", "1.0.0"); - } - - /** - * Method to create a deep copy of ControlLoopUpdateMsg. - * - * @return ControlLoopUpdate message - */ - public static ControlLoopUpdate createCopyControlLoopUpdateMsg(ControlLoopUpdate cpy) { - return new ControlLoopUpdate(cpy); - } - - /** - * Method to create ControlLoopUpdate using the arguments passed. - * - * @param jsonFilePath the path of the controlloop content - * - * @return ControlLoopUpdate message - * @throws CoderException exception while reading the file to object - */ - public static ControlLoopUpdate createParticipantClUpdateMsgFromJson(String jsonFilePath) - throws CoderException { - ControlLoopUpdate controlLoopUpdateMsg = - CODER.decode(new File(jsonFilePath), ControlLoopUpdate.class); - return controlLoopUpdateMsg; - } - - private static ToscaServiceTemplate testControlLoopRead() { - return testControlLoopYamlSerialization(TOSCA_TEMPLATE_YAML); - } - - private static ToscaServiceTemplate testControlLoopYamlSerialization(String controlLoopFilePath) { - String controlLoopString = ResourceUtils.getResourceAsString(controlLoopFilePath); - ToscaServiceTemplate serviceTemplate = yamlTranslator.fromYaml(controlLoopString, ToscaServiceTemplate.class); - return serviceTemplate; - } -} diff --git a/participant/participant-impl/participant-impl-dcae/src/test/resources/application_test.properties b/participant/participant-impl/participant-impl-dcae/src/test/resources/application_test.properties deleted file mode 100644 index 2c775c28d..000000000 --- a/participant/participant-impl/participant-impl-dcae/src/test/resources/application_test.properties +++ /dev/null @@ -1,38 +0,0 @@ -spring.security.user.name=healthcheck -spring.security.user.password=zb!XztG34 - -server.servlet.context-path=/onap/participantsim -server.error.path=/error - -participant.name=ControlLoopParticipant Dcae Test -participant.clampClientParameters.clientName=Clamp -participant.clampClientParameters.hostname=0.0.0.0 -participant.clampClientParameters.port=8443 -participant.clampClientParameters.userName=admin -participant.clampClientParameters.password=password -participant.clampClientParameters.https=true -participant.clampClientParameters.aaf=false -participant.consulClientParameters.clientName=Consul -participant.consulClientParameters.hostname=consul -participant.consulClientParameters.port=31321 -participant.consulClientParameters.userName=admin -participant.consulClientParameters.password=password -participant.consulClientParameters.https=false -participant.consulClientParameters.aaf=false -participant.intermediaryParameters.name=Participant parameters -participant.intermediaryParameters.reportingTimeInterval=120000 -participant.intermediaryParameters.description=Participant Description -participant.intermediaryParameters.participantId.name=DCAEParticipant0 -participant.intermediaryParameters.participantId.version=1.0.0 -participant.intermediaryParameters.participantType.name=org.onap.dcae.controlloop.DCAEMicroserviceControlLoopParticipant -participant.intermediaryParameters.participantType.version=2.3.4 -participant.intermediaryParameters.clampControlLoopTopics.name=ControlLoop Topics -participant.intermediaryParameters.clampControlLoopTopics.topicSources[0].topic=POLICY-CLRUNTIME-PARTICIPANT -participant.intermediaryParameters.clampControlLoopTopics.topicSources[0].servers[0]=localhost -participant.intermediaryParameters.clampControlLoopTopics.topicSources[0].topicCommInfrastructure=dmaap -participant.intermediaryParameters.clampControlLoopTopics.topicSources[0].fetchTimeout=15000 -participant.intermediaryParameters.clampControlLoopTopics.topicSinks[0].topic=POLICY-CLRUNTIME-PARTICIPANT -participant.intermediaryParameters.clampControlLoopTopics.topicSinks[0].servers[0]=localhost -participant.intermediaryParameters.clampControlLoopTopics.topicSinks[0].topicCommInfrastructure=dmaap - -participant.checkCount=10 diff --git a/participant/participant-impl/participant-impl-dcae/src/test/resources/parameters/logback-test.xml b/participant/participant-impl/participant-impl-dcae/src/test/resources/parameters/logback-test.xml deleted file mode 100644 index cf6b89eb9..000000000 --- a/participant/participant-impl/participant-impl-dcae/src/test/resources/parameters/logback-test.xml +++ /dev/null @@ -1,42 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> -<!-- - ============LICENSE_START======================================================= - Copyright (C) 2021 Nordix Foundation. - ================================================================================ - 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. - See the License for the specific language governing permissions and - limitations under the License. - - SPDX-License-Identifier: Apache-2.0 - ============LICENSE_END========================================================= ---> - -<configuration> - - <contextName>Participant</contextName> - <statusListener class="ch.qos.logback.core.status.OnConsoleStatusListener" /> - <property name="LOG_DIR" value="${java.io.tmpdir}/clamp_logging/" /> - - <!-- USE FOR STD OUT ONLY --> - <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender"> - <encoder> - <Pattern>%d %contextName [%t] %level %logger{36} - %msg%n</Pattern> - </encoder> - </appender> - - <root level="info"> - <appender-ref ref="STDOUT" /> - </root> - - <logger name="org.onap.policy.clamp.controlloop.participant" level="trace" additivity="false"> - <appender-ref ref="STDOUT" /> - </logger> -</configuration> diff --git a/participant/participant-impl/participant-impl-dcae/src/test/resources/rest/servicetemplates/pm_control_loop_tosca.yaml b/participant/participant-impl/participant-impl-dcae/src/test/resources/rest/servicetemplates/pm_control_loop_tosca.yaml deleted file mode 100644 index 33b42b7bc..000000000 --- a/participant/participant-impl/participant-impl-dcae/src/test/resources/rest/servicetemplates/pm_control_loop_tosca.yaml +++ /dev/null @@ -1,164 +0,0 @@ -tosca_definitions_version: tosca_simple_yaml_1_3 -data_types: - onap.datatypes.ToscaConceptIdentifier: - derived_from: tosca.datatypes.Root - properties: - name: - type: string - required: true - version: - type: string - required: true -node_types: - org.onap.policy.clamp.controlloop.Participant: - version: 1.0.1 - derived_from: tosca.nodetypes.Root - properties: - provider: - type: string - requred: false - org.onap.policy.clamp.controlloop.ControlLoopElement: - version: 1.0.1 - derived_from: tosca.nodetypes.Root - properties: - provider: - type: string - requred: false - participantType: - type: onap.datatypes.ToscaConceptIdentifier - requred: true - startPhase: - type: integer - required: false - constraints: - - greater-or-equal: 0 - metadata: - common: true - description: A value indicating the start phase in which this control loop element will be started, the - first start phase is zero. Control Loop Elements are started in their start_phase order and stopped - in reverse start phase order. Control Loop Elements with the same start phase are started and - stopped simultaneously - org.onap.policy.clamp.controlloop.ControlLoop: - version: 1.0.1 - derived_from: tosca.nodetypes.Root - properties: - provider: - type: string - requred: false - elements: - type: list - required: true - entry_schema: - type: onap.datatypes.ToscaConceptIdentifier - org.onap.policy.clamp.controlloop.DCAEMicroserviceControlLoopElement: - version: 1.0.1 - derived_from: org.onap.policy.clamp.controlloop.ControlLoopElement - properties: - dcae_blueprint_id: - type: onap.datatypes.ToscaConceptIdentifier - requred: true - org.onap.policy.clamp.controlloop.PolicyTypeControlLoopElement: - version: 1.0.1 - derived_from: org.onap.policy.clamp.controlloop.ControlLoopElement - properties: - policy_type_id: - type: onap.datatypes.ToscaConceptIdentifier - requred: true - org.onap.policy.clamp.controlloop.CDSControlLoopElement: - version: 1.0.1 - derived_from: org.onap.policy.clamp.controlloop.ControlLoopElement - properties: - cds_blueprint_id: - type: onap.datatypes.ToscaConceptIdentifier - requred: true -topology_template: - node_templates: - org.onap.dcae.controlloop.DCAEMicroserviceControlLoopParticipant: - version: 2.3.4 - type: org.onap.policy.clamp.controlloop.Participant - type_version: 1.0.1 - description: Participant for DCAE microservices - properties: - provider: ONAP - org.onap.policy.controlloop.PolicyControlLoopParticipant: - version: 2.3.1 - type: org.onap.policy.clamp.controlloop.Participant - type_version: 1.0.1 - description: Participant for DCAE microservices - properties: - provider: ONAP - org.onap.ccsdk.cds.controlloop.CdsControlLoopParticipant: - version: 2.2.1 - type: org.onap.policy.clamp.controlloop.Participant - type_version: 1.0.1 - description: Participant for DCAE microservices - properties: - provider: ONAP - org.onap.domain.pmsh.PMSH_DCAEMicroservice: - version: 1.2.3 - type: org.onap.policy.clamp.controlloop.DCAEMicroserviceControlLoopElement - type_version: 1.0.0 - description: Control loop element for the DCAE microservice for Performance Management Subscription Handling - properties: - provider: Ericsson - participantType: - name: org.onap.dcae.controlloop.DCAEMicroserviceControlLoopParticipant - version: 2.3.4 - dcae_blueprint_id: - name: org.onap.dcae.blueprints.PMSHBlueprint - version: 1.0.0 - org.onap.domain.pmsh.PMSH_MonitoringPolicyControlLoopElement: - version: 1.2.3 - type: org.onap.policy.clamp.controlloop.PolicyTypeControlLoopElement - type_version: 1.0.0 - description: Control loop element for the monitoring policy for Performance Management Subscription Handling - properties: - provider: Ericsson - participantType: - name: org.onap.policy.controlloop.PolicyControlLoopParticipant - version: 2.3.1 - policy_type_id: - name: onap.policies.monitoring.pm-subscription-handler - version: 1.0.0 - org.onap.domain.pmsh.PMSH_OperationalPolicyControlLoopElement: - version: 1.2.3 - type: org.onap.policy.clamp.controlloop.PolicyTypeControlLoopElement - type_version: 1.0.0 - description: Control loop element for the operational policy for Performance Management Subscription Handling - properties: - provider: Ericsson - participantType: - name: org.onap.policy.controlloop.PolicyControlLoopParticipant - version: 2.3.1 - policy_type_id: - name: onap.policies.operational.pm-subscription-handler - version: 1.0.0 - org.onap.domain.pmsh.PMSH_CDS_ControlLoopElement: - version: 1.2.3 - type: org.onap.policy.clamp.controlloop.ControlLoopElement - type_version: 1.0.0 - description: Control loop element for CDS for Performance Management Subscription Handling - properties: - provider: Ericsson - participantType: - name: org.onap.ccsdk.cds.controlloop.CdsControlLoopParticipant - version: 3.2.1 - cds_blueprint_id: - name: org.onap.ccsdk.cds.PMSHCdsBlueprint - version: 1.0.0 - org.onap.domain.pmsh.PMSHControlLoopDefinition: - version: 1.2.3 - type: org.onap.policy.clamp.controlloop.ControlLoop - type_version: 1.0.0 - description: Control loop for Performance Management Subscription Handling - properties: - provider: Ericsson - elements: - - name: org.onap.domain.pmsh.PMSH_DCAEMicroservice - version: 1.2.3 - - name: org.onap.domain.pmsh.PMSH_MonitoringPolicyControlLoopElement - version: 1.2.3 - - name: org.onap.domain.pmsh.PMSH_OperationalPolicyControlLoopElement - version: 1.2.3 - - name: org.onap.domain.pmsh.PMSH_CDS_ControlLoopElement - version: 1.2.3 diff --git a/participant/participant-impl/participant-impl-dcae/src/test/resources/rest/status.json b/participant/participant-impl/participant-impl-dcae/src/test/resources/rest/status.json deleted file mode 100644 index 143ef635d..000000000 --- a/participant/participant-impl/participant-impl-dcae/src/test/resources/rest/status.json +++ /dev/null @@ -1,3918 +0,0 @@ -{ - "name": "pmsh_loop", - "globalPropertiesJson": { - "dcaeDeployParameters": { - "uniqueBlueprintParameters": { - "tag_version": "nexus3.onap.org:10001/onap/org.onap.dcaegen2.services.pmsh:1.1.2", - "replicas": 1, - "operational_policy_name": "pmsh-operational-policy", - "control_loop_name": "pmsh-control-loop", - "pmsh_publish_topic_name": "unauthenticated.DCAE_CL_OUTPUT", - "policy_feedback_topic_name": "unauthenticated.PMSH_CL_INPUT", - "aai_notification_topic_name": "AAI-EVENT", - "publisher_client_role": "org.onap.dcae.pmPublisher", - "subscriber_client_role": "org.onap.dcae.pmSubscriber", - "dcae_location": "san-francisco", - "cpu_limit": "1000m", - "cpu_request": "1000m", - "memory_limit": "1024Mi", - "memory_request": "1024Mi", - "pgaas_cluster_name": "dcae-pg-primary.onap", - "enable_tls": true, - "protocol": "https", - "policy_model_id": "onap.policies.monitoring.dcae-pm-subscription-handler", - "policy_id": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh" - } - } - }, - "modelService": { - "serviceDetails": { - "serviceType": "", - "serviceRole": "", - "description": "vLBMS", - "type": "Service", - "instantiationType": "A-la-carte", - "namingPolicy": "", - "serviceEcompNaming": "true", - "environmentContext": "General_Revenue-Bearing", - "name": "vLoadBalancerMS", - "invariantUUID": "30ec5b59-4799-48d8-ac5f-1058a6b0e48f", - "ecompGeneratedNaming": "true", - "UUID": "63cac700-ab9a-4115-a74f-7eac85e3fce0", - "category": "Network L4+" - }, - "resourceDetails": { - "CP": {}, - "VL": {}, - "VF": { - "vLoadBalancerMS 0": { - "resourceVendor": "Test", - "name": "vLoadBalancerMS", - "resourceVendorModelNumber": "", - "description": "vLBMS", - "invariantUUID": "1a31b9f2-e50d-43b7-89b3-a040250cf506", - "UUID": "b4c4f3d7-929e-4b6d-a1cd-57e952ddc3e6", - "type": "VF", - "category": "Application L4+", - "subcategory": "Load Balancer", - "version": "1.0", - "customizationUUID": "465246dc-7748-45f4-a013-308d92922552", - "resourceVendorRelease": "1.0", - "controllerProperties": { - "sdnc_model_name": "baseconfiguration", - "sdnc_model_version": "1.0.0", - "workflows": { - "resource-assignment": { - "inputs": { - "resource-assignment-properties": { - "type": "object", - "properties": { - "request-id": { - "required": true, - "type": "string", - "input-param": true - }, - "service-instance-id": { - "required": true, - "type": "string", - "input-param": true - }, - "hostname": { - "required": true, - "type": "string", - "input-param": true - }, - "request-info": { - "type": "object", - "properties": { - "prop1": { - "required": true, - "type": "string", - "input-param": true - }, - "prop2": { - "required": true, - "type": "string", - "input-param": true - } - } - } - } - } - } - }, - "activate": { - "inputs": { - "resource-assignment-properties": { - "type": "object", - "properties": { - "request-id": { - "required": true, - "type": "string", - "input-param": true - }, - "service-instance-id": { - "required": true, - "type": "string", - "input-param": true - }, - "hostname": { - "required": true, - "type": "string", - "input-param": true - }, - "request-info": { - "type": "object", - "properties": { - "prop1": { - "required": true, - "type": "string", - "input-param": true - }, - "prop2": { - "required": true, - "type": "string", - "input-param": true - } - } - } - } - } - } - }, - "activate-restconf": { - "inputs": { - "resource-assignment-properties": { - "type": "object", - "properties": { - "request-id": { - "required": true, - "type": "string", - "input-param": true - }, - "service-instance-id": { - "required": true, - "type": "string", - "input-param": true - }, - "hostname": { - "required": true, - "type": "string", - "input-param": true - }, - "request-info": { - "type": "object", - "properties": { - "prop1": { - "required": true, - "type": "string", - "input-param": true - }, - "prop2": { - "required": true, - "type": "string", - "input-param": true - } - } - } - } - } - } - }, - "activate-cli": { - "inputs": { - "resource-assignment-properties": { - "type": "object", - "properties": { - "request-id": { - "required": true, - "type": "string", - "input-param": true - }, - "service-instance-id": { - "required": true, - "type": "string", - "input-param": true - }, - "hostname": { - "required": true, - "type": "string", - "input-param": true - }, - "request-info": { - "type": "object", - "properties": { - "prop1": { - "required": true, - "type": "string", - "input-param": true - }, - "prop2": { - "required": true, - "type": "string", - "input-param": true - } - } - } - } - } - } - }, - "assign-activate": { - "inputs": { - "resource-assignment-properties": { - "type": "object", - "properties": { - "request-id": { - "required": true, - "type": "string", - "input-param": true - }, - "service-instance-id": { - "required": true, - "type": "string", - "input-param": true - }, - "hostname": { - "required": true, - "type": "string", - "input-param": true - }, - "request-info": { - "type": "object", - "properties": { - "prop1": { - "required": true, - "type": "string", - "input-param": true - }, - "prop2": { - "required": true, - "type": "string", - "input-param": true - } - } - } - } - } - } - }, - "imperative-test-wf": { - "inputs": { - "resource-assignment-properties": { - "type": "object", - "properties": { - "request-id": { - "required": true, - "type": "string", - "input-param": true - }, - "service-instance-id": { - "required": true, - "type": "string", - "input-param": true - }, - "hostname": { - "required": true, - "type": "string", - "input-param": true - }, - "request-info": { - "type": "object", - "properties": { - "prop1": { - "required": true, - "type": "string", - "input-param": true - }, - "prop2": { - "required": true, - "type": "string", - "input-param": true - } - } - } - } - } - } - } - } - } - } - }, - "CR": {}, - "VFC": {}, - "PNF": {}, - "Service": {}, - "CVFC": {}, - "Service Proxy": {}, - "Configuration": {}, - "AllottedResource": {}, - "VFModule": { - "Vloadbalancerms..vpkg..module-1": { - "vfModuleModelInvariantUUID": "ca052563-eb92-4b5b-ad41-9111768ce043", - "vfModuleModelVersion": "1", - "vfModuleModelName": "Vloadbalancerms..vpkg..module-1", - "vfModuleModelUUID": "1e725ccc-b823-4f67-82b9-4f4367070dbc", - "vfModuleModelCustomizationUUID": "1bffdc31-a37d-4dee-b65c-dde623a76e52", - "min_vf_module_instances": 0, - "vf_module_label": "vpkg", - "max_vf_module_instances": 1, - "vf_module_type": "Expansion", - "isBase": false, - "initial_count": 0, - "volume_group": false - }, - "Vloadbalancerms..vdns..module-3": { - "vfModuleModelInvariantUUID": "4c10ba9b-f88f-415e-9de3-5d33336047fa", - "vfModuleModelVersion": "1", - "vfModuleModelName": "Vloadbalancerms..vdns..module-3", - "vfModuleModelUUID": "4fa73b49-8a6c-493e-816b-eb401567b720", - "vfModuleModelCustomizationUUID": "bafcdab0-801d-4d81-9ead-f464640a38b1", - "min_vf_module_instances": 0, - "vf_module_label": "vdns", - "max_vf_module_instances": 50, - "vf_module_type": "Expansion", - "isBase": false, - "initial_count": 0, - "volume_group": false - }, - "Vloadbalancerms..base_template..module-0": { - "vfModuleModelInvariantUUID": "921f7c96-ebdd-42e6-81b9-1cfc0c9796f3", - "vfModuleModelVersion": "1", - "vfModuleModelName": "Vloadbalancerms..base_template..module-0", - "vfModuleModelUUID": "63734409-f745-4e4d-a38b-131638a0edce", - "vfModuleModelCustomizationUUID": "86baddea-c730-4fb8-9410-cd2e17fd7f27", - "min_vf_module_instances": 1, - "vf_module_label": "base_template", - "max_vf_module_instances": 1, - "vf_module_type": "Base", - "isBase": true, - "initial_count": 1, - "volume_group": false - }, - "Vloadbalancerms..vlb..module-2": { - "vfModuleModelInvariantUUID": "a772a1f4-0064-412c-833d-4749b15828dd", - "vfModuleModelVersion": "1", - "vfModuleModelName": "Vloadbalancerms..vlb..module-2", - "vfModuleModelUUID": "0f5c3f6a-650a-4303-abb6-fff3e573a07a", - "vfModuleModelCustomizationUUID": "96a78aad-4ffb-4ef0-9c4f-deb03bf1d806", - "min_vf_module_instances": 0, - "vf_module_label": "vlb", - "max_vf_module_instances": 1, - "vf_module_type": "Expansion", - "isBase": false, - "initial_count": 0, - "volume_group": false - } - } - } - }, - "lastComputedState": "DESIGN", - "components": { - "POLICY": { - "componentState": { - "stateName": "NOT_SENT", - "description": "The policies defined have NOT yet been created on the policy engine" - } - }, - "DCAE": { - "componentState": { - "stateName": "${status}", - "description": "The DCAE blueprint has been found in the DCAE inventory but not yet instancianted for this loop" - } - } - }, - "operationalPolicies": [], - "microServicePolicies": [ - { - "name": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh", - "shared": false, - "jsonRepresentation": { - "title": "onap.policies.monitoring.dcae-pm-subscription-handler", - "type": "object", - "required": [], - "properties": { - "pmsh_policy": { - "title": "onap.datatypes.monitoring.subscription", - "type": "object", - "required": [ - "measurementGroups", - "fileBasedGP", - "fileLocation", - "subscriptionName", - "administrativeState", - "nfFilter" - ], - "properties": { - "measurementGroups": { - "type": "array", - "description": "Measurement Groups", - "items": { - "title": "onap.datatypes.monitoring.measurementGroups", - "type": "object", - "required": [ - "measurementGroup" - ], - "properties": { - "measurementGroup": { - "type": "object", - "description": "Measurement Group", - "properties": { - "onap.datatypes.monitoring.measurementGroup": { - "title": "onap.datatypes.monitoring.measurementGroup", - "type": "object", - "required": [ - "measurementTypes", - "managedObjectDNsBasic" - ], - "properties": { - "measurementTypes": { - "type": "array", - "description": "List of measurement types", - "items": { - "title": "onap.datatypes.monitoring.measurementTypes", - "type": "object", - "required": [ - "measurementType" - ], - "properties": { - "measurementType": { - "type": "object", - "description": "Measurement type object", - "properties": { - "onap.datatypes.monitoring.measurementType": { - "title": "onap.datatypes.monitoring.measurementType", - "type": "object", - "required": [ - "measurementType" - ], - "properties": { - "measurementType": { - "type": "string", - "description": "Measurement type" - } - } - } - } - } - } - }, - "format": "tabs-top" - }, - "managedObjectDNsBasic": { - "type": "array", - "description": "List of managed object distinguished names", - "items": { - "title": "onap.datatypes.monitoring.managedObjectDNsBasics", - "type": "object", - "required": [ - "managedObjectDNsBasic" - ], - "properties": { - "managedObjectDNsBasic": { - "type": "object", - "description": "Managed object distinguished name object", - "properties": { - "onap.datatypes.monitoring.managedObjectDNsBasic": { - "title": "onap.datatypes.monitoring.managedObjectDNsBasic", - "type": "object", - "required": [ - "DN" - ], - "properties": { - "DN": { - "type": "string", - "description": "Managed object distinguished name" - } - } - } - } - } - } - }, - "format": "tabs-top" - } - } - } - } - } - } - }, - "format": "tabs-top" - }, - "fileBasedGP": { - "type": "integer", - "description": "File based granularity period" - }, - "fileLocation": { - "type": "string", - "description": "ROP file location" - }, - "subscriptionName": { - "type": "string", - "description": "Name of the subscription" - }, - "administrativeState": { - "type": "string", - "description": "State of the subscription", - "enum": [ - "LOCKED", - "UNLOCKED" - ] - }, - "nfFilter": { - "type": "object", - "description": "Network function filter", - "properties": { - "onap.datatypes.monitoring.nfFilter": { - "title": "onap.datatypes.monitoring.nfFilter", - "type": "object", - "required": [ - "modelVersionIDs", - "modelInvariantIDs", - "modelNames", - "nfNames" - ], - "properties": { - "modelVersionIDs": { - "type": "array", - "description": "List of model version IDs", - "items": { - "type": "string" - }, - "format": "tabs-top" - }, - "modelInvariantIDs": { - "type": "array", - "description": "List of model invariant IDs", - "items": { - "type": "string" - }, - "format": "tabs-top" - }, - "modelNames": { - "type": "array", - "description": "List of model names", - "items": { - "type": "string" - }, - "format": "tabs-top" - }, - "nfNames": { - "type": "array", - "description": "List of network functions", - "items": { - "type": "string" - }, - "format": "tabs-top" - } - } - } - } - } - } - } - } - }, - "loopElementModel": { - "name": "onap.policies.monitoring.dcae-pm-subscription-handler", - "loopElementType": "MICRO_SERVICE_TYPE", - "policyModels": [ - { - "policyModelType": "onap.policies.monitoring.dcae-pm-subscription-handler", - "version": "1.0.0", - "policyAcronym": "dcae-pm-subscription-handler", - "policyPdpGroup": { - "supportedPdpGroups": [ - { - "ControlLoopGroup": [ - "apex", - "xacml" - ] - }, - { - "defaultGroup": [ - "xacml" - ] - } - ] - }, - "createdDate": "2021-03-30T09:55:52.261232Z", - "updatedDate": "2021-03-30T09:56:17.502284Z", - "updatedBy": "Not found", - "createdBy": "Not found" - } - ], - "createdDate": "2021-03-30T08:48:21Z", - "updatedDate": "2021-03-30T08:48:21Z", - "updatedBy": "Not found", - "createdBy": "Not found" - }, - "policyModel": { - "policyModelType": "onap.policies.monitoring.dcae-pm-subscription-handler", - "version": "1.0.0", - "policyAcronym": "dcae-pm-subscription-handler", - "policyPdpGroup": { - "supportedPdpGroups": [ - { - "ControlLoopGroup": [ - "apex", - "xacml" - ] - }, - { - "defaultGroup": [ - "xacml" - ] - } - ] - }, - "createdDate": "2021-03-30T09:55:52.261232Z", - "updatedDate": "2021-03-30T09:56:17.502284Z", - "updatedBy": "Not found", - "createdBy": "Not found" - }, - "createdDate": "2021-03-30T13:07:07.960379Z", - "updatedDate": "2021-03-30T13:07:07.960379Z", - "updatedBy": "admin", - "createdBy": "admin" - } - ], - "loopLogs": [ - { - "id": 478, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-05-07T09:32:44Z" - }, - { - "id": 477, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-05-07T09:32:44Z" - }, - { - "id": 476, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-05-07T09:32:43Z" - }, - { - "id": 475, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-05-07T09:32:43Z" - }, - { - "id": 474, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-05-07T09:32:43Z" - }, - { - "id": 473, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-05-07T09:32:43Z" - }, - { - "id": 472, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-05-07T09:32:39Z" - }, - { - "id": 471, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-05-07T09:32:39Z" - }, - { - "id": 470, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-05-07T09:32:35Z" - }, - { - "id": 451, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-04-07T13:34:30Z" - }, - { - "id": 450, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-04-07T13:34:30Z" - }, - { - "id": 449, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-04-07T13:34:30Z" - }, - { - "id": 448, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-04-07T13:34:30Z" - }, - { - "id": 447, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-04-07T13:34:30Z" - }, - { - "id": 446, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-07T13:34:30Z" - }, - { - "id": 445, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-04-07T13:34:26Z" - }, - { - "id": 444, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-07T13:34:26Z" - }, - { - "id": 443, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-04-07T13:34:22Z" - }, - { - "id": 442, - "logType": "INFO", - "logComponent": "POLICY", - "message": "PDP Group remove ALL status - : ", - "logInstant": "2021-04-07T08:32:06Z" - }, - { - "id": 441, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "STOP request", - "logInstant": "2021-04-07T08:32:02Z" - }, - { - "id": 440, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-04-07T08:23:46Z" - }, - { - "id": 439, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-04-07T08:23:46Z" - }, - { - "id": 438, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-04-07T08:23:46Z" - }, - { - "id": 437, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-04-07T08:23:46Z" - }, - { - "id": 436, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-04-07T08:23:46Z" - }, - { - "id": 435, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-07T08:23:46Z" - }, - { - "id": 434, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-04-07T08:23:42Z" - }, - { - "id": 433, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-07T08:23:41Z" - }, - { - "id": 432, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-04-07T08:23:37Z" - }, - { - "id": 431, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-04-06T15:06:27Z" - }, - { - "id": 430, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-04-06T15:06:27Z" - }, - { - "id": 429, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-04-06T15:06:27Z" - }, - { - "id": 428, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-04-06T15:06:27Z" - }, - { - "id": 427, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-04-06T15:06:27Z" - }, - { - "id": 426, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-06T15:06:27Z" - }, - { - "id": 425, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-04-06T15:06:22Z" - }, - { - "id": 424, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-06T15:06:22Z" - }, - { - "id": 423, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-04-06T15:06:18Z" - }, - { - "id": 422, - "logType": "INFO", - "logComponent": "POLICY", - "message": "PDP Group remove ALL status - : ", - "logInstant": "2021-04-06T15:06:04Z" - }, - { - "id": 421, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "STOP request", - "logInstant": "2021-04-06T15:06:00Z" - }, - { - "id": 420, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-04-06T15:05:28Z" - }, - { - "id": 419, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-04-06T15:05:28Z" - }, - { - "id": 418, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-04-06T15:05:28Z" - }, - { - "id": 417, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-04-06T15:05:28Z" - }, - { - "id": 416, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-04-06T15:05:28Z" - }, - { - "id": 415, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-06T15:05:28Z" - }, - { - "id": 414, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-04-06T15:05:24Z" - }, - { - "id": 413, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-06T15:05:23Z" - }, - { - "id": 412, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-04-06T15:05:19Z" - }, - { - "id": 411, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "UNDEPLOY request successfully executed", - "logInstant": "2021-04-06T15:05:07Z" - }, - { - "id": 410, - "logType": "WARNING", - "logComponent": "CLAMP", - "message": "Cannot Undeploy for the loop: pmsh_loop, the Deployment ID does not exist !", - "logInstant": "2021-04-06T15:05:07Z" - }, - { - "id": 409, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "DCAE UNDEPLOY request", - "logInstant": "2021-04-06T15:05:07Z" - }, - { - "id": 408, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DEPLOY loop status\n (Dep-id:CLAMP_7ae6f14d-80c8-4403-a174-ecb215d04c81,\n StatusUrl:) - : ", - "logInstant": "2021-04-06T15:02:46Z" - }, - { - "id": 407, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "DCAE DEPLOY request", - "logInstant": "2021-04-06T15:02:42Z" - }, - { - "id": 406, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-04-06T15:02:26Z" - }, - { - "id": 405, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-04-06T15:02:26Z" - }, - { - "id": 404, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-04-06T15:02:26Z" - }, - { - "id": 403, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-04-06T15:02:26Z" - }, - { - "id": 402, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-04-06T15:02:25Z" - }, - { - "id": 401, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-06T15:02:25Z" - }, - { - "id": 400, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-04-06T15:02:21Z" - }, - { - "id": 399, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-06T15:02:21Z" - }, - { - "id": 398, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-04-06T15:02:17Z" - }, - { - "id": 397, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-04-06T14:32:53Z" - }, - { - "id": 396, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-04-06T14:32:53Z" - }, - { - "id": 395, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-04-06T14:32:53Z" - }, - { - "id": 394, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-04-06T14:32:53Z" - }, - { - "id": 393, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-04-06T14:32:53Z" - }, - { - "id": 392, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-06T14:32:53Z" - }, - { - "id": 391, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-04-06T14:32:49Z" - }, - { - "id": 390, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-06T14:32:49Z" - }, - { - "id": 389, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-04-06T14:32:44Z" - }, - { - "id": 388, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-04-06T14:31:37Z" - }, - { - "id": 387, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-04-06T14:31:37Z" - }, - { - "id": 386, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-04-06T14:31:37Z" - }, - { - "id": 385, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-04-06T14:31:37Z" - }, - { - "id": 384, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-04-06T14:31:37Z" - }, - { - "id": 383, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-06T14:31:37Z" - }, - { - "id": 382, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-04-06T14:31:33Z" - }, - { - "id": 381, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-06T14:31:33Z" - }, - { - "id": 380, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-04-06T14:31:28Z" - }, - { - "id": 379, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-04-06T14:30:35Z" - }, - { - "id": 378, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-04-06T14:30:35Z" - }, - { - "id": 377, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-04-06T14:30:34Z" - }, - { - "id": 376, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-04-06T14:30:34Z" - }, - { - "id": 375, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-04-06T14:30:34Z" - }, - { - "id": 374, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-06T14:30:34Z" - }, - { - "id": 373, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-04-06T14:30:30Z" - }, - { - "id": 372, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-06T14:30:30Z" - }, - { - "id": 371, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-04-06T14:30:26Z" - }, - { - "id": 370, - "logType": "INFO", - "logComponent": "POLICY", - "message": "PDP Group remove ALL status - : ", - "logInstant": "2021-04-06T14:04:21Z" - }, - { - "id": 369, - "logType": "WARNING", - "logComponent": "CLAMP", - "message": "Cannot Undeploy for the loop: pmsh_loop, the Deployment ID does not exist !", - "logInstant": "2021-04-06T14:04:17Z" - }, - { - "id": 368, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "DELETE request", - "logInstant": "2021-04-06T14:04:17Z" - }, - { - "id": 367, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-04-06T14:03:52Z" - }, - { - "id": 366, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-04-06T14:03:52Z" - }, - { - "id": 365, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-04-06T14:03:51Z" - }, - { - "id": 364, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-04-06T14:03:51Z" - }, - { - "id": 363, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-04-06T14:03:51Z" - }, - { - "id": 362, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-06T14:03:51Z" - }, - { - "id": 361, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-04-06T14:03:47Z" - }, - { - "id": 360, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-06T14:03:47Z" - }, - { - "id": 359, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-04-06T14:03:43Z" - }, - { - "id": 358, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "UNDEPLOY request successfully executed", - "logInstant": "2021-04-06T14:03:35Z" - }, - { - "id": 357, - "logType": "WARNING", - "logComponent": "CLAMP", - "message": "Cannot Undeploy for the loop: pmsh_loop, the Deployment ID does not exist !", - "logInstant": "2021-04-06T14:03:35Z" - }, - { - "id": 356, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "DCAE UNDEPLOY request", - "logInstant": "2021-04-06T14:03:35Z" - }, - { - "id": 355, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-04-06T13:57:38Z" - }, - { - "id": 354, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-04-06T13:57:38Z" - }, - { - "id": 353, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-04-06T13:57:38Z" - }, - { - "id": 352, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-04-06T13:57:38Z" - }, - { - "id": 351, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-04-06T13:57:37Z" - }, - { - "id": 350, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-06T13:57:37Z" - }, - { - "id": 349, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-04-06T13:57:33Z" - }, - { - "id": 348, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-06T13:57:33Z" - }, - { - "id": 347, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-04-06T13:57:29Z" - }, - { - "id": 346, - "logType": "INFO", - "logComponent": "POLICY", - "message": "PDP Group remove ALL status - : ", - "logInstant": "2021-04-06T13:57:21Z" - }, - { - "id": 345, - "logType": "WARNING", - "logComponent": "CLAMP", - "message": "Cannot Undeploy for the loop: pmsh_loop, the Deployment ID does not exist !", - "logInstant": "2021-04-06T13:57:16Z" - }, - { - "id": 344, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "DELETE request", - "logInstant": "2021-04-06T13:57:16Z" - }, - { - "id": 343, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-04-06T13:16:29Z" - }, - { - "id": 342, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-04-06T13:16:29Z" - }, - { - "id": 341, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-04-06T13:16:29Z" - }, - { - "id": 340, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-04-06T13:16:29Z" - }, - { - "id": 339, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-04-06T13:16:29Z" - }, - { - "id": 338, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-06T13:16:29Z" - }, - { - "id": 337, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-04-06T13:16:24Z" - }, - { - "id": 336, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-06T13:16:24Z" - }, - { - "id": 335, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-04-06T13:16:20Z" - }, - { - "id": 334, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "Micro Service policies UPDATED", - "logInstant": "2021-04-01T16:12:47Z" - }, - { - "id": 333, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-04-01T16:09:36Z" - }, - { - "id": 332, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-04-01T16:09:36Z" - }, - { - "id": 331, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-04-01T16:09:36Z" - }, - { - "id": 330, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-04-01T16:09:36Z" - }, - { - "id": 329, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-04-01T16:09:36Z" - }, - { - "id": 328, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-01T16:09:36Z" - }, - { - "id": 327, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-04-01T16:09:32Z" - }, - { - "id": 326, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-01T16:09:32Z" - }, - { - "id": 325, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-04-01T16:09:27Z" - }, - { - "id": 324, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "Micro Service policies UPDATED", - "logInstant": "2021-04-01T15:16:20Z" - }, - { - "id": 323, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-04-01T15:15:57Z" - }, - { - "id": 322, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-04-01T15:15:57Z" - }, - { - "id": 321, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-04-01T15:15:57Z" - }, - { - "id": 320, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-04-01T15:15:57Z" - }, - { - "id": 319, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-04-01T15:15:57Z" - }, - { - "id": 318, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-01T15:15:57Z" - }, - { - "id": 317, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-04-01T15:15:52Z" - }, - { - "id": 316, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-01T15:15:52Z" - }, - { - "id": 315, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-04-01T15:15:48Z" - }, - { - "id": 314, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-04-01T15:14:19Z" - }, - { - "id": 313, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-04-01T15:14:19Z" - }, - { - "id": 312, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-04-01T15:14:19Z" - }, - { - "id": 311, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-04-01T15:14:19Z" - }, - { - "id": 310, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-04-01T15:14:19Z" - }, - { - "id": 309, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-01T15:14:19Z" - }, - { - "id": 308, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-04-01T15:14:15Z" - }, - { - "id": 307, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-01T15:14:15Z" - }, - { - "id": 306, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-04-01T15:14:10Z" - }, - { - "id": 305, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-04-01T15:10:59Z" - }, - { - "id": 304, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-04-01T15:10:59Z" - }, - { - "id": 303, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-04-01T15:10:59Z" - }, - { - "id": 302, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-04-01T15:10:59Z" - }, - { - "id": 301, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-04-01T15:10:59Z" - }, - { - "id": 300, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-01T15:10:59Z" - }, - { - "id": 299, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-04-01T15:10:55Z" - }, - { - "id": 298, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-01T15:10:54Z" - }, - { - "id": 297, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-04-01T15:10:50Z" - }, - { - "id": 287, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-04-01T14:31:38Z" - }, - { - "id": 286, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-04-01T14:31:38Z" - }, - { - "id": 285, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-04-01T14:31:37Z" - }, - { - "id": 284, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-04-01T14:31:37Z" - }, - { - "id": 283, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-04-01T14:31:37Z" - }, - { - "id": 282, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-01T14:31:37Z" - }, - { - "id": 281, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-04-01T14:31:33Z" - }, - { - "id": 280, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-01T14:31:33Z" - }, - { - "id": 279, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "Micro Service policies UPDATED", - "logInstant": "2021-04-01T14:31:32Z" - }, - { - "id": 278, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-04-01T14:31:31Z" - }, - { - "id": 277, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-04-01T14:31:31Z" - }, - { - "id": 276, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-04-01T14:31:30Z" - }, - { - "id": 275, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-04-01T14:31:30Z" - }, - { - "id": 274, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-04-01T14:31:29Z" - }, - { - "id": 273, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-04-01T14:31:29Z" - }, - { - "id": 272, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-04-01T14:31:29Z" - }, - { - "id": 271, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-04-01T14:31:29Z" - }, - { - "id": 270, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-04-01T14:31:29Z" - }, - { - "id": 269, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-04-01T14:31:29Z" - }, - { - "id": 268, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connection is still allocated", - "logInstant": "2021-04-01T14:31:29Z" - }, - { - "id": 267, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-04-01T14:31:29Z" - }, - { - "id": 266, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-04-01T14:31:29Z" - }, - { - "id": 265, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-04-01T14:31:29Z" - }, - { - "id": 264, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-04-01T14:31:29Z" - }, - { - "id": 263, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-04-01T14:31:29Z" - }, - { - "id": 262, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connection is still allocated", - "logInstant": "2021-04-01T14:31:29Z" - }, - { - "id": 261, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connection is still allocated", - "logInstant": "2021-04-01T14:31:29Z" - }, - { - "id": 260, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-04-01T14:31:29Z" - }, - { - "id": 259, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connection is still allocated", - "logInstant": "2021-04-01T14:31:29Z" - }, - { - "id": 258, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-04-01T14:31:29Z" - }, - { - "id": 257, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connection is still allocated", - "logInstant": "2021-04-01T14:31:28Z" - }, - { - "id": 256, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-04-01T14:31:28Z" - }, - { - "id": 255, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-04-01T14:31:28Z" - }, - { - "id": 254, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connection is still allocated", - "logInstant": "2021-04-01T14:31:28Z" - }, - { - "id": 253, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-04-01T14:31:28Z" - }, - { - "id": 252, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-04-01T14:31:28Z" - }, - { - "id": 251, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-04-01T14:31:28Z" - }, - { - "id": 250, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "Micro Service policies UPDATED", - "logInstant": "2021-04-01T12:39:55Z" - }, - { - "id": 249, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-04-01T12:38:31Z" - }, - { - "id": 248, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-04-01T12:38:31Z" - }, - { - "id": 247, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-04-01T12:38:30Z" - }, - { - "id": 246, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-04-01T12:38:30Z" - }, - { - "id": 245, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-04-01T12:38:30Z" - }, - { - "id": 244, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-01T12:38:30Z" - }, - { - "id": 243, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-04-01T12:38:26Z" - }, - { - "id": 242, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-01T12:38:26Z" - }, - { - "id": 241, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-04-01T12:38:22Z" - }, - { - "id": 240, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "Micro Service policies UPDATED", - "logInstant": "2021-04-01T12:37:20Z" - }, - { - "id": 239, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-04-01T12:37:19Z" - }, - { - "id": 238, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-04-01T12:37:19Z" - }, - { - "id": 237, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-04-01T12:37:19Z" - }, - { - "id": 236, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-04-01T12:37:19Z" - }, - { - "id": 235, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-04-01T12:37:19Z" - }, - { - "id": 234, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-01T12:37:19Z" - }, - { - "id": 233, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-04-01T12:37:14Z" - }, - { - "id": 232, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-01T12:37:14Z" - }, - { - "id": 231, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-04-01T12:37:10Z" - }, - { - "id": 221, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "Micro Service policies UPDATED", - "logInstant": "2021-04-01T11:57:59Z" - }, - { - "id": 220, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-04-01T11:57:34Z" - }, - { - "id": 219, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-04-01T11:57:34Z" - }, - { - "id": 218, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-04-01T11:57:34Z" - }, - { - "id": 217, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-04-01T11:57:33Z" - }, - { - "id": 216, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-04-01T11:57:33Z" - }, - { - "id": 215, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-01T11:57:33Z" - }, - { - "id": 214, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-04-01T11:57:29Z" - }, - { - "id": 213, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-04-01T11:57:29Z" - }, - { - "id": 212, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-04-01T11:57:25Z" - }, - { - "id": 211, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-03-31T15:50:20Z" - }, - { - "id": 210, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-03-31T15:50:20Z" - }, - { - "id": 209, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-03-31T15:50:20Z" - }, - { - "id": 208, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-03-31T15:50:20Z" - }, - { - "id": 207, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-03-31T15:50:20Z" - }, - { - "id": 206, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-31T15:50:20Z" - }, - { - "id": 205, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-03-31T15:50:16Z" - }, - { - "id": 204, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-31T15:50:16Z" - }, - { - "id": 203, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-03-31T15:50:11Z" - }, - { - "id": 202, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-03-31T15:49:39Z" - }, - { - "id": 201, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-03-31T15:49:39Z" - }, - { - "id": 200, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-03-31T15:49:39Z" - }, - { - "id": 199, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-03-31T15:49:39Z" - }, - { - "id": 198, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-03-31T15:49:39Z" - }, - { - "id": 197, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-31T15:49:39Z" - }, - { - "id": 196, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-03-31T15:49:35Z" - }, - { - "id": 195, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-31T15:49:35Z" - }, - { - "id": 194, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-03-31T15:49:30Z" - }, - { - "id": 193, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-03-31T15:49:06Z" - }, - { - "id": 192, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-03-31T15:49:06Z" - }, - { - "id": 191, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-03-31T15:49:06Z" - }, - { - "id": 190, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-03-31T15:49:06Z" - }, - { - "id": 189, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-03-31T15:49:06Z" - }, - { - "id": 188, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-31T15:49:06Z" - }, - { - "id": 187, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-03-31T15:49:01Z" - }, - { - "id": 186, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-31T15:49:01Z" - }, - { - "id": 185, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-03-31T15:48:57Z" - }, - { - "id": 184, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-03-31T15:47:28Z" - }, - { - "id": 183, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-03-31T15:47:28Z" - }, - { - "id": 182, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-03-31T15:47:28Z" - }, - { - "id": 181, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-03-31T15:47:28Z" - }, - { - "id": 180, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-03-31T15:47:27Z" - }, - { - "id": 179, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-31T15:47:27Z" - }, - { - "id": 178, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-03-31T15:47:23Z" - }, - { - "id": 177, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-31T15:47:23Z" - }, - { - "id": 176, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-03-31T15:47:19Z" - }, - { - "id": 175, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-03-31T15:43:41Z" - }, - { - "id": 174, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-03-31T15:43:41Z" - }, - { - "id": 173, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-03-31T15:43:41Z" - }, - { - "id": 172, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-03-31T15:43:41Z" - }, - { - "id": 171, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-03-31T15:43:41Z" - }, - { - "id": 170, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-31T15:43:41Z" - }, - { - "id": 169, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-03-31T15:43:36Z" - }, - { - "id": 168, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-31T15:43:36Z" - }, - { - "id": 167, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-03-31T15:43:34Z" - }, - { - "id": 166, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-03-31T15:43:34Z" - }, - { - "id": 165, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-03-31T15:43:34Z" - }, - { - "id": 164, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-03-31T15:43:34Z" - }, - { - "id": 163, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-03-31T15:43:34Z" - }, - { - "id": 162, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-03-31T15:43:34Z" - }, - { - "id": 161, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-03-31T15:43:33Z" - }, - { - "id": 160, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-03-31T15:43:33Z" - }, - { - "id": 159, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-03-31T15:43:33Z" - }, - { - "id": 158, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-03-31T15:43:33Z" - }, - { - "id": 157, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-03-31T15:43:33Z" - }, - { - "id": 156, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-03-31T15:43:33Z" - }, - { - "id": 155, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-03-31T15:43:33Z" - }, - { - "id": 154, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-03-31T15:43:33Z" - }, - { - "id": 153, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-03-31T15:43:33Z" - }, - { - "id": 152, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connection is still allocated", - "logInstant": "2021-03-31T15:43:33Z" - }, - { - "id": 151, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connection is still allocated", - "logInstant": "2021-03-31T15:43:33Z" - }, - { - "id": 150, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connection is still allocated", - "logInstant": "2021-03-31T15:43:33Z" - }, - { - "id": 149, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-03-31T15:43:32Z" - }, - { - "id": 148, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-03-31T15:43:32Z" - }, - { - "id": 147, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-03-31T15:43:32Z" - }, - { - "id": 146, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connection is still allocated", - "logInstant": "2021-03-31T15:43:32Z" - }, - { - "id": 145, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connection is still allocated", - "logInstant": "2021-03-31T15:43:32Z" - }, - { - "id": 144, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connection is still allocated", - "logInstant": "2021-03-31T15:43:32Z" - }, - { - "id": 143, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-03-31T15:43:32Z" - }, - { - "id": 142, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-03-31T15:43:32Z" - }, - { - "id": 141, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-03-31T15:43:32Z" - }, - { - "id": 140, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-03-31T15:43:32Z" - }, - { - "id": 139, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-03-31T10:13:01Z" - }, - { - "id": 138, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-03-31T10:13:01Z" - }, - { - "id": 137, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-03-31T10:13:00Z" - }, - { - "id": 136, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-03-31T10:13:00Z" - }, - { - "id": 135, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-03-31T10:13:00Z" - }, - { - "id": 134, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-31T10:13:00Z" - }, - { - "id": 133, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-03-31T10:12:56Z" - }, - { - "id": 132, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-31T10:12:56Z" - }, - { - "id": 131, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-03-31T10:12:52Z" - }, - { - "id": 130, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-03-31T09:55:12Z" - }, - { - "id": 129, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-03-31T09:55:12Z" - }, - { - "id": 128, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-03-31T09:55:12Z" - }, - { - "id": 127, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-03-31T09:55:12Z" - }, - { - "id": 126, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-03-31T09:55:12Z" - }, - { - "id": 125, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-31T09:55:12Z" - }, - { - "id": 124, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-03-31T09:55:08Z" - }, - { - "id": 123, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-31T09:55:07Z" - }, - { - "id": 122, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-03-31T09:55:03Z" - }, - { - "id": 121, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-03-31T09:46:18Z" - }, - { - "id": 120, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-03-31T09:46:18Z" - }, - { - "id": 119, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-03-31T09:46:18Z" - }, - { - "id": 118, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-03-31T09:46:18Z" - }, - { - "id": 117, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-03-31T09:46:18Z" - }, - { - "id": 116, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-31T09:46:18Z" - }, - { - "id": 115, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-03-31T09:46:13Z" - }, - { - "id": 114, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-31T09:46:13Z" - }, - { - "id": 113, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-03-31T09:46:09Z" - }, - { - "id": 112, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-03-31T09:45:56Z" - }, - { - "id": 111, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-03-31T09:45:56Z" - }, - { - "id": 110, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-03-31T09:45:56Z" - }, - { - "id": 109, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-03-31T09:45:56Z" - }, - { - "id": 108, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-03-31T09:45:56Z" - }, - { - "id": 107, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-31T09:45:55Z" - }, - { - "id": 106, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-03-31T09:45:51Z" - }, - { - "id": 105, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-31T09:45:51Z" - }, - { - "id": 104, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-03-31T09:45:47Z" - }, - { - "id": 103, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-03-30T16:00:55Z" - }, - { - "id": 102, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-03-30T16:00:55Z" - }, - { - "id": 101, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-03-30T16:00:55Z" - }, - { - "id": 100, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-03-30T16:00:55Z" - }, - { - "id": 99, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-03-30T16:00:55Z" - }, - { - "id": 98, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-30T16:00:54Z" - }, - { - "id": 97, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-03-30T16:00:50Z" - }, - { - "id": 96, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-30T16:00:50Z" - }, - { - "id": 95, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-03-30T16:00:46Z" - }, - { - "id": 94, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-03-30T15:58:05Z" - }, - { - "id": 93, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-03-30T15:58:05Z" - }, - { - "id": 92, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-03-30T15:58:05Z" - }, - { - "id": 91, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-03-30T15:58:05Z" - }, - { - "id": 90, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-03-30T15:58:05Z" - }, - { - "id": 89, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-30T15:58:05Z" - }, - { - "id": 88, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-03-30T15:58:00Z" - }, - { - "id": 87, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-30T15:58:00Z" - }, - { - "id": 86, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-03-30T15:57:56Z" - }, - { - "id": 85, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-03-30T15:00:21Z" - }, - { - "id": 84, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-03-30T15:00:21Z" - }, - { - "id": 83, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-03-30T15:00:21Z" - }, - { - "id": 82, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-03-30T15:00:21Z" - }, - { - "id": 81, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-03-30T15:00:21Z" - }, - { - "id": 80, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-30T15:00:21Z" - }, - { - "id": 79, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-03-30T15:00:17Z" - }, - { - "id": 78, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-30T15:00:17Z" - }, - { - "id": 77, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-03-30T15:00:12Z" - }, - { - "id": 76, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-03-30T14:51:24Z" - }, - { - "id": 75, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-03-30T14:51:23Z" - }, - { - "id": 74, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-03-30T14:51:23Z" - }, - { - "id": 73, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-03-30T14:51:23Z" - }, - { - "id": 72, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-03-30T14:51:23Z" - }, - { - "id": 71, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-30T14:51:23Z" - }, - { - "id": 70, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-03-30T14:51:19Z" - }, - { - "id": 69, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-30T14:51:19Z" - }, - { - "id": 68, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-03-30T14:51:15Z" - }, - { - "id": 67, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-03-30T14:45:06Z" - }, - { - "id": 66, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-03-30T14:45:06Z" - }, - { - "id": 65, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-03-30T14:45:06Z" - }, - { - "id": 64, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-03-30T14:45:06Z" - }, - { - "id": 63, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-03-30T14:45:06Z" - }, - { - "id": 62, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-30T14:45:06Z" - }, - { - "id": 61, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-03-30T14:45:02Z" - }, - { - "id": 60, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-30T14:45:02Z" - }, - { - "id": 59, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-03-30T14:44:57Z" - }, - { - "id": 58, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-03-30T14:44:31Z" - }, - { - "id": 57, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-03-30T14:44:31Z" - }, - { - "id": 56, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-03-30T14:44:31Z" - }, - { - "id": 55, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-03-30T14:44:31Z" - }, - { - "id": 54, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-03-30T14:44:31Z" - }, - { - "id": 53, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-30T14:44:31Z" - }, - { - "id": 52, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-03-30T14:44:27Z" - }, - { - "id": 51, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-30T14:44:26Z" - }, - { - "id": 50, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-03-30T14:44:22Z" - }, - { - "id": 49, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-03-30T14:32:12Z" - }, - { - "id": 48, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-03-30T14:32:12Z" - }, - { - "id": 47, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-03-30T14:32:12Z" - }, - { - "id": 46, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-03-30T14:32:12Z" - }, - { - "id": 45, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-03-30T14:32:12Z" - }, - { - "id": 44, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-30T14:32:11Z" - }, - { - "id": 43, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-03-30T14:32:07Z" - }, - { - "id": 42, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-30T14:32:07Z" - }, - { - "id": 41, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-03-30T14:32:03Z" - }, - { - "id": 40, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request successfully executed", - "logInstant": "2021-03-30T13:07:24Z" - }, - { - "id": 39, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "New loop state is: DESIGN", - "logInstant": "2021-03-30T13:07:24Z" - }, - { - "id": 38, - "logType": "INFO", - "logComponent": "DCAE", - "message": "DCAE state set to: BLUEPRINT_DEPLOYED - message: ", - "logInstant": "2021-03-30T13:07:24Z" - }, - { - "id": 37, - "logType": "INFO", - "logComponent": "POLICY", - "message": "Policy state set to: NOT_SENT", - "logInstant": "2021-03-30T13:07:24Z" - }, - { - "id": 36, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET Policy deployment\n status - : ", - "logInstant": "2021-03-30T13:07:24Z" - }, - { - "id": 35, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-30T13:07:24Z" - }, - { - "id": 34, - "logType": "INFO", - "logComponent": "POLICY", - "message": "MICROSERVICE_vLoadBalancerMS_v1_0_dcae-pm-subscription-handler_1_0_0_mHh GET\n Policy status - : ", - "logInstant": "2021-03-30T13:07:19Z" - }, - { - "id": 33, - "logType": "ERROR", - "logComponent": "CLAMP", - "message": "GET policy request failed, Error reported: Connect to localhost:8085 [localhost/127.0.0.1, localhost/0:0:0:0:0:0:0:1] failed: Connection refused: connect", - "logInstant": "2021-03-30T13:07:19Z" - }, - { - "id": 32, - "logType": "INFO", - "logComponent": "CLAMP", - "message": "GET STATUS request", - "logInstant": "2021-03-30T13:07:15Z" - } - ], - "loopTemplate": { - "name": "LOOP_TEMPLATE_k8s_pmsh", - "dcaeBlueprintId": "9dc5dba0-e685-4d5a-b144-8f4d84cfa01f", - "loopElementModelsUsed": [ - { - "loopElementModel": { - "name": "onap.policies.monitoring.dcae-pm-subscription-handler", - "loopElementType": "MICRO_SERVICE_TYPE", - "policyModels": [ - { - "policyModelType": "onap.policies.monitoring.dcae-pm-subscription-handler", - "version": "1.0.0", - "policyAcronym": "dcae-pm-subscription-handler", - "policyPdpGroup": { - "supportedPdpGroups": [ - { - "ControlLoopGroup": [ - "apex", - "xacml" - ] - }, - { - "defaultGroup": [ - "xacml" - ] - } - ] - }, - "createdDate": "2021-03-30T09:55:52.261232Z", - "updatedDate": "2021-03-30T09:56:17.502284Z", - "updatedBy": "Not found", - "createdBy": "Not found" - } - ], - "createdDate": "2021-03-30T08:48:21Z", - "updatedDate": "2021-03-30T08:48:21Z", - "updatedBy": "Not found", - "createdBy": "Not found" - }, - "flowOrder": 0 - } - ], - "modelService": { - "serviceDetails": { - "serviceType": "", - "serviceRole": "", - "description": "vLBMS", - "type": "Service", - "instantiationType": "A-la-carte", - "namingPolicy": "", - "serviceEcompNaming": "true", - "environmentContext": "General_Revenue-Bearing", - "name": "vLoadBalancerMS", - "invariantUUID": "30ec5b59-4799-48d8-ac5f-1058a6b0e48f", - "ecompGeneratedNaming": "true", - "UUID": "63cac700-ab9a-4115-a74f-7eac85e3fce0", - "category": "Network L4+" - }, - "resourceDetails": { - "CP": {}, - "VL": {}, - "VF": { - "vLoadBalancerMS 0": { - "resourceVendor": "Test", - "name": "vLoadBalancerMS", - "resourceVendorModelNumber": "", - "description": "vLBMS", - "invariantUUID": "1a31b9f2-e50d-43b7-89b3-a040250cf506", - "UUID": "b4c4f3d7-929e-4b6d-a1cd-57e952ddc3e6", - "type": "VF", - "category": "Application L4+", - "subcategory": "Load Balancer", - "version": "1.0", - "customizationUUID": "465246dc-7748-45f4-a013-308d92922552", - "resourceVendorRelease": "1.0", - "controllerProperties": { - "sdnc_model_name": "baseconfiguration", - "sdnc_model_version": "1.0.0", - "workflows": { - "resource-assignment": { - "inputs": { - "resource-assignment-properties": { - "type": "object", - "properties": { - "request-id": { - "required": true, - "type": "string", - "input-param": true - }, - "service-instance-id": { - "required": true, - "type": "string", - "input-param": true - }, - "hostname": { - "required": true, - "type": "string", - "input-param": true - }, - "request-info": { - "type": "object", - "properties": { - "prop1": { - "required": true, - "type": "string", - "input-param": true - }, - "prop2": { - "required": true, - "type": "string", - "input-param": true - } - } - } - } - } - } - }, - "activate": { - "inputs": { - "resource-assignment-properties": { - "type": "object", - "properties": { - "request-id": { - "required": true, - "type": "string", - "input-param": true - }, - "service-instance-id": { - "required": true, - "type": "string", - "input-param": true - }, - "hostname": { - "required": true, - "type": "string", - "input-param": true - }, - "request-info": { - "type": "object", - "properties": { - "prop1": { - "required": true, - "type": "string", - "input-param": true - }, - "prop2": { - "required": true, - "type": "string", - "input-param": true - } - } - } - } - } - } - }, - "activate-restconf": { - "inputs": { - "resource-assignment-properties": { - "type": "object", - "properties": { - "request-id": { - "required": true, - "type": "string", - "input-param": true - }, - "service-instance-id": { - "required": true, - "type": "string", - "input-param": true - }, - "hostname": { - "required": true, - "type": "string", - "input-param": true - }, - "request-info": { - "type": "object", - "properties": { - "prop1": { - "required": true, - "type": "string", - "input-param": true - }, - "prop2": { - "required": true, - "type": "string", - "input-param": true - } - } - } - } - } - } - }, - "activate-cli": { - "inputs": { - "resource-assignment-properties": { - "type": "object", - "properties": { - "request-id": { - "required": true, - "type": "string", - "input-param": true - }, - "service-instance-id": { - "required": true, - "type": "string", - "input-param": true - }, - "hostname": { - "required": true, - "type": "string", - "input-param": true - }, - "request-info": { - "type": "object", - "properties": { - "prop1": { - "required": true, - "type": "string", - "input-param": true - }, - "prop2": { - "required": true, - "type": "string", - "input-param": true - } - } - } - } - } - } - }, - "assign-activate": { - "inputs": { - "resource-assignment-properties": { - "type": "object", - "properties": { - "request-id": { - "required": true, - "type": "string", - "input-param": true - }, - "service-instance-id": { - "required": true, - "type": "string", - "input-param": true - }, - "hostname": { - "required": true, - "type": "string", - "input-param": true - }, - "request-info": { - "type": "object", - "properties": { - "prop1": { - "required": true, - "type": "string", - "input-param": true - }, - "prop2": { - "required": true, - "type": "string", - "input-param": true - } - } - } - } - } - } - }, - "imperative-test-wf": { - "inputs": { - "resource-assignment-properties": { - "type": "object", - "properties": { - "request-id": { - "required": true, - "type": "string", - "input-param": true - }, - "service-instance-id": { - "required": true, - "type": "string", - "input-param": true - }, - "hostname": { - "required": true, - "type": "string", - "input-param": true - }, - "request-info": { - "type": "object", - "properties": { - "prop1": { - "required": true, - "type": "string", - "input-param": true - }, - "prop2": { - "required": true, - "type": "string", - "input-param": true - } - } - } - } - } - } - } - } - } - } - }, - "CR": {}, - "VFC": {}, - "PNF": {}, - "Service": {}, - "CVFC": {}, - "Service Proxy": {}, - "Configuration": {}, - "AllottedResource": {}, - "VFModule": { - "Vloadbalancerms..vpkg..module-1": { - "vfModuleModelInvariantUUID": "ca052563-eb92-4b5b-ad41-9111768ce043", - "vfModuleModelVersion": "1", - "vfModuleModelName": "Vloadbalancerms..vpkg..module-1", - "vfModuleModelUUID": "1e725ccc-b823-4f67-82b9-4f4367070dbc", - "vfModuleModelCustomizationUUID": "1bffdc31-a37d-4dee-b65c-dde623a76e52", - "min_vf_module_instances": 0, - "vf_module_label": "vpkg", - "max_vf_module_instances": 1, - "vf_module_type": "Expansion", - "isBase": false, - "initial_count": 0, - "volume_group": false - }, - "Vloadbalancerms..vdns..module-3": { - "vfModuleModelInvariantUUID": "4c10ba9b-f88f-415e-9de3-5d33336047fa", - "vfModuleModelVersion": "1", - "vfModuleModelName": "Vloadbalancerms..vdns..module-3", - "vfModuleModelUUID": "4fa73b49-8a6c-493e-816b-eb401567b720", - "vfModuleModelCustomizationUUID": "bafcdab0-801d-4d81-9ead-f464640a38b1", - "min_vf_module_instances": 0, - "vf_module_label": "vdns", - "max_vf_module_instances": 50, - "vf_module_type": "Expansion", - "isBase": false, - "initial_count": 0, - "volume_group": false - }, - "Vloadbalancerms..base_template..module-0": { - "vfModuleModelInvariantUUID": "921f7c96-ebdd-42e6-81b9-1cfc0c9796f3", - "vfModuleModelVersion": "1", - "vfModuleModelName": "Vloadbalancerms..base_template..module-0", - "vfModuleModelUUID": "63734409-f745-4e4d-a38b-131638a0edce", - "vfModuleModelCustomizationUUID": "86baddea-c730-4fb8-9410-cd2e17fd7f27", - "min_vf_module_instances": 1, - "vf_module_label": "base_template", - "max_vf_module_instances": 1, - "vf_module_type": "Base", - "isBase": true, - "initial_count": 1, - "volume_group": false - }, - "Vloadbalancerms..vlb..module-2": { - "vfModuleModelInvariantUUID": "a772a1f4-0064-412c-833d-4749b15828dd", - "vfModuleModelVersion": "1", - "vfModuleModelName": "Vloadbalancerms..vlb..module-2", - "vfModuleModelUUID": "0f5c3f6a-650a-4303-abb6-fff3e573a07a", - "vfModuleModelCustomizationUUID": "96a78aad-4ffb-4ef0-9c4f-deb03bf1d806", - "min_vf_module_instances": 0, - "vf_module_label": "vlb", - "max_vf_module_instances": 1, - "vf_module_type": "Expansion", - "isBase": false, - "initial_count": 0, - "volume_group": false - } - } - } - }, - "maximumInstancesAllowed": 0, - "uniqueBlueprint": true, - "allowedLoopType": "CLOSED", - "createdDate": "2021-03-30T08:48:21Z", - "updatedDate": "2021-03-30T08:48:21Z", - "updatedBy": "Not found", - "createdBy": "Not found" - }, - "createdDate": "2021-03-30T13:07:07.901081Z", - "updatedDate": "2021-03-30T13:07:07.901081Z", - "updatedBy": "admin", - "createdBy": "admin" -} diff --git a/participant/participant-impl/participant-impl-kubernetes/src/main/java/org/onap/policy/clamp/controlloop/participant/kubernetes/handler/ControlLoopElementHandler.java b/participant/participant-impl/participant-impl-kubernetes/src/main/java/org/onap/policy/clamp/controlloop/participant/kubernetes/handler/ControlLoopElementHandler.java index a12fdcaac..a5d1f8841 100644 --- a/participant/participant-impl/participant-impl-kubernetes/src/main/java/org/onap/policy/clamp/controlloop/participant/kubernetes/handler/ControlLoopElementHandler.java +++ b/participant/participant-impl/participant-impl-kubernetes/src/main/java/org/onap/policy/clamp/controlloop/participant/kubernetes/handler/ControlLoopElementHandler.java @@ -147,8 +147,9 @@ public class ControlLoopElementHandler implements ControlLoopElementListener { var config = CODER.convert(nodeTemplate.getProperties(), ThreadConfig.class); checkPodStatus(chartInfo, config.uninitializedToPassiveTimeout, config.podStatusCheckInterval); - intermediaryApi.updateControlLoopElementState(element.getId(), ControlLoopOrderedState.PASSIVE, - ControlLoopState.UNINITIALISED, ParticipantMessageType.CONTROL_LOOP_STATE_CHANGE); + intermediaryApi.updateControlLoopElementState(controlLoopId, element.getId(), + ControlLoopOrderedState.PASSIVE, ControlLoopState.UNINITIALISED, + ParticipantMessageType.CONTROL_LOOP_STATE_CHANGE); } catch (ServiceException | CoderException | IOException e) { LOGGER.warn("Installation of Helm chart failed", e); diff --git a/participant/participant-impl/pom.xml b/participant/participant-impl/pom.xml index 439bdea90..006d38def 100644 --- a/participant/participant-impl/pom.xml +++ b/participant/participant-impl/pom.xml @@ -36,7 +36,6 @@ <modules> <module>participant-impl-simulator</module> - <module>participant-impl-dcae</module> <module>participant-impl-policy</module> <module>participant-impl-cds</module> <module>participant-impl-kubernetes</module> |