Merge "Removed policy upgrade from acm docs"

[policy/parent.git] / docs / apex / APEX-PCVS-Example.rst

diff --git a/docs/apex/APEX-PCVS-Example.rst b/docs/apex/APEX-PCVS-Example.rst
index fc42030..380a258 100644 (file)
--- a/docs/apex/APEX-PCVS-Example.rst
+++ b/docs/apex/APEX-PCVS-Example.rst
@@ -16,12 +16,11 @@ Introduction
 
            .. container:: paragraph
 
 
            .. container:: paragraph
 

-                  This module contains several demos for
-                  Policy-controlled Video Streaming (PCVS). Each demo
-                  defines a policy using AVRO and Javascript (or other
-                  scripting languages for the policy logic). To run the
-                  demo, a vanilla Ubuntu server with some extra software
-                  packages is required:
+              This module contains several demos for
+              Policy-controlled Video Streaming (PCVS). Each demo
+              defines a policy using AVRO and Javascript (or other
+              scripting languages for the policy logic). To run the
+              demo, a vanilla Ubuntu server with some extra software packages is required:

 
                .. container:: ulist
 
 
                .. container:: ulist
 


@@ -219,7 +218,7 @@ Install Ubuntu Server and SW
 
 
 VPN SLA Demo
 
 
 VPN SLA Demo

-^^^^^^^^^^^^^
+^^^^^^^^^^^^

 
           .. container:: sect1
 
 
           .. container:: sect1
 


@@ -526,14 +525,6 @@ VPN SLA Demo
                         ``http://localhost:8080/ui/pages/index.html``
                         should work on the same host
 
                         ``http://localhost:8080/ui/pages/index.html``
                         should work on the same host
 

-                     -  APEX please see the APEX documentation for
-                        `Monitoring
-                        Client <https://ericsson.github.io/apex-docs/user-manual/engine-apps/um-engapps-eng-monitoring.html>`__
-                        or `Full
-                        Client <https://ericsson.github.io/apex-docs/user-manual/engine-apps/um-engapps-full-client.html>`__
-                        for details on how to monitor APEX.
-
-

 VPN SLA Policy
 ^^^^^^^^^^^^^^
 
 VPN SLA Policy
 ^^^^^^^^^^^^^^
 


@@ -585,60 +576,11 @@ Context Schemas
                   model edges and nodes for the topology, customers, and
                   problems with all information on detected problems.
 
                   model edges and nodes for the topology, customers, and
                   problems with all information on detected problems.
 

-               .. container:: listingblock
-
-                  .. container:: content
-
-                     .. code:: CodeRay
-
-                        {
-                            "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"}
-                            ]
-                        }
-
-               .. container:: listingblock
-
-                  .. container:: content
-
-                     .. code:: CodeRay
-
-                        {
-                            "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"}
-                            ]
-                        }
-
-               .. container:: listingblock
-
-                  .. container:: content
+                  .. container:: ulist

 
 

-                     .. code:: CodeRay
-
-                        {
-                            "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"}
-                                }
-                            ]
-                        }
+                     -  |avroSchemaEdges_link|
+                     -  |avroSchemaNodes_link|
+                     -  |avroSchemaCustomers_link|

 
 
 Trigger Schemas
 
 
 Trigger Schemas


@@ -652,27 +594,14 @@ Trigger Schemas
 
                   The trigger event provides a status as ``UP`` or
                   ``DOWN``. To avoid tests for these strings in the
 
                   The trigger event provides a status as ``UP`` or
                   ``DOWN``. To avoid tests for these strings in the

-                  logic, we defined an Avro schema for an enumeration.
+                  logic, we defined an Avro schema for an enumeration (|avroSchemaLinkStatus_link|).

                   This does not impact the trigger system (it can still
                   send the strings), but makes the task logic simpler.
 
                   This does not impact the trigger system (it can still
                   send the strings), but makes the task logic simpler.
 

-               .. container:: listingblock
-
-                  .. container:: content
-
-                     .. code:: CodeRay

 
 

-                        {
-                            "type": "enum",
-                            "name": "Status",
-                            "symbols" : [
-                                "UP",
-                                "DOWN"
-                            ]
-                        }

 
 Context Logic Nodes
 
 Context Logic Nodes

---------------------
+-------------------

 
          .. container:: sect1
 
 
          .. container:: sect1
 


@@ -682,80 +611,10 @@ Context Logic Nodes
 
                   The node context logic simply takes the trigger event
                   (for context) and creates a new node in the local
 
                   The node context logic simply takes the trigger event
                   (for context) and creates a new node in the local

-                  context topology.
-
-               .. container:: listingblock
-
-                  .. container:: content
-
-                     .. code:: CodeRay
-
-                        /*
-                         * ============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=========================================================
-                         */
-
-                        load("nashorn:mozilla_compat.js");
-
-                        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);
-
-                        var returnValueType = Java.type("java.lang.Boolean");
-                        var returnValue = new returnValueType(true);
-                        logger.trace("finished: " + executor.subject.id);
-                        logger.debug(".");
+                  context topology (|cntxtNodes_link|).

 
 Context Logic Edges
 
 Context Logic Edges

---------------------
+-------------------

 
          .. container:: sect1
 
 
          .. container:: sect1
 


@@ -765,79 +624,8 @@ Context Logic Edges
 
                   The edge context logic simply takes the trigger event
                   (for context) and creates a new edge in the local
 
                   The edge context logic simply takes the trigger event
                   (for context) and creates a new edge in the local

-                  context topology.
-
-               .. container:: listingblock
+                  context topology (|cntxtEdges_link|).

 
 

-                  .. container:: content
-
-                     .. code:: CodeRay
-
-                        /*
-                         * ============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=========================================================
-                         */
-
-                        load("nashorn:mozilla_compat.js");
-
-                        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);
-
-                        var returnValueType = Java.type("java.lang.Boolean");
-                        var returnValue = new returnValueType(true);
-                        logger.trace("finished: " + executor.subject.id);
-                        logger.debug(".");

 
 Context Logic Customer
 ----------------------
 
 Context Logic Customer
 ----------------------


@@ -850,94 +638,8 @@ Context Logic Customer
 
                   The customer context logic simply takes the trigger
                   event (for context) and creates a new customer in the
 
                   The customer context logic simply takes the trigger
                   event (for context) and creates a new customer in the

-                  local context topology.
-
-               .. container:: listingblock
-
-                  .. container:: content
+                  local context topology (|cntxtCustomer_link|).

 
 

-                     .. code:: CodeRay
-
-                        /*
-                         * ============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=========================================================
-                         */
-
-                        load("nashorn:mozilla_compat.js");
-
-                        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);
-
-                        var returnValueType = Java.type("java.lang.Boolean");
-                        var returnValue = new returnValueType(true);
-                        logger.trace("finished: " + executor.subject.id);
-                        logger.debug(".");

 
 Logic: Match
 ------------
 
 Logic: Match
 ------------


@@ -952,94 +654,8 @@ Logic: Match
                   simple. Beside taking the trigger event, it also
                   creates a timestamp. This timestamp is later used for
                   SLA and downtime calculations as well as for some
                   simple. Beside taking the trigger event, it also
                   creates a timestamp. This timestamp is later used for
                   SLA and downtime calculations as well as for some

-                  performance information of the policy.
-
-               .. container:: listingblock
-
-                  .. container:: content
-
-                     .. code:: CodeRay
-
-                        /*
-                         * ============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=========================================================
-                         */
-
-                        load("nashorn:mozilla_compat.js");
-
-                        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);
-
-                        var returnValueType = Java.type("java.lang.Boolean");
-                        var returnValue = new returnValueType(true);
-                        logger.trace("finished: " + executor.subject.id);
-                        logger.debug(".m");
+                  performance information of the policy .
+                  Sample |taskMatch_link|

 
 
 Logic: Policy Establish State
 
 
 Logic: Policy Establish State


@@ -1065,183 +681,7 @@ Logic: Policy Establish State
                   problem still exists). It also calculates customer SLA
                   downtime and checks for any SLA violations. Finally,
                   it creates a situation object.
                   problem still exists). It also calculates customer SLA
                   downtime and checks for any SLA violations. Finally,
                   it creates a situation object.

-
-               .. container:: listingblock
-
-                  .. container:: content
-
-                     .. code:: CodeRay
-
-                        /*
-                         * ============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=========================================================
-                         */
-
-                        load("nashorn:mozilla_compat.js");
-                        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 + ">");
-
-                        var returnValueType = Java.type("java.lang.Boolean");
-                        var returnValue = new returnValueType(true);
-                        logger.trace("finished: " + executor.subject.id);
-                        logger.debug(".e");
+                  Sample |taskEstablish_link|

 
 Logic: Policy Decide State
 --------------------------
 
 Logic: Policy Decide State
 --------------------------


@@ -1257,413 +697,24 @@ Logic: Policy Decide State
                   Task Selection Logic (TSL). This TSL select a task in
                   the current policy execution (i.e. potentially a
                   different one per execution).
                   Task Selection Logic (TSL). This TSL select a task in
                   the current policy execution (i.e. potentially a
                   different one per execution).

-
-               .. container:: listingblock
-
-                  .. container:: content
-
-                     .. code:: CodeRay
-
-                        /*
-                         * ============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=========================================================
-                         */
-
-                        load("nashorn:mozilla_compat.js");
-                        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 returnValueType = Java.type("java.lang.Boolean");
-                        if (ifSituation.get("problemID") == "NONE") {
-                            logger.trace("-- situation has no problem, selecting <VpnSlaPolicyDecideNoneTask>");
-                            executor.subject.getTaskKey("VpnSlaPolicyDecideNoneTask").copyTo(executor.selectedTask);
-                            var returnValue = new returnValueType(true);
-                        } else if (albumProblemMap.get(ifSituation.get("problemID")).get("status") == "SOLVED") {
-                            logger.trace("-- situation is solved, selecting <VpnSlaPolicyDecideSolvedTask>");
-                            executor.subject.getTaskKey("VpnSlaPolicyDecideSolvedTask").copyTo(executor.selectedTask);
-                            var returnValue = new returnValueType(true);
-                        } 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);
-                            var returnValue = new returnValueType(true);
-                        } 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);
-                            var returnValue = new returnValueType(true);
-                        } else {
-                            logger.error("-- detected unknown decision for situation <" + ifSituation.get("problemID") + ">");
-                            rootLogger.error(executor.subject.id + " " + "-- detected unknown decision for situation <"
-                                    + ifSituation.get("problemID") + ">");
-                            var returnValue = new returnValueType(false);
-                        }
-
-                        logger.trace("finished: " + executor.subject.id);
-                        logger.debug(".d-tsl");
+                  Sample |tslDecide_Link|

 
                .. container:: paragraph
 
                   The actual task logic are then ``none``, ``solved``,
                   ``sla``, and ``priority``.
 
                .. container:: paragraph
 
                   The actual task logic are then ``none``, ``solved``,
                   ``sla``, and ``priority``.

+                  Sample task logic are as given below :

 
 

-Logic: Decide None
--------------------
-
-         .. container:: sect1
-
-            .. container:: sectionbody
-
-               .. container:: listingblock
-
-                  .. container:: content
-
-                     .. code:: CodeRay
-
-                        /*
-                         * ============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=========================================================
-                         */
-
-                        load("nashorn:mozilla_compat.js");
-                        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 returnValueType = Java.type("java.lang.Boolean");
-                        if (ifSituation.get("problemID") == "NONE") {
-                            logger.trace("-- no problem, everything ok");
-                            var returnValue = new returnValueType(true);
-                        } 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");
-                            var returnValue = new returnValueType(false);
-                        }
-
-                        executor.outFields["decision"] = decision;
-
-                        logger.trace("finished: " + executor.subject.id);
-                        logger.debug(".d-non");
-
-Logic: Decide Solved
----------------------
-
-         .. container:: sect1
-
-            .. container:: sectionbody
-
-               .. container:: listingblock
-
-                  .. container:: content
-
-                     .. code:: CodeRay
-
-                        /*
-                         * ============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=========================================================
-                         */
-
-                        load("nashorn:mozilla_compat.js");
-                        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 returnValueType = Java.type("java.lang.Boolean");
-                        if (albumProblemMap.get(ifSituation.get("problemID")).get("status") == "SOLVED") {
-                            logger.trace("-- problem solved");
-                            var returnValue = new returnValueType(true);
-                        } 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");
-                            var returnValue = new returnValueType(false);
-                        }
-
-                        executor.outFields["decision"] = decision;
-
-                        logger.info("vpnsla: sla solved, problem solved");
-
-                        logger.trace("finished: " + executor.subject.id);
-                        logger.debug(".d-non");
-
-Logic: Decide SLA
-------------------
-
-         .. container:: sect1
-
-            .. container:: sectionbody
-
-               .. container:: listingblock
-
-                  .. container:: content
+                  .. container:: ulist

 
 

-                     .. code:: CodeRay
-
-                        /*
-                         * ============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=========================================================
-                         */
-
-                        load("nashorn:mozilla_compat.js");
-                        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 returnValueType = Java.type("java.lang.Boolean");
-                        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);
-                            var returnValue = new returnValueType(true);
-                        } 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");
-                            var returnValue = new returnValueType(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");
-
-Logic: Decide Priority
-----------------------
+                     -  |taskDecideNone_link|
+                     -  |taskDecideSolved_Link|
+                     -  |taskDecideSla_link|
+                     -  |taskDecidePriority_Link|

 
 

-         .. container:: sect2
-
-            .. container:: listingblock
-
-               .. container:: content
-
-                  .. code:: CodeRay
-
-                     /*
-                      * ============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=========================================================
-                      */
-
-                     load("nashorn:mozilla_compat.js");
-                     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 returnValueType = Java.type("java.lang.Boolean");
-                     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"));
-                             }
-                         }
-                         var returnValue = new returnValueType(true);
-                     } 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");
-                         var returnValue = new returnValueType(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");

 
 Logic: Policy Act State
 
 Logic: Policy Act State

-------------------------
+-----------------------

 
          .. container:: sect1
 
 
          .. container:: sect1
 


@@ -1674,82 +725,7 @@ Logic: Policy Act State
                   This is the logic for the act state. It is simply
                   selecting an action, and creating the repsonse event
                   for the orchestrator (the output of the policy).
                   This is the logic for the act state. It is simply
                   selecting an action, and creating the repsonse event
                   for the orchestrator (the output of the policy).

-
-               .. container:: listingblock
-
-                  .. container:: content
-
-                     .. code:: CodeRay
-
-                        /*
-                         * ============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=========================================================
-                         */
-
-                        load("nashorn:mozilla_compat.js");
-
-                        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:
-
-                        }
-
-                        var returnValueType = Java.type("java.lang.Boolean");
-                        var returnValue = new returnValueType(true);
-
-                        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");
+                  Sample |taskAct_link|

 
 CLI Spec
 --------
 
 CLI Spec
 --------


@@ -1767,337 +743,8 @@ CLI Spec
                   APEX CLI Editor. The script below shows the actual
                   policy specification. All logic and schemas are
                   included (as macro file).
                   APEX CLI Editor. The script below shows the actual
                   policy specification. All logic and schemas are
                   included (as macro file).

+                  Sample |vpnsla-apex_link|

 
 

-               .. container:: listingblock
-
-                  .. container:: content
-
-                     .. code:: CodeRay
-
-                        #-------------------------------------------------------------------------------
-                        # ============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

 
 Context Events Nodes
 --------------------
 
 Context Events Nodes
 --------------------


@@ -2110,112 +757,10 @@ Context Events Nodes
 
                   The following events create all nodes of the topology.
 
 
                   The following events create all nodes of the topology.
 

-               .. container:: listingblock
+                  .. container:: ulist

 
 

-                  .. container:: content
+                     -  |ctxtNodesJson_link|

 
 

-                     .. code:: CodeRay
-
-                        {
-                            "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"
-                        }

 
 Context Events Edges
 --------------------
 
 Context Events Edges
 --------------------


@@ -2228,131 +773,10 @@ Context Events Edges
 
                   The following events create all edges of the topology.
 
 
                   The following events create all edges of the topology.
 

-               .. container:: listingblock
+                  .. container:: ulist

 
 

-                  .. container:: content
+                     -  |ctxtEdgesJson_link|

 
 

-                     .. code:: CodeRay
-
-                        {
-                            "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
-                        }

 
 Context Events Customers
 ------------------------
 
 Context Events Customers
 ------------------------


@@ -2363,42 +787,12 @@ Context Events Customers
 
                .. container:: paragraph
 
 
                .. container:: paragraph
 

-                  The following events create all customers of the
-                  topology.
+                  The following events create all customers of the topology.

 
 

-               .. container:: listingblock
+                  .. container:: ulist

 
 

-                  .. container:: content
+                     -  |ctxtCustomerJson_link|

 
 

-                     .. code:: CodeRay
-
-                        {
-                            "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
-                        }

 
 Trigger Examples
 ----------------
 
 Trigger Examples
 ----------------


@@ -2411,61 +805,9 @@ Trigger Examples
 
                   The following events are examples for trigger events
 
 
                   The following events are examples for trigger events
 

-               .. container:: listingblock
-
-                  .. container:: content
+                  .. container:: ulist

 
 

-                     .. code:: CodeRay
-
-                        {
-                            "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"
-                        }
+                     -  |triggerEdgeJson_link|

 
 Link Monitor
 ------------
 
 Link Monitor
 ------------


@@ -2480,227 +822,7 @@ Link Monitor
                   sends the context events to APEX to initialize the
                   topology and the customers. Then it takes events from
                   Kafka and sends them to APEX.
                   sends the context events to APEX to initialize the
                   topology and the customers. Then it takes events from
                   Kafka and sends them to APEX.

-
-               .. container:: listingblock
-
-                  .. container:: content
-
-                     .. code:: CodeRay
-
-                        # ============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
+                  Sample |linkMonitor_link|

 
 Mininet Topology
 ----------------
 
 Mininet Topology
 ----------------


@@ -2711,232 +833,11 @@ Mininet Topology
 
                .. container:: paragraph
 
 
                .. container:: paragraph
 

-                  The topology is realized using Mininet. The following
-                  script is use to estalish the topology and to realize
+                  The topology is realized using Mininet. This
+                  script is used to establish the topology and to realize

                   network configurations.
                   network configurations.

+                  Sample |mininetTopology_link|

 
 

-               .. container:: listingblock
-
-                  .. container:: content
-
-                     .. code:: CodeRay
-
-                        # ============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()

 
    .. container::
       :name: footer-text
 
    .. container::
       :name: footer-text


@@ -2945,10 +846,71 @@ Mininet Topology
       Last updated 2020-04-03 16:04:24 IST
 
 
       Last updated 2020-04-03 16:04:24 IST
 
 

-.. |ONAP| image:: ../../../images/logos.png
-   :class: builtBy
-   :target: http://www.onap.org/
-

 .. |VPN SLA Architecture| image:: images/pcvs/vpnsla-arch.png
 
 .. |VPN SLA Architecture| image:: images/pcvs/vpnsla-arch.png
 

+.. |avroSchemaEdges_link| raw:: html
+
+  <a href="https://github.com/onap/policy-apex-pdp/tree/master/examples/examples-pcvs/src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/avro/topology-edges.avsc" target="_blank">AVRO Schema Edges</a>
+.. |avroSchemaNodes_link| raw:: html
+
+  <a href="https://github.com/onap/policy-apex-pdp/tree/master/examples/examples-pcvs/src//main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/avro/topology-nodes.avsc" target="_blank">AVRO Schema Nodes</a>
+.. |avroSchemaCustomers_link| raw:: html
+
+  <a href="https://github.com/onap/policy-apex-pdp/tree/master/examples/examples-pcvs/src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/avro/customers.avsc" target="_blank">AVRO Schema Customers</a>
+.. |avroSchemaLinkStatus_link| raw:: html
+
+  <a href="https://github.com/onap/policy-apex-pdp/tree/master/examples/examples-pcvs/src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/avro/link-status.avsc" target="_blank">AVRO Schema Link Status</a>
+.. |cntxtNodes_link| raw:: html
+
+  <a href="https://github.com/onap/policy-apex-pdp/tree/master/examples/examples-pcvs/src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/ctxt-nodes.js" target="_blank">Logic Node Context</a>
+.. |cntxtEdges_link| raw:: html
+
+  <a href="https://github.com/onap/policy-apex-pdp/tree/master/examples/examples-pcvs/src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/ctxt-edges.js" target="_blank">Logic Edge Context</a>
+.. |cntxtCustomer_link| raw:: html
+
+  <a href="https://github.com/onap/policy-apex-pdp/tree/master/examples/examples-pcvs/src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/ctxt-customer.js" target="_blank">Logic Customer Context</a>
+.. |taskMatch_link| raw:: html
+
+  <a href="https://github.com/onap/policy-apex-pdp/tree/master/examples/examples-pcvs/src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/task-match.js" target="_blank">Logic Policy Match State</a>
+.. |taskEstablish_link| raw:: html
+
+  <a href="https://github.com/onap/policy-apex-pdp/tree/master/examples/examples-pcvs/src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/task-establish.js" target="_blank">Logic Policy Establish State</a>
+.. |tslDecide_Link| raw:: html
+
+  <a href="https://github.com/onap/policy-apex-pdp/tree/master/examples/examples-pcvs/src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/tsl-decide.js" target="_blank">JS Logic Policy Decide State - TSL</a>
+.. |taskDecideNone_link| raw:: html
+
+  <a href="https://github.com/onap/policy-apex-pdp/tree/master/examples/examples-pcvs/src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/task-decide-none.js" target="_blank">Logic: Decide None</a>
+.. |taskDecideSolved_Link| raw:: html
+
+  <a href="https://github.com/onap/policy-apex-pdp/tree/master/examples/examples-pcvs/src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/task-decide-solved.js" target="_blank">Logic: Decide Solved</a>
+.. |taskDecideSla_link| raw:: html
+
+  <a href="https://github.com/onap/policy-apex-pdp/tree/master/examples/examples-pcvs/src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/task-decide-sla.js" target="_blank">Logic: Decide SLA</a>
+.. |taskDecidePriority_Link| raw:: html
+
+  <a href="https://github.com/onap/policy-apex-pdp/tree/master/examples/examples-pcvs/src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/task-decide-priority.js" target="_blank">Logic: Decide Priority</a>
+.. |taskAct_link| raw:: html
+
+  <a href="https://github.com/onap/policy-apex-pdp/tree/master/examples/examples-pcvs/src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/logic/task-act.js" target="_blank">Logic Policy Act State</a>
+.. |vpnsla-apex_link| raw:: html
+
+  <a href="https://github.com/onap/policy-apex-pdp/tree/master/examples/examples-pcvs/src/main/resources/org/onap/policy/apex/examples/pcvs/vpnsla/vpnsla.apex" target="_blank">APEX VPN SLA Policy Specification</a>
+.. |ctxtNodesJson_link| raw:: html
+
+  <a href="https://github.com/onap/policy-apex-pdp/tree/master/examples/examples-pcvs/src/main/resources/examples/events/pcvs/vpnsla/CtxtNodes.json" target="_blank">Context Events Nodes</a>
+.. |ctxtEdgesJson_link| raw:: html
+
+  <a href="https://github.com/onap/policy-apex-pdp/tree/master/examples/examples-pcvs/src/main/resources/examples/events/pcvs/vpnsla/CtxtEdges.json" target="_blank">Context Events Edges</a>
+.. |ctxtCustomerJson_link| raw:: html
+
+  <a href="https://github.com/onap/policy-apex-pdp/tree/master/examples/examples-pcvs/src/main/resources/examples/events/pcvs/vpnsla/CtxtCustomers.json" target="_blank">Context Events Customers</a>
+.. |triggerEdgeJson_link| raw:: html
+
+  <a href="https://github.com/onap/policy-apex-pdp/tree/master/examples/examples-pcvs/src/main/resources/examples/events/pcvs/vpnsla/Trigger_Edge09.json" target="_blank">Trigger Examples</a>
+.. |linkMonitor_link| raw:: html
+
+  <a href="https://github.com/onap/policy-apex-pdp/tree/master/examples/examples-pcvs/src/main/resources/examples/scripts/pcvs/vpnsla/LinkMonitor.py" target="_blank">Link Monitor</a>
+.. |mininetTopology_link| raw:: html

 
 

+  <a href="https://github.com/onap/policy-apex-pdp/tree/master/examples/examples-pcvs/src/main/resources/examples/scripts/pcvs/vpnsla/MininetTopology.py" target="_blank">Mininet Topology</a>