+++ /dev/null
-<!--
- ============LICENSE_START=======================================================
- Copyright (C) 2018 Ericsson. All rights reserved.
- Modifications Copyright (C) 2020,2022 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.apex-pdp.examples</groupId>
- <artifactId>examples</artifactId>
- <version>2.9.2-SNAPSHOT</version>
- </parent>
-
- <artifactId>examples-pcvs</artifactId>
- <name>${project.artifactId}</name>
- <description>Example for Policy-controlled Video Streaming</description>
-
- <properties>
- <policymodel.name>vpnsla</policymodel.name>
- </properties>
-
- <dependencies>
- <dependency>
- <groupId>org.onap.policy.common</groupId>
- <artifactId>utils</artifactId>
- </dependency>
- <dependency>
- <groupId>org.onap.policy.apex-pdp.model</groupId>
- <artifactId>model</artifactId>
- <version>${project.version}</version>
- </dependency>
- <dependency>
- <groupId>org.onap.policy.apex-pdp.core</groupId>
- <artifactId>core</artifactId>
- <version>${project.version}</version>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.onap.policy.apex-pdp.auth</groupId>
- <artifactId>cli-editor</artifactId>
- <version>${project.version}</version>
- </dependency>
- <dependency>
- <groupId>org.onap.policy.apex-pdp.plugins.plugins-executor</groupId>
- <artifactId>plugins-executor-mvel</artifactId>
- <version>${project.version}</version>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.onap.policy.apex-pdp.plugins.plugins-executor</groupId>
- <artifactId>plugins-executor-javascript</artifactId>
- <version>${project.version}</version>
- <scope>test</scope>
- </dependency>
- </dependencies>
-
- <build>
- <plugins>
- <plugin>
- <groupId>org.codehaus.mojo</groupId>
- <artifactId>exec-maven-plugin</artifactId>
- <executions>
- <execution>
- <id>generate-policy</id>
- <phase>compile</phase>
- <goals>
- <goal>java</goal>
- </goals>
- <configuration>
- <mainClass>org.onap.policy.apex.auth.clieditor.ApexCommandLineEditorMain</mainClass>
- <classpathScope>compile</classpathScope>
- <arguments>
- <argument>-command-file=${project.basedir}/src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/${policymodel.name}.apex</argument>
- <argument>-output-model-file=${project.build.directory}/classes/examples/models/pcvs/vpnsla/${policymodel.name}.json</argument>
- <argument>-log-file=${project.build.directory}/${policymodel.name}_policygeneration.log</argument>
- <argument>-working-dir=${project.basedir}</argument>
- </arguments>
- </configuration>
- </execution>
- </executions>
- </plugin>
- </plugins>
- </build>
-</project>
+++ /dev/null
-{
- "engineServiceParameters":{
- "name" : "VpnSlaApexEngine",
- "version" : "1.0.0",
- "id" : 45,
- "instanceCount" : 1,
- "deploymentPort" : 12345,
- "engineParameters" : {
- "executorParameters" : {
- "JAVASCRIPT" : {
- "parameterClassName" : "org.onap.policy.apex.plugins.executor.javascript.JavascriptExecutorParameters"
- }
- },
- 'contextParameters':{
- 'parameterClassName' : 'org.onap.policy.apex.context.parameters.ContextParameters',
- 'schemaParameters':{
- 'Avro':{
- 'parameterClassName' : 'org.onap.policy.apex.plugins.context.schema.avro.AvroSchemaHelperParameters'
- }
- }
- }
- }
- },
- "eventOutputParameters": {
- "aProducer": {
- "carrierTechnologyParameters":{
- "carrierTechnology" : "KAFKA",
- "parameterClassName" : "org.onap.policy.apex.plugins.event.carrier.kafka.KafkaCarrierTechnologyParameters",
- "parameters" : {
- 'bootstrapServers' : 'localhost:9092',
- 'acks' : 'all',
- 'retries' : 0,
- 'batchSize' : 16384,
- 'lingerTime' : 1,
- 'bufferMemory' : 33554432,
- 'producerTopic' : 'apex-out',
- 'keySerializer' : 'org.apache.kafka.common.serialization.StringSerializer',
- 'valueSerializer' : 'org.apache.kafka.common.serialization.StringSerializer'
- }
- },
- "eventProtocolParameters":{
- "eventProtocol" : "JSON"
- }
- }
- },
- "eventInputParameters": {
- "aConsumer": {
- "carrierTechnologyParameters":{
- "carrierTechnology" : "KAFKA",
- "parameterClassName" : "org.onap.policy.apex.plugins.event.carrier.kafka.KafkaCarrierTechnologyParameters",
- "parameters" : {
- 'bootstrapServers' : 'localhost:9092',
- 'groupId' : 'apex-group-id',
- 'enableAutoCommit' : true,
- 'autoCommitTime' : 1000,
- 'sessionTimeout' : 30000,
- 'consumerPollTime' : 100,
- 'consumerTopicList' : ['apex-in-0', 'apex-in-1'],
- 'keyDeserializer' : 'org.apache.kafka.common.serialization.StringDeserializer',
- 'valueDeserializer' : 'org.apache.kafka.common.serialization.StringDeserializer'
- }
- },
- "eventProtocolParameters":{
- "eventProtocol" : "JSON"
- }
- }
- }
-}
+++ /dev/null
-{
- "engineServiceParameters":{
- "name" : "VpnSlaApexEngine",
- "version" : "1.0.0",
- "id" : 45,
- "instanceCount" : 1,
- "deploymentPort" : 12345,
- "engineParameters" : {
- "executorParameters" : {
- "JAVASCRIPT" : {
- "parameterClassName" : "org.onap.policy.apex.plugins.executor.javascript.JavascriptExecutorParameters"
- }
- },
- "contextParameters":{
- "parameterClassName" : "org.onap.policy.apex.context.parameters.ContextParameters",
- "schemaParameters":{
- "Avro":{
- "parameterClassName" : "org.onap.policy.apex.plugins.context.schema.avro.AvroSchemaHelperParameters"
- }
- }
- }
- }
- },
- "eventOutputParameters": {
- "FirstProducer": {
- "carrierTechnologyParameters" : {
- "carrierTechnology" : "FILE",
- "parameters" : {
- "standardIo" : true
- }
- },
- "eventProtocolParameters" : {
- "eventProtocol" : "JSON"
- }
- }
- },
- "eventInputParameters": {
- "FirstConsumer": {
- "carrierTechnologyParameters" : {
- "carrierTechnology" : "FILE",
- "parameters" : {
- "standardIo" : true
- }
- },
- "eventProtocolParameters" : {
- "eventProtocol" : "JSON"
- }
- }
- }
-}
+++ /dev/null
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "CustomerContextEventIn",
- "version": "1.0.0",
- "source": "CtxtManagement",
- "target" : "VpnSlaPolicy_CustomerContext",
- "customerName": "A",
- "links": "L01 L05 L09 L10",
- "dtSLA": 180,
- "dtYTD": 10,
- "priority": false,
- "satisfaction": 80
-}
-
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "CustomerContextEventIn",
- "version": "1.0.0",
- "source": "CtxtManagement",
- "target" : "VpnSlaPolicy_CustomerContext",
- "customerName": "B",
- "links": "L02 L07 L09 L10",
- "dtSLA": 180,
- "dtYTD": 120,
- "priority": true,
- "satisfaction": 99
-}
-
+++ /dev/null
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "EdgeContextEventIn",
- "version": "1.0.0",
- "source": "CtxtManagement",
- "target" : "VpnSlaPolicy_EdgeContext",
- "edgeName": "L01",
- "start": "A1",
- "end": "A1CO",
- "status": true
-}
-
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "EdgeContextEventIn",
- "version": "1.0.0",
- "source": "CtxtManagement",
- "target" : "VpnSlaPolicy_EdgeContext",
- "edgeName": "L02",
- "start": "B1",
- "end": "B1CO",
- "status": true
-}
-
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "EdgeContextEventIn",
- "version": "1.0.0",
- "source": "CtxtManagement",
- "target" : "VpnSlaPolicy_EdgeContext",
- "edgeName": "L03",
- "start": "A2",
- "end": "A2CO",
- "status": true
-}
-
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "EdgeContextEventIn",
- "version": "1.0.0",
- "source": "CtxtManagement",
- "target" : "VpnSlaPolicy_EdgeContext",
- "edgeName": "L04",
- "start": "B2",
- "end": "B2CO",
- "status": true
-}
-
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "EdgeContextEventIn",
- "version": "1.0.0",
- "source": "CtxtManagement",
- "target" : "VpnSlaPolicy_EdgeContext",
- "edgeName": "L05",
- "start": "A1CO",
- "end": "BBL",
- "status": true
-}
-
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "EdgeContextEventIn",
- "version": "1.0.0",
- "source": "CtxtManagement",
- "target" : "VpnSlaPolicy_EdgeContext",
- "edgeName": "L06",
- "start": "B1CO",
- "end": "BBL",
- "status": true
-}
-
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "EdgeContextEventIn",
- "version": "1.0.0",
- "source": "CtxtManagement",
- "target" : "VpnSlaPolicy_EdgeContext",
- "edgeName": "L07",
- "start": "A2CO",
- "end": "BBR",
- "status": true
-}
-
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "EdgeContextEventIn",
- "version": "1.0.0",
- "source": "CtxtManagement",
- "target" : "VpnSlaPolicy_EdgeContext",
- "edgeName": "L08",
- "start": "B2CO",
- "end": "BBR",
- "status": true
-}
-
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "EdgeContextEventIn",
- "version": "1.0.0",
- "source": "CtxtManagement",
- "target" : "VpnSlaPolicy_EdgeContext",
- "edgeName": "L09",
- "start": "BBL",
- "end": "BBR",
- "status": true
-}
-
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "EdgeContextEventIn",
- "version": "1.0.0",
- "source": "CtxtManagement",
- "target" : "VpnSlaPolicy_EdgeContext",
- "edgeName": "L10",
- "start": "BBR",
- "end": "BBL",
- "status": true
-}
-
+++ /dev/null
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "NodeContextEventIn",
- "version": "1.0.0",
- "source": "CtxtManagement",
- "target" : "VpnSlaPolicy_NodeContext",
- "nodeName": "A1",
- "mininetName": "nn"
-}
-
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "NodeContextEventIn",
- "version": "1.0.0",
- "source": "CtxtManagement",
- "target" : "VpnSlaPolicy_NodeContext",
- "nodeName": "A2",
- "mininetName": "nn"
-}
-
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "NodeContextEventIn",
- "version": "1.0.0",
- "source": "CtxtManagement",
- "target" : "VpnSlaPolicy_NodeContext",
- "nodeName": "B1",
- "mininetName": "nn"
-}
-
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "NodeContextEventIn",
- "version": "1.0.0",
- "source": "CtxtManagement",
- "target" : "VpnSlaPolicy_NodeContext",
- "nodeName": "B2",
- "mininetName": "nn"
-}
-
-
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "NodeContextEventIn",
- "version": "1.0.0",
- "source": "CtxtManagement",
- "target" : "VpnSlaPolicy_NodeContext",
- "nodeName": "A1CO",
- "mininetName": "s1"
-}
-
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "NodeContextEventIn",
- "version": "1.0.0",
- "source": "CtxtManagement",
- "target" : "VpnSlaPolicy_NodeContext",
- "nodeName": "A2CO",
- "mininetName": "s2"
-}
-
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "NodeContextEventIn",
- "version": "1.0.0",
- "source": "CtxtManagement",
- "target" : "VpnSlaPolicy_NodeContext",
- "nodeName": "B1CO",
- "mininetName": "s3"
-}
-
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "NodeContextEventIn",
- "version": "1.0.0",
- "source": "CtxtManagement",
- "target" : "VpnSlaPolicy_NodeContext",
- "nodeName": "B2CO",
- "mininetName": "s4"
-}
-
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "NodeContextEventIn",
- "version": "1.0.0",
- "source": "CtxtManagement",
- "target" : "VpnSlaPolicy_NodeContext",
- "nodeName": "BBL",
- "mininetName": "s5"
-}
-
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "NodeContextEventIn",
- "version": "1.0.0",
- "source": "CtxtManagement",
- "target" : "VpnSlaPolicy_NodeContext",
- "nodeName": "BBR",
- "mininetName": "s6"
-}
-
+++ /dev/null
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "VpnSlaTrigger",
- "version": "1.0.0",
- "source": "ExampleEvents",
- "target" : "VpnSlaPolicy",
- "edgeName": "L09",
- "status": "UP"
-}
-
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "VpnSlaTrigger",
- "version": "1.0.0",
- "source": "ExampleEvents",
- "target" : "VpnSlaPolicy",
- "edgeName": "L09",
- "status": "UP"
-}
-
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "VpnSlaTrigger",
- "version": "1.0.0",
- "source": "ExampleEvents",
- "target" : "VpnSlaPolicy",
- "edgeName": "L09",
- "status": "DOWN"
-}
-
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "VpnSlaTrigger",
- "version": "1.0.0",
- "source": "ExampleEvents",
- "target" : "VpnSlaPolicy",
- "edgeName": "L09",
- "status": "DOWN"
-}
-
-{
- "nameSpace": "org.onap.policy.apex.examples.pcvs.vpnsla",
- "name": "VpnSlaTrigger",
- "version": "1.0.0",
- "source": "ExampleEvents",
- "target" : "VpnSlaPolicy",
- "edgeName": "L09",
- "status": "UP"
-}
-
+++ /dev/null
-# ============LICENSE_START=======================================================
-# Copyright (C) 2016-2018 Ericsson. 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=========================================================
-
-import http.client
-import json
-import time
-from kafka import KafkaConsumer, KafkaProducer
-
-class StaticFlowPusher(object):
-
- def __init__(self, server):
- self.server = server
-
- def get(self, data):
- ret = self.rest_call({}, 'GET')
- return json.loads(ret[2])
-
- def set(self, data):
- ret = self.rest_call(data, 'POST')
- return ret[0] == 200
-
- def remove(self, objtype, data):
- ret = self.rest_call(data, 'DELETE')
- return ret[0] == 200
-
- def getControllerSummary(self, data):
- ret = self.rest_call_controller_summary({}, 'GET')
- return json.loads(ret[2])
-
- def getLinks(self, data):
- ret = self.rest_call_links({}, 'GET')
- return json.loads(ret[2].decode())
-
- def rest_call(self, data, action):
- path = '/wm/staticflowpusher/json'
- headers = {
- 'Content-type': 'application/json',
- 'Accept': 'application/json',
- }
- body = json.dumps(data)
- conn = http.client.HTTPConnection(self.server, 8080)
- conn.request(action, path, body, headers)
- response = conn.getresponse()
- ret = (response.status, response.reason, response.read())
- print(ret)
- conn.close()
- return ret
-
- def rest_call_controller_summary(self, data, action):
- path = '/wm/core/controller/summary/json'
- headers = {
- 'Content-type': 'application/json',
- 'Accept': 'application/json',
- }
- body = json.dumps(data)
- conn = http.client.HTTPConnection(self.server, 8080)
- conn.request(action, path, body, headers)
- response = conn.getresponse()
- ret = (response.status, response.reason, response.read())
- print(ret)
- conn.close()
- return ret
-
- def rest_call_links(self, data, action):
- path = '/wm/topology/links/json'
- headers = {
- 'Content-type': 'application/json',
- 'Accept': 'application/json',
- }
- body = json.dumps(data)
- conn = http.client.HTTPConnection(self.server, 8080)
- conn.request(action, path, body, headers)
- response = conn.getresponse()
- ret = (response.status, response.reason, response.read())
- conn.close()
- return ret
-
-pusher = StaticFlowPusher('127.0.1.1')
-
-
-def parseLinks(links):
- #print("\n\n\n",links)
- result = []
- for link in links:
- list = []
- #print("\n\n\n",link)
- #print("\nsrc-switch : s", link['src-switch'][len(link['src-switch'])-1])
- #print("\ndst-switch : s", link['dst-switch'][len(link['dst-switch'])-1])
- list.append("s")
- list.append(link['src-switch'][len(link['src-switch'])-1])
- list.append("-s")
- list.append(link['dst-switch'][len(link['dst-switch'])-1])
- result.append(''.join(list))
- #print(result, "\n")
- return result
-
-
-
-counter =0
-healthyList = []
-testableList = []
-healthyLinks = ""
-testableLinks = ""
-producer = KafkaProducer(bootstrap_servers='localhost:9092')
-while(True):
- time.sleep(30)
- switchLinks = pusher.getLinks({})
- if counter == 0:
- healthyList = parseLinks(switchLinks)
- #Build All Links
- print("READING LINKS FROM MININET\n")
- for l in healthyList:
- link = ""
- #print(l, "\n")
- #Links between switches [s6-s7 is ignored so it matches VPN SCENARIO]
- if(l == "s1-s5"):
- link = "{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'EdgeContextEventIn','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy_EdgeContext','status': true,'edgeName': 'L05', 'start': 'A1CO','end': 'BBL'}"
- producer.send("apex-in-0", bytes(link, encoding="ascii"))
- if(l == "s5-s6"):
- link = "{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'EdgeContextEventIn','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy_EdgeContext','status': true,'edgeName': 'L09', 'start': 'BBL','end': 'BBR'}"
- producer.send("apex-in-0", bytes(link, encoding="ascii"))
- if(l == "s2-s6"):
- link = "{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'EdgeContextEventIn','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy_EdgeContext','status': true,'edgeName': 'L07', 'start': 'A2CO','end': 'BBR'}"
- producer.send("apex-in-0", bytes(link, encoding="ascii"))
- if(l == "s5-s7"):
- link = "{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'EdgeContextEventIn','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy_EdgeContext','status': true,'edgeName': 'L10', 'start': 'BBR','end': 'BBL'}"
- producer.send("apex-in-0", bytes(link, encoding="ascii"))
- if(l == "s3-s5"):
- link = "{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'EdgeContextEventIn','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy_EdgeContext','status': true,'edgeName': 'L06', 'start': 'B1CO','end': 'BBL'}"
- producer.send("apex-in-0", bytes(link, encoding="ascii"))
- if(l == "s4-s6"):
- link = "{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'EdgeContextEventIn','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy_EdgeContext','status': true,'edgeName': 'L08', 'start': 'B2CO','end': 'BBR'}"
- producer.send("apex-in-0", bytes(link, encoding="ascii"))
- #Links between switches and hosts [NoT SENT IN FROM FLOODLIGHT]
- producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'EdgeContextEventIn','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy_EdgeContext','status': true,'edgeName': 'L01', 'start': 'A1','end': 'A1CO'}")
- producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'EdgeContextEventIn','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy_EdgeContext','status': true,'edgeName': 'L02', 'start': 'B1','end': 'B1CO'}")
- producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'EdgeContextEventIn','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy_EdgeContext','status': true,'edgeName': 'L03', 'start': 'A2','end': 'A2CO'}")
- producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'EdgeContextEventIn','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy_EdgeContext','status': true,'edgeName': 'L04', 'start': 'B2','end': 'B2CO'}")
- print("LINKS HAVE BEEN SENT TO APEX\n")
-
- #Build Customers
- print("BUILDING CUSTOMERS\n")
- producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'CustomerContextEventIn','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy_CustomerContext','dtYTD': 10,'dtSLA': 180,'links': 'L01 L05 L09 L10','customerName': 'A', 'priority': true,'satisfaction': 80}")
- producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'CustomerContextEventIn','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy_CustomerContext','dtYTD': 120,'dtSLA': 180,'links': 'L02 L07 L09 L10','customerName': 'B', 'priority': false,'satisfaction': 99}")
- print("CUSTOMERS HAVE BEEN SENT TO APEX\n")
- healthyLinks = switchLinks
- myfile = open('LinkInfo.json', 'a')
- myfile.write(str(healthyLinks))
- myfile.write('\n')
- myfile.close()
- print("We start off with", len(healthyLinks), "healthy Links!\n")
- else:
- testableList = parseLinks(switchLinks)
- issueLink = "";
- for h in healthyList:
- issueLink = h
- for t in testableList:
- if t == h:
- issueLink = ""
- if issueLink != "":
- print("There is an issue with the links! ", issueLink, " \n")
- if(issueLink == "s1-s5"):
- link = "{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'DOWN','edgeName': 'L05'}"
- producer.send("apex-in-0", bytes(link, encoding="ascii"))
- if(issueLink == "s5-s6"):
- link = "{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'DOWN','edgeName': 'L09'}"
- producer.send("apex-in-0", bytes(link, encoding="ascii"))
- if(issueLink == "s2-s6"):
- link = "{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'DOWN','edgeName': 'L07'}"
- producer.send("apex-in-0", bytes(link, encoding="ascii"))
- if(issueLink == "s5-s7"):
- link = "{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'DOWN','edgeName': 'L10'}"
- producer.send("apex-in-0", bytes(link, encoding="ascii"))
- if(issueLink == "s3-s5"):
- link = "{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'DOWN','edgeName': 'L06'}"
- producer.send("apex-in-0", bytes(link, encoding="ascii"))
- if(issueLink == "s4-s6"):
- link = "{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'DOWN','edgeName': 'L08'}"
- producer.send("apex-in-0", bytes(link, encoding="ascii"))
- break
- if issueLink == "":
- print("All Links are working\n")
- producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'UP','edgeName': 'L01'}")
- producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'UP','edgeName': 'L02'}")
- producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'UP','edgeName': 'L03'}")
- producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'UP','edgeName': 'L04'}")
- producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'UP','edgeName': 'L05'}")
- producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'UP','edgeName': 'L06'}")
- producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'UP','edgeName': 'L07'}")
- producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'UP','edgeName': 'L08'}")
- producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'UP','edgeName': 'L09'}")
- producer.send("apex-in-0", b"{'nameSpace': 'org.onap.policy.apex.examples.pcvs.vpnsla','name': 'VpnSlaTrigger','version': '1.0.0','source': 'LinkMonitor.py','target': 'VpnSlaPolicy','status': 'UP','edgeName': 'L10'}")
-
- testableLinks = switchLinks
- myfile = open('LinkInfo.json', 'a')
- myfile.write(str(testableLinks))
- myfile.write('\n')
- myfile.close()
- counter += 1
+++ /dev/null
-# ============LICENSE_START=======================================================
-# Copyright (C) 2016-2018 Ericsson. 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=========================================================
-
-#Add Mininet to PATH
-import sys
-sys.path.insert(0, "/~/mininet")
-
-#Kafka
-import httplib
-import json
-import time
-from kafka import KafkaConsumer, KafkaProducer
-
-#Mininet
-from mininet.clean import *
-from mininet.cli import *
-from mininet.link import *
-from mininet.log import *
-from mininet.net import *
-from mininet.node import *
-from mininet.nodelib import *
-from mininet.topo import *
-from mininet.topolib import *
-
-class StaticFlowPusher(object):
- def __init__(self, server):
- self.server = server
-
- def enableFirewall(self, data):
- path = "/wm/firewall/module/enable/json"
- headers = {'Content-Type': 'application/json','Accept': 'application/json',}
- body = json.dumps(data)
- conn = httplib.HTTPConnection(self.server, 8080)
- conn.request("PUT", path, "")
- response = conn.getresponse()
- ret = (response.status, response.reason, response.read())
- conn.close()
- return ret
-
- def addRule(self, data):
- path = '/wm/firewall/rules/json'
- headers = {'Content-Type': 'application/json','Accept': 'application/json',}
- body = json.dumps(data)
- conn = httplib.HTTPConnection(self.server, 8080)
- conn.request('POST', path, body, headers)
- response = conn.getresponse()
- ret = (response.status, response.reason, response.read())
- conn.close()
- return ret
-
- def deleteRule(self, data):
- path = '/wm/firewall/rules/json'
- headers = {'Content-Type': 'application/json','Accept': 'application/json',}
- body = json.dumps(data)
- conn = httplib.HTTPConnection(self.server, 8080)
- conn.request('DELETE', path, body, headers)
- response = conn.getresponse()
- ret = (response.status, response.reason, response.read())
- conn.close()
- return ret
-
-#Build Pusher(REST/IN)
-pusher = StaticFlowPusher('127.0.0.1')
-
-net = Mininet(link=TCLink)
-
-#Create Customers
-customerA1 = net.addHost( 'A1' )
-customerA2 = net.addHost( 'A2' )
-customerB1 = net.addHost( 'B1' )
-customerB2 = net.addHost( 'B2' )
-
-#Create Switches
-switchA1CO = net.addSwitch( 's1' )
-switchA2CO = net.addSwitch( 's2' )
-switchB1CO = net.addSwitch( 's3' )
-switchB2CO = net.addSwitch( 's4' )
-switchBBL = net.addSwitch( 's5' )
-switchBBR = net.addSwitch( 's6' )
-# we need an extra switch here because Mininet does not allow two links between two switches
-switchEx = net.addSwitch( 's7' )
-
-#Create Links
-net.addLink( customerA1, switchA1CO )
-net.addLink( customerA2, switchA2CO )
-net.addLink( customerB1, switchB1CO )
-net.addLink( customerB2, switchB2CO )
-net.addLink( switchA1CO, switchBBL )
-net.addLink( switchB1CO, switchBBL )
-net.addLink( switchA2CO, switchBBR )
-net.addLink( switchB2CO, switchBBR )
-net.addLink( switchBBL, switchBBR)
-net.addLink( switchBBR, switchEx, bw=1.2 )
-net.addLink( switchEx, switchBBL )
-
-#Create Controller
-floodlightController = net.addController(name='c0' , controller=RemoteController , ip='127.0.0.1', port=6653)
-
-net.start()
-
-if pusher.enableFirewall({})[0] == 200:
- print("Firewall enabled!")
-
-#print(pusher.addRule({"switchid": "00:00:00:00:00:00:00:01"})[2])
-s1id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:01"})[2])['rule-id']
-s2id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:02"})[2])['rule-id']
-s3id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:03"})[2])['rule-id']
-s4id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:04"})[2])['rule-id']
-s5id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:05"})[2])['rule-id']
-s6id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:06"})[2])['rule-id']
-s7id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:07"})[2])['rule-id']
-
-
-result = 100
-while result!=0:
- result = net.pingAll(None)
-print("Network Simulation Complete")
-
-#Assume control and when finished "exit"
-cli = CLI( net )
-
-consumer = KafkaConsumer(bootstrap_servers='localhost:9092',auto_offset_reset='latest')
-consumer.subscribe(['apex-out'])
-print("Starting Message Loop")
-for message in consumer:
- myOutput = json.loads(message.value.decode())
- action = ""
- try:
- print("Checking Message")
- #print("SWITCHES= ",net.switches)
- #print("LINKS= ",net.links)
- #print("VALUES= ",net.values)
- if myOutput['edgeName'] != '':
- print("Message Received: ",myOutput['edgeName'])
- pusher.deleteRule({"ruleid": s1id})
- pusher.deleteRule({"ruleid": s2id})
- pusher.deleteRule({"ruleid": s3id})
- pusher.deleteRule({"ruleid": s4id})
- pusher.deleteRule({"ruleid": s5id})
- pusher.deleteRule({"ruleid": s6id})
- pusher.deleteRule({"ruleid": s7id})
- s1id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:01"})[2])['rule-id']
- s2id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:02"})[2])['rule-id']
- s3id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:03"})[2])['rule-id']
- s4id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:04"})[2])['rule-id']
- s5id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:05"})[2])['rule-id']
- s6id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:06"})[2])['rule-id']
- s7id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:07"})[2])['rule-id']
- if myOutput['edgeName'] == "L01":
- action = "link s1 s5 down"
- #net.configLinkStatus('s1', 's5', "down")
- pusher.deleteRule({"ruleid": s1id})
- s1id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:01", "action": "DENY"})[2])['rule-id']
- if myOutput['edgeName'] == "L02":
- action = "link s3 s5 down"
- #net.configLinkStatus('s3', 's5', "down")
- pusher.deleteRule({"ruleid": s3id})
- s3id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:03", "action": "DENY"})[2])['rule-id']
- if myOutput['edgeName'] == "L03":
- action = "link s2 s6 down"
- #net.configLinkStatus('s2', 's6', "down")
- pusher.deleteRule({"ruleid": s1id})
- s1id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:01", "action": "DENY"})[2])['rule-id']
- if myOutput['edgeName'] == "L04":
- action = "link s4 s6 down"
- #net.configLinkStatus('s4', 's6', "down")
- pusher.deleteRule({"ruleid": s3id})
- s3id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:03", "action": "DENY"})[2])['rule-id']
- if myOutput['edgeName'] == "L05":
- action = "link s1 s5 down"
- #net.configLinkStatus('s1', 's5', "down")
- pusher.deleteRule({"ruleid": s1id})
- s1id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:01", "action": "DENY"})[2])['rule-id']
- if myOutput['edgeName'] == "L06":
- action = "link s3 s5 down"
- #net.configLinkStatus('s3', 's5', "down")
- pusher.deleteRule({"ruleid": s3id})
- s3id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:03", "action": "DENY"})[2])['rule-id']
- if myOutput['edgeName'] == "L07":
- action = "link s2 s6 down"
- #net.configLinkStatus('s2', 's6', "down")
- pusher.deleteRule({"ruleid": s2id})
- s2id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:02", "action": "DENY"})[2])['rule-id']
- if myOutput['edgeName'] == "L08":
- action = "link s4 s6 down"
- #net.configLinkStatus('s4', 's6', "down")
- pusher.deleteRule({"ruleid": s4id})
- s4id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:04", "action": "DENY"})[2])['rule-id']
- if myOutput['edgeName'] == "L09":
- action = "link s5 s6 down"
- #net.configLinkStatus('s5', 's6', "down")
- pusher.deleteRule({"ruleid": s7id})
- s7id = json.loads(pusher.addRule({"switchid": "00:00:00:00:00:00:00:07", "action": "DENY"})[2])['rule-id']
- if myOutput['edgeName'] == "L10":
- print("L10")
- #print(action)
- #print("3")
- except KeyError:
- print(myOutput)
-print("HA")
-net.stop()
+++ /dev/null
-#!/usr/bin/env bash
-
-# ============LICENSE_START=======================================================
-# Copyright (C) 2016-2018 Ericsson. 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=========================================================
-
-cp $APEX_HOME/etc/logback-logic.xml $APEX_HOME/etc/logback.xml
-cp $APEX_HOME/examples/scripts/pcvs/vpnsla/LinkMonitor.py $src_dir/kafka-python
-
+++ /dev/null
-#!/usr/bin/env bash
-
-# ============LICENSE_START=======================================================
-# Copyright (C) 2016-2018 Ericsson. 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=========================================================
-
-export src_dir=/usr/local/src
-export APEX_HOME=/opt/app/policy/apex-pdp
-export APEX_USER=apexuser
+++ /dev/null
-#!/usr/bin/env bash
-
-# ============LICENSE_START=======================================================
-# Copyright (C) 2016-2018 Ericsson. 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=========================================================
-
-(cd $APEX_HOME; ./bin/apexApps.sh engine -c examples/config/pcvs/vpnsla/kafka2kafka.json)
+++ /dev/null
-#!/usr/bin/env bash
-
-# ============LICENSE_START=======================================================
-# Copyright (C) 2016-2018 Ericsson. 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=========================================================
-
-(cd $src_dir/floodlight-master; java -jar target/floodlight.jar)
+++ /dev/null
-#!/usr/bin/env bash
-
-# ============LICENSE_START=======================================================
-# Copyright (C) 2016-2018 Ericsson. 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=========================================================
-
-/opt/Kafka/kafka_2.12-1.0.0/bin/kafka-server-start.sh /opt/Kafka/kafka_2.12-1.0.0/config/server.properties
\ No newline at end of file
+++ /dev/null
-#!/usr/bin/env bash
-
-# ============LICENSE_START=======================================================
-# Copyright (C) 2016-2018 Ericsson. 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=========================================================
-
-(cd $src_dir; python3 $src_dir/kafka-python/LinkMonitor.py)
\ No newline at end of file
+++ /dev/null
-#!/usr/bin/env bash
-
-# ============LICENSE_START=======================================================
-# Copyright (C) 2016-2018 Ericsson. 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=========================================================
-
-mn -c && python $APEX_HOME/examples/scripts/pcvs/vpnsla/MininetTopology.py
+++ /dev/null
-#!/usr/bin/env bash
-
-# ============LICENSE_START=======================================================
-# Copyright (C) 2016-2018 Ericsson. 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=========================================================
-
-MOD_SCRIPT_NAME=`basename $0`
-
-if [ $# -eq 0 ]; then
- echo ""
- echo "$MOD_SCRIPT_NAME - run VLC that streams video"
- echo ""
- echo " Usage: $MOD_SCRIPT_NAME [video file]"
- echo ""
- exit
-fi
-
-vlc-wrapper -vvv $1 --sout "#duplicate{dst=rtp{dst=10.0.0.2,port=5004,mux=ts},dst=display}" --sout-keep -q
-
+++ /dev/null
-#!/usr/bin/env bash
-
-# ============LICENSE_START=======================================================
-# Copyright (C) 2016-2018 Ericsson. 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=========================================================
-
-vlc-wrapper rtp://@:5004 -q
-
+++ /dev/null
-#!/usr/bin/env bash
-
-# ============LICENSE_START=======================================================
-# Copyright (C) 2016-2018 Ericsson. 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=========================================================
-
-MOD_SCRIPT_NAME=`basename $0`
-
-if [ $# -eq 0 ]; then
- echo ""
- echo "$MOD_SCRIPT_NAME - run VLC that streams video"
- echo ""
- echo " Usage: $MOD_SCRIPT_NAME [video file]"
- echo ""
- exit
-fi
-
-vlc-wrapper -vvv $1 --sout "#duplicate{dst=rtp{dst=10.0.0.4,port=5004,mux=ts},dst=display}" --sout-keep -q
-
+++ /dev/null
-#!/usr/bin/env bash
-
-# ============LICENSE_START=======================================================
-# Copyright (C) 2016-2018 Ericsson. 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=========================================================
-
-vlc-wrapper rtp://@:5004 -q
-
+++ /dev/null
-{
- "type" : "record",
- "name" : "Customer",
- "fields" : [
- {"name" : "customerName", "type" : "string"},
- {"name" : "dtSLA" , "type" : "int"},
- {"name" : "dtYTD" , "type" : "int"},
- {"name" : "priority" , "type" : "boolean"},
- {"name" : "satisfaction", "type" : "int"},
- {
- "name": "links",
- "doc": "Links used by this customer",
- "type": {"type" : "array", "items" : "string"}
- }
- ]
-}
+++ /dev/null
-{
- "type" : "record",
- "name" : "Situation",
- "fields" : [
- {"name": "description", "type": "string", "doc": "Description of the taken decision"},
- {
- "name": "decision",
- "doc": "taken decision",
- "type": {
- "type": "enum",
- "name": "decisionEnum",
- "symbols" : [
- "IMPEDE",
- "REBUILD",
- "NONE"
- ]
- }
- },
- {"name": "customers", "type": {"type" : "array", "items" : "string"}, "doc": "List of customers affected by the decision"},
- {"name": "problemID", "type": "string", "doc": "Identifier of the problem for lookup in problemMap"}
- ]
-}
+++ /dev/null
-{
- "type": "enum",
- "name": "Status",
- "symbols" : [
- "UP",
- "DOWN"
- ]
-}
+++ /dev/null
-{
- "type" : "record",
- "name" : "Problem",
- "fields" : [
- {"name": "edge", "type": "string"},
- {"name": "startTime", "type": "long"},
- {"name": "lastUpdate", "type": "long"},
- {"name": "endTime", "type": "long"},
- {
- "name": "status",
- "doc": "problem status",
- "type": {
- "type": "enum",
- "name": "statusEnum",
- "symbols" : [
- "NONE",
- "STILL",
- "SOLVED",
- "NEW"
- ]
- }
- },
- {
- "name": "edgeUsedBy",
- "doc": "customers using the edge",
- "type": {"type" : "array", "items" : "string"}
- },
- {
- "name": "impededLast",
- "doc": "customers last impeded",
- "type": {"type" : "array", "items" : "string"}
- }
- ]
-}
+++ /dev/null
-{
- "type" : "record",
- "name" : "Situation",
- "fields" : [
- {"name": "problemID", "type": "string", "doc": "Identifier of the problem for lookup in problemMap"},
- {"name": "violatedSLAs", "type": {"type" : "array", "items" : "string"}, "doc": "List of customers with SLA violations"}
- ]
-}
+++ /dev/null
-{
- "type" : "record",
- "name" : "TopologyEdges",
- "fields" : [
- {"name": "name", "type": "string", "doc": "Name of the Edge, typically a link name"},
- {"name": "start", "type": "string", "doc": "Edge endpoint: start - a node name"},
- {"name": "end", "type": "string", "doc": "Edge endpoint: end - a node name"},
- {"name": "active", "type": "boolean", "doc": "Flag for active/inactive edges, inactive means a link is down"}
- ]
-}
+++ /dev/null
-{
- "type" : "record",
- "name" : "TopologyNodes",
- "fields" : [
- {"name" : "name", "type" : "string", "doc": "The name of the node"},
- {"name" : "mnname", "type" : "string", "doc": "The name of the node in Mininet"}
- ]
-}
+++ /dev/null
-/*
- * ============LICENSE_START=======================================================
- * Copyright (C) 2016-2018 Ericsson. All rights reserved.
- * Modifications Copyright (C) 2020 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=========================================================
- */
-
-var logger = executor.logger;
-logger.trace("start: " + executor.subject.id);
-logger.trace("-- infields: " + executor.inFields);
-
-var ifCustomerName = executor.inFields["customerName"];
-var ifLinks = executor.inFields["links"];
-
-logger.trace("-- got infields, testing existing customer");
-var ctxtCustomer = executor.getContextAlbum("albumCustomerMap").get(ifCustomerName);
-if (ctxtCustomer != null) {
- executor.getContextAlbum("albumCustomerMap").remove(ifCustomerName);
- logger.trace("-- removed customer: <" + ifCustomerName + ">");
-}
-
-logger.trace("-- creating customer: <" + ifCustomerName + ">");
-var links = new Array();
-for (var i = 0; i < ifLinks.split(" ").length; i++) {
- var link = executor.getContextAlbum("albumTopoEdges").get(ifLinks.split(" ")[i]);
- if (link != null) {
- logger.trace("-- link: <" + ifLinks.split(" ")[i] + ">");
- links.push(ifLinks.split(" ")[i]);
- } else {
- logger.trace("-- unknown link: <" + ifLinks.split(" ")[i] + "> for customer <" + ifCustomerName + ">");
- }
-}
-logger.trace("-- links: <" + links + ">");
-ctxtCustomer = "{customerName:" + ifCustomerName + ", dtSLA:" + executor.inFields["dtSLA"] + ", dtYTD:"
- + executor.inFields["dtYTD"] + ", priority:" + executor.inFields["priority"] + ", satisfaction:"
- + executor.inFields["satisfaction"] + ", links:[" + links + "]}";
-
-executor.getContextAlbum("albumCustomerMap").put(ifCustomerName, ctxtCustomer);
-
-if (logger.isTraceEnabled()) {
- logger.trace(" >> *** Customers ***");
- if (executor.getContextAlbum("albumCustomerMap") != null) {
- for (var i = 0; i < executor.getContextAlbum("albumCustomerMap").values().size(); i++) {
- logger.trace(" >> >> " + executor.getContextAlbum("albumCustomerMap").values().get(i).get("customerName")
- + " : " + "dtSLA=" + executor.getContextAlbum("albumCustomerMap").values().get(i).get("dtSLA")
- + " : " + "dtYTD=" + executor.getContextAlbum("albumCustomerMap").values().get(i).get("dtYTD")
- + " : " + "links=" + executor.getContextAlbum("albumCustomerMap").values().get(i).get("links")
- + " : " + "priority="
- + executor.getContextAlbum("albumCustomerMap").values().get(i).get("priority") + " : "
- + "satisfaction="
- + executor.getContextAlbum("albumCustomerMap").values().get(i).get("satisfaction"));
- }
- } else {
- logger.trace(" >> >> customer album is null");
- }
-}
-
-executor.outFields["report"] = "customer ctxt :: added customer: " + ifCustomerName;
-
-logger.info("vpnsla: ctxt added customer " + ifCustomerName);
-
-logger.trace("finished: " + executor.subject.id);
-logger.debug(".");
-
-true;
+++ /dev/null
-/*
- * ============LICENSE_START=======================================================
- * Copyright (C) 2016-2018 Ericsson. All rights reserved.
- * Modifications Copyright (C) 2020 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=========================================================
- */
-
-var logger = executor.logger;
-logger.trace("start: " + executor.subject.id);
-logger.trace("-- infields: " + executor.inFields);
-
-var ifEdgeName = executor.inFields["edgeName"];
-var ifEdgeStatus = executor.inFields["status"];
-
-var albumTopoEdges = executor.getContextAlbum("albumTopoEdges");
-
-logger.trace("-- got infields, testing existing edge");
-
-var ctxtEdge = albumTopoEdges.get(ifEdgeName);
-if (ctxtEdge != null) {
- albumTopoEdges.remove(ifEdgeName);
- logger.trace("-- removed edge: <" + ifEdgeName + ">");
-}
-
-logger.trace("-- creating edge: <" + ifEdgeName + ">");
-ctxtEdge = "{name:" + ifEdgeName + ", start:" + executor.inFields["start"] + ", end:" + executor.inFields["end"]
- + ", active:" + ifEdgeStatus + "}";
-albumTopoEdges.put(ifEdgeName, ctxtEdge);
-
-if (logger.isTraceEnabled()) {
- logger.trace(" >> *** Edges ***");
- if (albumTopoEdges != null) {
- for (var i = 0; i < albumTopoEdges.values().size(); i++) {
- logger.trace(" >> >> " + albumTopoEdges.values().get(i).get("name") + " \t "
- + albumTopoEdges.values().get(i).get("start") + " --> " + albumTopoEdges.values().get(i).get("end")
- + " \t " + albumTopoEdges.values().get(i).get("active"));
- }
- } else {
- logger.trace(" >> >> edge album is null");
- }
-}
-
-executor.outFields["report"] = "edge ctxt :: added edge " + ifEdgeName;
-
-logger.info("vpnsla: ctxt added edge " + ifEdgeName);
-
-logger.trace("finished: " + executor.subject.id);
-logger.debug(".");
-
-true;
+++ /dev/null
-/*
- * ============LICENSE_START=======================================================
- * Copyright (C) 2016-2018 Ericsson. All rights reserved.
- * Modifications Copyright (C) 2020 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=========================================================
- */
-
-var logger = executor.logger;
-logger.trace("start: " + executor.subject.id);
-logger.trace("-- infields: " + executor.inFields);
-
-var ifNodeName = executor.inFields["nodeName"];
-var ifMininetName = executor.inFields["mininetName"];
-
-var albumTopoNodes = executor.getContextAlbum("albumTopoNodes");
-
-logger.trace("-- got infields, testing existing node");
-
-var ctxtNode = albumTopoNodes.get(ifNodeName);
-if (ctxtNode != null) {
- albumTopoNodes.remove(ifNodeName);
- logger.trace("-- removed node: <" + ifNodeName + ">");
-}
-
-logger.trace("-- creating node: <" + ifNodeName + ">");
-ctxtNode = "{name:" + ifNodeName + ", mnname:" + ifMininetName + "}";
-albumTopoNodes.put(ifNodeName, ctxtNode);
-
-if (logger.isTraceEnabled()) {
- logger.trace(" >> *** Nodes ***");
- if (albumTopoNodes != null) {
- for (var i = 0; i < albumTopoNodes.values().size(); i++) {
- logger.trace(" >> >> " + albumTopoNodes.values().get(i).get("name") + " : "
- + albumTopoNodes.values().get(i).get("mnname"));
- }
- } else {
- logger.trace(" >> >> node album is null");
- }
-}
-
-executor.outFields["report"] = "node ctxt :: added node " + ifNodeName;
-
-logger.info("vpnsla: ctxt added node " + ifNodeName);
-
-logger.trace("finished: " + executor.subject.id);
-logger.debug(".");
-
-true;
+++ /dev/null
-/*
- * ============LICENSE_START=======================================================
- * Copyright (C) 2016-2018 Ericsson. All rights reserved.
- * Modifications Copyright (C) 2020 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=========================================================
- */
-
-var logger = executor.logger;
-logger.trace("start: " + executor.subject.id);
-logger.trace("-- infields: " + executor.inFields);
-
-var ifDecision = executor.inFields["decision"];
-var ifMatchStart = executor.inFields["matchStart"];
-
-var albumCustomerMap = executor.getContextAlbum("albumCustomerMap");
-var albumProblemMap = executor.getContextAlbum("albumProblemMap");
-
-switch (ifDecision.get("decision").toString()) {
-case "NONE":
- executor.outFields["edgeName"] = "";
- executor.outFields["action"] = "";
- break;
-case "IMPEDE":
- for (var i = 0; i < ifDecision.get("customers").size(); i++) {
- customer = albumCustomerMap.get(ifDecision.get("customers").get(i).toString());
- executor.outFields["edgeName"] = customer.get("links").get(0);
- executor.outFields["action"] = "firewall";
- }
- break;
-case "REBUILD":
- // finally solved, remove problem
- albumProblemMap.remove(ifDecision.get("problemID"));
- executor.outFields["edgeName"] = "L10"; // this is ###static###
- executor.outFields["action"] = "rebuild"; // this is ###static###
- break;
-default:
-
-}
-
-if (executor.outFields["action"] != "") {
- logger.info("vpnsla: action is to " + executor.outFields["action"] + " " + executor.outFields["edgeName"]);
-} else {
- logger.info("vpnsla: no action required");
-}
-
-logger.trace("-- outfields: " + executor.outFields);
-logger.trace("finished: " + executor.subject.id);
-logger.debug(".a");
-
-var now = new Date().getTime();
-logger.info("VPN SLA finished in " + (now - ifMatchStart) + " ms");
-
-true;
+++ /dev/null
-/*
- * ============LICENSE_START=======================================================
- * Copyright (C) 2016-2018 Ericsson. All rights reserved.
- * Modifications Copyright (C) 2020 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=========================================================
- */
-
-importClass(org.slf4j.LoggerFactory);
-
-importClass(java.util.ArrayList);
-
-importClass(org.apache.avro.generic.GenericData.Array);
-importClass(org.apache.avro.generic.GenericRecord);
-importClass(org.apache.avro.Schema);
-
-var logger = executor.logger;
-logger.trace("start: " + executor.subject.id);
-logger.trace("-- infields: " + executor.inFields);
-
-var rootLogger = LoggerFactory.getLogger(logger.ROOT_LOGGER_NAME);
-
-var ifSituation = executor.inFields["situation"];
-
-// create outfiled for decision
-var decision = executor.subject.getOutFieldSchemaHelper("decision").createNewInstance();
-decision.put("description", "None, everything is ok");
-decision.put("decision", "NONE");
-decision.put("customers", new ArrayList());
-
-var returnValue = true;
-if (ifSituation.get("problemID") == "NONE") {
- logger.trace("-- no problem, everything ok");
-} else {
- logger.trace("-- wrong problemID <" + problemID + "> for NONE task, we should not be here");
- rootLogger.error(executor.subject.id + " " + "-- wrong problemID <" + problemID
- + "> for NONE task, we should not be here");
- returnValue = false;
-}
-
-executor.outFields["decision"] = decision;
-
-logger.trace("finished: " + executor.subject.id);
-logger.debug(".d-non");
-
-returnValue;
+++ /dev/null
-/*
- * ============LICENSE_START=======================================================
- * Copyright (C) 2016-2018 Ericsson. All rights reserved.
- * Modifications Copyright (C) 2020 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=========================================================
- */
-
-importClass(org.slf4j.LoggerFactory);
-
-importClass(java.util.ArrayList);
-
-importClass(org.apache.avro.generic.GenericData.Array);
-importClass(org.apache.avro.generic.GenericRecord);
-importClass(org.apache.avro.Schema);
-
-var logger = executor.logger;
-logger.trace("start: " + executor.subject.id);
-logger.trace("-- infields: " + executor.inFields);
-
-var rootLogger = LoggerFactory.getLogger(logger.ROOT_LOGGER_NAME);
-
-var ifSituation = executor.inFields["situation"];
-
-var albumCustomerMap = executor.getContextAlbum("albumCustomerMap");
-var albumProblemMap = executor.getContextAlbum("albumProblemMap");
-
-// create outfiled for decision
-var decision = executor.subject.getOutFieldSchemaHelper("decision").createNewInstance();
-decision.put("description", "None, everything is ok");
-decision.put("decision", "IMPEDE");
-decision.put("problemID", ifSituation.get("problemID"));
-decision.put("customers", new ArrayList());
-
-var problem = albumProblemMap.get(ifSituation.get("problemID"));
-var returnValue = true;
-if (problem != null && ifSituation.get("violatedSLAs").size() > 0) {
- logger.trace("-- impede by priority");
- for (var i = 0; i < problem.get("edgeUsedBy").size(); i++) {
- customerCtxt = albumCustomerMap.get(problem.get("edgeUsedBy").get(i).toString());
- if (customerCtxt.get("priority") == false) {
- decision.get("customers").add(customerCtxt.get("customerName"));
- }
- }
-} else {
- logger.trace("-- wrong problemID <" + ifSituation.get("problemID") + "> for PRIORITY task, we should not be here");
- rootLogger.error(executor.subject.id + " " + "-- wrong problemID <" + ifSituation.get("problemID")
- + "> for PRIORITY task, we should not be here");
- returnValue = false;
-}
-
-// set impededLast to decision[customers]
-problem.get("impededLast").clear();
-problem.get("impededLast").addAll(decision.get("customers"));
-
-executor.outFields["decision"] = decision;
-logger.trace("-- decision: " + decision);
-
-logger.info("vpnsla: priority, impeding customers " + decision.get("customers"));
-
-logger.trace("finished: " + executor.subject.id);
-logger.debug(".d-pri");
-
-returnValue;
+++ /dev/null
-/*
- * ============LICENSE_START=======================================================
- * Copyright (C) 2016-2018 Ericsson. All rights reserved.
- * Modifications Copyright (C) 2020 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=========================================================
- */
-
-importClass(org.slf4j.LoggerFactory);
-
-importClass(java.util.ArrayList);
-
-importClass(org.apache.avro.generic.GenericData.Array);
-importClass(org.apache.avro.generic.GenericRecord);
-importClass(org.apache.avro.Schema);
-
-var logger = executor.logger;
-logger.trace("start: " + executor.subject.id);
-logger.trace("-- infields: " + executor.inFields);
-
-var rootLogger = LoggerFactory.getLogger(logger.ROOT_LOGGER_NAME);
-
-var ifSituation = executor.inFields["situation"];
-
-var albumCustomerMap = executor.getContextAlbum("albumCustomerMap");
-var albumProblemMap = executor.getContextAlbum("albumProblemMap");
-
-// create outfiled for decision
-var decision = executor.subject.getOutFieldSchemaHelper("decision").createNewInstance();
-decision.put("description", "Impede given customers selected based on maximum SLA delta");
-decision.put("decision", "IMPEDE");
-decision.put("problemID", ifSituation.get("problemID"));
-decision.put("customers", new ArrayList());
-
-var problem = albumProblemMap.get(ifSituation.get("problemID"));
-var returnValue = true;
-if (problem != null && ifSituation.get("violatedSLAs").size() == 0) {
- logger.trace("-- impede by maximum SLA");
- var customer = "";
- var customerSla = 0;
- for (var i = 0; i < problem.get("edgeUsedBy").size(); i++) {
- customerCtxt = albumCustomerMap.get(problem.get("edgeUsedBy").get(i).toString());
- if (customerSla == 0) {
- customerSla = customerCtxt.get("dtSLA") - customerCtxt.get("dtYTD");
- }
- if ((customerCtxt.get("dtSLA") - customerCtxt.get("dtYTD")) >= customerSla) {
- customer = customerCtxt.get("customerName");
- customerSla = (customerCtxt.get("dtSLA") - customerCtxt.get("dtYTD"));
- }
- }
- decision.get("customers").add(customer);
-} else {
- logger.trace("-- wrong problemID <" + ifSituation.get("problemID") + "> for SLA task, we should not be here");
- rootLogger.error(executor.subject.id + " " + "-- wrong problemID <" + ifSituation.get("problemID")
- + "> for SLA task, we should not be here");
- returnValue = false;
-}
-
-// set impededLast to decision[customers]
-problem.get("impededLast").clear();
-problem.get("impededLast").addAll(decision.get("customers"));
-
-executor.outFields["decision"] = decision;
-logger.trace("-- decision: " + decision);
-
-logger.info("vpnsla: sla balance, impeding customers " + decision.get("customers"));
-
-logger.trace("finished: " + executor.subject.id);
-logger.debug(".d-sla");
-
-returnValue;
+++ /dev/null
-/*
- * ============LICENSE_START=======================================================
- * Copyright (C) 2016-2018 Ericsson. All rights reserved.
- * Modifications Copyright (C) 2020 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=========================================================
- */
-
-importClass(org.slf4j.LoggerFactory);
-
-importClass(java.util.ArrayList);
-
-importClass(org.apache.avro.generic.GenericData.Array);
-importClass(org.apache.avro.generic.GenericRecord);
-importClass(org.apache.avro.Schema);
-
-var logger = executor.logger;
-logger.trace("start: " + executor.subject.id);
-logger.trace("-- infields: " + executor.inFields);
-
-var rootLogger = LoggerFactory.getLogger(logger.ROOT_LOGGER_NAME);
-
-var ifSituation = executor.inFields["situation"];
-
-var albumProblemMap = executor.getContextAlbum("albumProblemMap");
-
-// create outfiled for decision
-var decision = executor.subject.getOutFieldSchemaHelper("decision").createNewInstance();
-decision.put("description", "None, everything is ok");
-decision.put("decision", "REBUILD");
-decision.put("customers", new ArrayList());
-decision.put("problemID", ifSituation.get("problemID"));
-
-var returnValue = true;
-if (albumProblemMap.get(ifSituation.get("problemID")).get("status") == "SOLVED") {
- logger.trace("-- problem solved");
-} else {
- logger.trace("-- wrong problemID <" + problemID + "> for SOLVED task, we should not be here");
- rootLogger.error(executor.subject.id + " " + "-- wrong problemID <" + problemID
- + "> for SOLVED task, we should not be here");
- returnValue = false;
-}
-
-executor.outFields["decision"] = decision;
-
-logger.info("vpnsla: sla solved, problem solved");
-
-logger.trace("finished: " + executor.subject.id);
-logger.debug(".d-non");
-
-returnValue;
+++ /dev/null
-/*
- * ============LICENSE_START=======================================================
- * Copyright (C) 2016-2018 Ericsson. All rights reserved.
- * Modifications Copyright (C) 2020 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=========================================================
- */
-
-importClass(org.slf4j.LoggerFactory);
-
-importClass(java.util.ArrayList);
-
-importClass(org.apache.avro.generic.GenericData.Array);
-importClass(org.apache.avro.generic.GenericRecord);
-importClass(org.apache.avro.Schema);
-
-var logger = executor.logger;
-logger.trace("start: " + executor.subject.id);
-logger.trace("-- infields: " + executor.inFields);
-
-var rootLogger = LoggerFactory.getLogger(logger.ROOT_LOGGER_NAME);
-
-var ifEdgeName = executor.inFields["edgeName"];
-var ifEdgeStatus = executor.inFields["status"].toString();
-var ifhasChanged = executor.inFields["hasChanged"];
-var ifMatchStart = executor.inFields["matchStart"];
-
-var albumCustomerMap = executor.getContextAlbum("albumCustomerMap");
-var albumProblemMap = executor.getContextAlbum("albumProblemMap");
-
-var linkProblem = albumProblemMap.get(ifEdgeName);
-
-// create outfiled for situation
-var situation = executor.subject.getOutFieldSchemaHelper("situation").createNewInstance();
-situation.put("violatedSLAs", new ArrayList());
-
-// create a string as states+hasChanged+linkProblem and switch over it
-var switchTest = ifEdgeStatus + ":" + ifhasChanged + ":" + (linkProblem == null ? "no" : "yes");
-switch (switchTest) {
-case "UP:false:no":
- logger.trace("-- edge <" + ifEdgeName + "> UP:false:no => everything ok");
- logger.info("vpnsla: everything ok");
- situation.put("problemID", "NONE");
- break;
-case "UP:false:yes":
- logger.trace("-- edge <" + ifEdgeName + "> UP:false:yes ==> did we miss earlier up?, removing problem");
- albumProblemMap.remove(ifEdgeName);
- linkProblem = null;
- situation.put("problemID", "NONE");
- break;
-case "UP:true:no":
- logger.trace("-- edge <" + ifEdgeName + "> UP:true:no ==> did we miss the earlier down?, creating new problem");
- situation.put("problemID", ifEdgeName);
- break;
-case "UP:true:yes":
- logger.trace("-- edge <" + ifEdgeName + "> UP:true:yes ==> detected solution, link up again");
- logger.info("vpnsla: problem solved");
- linkProblem.put("endTime", ifMatchStart);
- linkProblem.put("status", "SOLVED");
- situation.put("problemID", "NONE");
- break;
-case "DOWN:false:no":
- logger.trace("-- edge <" + ifEdgeName + "> DOWN:false:no ==> did we miss an earlier down?, creating new problem");
- situation.put("problemID", ifEdgeName);
- break;
-case "DOWN:false:yes":
- logger.trace("-- edge <" + ifEdgeName + "> DOWN:false:yes ==> problem STILL exists");
- logger.info("vpnsla: problem still exists");
- linkProblem.put("status", "STILL");
- situation.put("problemID", ifEdgeName);
- break;
-case "DOWN:true:no":
- logger.trace("-- edge <" + ifEdgeName + "> DOWN:true:no ==> found NEW problem");
- logger.info("vpnsla: this is a new problem");
- situation.put("problemID", ifEdgeName);
- break;
-case "DOWN:true:yes":
- logger.trace("-- edge <" + ifEdgeName
- + "> DOWN:true:yes ==> did we miss to remove an earlier problem?, remove and create new problem");
- linkProblem = null;
- situation.put("problemID", ifEdgeName);
- break;
-
-default:
- logger.error("-- input wrong for edge" + ifEdgeName + ": edge status <" + ifEdgeStatus
- + "> unknown or null on hasChanged <" + ifhasChanged + ">");
- rootLogger.error("-- input wrong for edge" + ifEdgeName + ": edge status <" + ifEdgeStatus
- + "> unknown or null on hasChanged <" + ifhasChanged + ">");
-}
-
-// create new problem if situation requires it
-if (situation.get("problemID").equals(ifEdgeName) && linkProblem == null) {
- logger.trace("-- edge <" + ifEdgeName + "> creating new problem");
- linkProblem = albumProblemMap.getSchemaHelper().createNewInstance();
- linkProblem.put("edge", ifEdgeName);
- linkProblem.put("startTime", ifMatchStart);
- linkProblem.put("lastUpdate", ifMatchStart);
- linkProblem.put("endTime", 0);
- linkProblem.put("status", "NEW");
- linkProblem.put("edgeUsedBy", new ArrayList());
- linkProblem.put("impededLast", new ArrayList());
-
- for (var i = 0; i < albumCustomerMap.values().size(); i++) {
- var customer = albumCustomerMap.values().get(i);
- var customerLinks = albumCustomerMap.values().get(i).get("links");
- for (var k = 0; k < customerLinks.size(); k++) {
- if (customerLinks.get(k) == ifEdgeName) {
- linkProblem.get("edgeUsedBy").add(customer.get("customerName"));
- }
- }
- }
- albumProblemMap.put(ifEdgeName, linkProblem);
- logger.trace("-- edge <" + ifEdgeName + "> problem created as <" + linkProblem + ">");
-}
-
-// set dtYTD if situation requires it
-if (linkProblem != null && (linkProblem.get("status") == "STILL" || linkProblem.get("status") == "SOLVED")) {
- var linkDownTimeinSecs = (ifMatchStart - linkProblem.get("lastUpdate")) / 1000;
- logger.trace("-- edge <" + ifEdgeName + "> down time: " + linkDownTimeinSecs + " s");
- for (var k = 0; k < linkProblem.get("impededLast").size(); k++) {
- for (var i = 0; i < albumCustomerMap.values().size(); i++) {
- var customer = albumCustomerMap.values().get(i);
- if (customer.get("customerName").equals(linkProblem.get("impededLast").get(k))) {
- logger.info("-- vpnsla: customer " + customer.get("customerName") + " YDT downtime increased from "
- + customer.get("dtYTD") + " to " + (customer.get("dtYTD") + linkDownTimeinSecs));
- customer.put("dtYTD", (customer.get("dtYTD") + linkDownTimeinSecs))
- }
- }
- }
- // set lastUpdate to this policy execution for next execution calculation
- linkProblem.put("lastUpdate", ifMatchStart);
-}
-
-// check SLA violations if situation requires it
-if (linkProblem != null && linkProblem.get("status") != "SOLVED") {
- logger.info(">e> customer\tDT SLA\tDT YTD\tviolation");
- for (var i = 0; i < albumCustomerMap.values().size(); i++) {
- var customer = albumCustomerMap.values().get(i);
- if (customer.get("dtYTD") > customer.get("dtSLA")) {
- situation.get("violatedSLAs").add(customer.get("customerName"));
- logger.info(">e> " + customer.get("customerName") + "\t\t" + customer.get("dtSLA") + "s\t"
- + customer.get("dtYTD") + "s\t" + "!!");
- } else {
- logger.info(">e> " + customer.get("customerName") + "\t\t" + customer.get("dtSLA") + "s\t"
- + customer.get("dtYTD") + "s");
- }
- }
-}
-
-executor.outFields["situation"] = situation;
-
-logger.trace("-- out fields <" + executor.outFields + ">");
-
-logger.trace("finished: " + executor.subject.id);
-logger.debug(".e");
-
-true;
+++ /dev/null
-/*
- * ============LICENSE_START=======================================================
- * Copyright (C) 2016-2018 Ericsson. All rights reserved.
- * Modifications Copyright (C) 2020 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=========================================================
- */
-
-var now = new Date().getTime();
-executor.outFields["matchStart"] = now;
-
-importClass(org.slf4j.LoggerFactory);
-
-var logger = executor.logger;
-logger.trace("start: " + executor.subject.id);
-logger.trace("-- infields: " + executor.inFields);
-
-var rootLogger = LoggerFactory.getLogger(logger.ROOT_LOGGER_NAME);
-
-var ifEdgeName = executor.inFields["edgeName"];
-var ifLinkStatus = executor.inFields["status"];
-
-var albumTopoEdges = executor.getContextAlbum("albumTopoEdges");
-
-logger.trace("-- got infields, checking albumTopoEdges changes");
-
-var active = false;
-switch (ifLinkStatus.toString()) {
-case "UP":
- active = true;
- break;
-case "DOWN":
- active = false;
- break;
-default:
- active = false;
- logger.error("-- trigger sent unknown link status <" + ifLinkStatus + "> for link <" + ifEdgeName + ">");
- rootLogger.error(executor.subject.id + " " + "-- trigger sent unknown link status <" + ifLinkStatus
- + "> for link <" + ifEdgeName + ">");
-}
-
-var link = albumTopoEdges.get(ifEdgeName);
-if (link == null) {
- logger.trace("-- link <" + ifEdgeName + "> not in albumTopoEdges");
-} else {
- logger.trace("-- found link <" + link + "> in albumTopoEdges");
- logger.trace("-- active <" + active + "> : link.active <" + link.get("active") + ">");
- if (active != link.get("active")) {
- link.put("active", active);
- logger.trace("-- link <" + ifEdgeName + "> status changed to <active:" + link.get("active") + ">");
- executor.outFields["hasChanged"] = true;
- } else {
- logger.trace("-- link <" + ifEdgeName + "> status not changed <active:" + link.get("active") + ">");
- executor.outFields["hasChanged"] = false;
- }
-}
-
-executor.outFields["edgeName"] = ifEdgeName;
-executor.outFields["status"] = ifLinkStatus;
-
-logger.info("vpnsla: detected " + ifEdgeName + " as " + ifLinkStatus);
-
-logger.trace("finished: " + executor.subject.id);
-logger.debug(".m");
-
-true;
+++ /dev/null
-/*
- * ============LICENSE_START=======================================================
- * Copyright (C) 2016-2018 Ericsson. All rights reserved.
- * Modifications Copyright (C) 2020 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=========================================================
- */
-
-importClass(org.slf4j.LoggerFactory);
-
-var logger = executor.logger;
-logger.trace("start: " + executor.subject.id + " - TSL");
-
-var rootLogger = LoggerFactory.getLogger(logger.ROOT_LOGGER_NAME);
-
-var ifSituation = executor.inFields["situation"];
-
-var albumProblemMap = executor.getContextAlbum("albumProblemMap");
-
-var returnValue = true;
-if (ifSituation.get("problemID") == "NONE") {
- logger.trace("-- situation has no problem, selecting <VpnSlaPolicyDecideNoneTask>");
- executor.subject.getTaskKey("VpnSlaPolicyDecideNoneTask").copyTo(executor.selectedTask);
-} else if (albumProblemMap.get(ifSituation.get("problemID")).get("status") == "SOLVED") {
- logger.trace("-- situation is solved, selecting <VpnSlaPolicyDecideSolvedTask>");
- executor.subject.getTaskKey("VpnSlaPolicyDecideSolvedTask").copyTo(executor.selectedTask);
-} else if (ifSituation.get("violatedSLAs") != null && ifSituation.get("violatedSLAs").size() > 0) {
- logger.trace("-- situation is problem with violations, selecting <VpnSlaPolicyDecidePriorityTask>");
- executor.subject.getTaskKey("VpnSlaPolicyDecidePriorityTask").copyTo(executor.selectedTask);
-} else if (ifSituation.get("violatedSLAs") != null && ifSituation.get("violatedSLAs").size() == 0) {
- logger.trace("-- situation is problem without violations, selecting <VpnSlaPolicyDecideSlaTask>");
- executor.subject.getTaskKey("VpnSlaPolicyDecideSlaTask").copyTo(executor.selectedTask);
-} else {
- logger.error("-- detected unknown decision for situation <" + ifSituation.get("problemID") + ">");
- rootLogger.error(executor.subject.id + " " + "-- detected unknown decision for situation <"
- + ifSituation.get("problemID") + ">");
- returnValue = false;
-}
-
-logger.trace("finished: " + executor.subject.id);
-logger.debug(".d-tsl");
-
-returnValue;
+++ /dev/null
-#-------------------------------------------------------------------------------
-# ============LICENSE_START=======================================================
-# Copyright (C) 2016-2018 Ericsson. 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=========================================================
-#-------------------------------------------------------------------------------
-
-# ============LICENSE_START=======================================================
-# Copyright (C) 2016-2018 Ericsson. 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=========================================================
-
-model create name=PCVS-VpnSla version=1.0.0 description="Policies-Controlled Video Streaming, VPN SLA Policy Model"
-
-
-
-schema create name=reportDecl version=1.0.0 description="Report of activities of a policy/task" flavour=Java schema=java.lang.String
-event create name=ReportOut version=1.0.0 description="Report of a policy (issued by a task)" nameSpace=org.onap.policy.apex.examples.pcvs.vpnsla source="APEX" target="CtxtManagement"
-event parameter create name=ReportOut version=1.0.0 parName=report schemaName=reportDecl schemaVersion=1.0.0
-
-schema create name=timestampDecl version=1.0.0 description="Timestamp" flavour=Java schema=java.lang.Long
-
-
-
-schema create name=ctxtEdgeNameDecl version=1.0.0 description="Topology Edges: edge (link) name" flavour=Java schema=java.lang.String
-schema create name=ctxtEdgeStartDecl version=1.0.0 description="Topology Edges: edge endpoint (start)" flavour=Java schema=java.lang.String
-schema create name=ctxtEdgeEndDecl version=1.0.0 description="Topology Edges: edge endpoint (end)" flavour=Java schema=java.lang.String
-schema create name=ctxtEdgeStatusDecl version=1.0.0 description="Topology Edges: edge status as up (true) or down (false)" flavour=Java schema=java.lang.Boolean
-
-schema create name=ctxtTopologyEdgesDecl version=1.0.0 description="Topology Edges Context Map" flavour=Avro schema=LS
-#MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/avro/topology-edges.avsc"
-LE
-album create name=albumTopoEdges scope=global writable=true schemaName=ctxtTopologyEdgesDecl
-
-
-task create name=EdgeContextTask version=1.0.0 description="This task adds event context to edge context"
-task inputfield create name=EdgeContextTask version=1.0.0 fieldName=edgeName schemaName=ctxtEdgeNameDecl schemaVersion=1.0.0
-task inputfield create name=EdgeContextTask version=1.0.0 fieldName=start schemaName=ctxtEdgeStartDecl schemaVersion=1.0.0
-task inputfield create name=EdgeContextTask version=1.0.0 fieldName=end schemaName=ctxtEdgeEndDecl schemaVersion=1.0.0
-task inputfield create name=EdgeContextTask version=1.0.0 fieldName=status schemaName=ctxtEdgeStatusDecl schemaVersion=1.0.0
-task outputfield create name=EdgeContextTask version=1.0.0 fieldName=report schemaName=reportDecl schemaVersion=1.0.0
-task contextref create name=EdgeContextTask albumName=albumTopoEdges
-task logic create name=EdgeContextTask logicFlavour=JAVASCRIPT logic=LS
-#MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/ctxt-edges.js"
-LE
-
-event create name=EdgeContextEventIn version=1.0.0 description="Event to add an Edge to engine Context" nameSpace=org.onap.policy.apex.examples.pcvs.vpnsla source="CtxtManagement" target="APEX"
-event parameter create name=EdgeContextEventIn version=1.0.0 parName=edgeName schemaName=ctxtEdgeNameDecl schemaVersion=1.0.0
-event parameter create name=EdgeContextEventIn version=1.0.0 parName=start schemaName=ctxtEdgeStartDecl schemaVersion=1.0.0
-event parameter create name=EdgeContextEventIn version=1.0.0 parName=end schemaName=ctxtEdgeEndDecl schemaVersion=1.0.0
-event parameter create name=EdgeContextEventIn version=1.0.0 parName=status schemaName=ctxtEdgeStatusDecl schemaVersion=1.0.0
-
-policy create name=EdgeContextPolicy version=1.0.0 description="Policy that adds an edge to context" template=FREEFORM firstState=EdgeContextState
-policy state create name=EdgeContextPolicy version=1.0.0 stateName=EdgeContextState triggerName=EdgeContextEventIn triggerVersion=1.0.0 defaultTaskName=EdgeContextTask defaultTaskVersion=1.0.0
-policy state output create name=EdgeContextPolicy version=1.0.0 stateName=EdgeContextState outputName=EdgeContextState_Output_Direct eventName=ReportOut eventVersion=1.0.0 nextState=NULL
-policy state taskref create name=EdgeContextPolicy version=1.0.0 stateName=EdgeContextState taskLocalName=doContext taskName=EdgeContextTask taskVersion=1.0.0 outputType=DIRECT outputName=EdgeContextState_Output_Direct
-
-
-
-schema create name=ctxtNodeNameDecl version=1.0.0 description="Topology Nodes: node name" flavour=Java schema=java.lang.String
-schema create name=ctxtNodeMininetNameDecl version=1.0.0 description="Topology Nodes: node name in Mininet" flavour=Java schema=java.lang.String
-
-schema create name=ctxtTopologyNodesDecl version=1.0.0 description="Topology Nodes Context Map" flavour=Avro schema=LS
-#MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/avro/topology-nodes.avsc"
-LE
-album create name=albumTopoNodes scope=global writable=true schemaName=ctxtTopologyNodesDecl
-
-task create name=NodeContextTask version=1.0.0 description="This task adds event context to node context"
-task inputfield create name=NodeContextTask version=1.0.0 fieldName=nodeName schemaName=ctxtNodeNameDecl schemaVersion=1.0.0
-task inputfield create name=NodeContextTask version=1.0.0 fieldName=mininetName schemaName=ctxtNodeMininetNameDecl schemaVersion=1.0.0
-task outputfield create name=NodeContextTask version=1.0.0 fieldName=report schemaName=reportDecl schemaVersion=1.0.0
-task contextref create name=NodeContextTask albumName=albumTopoNodes
-task logic create name=NodeContextTask logicFlavour=JAVASCRIPT logic=LS
-#MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/ctxt-nodes.js"
-LE
-
-event create name=NodeContextEventIn version=1.0.0 description="Event to add Node to engine Context" nameSpace=org.onap.policy.apex.examples.pcvs.vpnsla source="CtxtManagement" target="APEX"
-event parameter create name=NodeContextEventIn version=1.0.0 parName=nodeName schemaName=ctxtNodeNameDecl schemaVersion=1.0.0
-event parameter create name=NodeContextEventIn version=1.0.0 parName=mininetName schemaName=ctxtNodeMininetNameDecl schemaVersion=1.0.0
-
-policy create name=NodeContextPolicy version=1.0.0 description="Policy that adds an node to context" template=FREEFORM firstState=NodeContextState
-policy state create name=NodeContextPolicy version=1.0.0 stateName=NodeContextState triggerName=NodeContextEventIn triggerVersion=1.0.0 defaultTaskName=NodeContextTask defaultTaskVersion=1.0.0
-policy state output create name=NodeContextPolicy version=1.0.0 stateName=NodeContextState outputName=NodeContextState_Output_Direct eventName=ReportOut eventVersion=1.0.0 nextState=NULL
-policy state taskref create name=NodeContextPolicy version=1.0.0 stateName=NodeContextState taskLocalName=doContext taskName=NodeContextTask taskVersion=1.0.0 outputType=DIRECT outputName=NodeContextState_Output_Direct
-
-
-
-
-schema create name=ctxtCustomerNameDecl version=1.0.0 description="Customer Context: customer name" flavour=Java schema=java.lang.String
-schema create name=ctxtCustomerPriorityDecl version=1.0.0 description="Customer Context: priority flag" flavour=Java schema=java.lang.Boolean
-schema create name=ctxtCustomerSatisfactionDecl version=1.0.0 description="Customer Context: satisfaction in percent" flavour=Java schema=java.lang.Integer
-schema create name=ctxtCustomerDowntimeSLADecl version=1.0.0 description="Customer Context: contracted downtime as per SLA" flavour=Java schema=java.lang.Integer
-schema create name=ctxtCustomerDowntimeYTDDecl version=1.0.0 description="Customer Context: year-to-date downtime experienced" flavour=Java schema=java.lang.Integer
-schema create name=ctxtCustomerLinksDecl version=1.0.0 description="Customer Context: links a customer uses (for events/task)" flavour=Java schema=java.lang.String
-
-schema create name=ctxtCustomerMapDecl version=1.0.0 description="Map of customers with all known information" flavour=Avro schema=LS
-#MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/avro/customers.avsc"
-LE
-album create name=albumCustomerMap scope=global writable=true schemaName=ctxtCustomerMapDecl
-
-task create name=CustomerContextTask version=1.0.0 description="This task adds event context to customer context"
-task inputfield create name=CustomerContextTask version=1.0.0 fieldName=customerName schemaName=ctxtCustomerNameDecl schemaVersion=1.0.0
-task inputfield create name=CustomerContextTask version=1.0.0 fieldName=priority schemaName=ctxtCustomerPriorityDecl schemaVersion=1.0.0
-task inputfield create name=CustomerContextTask version=1.0.0 fieldName=satisfaction schemaName=ctxtCustomerSatisfactionDecl schemaVersion=1.0.0
-task inputfield create name=CustomerContextTask version=1.0.0 fieldName=dtSLA schemaName=ctxtCustomerDowntimeSLADecl schemaVersion=1.0.0
-task inputfield create name=CustomerContextTask version=1.0.0 fieldName=dtYTD schemaName=ctxtCustomerDowntimeYTDDecl schemaVersion=1.0.0
-task inputfield create name=CustomerContextTask version=1.0.0 fieldName=links schemaName=ctxtCustomerLinksDecl schemaVersion=1.0.0
-task outputfield create name=CustomerContextTask version=1.0.0 fieldName=report schemaName=reportDecl schemaVersion=1.0.0
-task contextref create name=CustomerContextTask albumName=albumCustomerMap
-task contextref create name=CustomerContextTask albumName=albumTopoEdges
-task logic create name=CustomerContextTask logicFlavour=JAVASCRIPT logic=LS
-#MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/ctxt-customer.js"
-LE
-
-event create name=CustomerContextEventIn version=1.0.0 description="Event to add Customers to engine Context" nameSpace=org.onap.policy.apex.examples.pcvs.vpnsla source="CtxtManagement" target="APEX"
-event parameter create name=CustomerContextEventIn version=1.0.0 parName=customerName schemaName=ctxtCustomerNameDecl schemaVersion=1.0.0
-event parameter create name=CustomerContextEventIn version=1.0.0 parName=priority schemaName=ctxtCustomerPriorityDecl schemaVersion=1.0.0
-event parameter create name=CustomerContextEventIn version=1.0.0 parName=satisfaction schemaName=ctxtCustomerSatisfactionDecl schemaVersion=1.0.0
-event parameter create name=CustomerContextEventIn version=1.0.0 parName=dtSLA schemaName=ctxtCustomerDowntimeSLADecl schemaVersion=1.0.0
-event parameter create name=CustomerContextEventIn version=1.0.0 parName=dtYTD schemaName=ctxtCustomerDowntimeYTDDecl schemaVersion=1.0.0
-event parameter create name=CustomerContextEventIn version=1.0.0 parName=links schemaName=ctxtCustomerLinksDecl schemaVersion=1.0.0
-
-policy create name=CustomerContextPolicy version=1.0.0 description="Policy that adds Customer information to engine context" template=FREEFORM firstState=CustomerContextState
-policy state create name=CustomerContextPolicy version=1.0.0 stateName=CustomerContextState triggerName=CustomerContextEventIn triggerVersion=1.0.0 defaultTaskName=CustomerContextTask defaultTaskVersion=1.0.0
-policy state output create name=CustomerContextPolicy version=1.0.0 stateName=CustomerContextState outputName=CustomerContextState_Output_Direct eventName=ReportOut eventVersion=1.0.0 nextState=NULL
-policy state taskref create name=CustomerContextPolicy version=1.0.0 stateName=CustomerContextState taskLocalName=doContext taskName=CustomerContextTask taskVersion=1.0.0 outputType=DIRECT outputName=CustomerContextState_Output_Direct
-
-
-
-
-schema create name=edgeNameDecl version=1.0.0 description="Edge name" flavour=Java schema=java.lang.String
-schema create name=edgeStatusDecl version=1.0.0 description="Statuf of the edge (UP, DOWN)" flavour=Avro schema=LS
-#MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/avro/link-status.avsc"
-LE
-schema create name=edgeChangedDecl version=1.0.0 description="Status Change (true:change, false:no change)" flavour=Java schema=java.lang.Boolean
-
-task create name=VpnSlaPolicyMatchTask version=1.0.0 description="Pre-process an edge event"
-task inputfield create name=VpnSlaPolicyMatchTask version=1.0.0 fieldName=edgeName schemaName=edgeNameDecl schemaVersion=1.0.0
-task inputfield create name=VpnSlaPolicyMatchTask version=1.0.0 fieldName=status schemaName=edgeStatusDecl schemaVersion=1.0.0
-task outputfield create name=VpnSlaPolicyMatchTask version=1.0.0 fieldName=edgeName schemaName=edgeNameDecl schemaVersion=1.0.0
-task outputfield create name=VpnSlaPolicyMatchTask version=1.0.0 fieldName=status schemaName=edgeStatusDecl schemaVersion=1.0.0
-task outputfield create name=VpnSlaPolicyMatchTask version=1.0.0 fieldName=hasChanged schemaName=edgeChangedDecl schemaVersion=1.0.0
-task outputfield create name=VpnSlaPolicyMatchTask version=1.0.0 fieldName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
-task contextref create name=VpnSlaPolicyMatchTask albumName=albumTopoEdges
-task logic create name=VpnSlaPolicyMatchTask logicFlavour=JAVASCRIPT logic=LS
-#MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/task-match.js"
-LE
-
-
-
-
-schema create name=problemMapDecl version=1.0.0 description="Map of problems with all known Information" flavour=Avro schema=LS
-#MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/avro/problems.avsc"
-LE
-album create name=albumProblemMap scope=global writable=true schemaName=problemMapDecl
-
-schema create name=establishSituationDecl version=1.0.0 description="Establish: the situation that was established" flavour=Avro schema=LS
-#MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/avro/situation.avsc"
-LE
-
-task create name=VpnSlaPolicyEstablishTask version=1.0.0 description="Task taking a match event and establishing a situation"
-task inputfield create name=VpnSlaPolicyEstablishTask version=1.0.0 fieldName=edgeName schemaName=edgeNameDecl schemaVersion=1.0.0
-task inputfield create name=VpnSlaPolicyEstablishTask version=1.0.0 fieldName=status schemaName=edgeStatusDecl schemaVersion=1.0.0
-task inputfield create name=VpnSlaPolicyEstablishTask version=1.0.0 fieldName=hasChanged schemaName=edgeChangedDecl schemaVersion=1.0.0
-task inputfield create name=VpnSlaPolicyEstablishTask version=1.0.0 fieldName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
-task outputfield create name=VpnSlaPolicyEstablishTask version=1.0.0 fieldName=situation schemaName=establishSituationDecl schemaVersion=1.0.0
-task outputfield create name=VpnSlaPolicyEstablishTask version=1.0.0 fieldName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
-task contextref create name=VpnSlaPolicyEstablishTask albumName=albumProblemMap
-task contextref create name=VpnSlaPolicyEstablishTask albumName=albumCustomerMap
-task logic create name=VpnSlaPolicyEstablishTask logicFlavour=JAVASCRIPT logic=LS
-#MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/task-establish.js"
-LE
-
-
-
-
-schema create name=decideDecisionDecl version=1.0.0 description="Decide: the taken decision" flavour=Avro schema=LS
-#MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/avro/decision.avsc"
-LE
-
-task create name=VpnSlaPolicyDecideNoneTask version=1.0.0 description="Decide task for a 'none' problem"
-task inputfield create name=VpnSlaPolicyDecideNoneTask version=1.0.0 fieldName=situation schemaName=establishSituationDecl schemaVersion=1.0.0
-task inputfield create name=VpnSlaPolicyDecideNoneTask version=1.0.0 fieldName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
-task outputfield create name=VpnSlaPolicyDecideNoneTask version=1.0.0 fieldName=decision schemaName=decideDecisionDecl schemaVersion=1.0.0
-task outputfield create name=VpnSlaPolicyDecideNoneTask version=1.0.0 fieldName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
-task logic create name=VpnSlaPolicyDecideNoneTask logicFlavour=JAVASCRIPT logic=LS
-#MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/task-decide-none.js"
-LE
-
-
-task create name=VpnSlaPolicyDecideSlaTask version=1.0.0 description="Decide task solving the problem by balancing SLAs"
-task inputfield create name=VpnSlaPolicyDecideSlaTask version=1.0.0 fieldName=situation schemaName=establishSituationDecl schemaVersion=1.0.0
-task inputfield create name=VpnSlaPolicyDecideSlaTask version=1.0.0 fieldName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
-task outputfield create name=VpnSlaPolicyDecideSlaTask version=1.0.0 fieldName=decision schemaName=decideDecisionDecl schemaVersion=1.0.0
-task outputfield create name=VpnSlaPolicyDecideSlaTask version=1.0.0 fieldName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
-task contextref create name=VpnSlaPolicyDecideSlaTask albumName=albumCustomerMap
-task contextref create name=VpnSlaPolicyDecideSlaTask albumName=albumProblemMap
-task logic create name=VpnSlaPolicyDecideSlaTask logicFlavour=JAVASCRIPT logic=LS
-#MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/task-decide-sla.js"
-LE
-
-
-task create name=VpnSlaPolicyDecidePriorityTask version=1.0.0 description="Decide task solving the problem by using customer priorities"
-task inputfield create name=VpnSlaPolicyDecidePriorityTask version=1.0.0 fieldName=situation schemaName=establishSituationDecl schemaVersion=1.0.0
-task inputfield create name=VpnSlaPolicyDecidePriorityTask version=1.0.0 fieldName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
-task outputfield create name=VpnSlaPolicyDecidePriorityTask version=1.0.0 fieldName=decision schemaName=decideDecisionDecl schemaVersion=1.0.0
-task outputfield create name=VpnSlaPolicyDecidePriorityTask version=1.0.0 fieldName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
-task contextref create name=VpnSlaPolicyDecidePriorityTask albumName=albumCustomerMap
-task contextref create name=VpnSlaPolicyDecidePriorityTask albumName=albumProblemMap
-task logic create name=VpnSlaPolicyDecidePriorityTask logicFlavour=JAVASCRIPT logic=LS
-#MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/task-decide-priority.js"
-LE
-
-
-task create name=VpnSlaPolicyDecideSolvedTask version=1.0.0 description="Decide task solving the problem by using customer priorities"
-task inputfield create name=VpnSlaPolicyDecideSolvedTask version=1.0.0 fieldName=situation schemaName=establishSituationDecl schemaVersion=1.0.0
-task inputfield create name=VpnSlaPolicyDecideSolvedTask version=1.0.0 fieldName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
-task outputfield create name=VpnSlaPolicyDecideSolvedTask version=1.0.0 fieldName=decision schemaName=decideDecisionDecl schemaVersion=1.0.0
-task outputfield create name=VpnSlaPolicyDecideSolvedTask version=1.0.0 fieldName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
-task contextref create name=VpnSlaPolicyDecideSolvedTask albumName=albumProblemMap
-task logic create name=VpnSlaPolicyDecideSolvedTask logicFlavour=JAVASCRIPT logic=LS
-#MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/task-decide-solved.js"
-LE
-
-
-
-
-schema create name=actionDecl version=1.0.0 description="An action for the actioning system" flavour=Java schema=java.lang.String
-
-task create name=VpnSlaPolicyActTask version=1.0.0 description="Task issueing an action for taken decision"
-task inputfield create name=VpnSlaPolicyActTask version=1.0.0 fieldName=decision schemaName=decideDecisionDecl schemaVersion=1.0.0
-task inputfield create name=VpnSlaPolicyActTask version=1.0.0 fieldName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
-task outputfield create name=VpnSlaPolicyActTask version=1.0.0 fieldName=edgeName schemaName=edgeNameDecl schemaVersion=1.0.0
-task outputfield create name=VpnSlaPolicyActTask version=1.0.0 fieldName=action schemaName=actionDecl schemaVersion=1.0.0
-task contextref create name=VpnSlaPolicyActTask albumName=albumCustomerMap
-task contextref create name=VpnSlaPolicyActTask albumName=albumProblemMap
-task logic create name=VpnSlaPolicyActTask logicFlavour=JAVASCRIPT logic=LS
-#MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/task-act.js"
-LE
-
-
-
-
-
-
-
-event create name=VpnSlaTrigger version=1.0.0 description="Event triggering the VPN SLA policy" nameSpace=org.onap.policy.apex.examples.pcvs.vpnsla source="TriggerSys" target="VpnSlaMatch"
-event parameter create name=VpnSlaTrigger version=1.0.0 parName=edgeName schemaName=edgeNameDecl schemaVersion=1.0.0
-event parameter create name=VpnSlaTrigger version=1.0.0 parName=status schemaName=edgeStatusDecl schemaVersion=1.0.0
-
-event create name=VpnSlaMatchOut version=1.0.0 description="Event with matched trigger for the VPN SLA policy" nameSpace=org.onap.policy.apex.examples.pcvs.vpnsla source="VpnSlaMatch" target="VpnSlaEstablish"
-event parameter create name=VpnSlaMatchOut version=1.0.0 parName=edgeName schemaName=edgeNameDecl schemaVersion=1.0.0
-event parameter create name=VpnSlaMatchOut version=1.0.0 parName=status schemaName=edgeStatusDecl schemaVersion=1.0.0
-event parameter create name=VpnSlaMatchOut version=1.0.0 parName=hasChanged schemaName=edgeChangedDecl schemaVersion=1.0.0
-event parameter create name=VpnSlaMatchOut version=1.0.0 parName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
-
-event create name=VpnSlaEstablishOut version=1.0.0 description="Event with situation for the SLA policy" nameSpace=org.onap.policy.apex.examples.pcvs.vpnsla source="SlaEstablish" target="SlaDecide"
-event parameter create name=VpnSlaEstablishOut version=1.0.0 parName=situation schemaName=establishSituationDecl schemaVersion=1.0.0
-event parameter create name=VpnSlaEstablishOut version=1.0.0 parName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
-
-event create name=VpnSlaDecideOut version=1.0.0 description="Event with a decision for the SLA policy" nameSpace=org.onap.policy.apex.examples.pcvs.vpnsla source="SlaDecide" target="SlaAct"
-event parameter create name=VpnSlaDecideOut version=1.0.0 parName=decision schemaName=decideDecisionDecl schemaVersion=1.0.0
-event parameter create name=VpnSlaDecideOut version=1.0.0 parName=matchStart schemaName=timestampDecl schemaVersion=1.0.0
-
-event create name=VpnSlaActOut version=1.0.0 description="Event action" nameSpace=org.onap.policy.apex.examples.pcvs.vpnsla source="SlaAct" target="ActioningSystem"
-event parameter create name=VpnSlaActOut version=1.0.0 parName=edgeName schemaName=edgeNameDecl schemaVersion=1.0.0
-event parameter create name=VpnSlaActOut version=1.0.0 parName=action schemaName=actionDecl schemaVersion=1.0.0
-
-
-policy create name=VpnSlaPolicy version=1.0.0 description="Policy deciding customer treatment based on SLAs as MEDA policy" template=FREEFORM firstState=VpnSlaPolicyMatchState
-
-policy state create name=VpnSlaPolicy version=1.0.0 stateName=VpnSlaPolicyActState triggerName=VpnSlaDecideOut triggerVersion=1.0.0 defaultTaskName=VpnSlaPolicyActTask defaultTaskVersion=1.0.0
-policy state output create name=VpnSlaPolicy version=1.0.0 stateName=VpnSlaPolicyActState outputName=SlaPolicyAct_Output_Direct eventName=VpnSlaActOut eventVersion=1.0.0 nextState=NULL
-policy state taskref create name=VpnSlaPolicy version=1.0.0 stateName=VpnSlaPolicyActState taskLocalName=act taskName=VpnSlaPolicyActTask taskVersion=1.0.0 outputType=DIRECT outputName=SlaPolicyAct_Output_Direct
-
-policy state create name=VpnSlaPolicy version=1.0.0 stateName=VpnSlaPolicyDecideState triggerName=VpnSlaEstablishOut triggerVersion=1.0.0 defaultTaskName=VpnSlaPolicyDecideSlaTask defaultTaskVersion=1.0.0
-policy state contextref create name=VpnSlaPolicy version=1.0.0 stateName=VpnSlaPolicyDecideState albumName=albumProblemMap
-policy state selecttasklogic create name=VpnSlaPolicy stateName=VpnSlaPolicyDecideState logicFlavour=JAVASCRIPT logic=LS
-#MACROFILE:"src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/tsl-decide.js"
-LE
-policy state output create name=VpnSlaPolicy version=1.0.0 stateName=VpnSlaPolicyDecideState outputName=VpnSlaPolicyDecide_Output_Direct eventName=VpnSlaDecideOut eventVersion=1.0.0 nextState=VpnSlaPolicyActState
-policy state taskref create name=VpnSlaPolicy version=1.0.0 stateName=VpnSlaPolicyDecideState taskLocalName=decideNone taskName=VpnSlaPolicyDecideNoneTask taskVersion=1.0.0 outputType=DIRECT outputName=VpnSlaPolicyDecide_Output_Direct
-policy state taskref create name=VpnSlaPolicy version=1.0.0 stateName=VpnSlaPolicyDecideState taskLocalName=decideNone taskName=VpnSlaPolicyDecideSolvedTask taskVersion=1.0.0 outputType=DIRECT outputName=VpnSlaPolicyDecide_Output_Direct
-policy state taskref create name=VpnSlaPolicy version=1.0.0 stateName=VpnSlaPolicyDecideState taskLocalName=decideSla taskName=VpnSlaPolicyDecideSlaTask taskVersion=1.0.0 outputType=DIRECT outputName=VpnSlaPolicyDecide_Output_Direct
-policy state taskref create name=VpnSlaPolicy version=1.0.0 stateName=VpnSlaPolicyDecideState taskLocalName=decidePriority taskName=VpnSlaPolicyDecidePriorityTask taskVersion=1.0.0 outputType=DIRECT outputName=VpnSlaPolicyDecide_Output_Direct
-
-policy state create name=VpnSlaPolicy version=1.0.0 stateName=VpmSlaPolicyEstablishState triggerName=VpnSlaMatchOut triggerVersion=1.0.0 defaultTaskName=VpnSlaPolicyEstablishTask defaultTaskVersion=1.0.0
-policy state output create name=VpnSlaPolicy version=1.0.0 stateName=VpmSlaPolicyEstablishState outputName=VpnSlaPolicyEstablish_Output_Direct eventName=VpnSlaEstablishOut eventVersion=1.0.0 nextState=VpnSlaPolicyDecideState
-policy state taskref create name=VpnSlaPolicy version=1.0.0 stateName=VpmSlaPolicyEstablishState taskLocalName=establish taskName=VpnSlaPolicyEstablishTask taskVersion=1.0.0 outputType=DIRECT outputName=VpnSlaPolicyEstablish_Output_Direct
-
-policy state create name=VpnSlaPolicy version=1.0.0 stateName=VpnSlaPolicyMatchState triggerName=VpnSlaTrigger triggerVersion=1.0.0 defaultTaskName=VpnSlaPolicyMatchTask defaultTaskVersion=1.0.0
-policy state output create name=VpnSlaPolicy version=1.0.0 stateName=VpnSlaPolicyMatchState outputName=VpnSlaPolicyMatch_Output_Direct eventName=VpnSlaMatchOut eventVersion=1.0.0 nextState=VpmSlaPolicyEstablishState
-policy state taskref create name=VpnSlaPolicy version=1.0.0 stateName=VpnSlaPolicyMatchState taskLocalName=match taskName=VpnSlaPolicyMatchTask taskVersion=1.0.0 outputType=DIRECT outputName=VpnSlaPolicyMatch_Output_Direct
-
-
-
-validate
-quit
-
+++ /dev/null
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
- ============LICENSE_START=======================================================
- Copyright (C) 2016-2018 Ericsson. 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=========================================================
--->
-
-<configuration>
- <contextName>Apex</contextName>
-
- <statusListener class="ch.qos.logback.core.status.OnConsoleStatusListener" />
- <property name="LOG_DIR" value="${java.io.tmpdir}/apex_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.infinispan" level="INFO" additivity="false">
- <appender-ref ref="STDOUT" />
- </logger>
-
- <logger name="org.apache.zookeeper.ClientCnxn" level="OFF" additivity="false">
- <appender-ref ref="STDOUT" />
- </logger>
-
- <appender name="FILE" class="ch.qos.logback.core.FileAppender">
- <file>${LOG_DIR}/apex.log</file>
- <encoder>
- <pattern>%d %-5relative [procId=${processId}] [%thread] %-5level
- %logger{26} - %msg %n %ex{full}</pattern>
- </encoder>
- </appender>
-
- <appender name="CTXT_FILE" class="ch.qos.logback.core.FileAppender">
- <file>${LOG_DIR}/apex_ctxt.log</file>
- <encoder>
- <pattern>%d %-5relative [procId=${processId}] [%thread] %-5level
- %logger{26} - %msg %n %ex{full}</pattern>
- </encoder>
- </appender>
-
- <logger name="org.onap.policy.apex.core.context.impl.monitoring" level="INFO" additivity="false">
- <appender-ref ref="CTXT_FILE" />
- </logger>
-
- <logger name="org.onap.policy.apex" level="INFO" additivity="false">
- <appender-ref ref="STDOUT" />
- </logger>
-
- <logger name="org.onap.policy.apex.core.infrastructure" level="INFO" additivity="false">
- <appender-ref ref="STDOUT" />
- </logger>
-</configuration>
+++ /dev/null
-{
- "engineServiceParameters":{
- "name" : "VpnSlaApexEngine",
- "version" : "1.0.0",
- "id" : 45,
- "instanceCount" : 1,
- "deploymentPort" : 12345,
- "engineParameters" : {
- "executorParameters" : {
- "JAVASCRIPT" : {
- "parameterClassName" : "org.onap.policy.apex.plugins.executor.javascript.JavascriptExecutorParameters"
- }
- },
- "contextParameters":{
- "parameterClassName" : "org.onap.policy.apex.context.parameters.ContextParameters",
- "schemaParameters":{
- "Avro":{
- "parameterClassName" : "org.onap.policy.apex.plugins.context.schema.avro.AvroSchemaHelperParameters"
- }
- }
- }
- }
- },
- "eventOutputParameters": {
- "FirstProducer": {
- "carrierTechnologyParameters" : {
- "carrierTechnology" : "FILE",
- "parameters" : {
- "standardIO" : true
- }
- },
- "eventProtocolParameters" : {
- "eventProtocol" : "JSON"
- }
- }
- },
- "eventInputParameters": {
- "FirstConsumer": {
- "carrierTechnologyParameters" : {
- "carrierTechnology" : "FILE",
- "parameters" : {
- "standardIO" : true
- }
- },
- "eventProtocolParameters" : {
- "eventProtocol" : "JSON"
- }
- }
- }
-}
<module>examples-aadm</module>
<module>examples-acm</module>
<module>examples-adaptive</module>
- <module>examples-pcvs</module>
<module>examples-decisionmaker</module>
<module>examples-periodic</module>
<module>examples-onap-vcpe</module>
Code Review / policy / apex-pdp.git / commitdiff