Newer
Older
/*
* Copyright (c) 2019 InterDigital Communications, Inc
*
* 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.
*/
package model
import (
"fmt"
"testing"
dataModel "github.com/InterDigitalInc/AdvantEDGE/go-packages/meep-data-model"
log "github.com/InterDigitalInc/AdvantEDGE/go-packages/meep-logger"
Kevin Di Lallo
committed
const modelRedisAddr string = "localhost:30380"
const modelRedisTestTable = 0
const modelName string = "test-model"
const moduleName string = "test-module"
Kevin Di Lallo
committed
const moduleNamespace string = "test-ns"
const testScenario_v1_0_0 string = `{"version":"1.0.0","name":"demo1","deployment":{"interDomainLatency":50,"interDomainLatencyVariation":5,"interDomainThroughput":1000,"domains":[{"id":"PUBLIC","name":"PUBLIC","type":"PUBLIC","interZoneLatency":6,"interZoneLatencyVariation":2,"interZoneThroughput":1000000,"zones":[{"id":"PUBLIC-COMMON","name":"PUBLIC-COMMON","type":"COMMON","interFogLatency":2,"interFogLatencyVariation":1,"interFogThroughput":1000000,"interEdgeLatency":3,"interEdgeLatencyVariation":1,"interEdgeThroughput":1000000,"edgeFogLatency":5,"edgeFogLatencyVariation":1,"edgeFogThroughput":1000000,"networkLocations":[{"id":"PUBLIC-COMMON-DEFAULT","name":"PUBLIC-COMMON-DEFAULT","type":"DEFAULT","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":50000,"terminalLinkPacketLoss":1,"physicalLocations":[{"id":"cloud1","name":"cloud1","type":"DC","processes":[{"id":"cloud1-iperf","name":"cloud1-iperf","type":"CLOUD-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT","commandExe":"/bin/bash","serviceConfig":{"name":"cloud1-iperf","ports":[{"protocol":"UDP","port":80}]}},{"id":"cloud1-svc","name":"cloud1-svc","type":"CLOUD-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=cloud1-svc, MGM_APP_ID=cloud1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"cloud1-svc","ports":[{"protocol":"TCP","port":80}]}}]}]}]}]},{"id":"operator1","name":"operator1","type":"OPERATOR","interZoneLatency":15,"interZoneLatencyVariation":3,"interZoneThroughput":1000,"zones":[{"id":"operator1-COMMON","name":"operator1-COMMON","type":"COMMON","interFogLatency":2,"interFogLatencyVariation":1,"interFogThroughput":1000000,"interEdgeLatency":3,"interEdgeLatencyVariation":1,"interEdgeThroughput":1000000,"edgeFogLatency":5,"edgeFogLatencyVariation":1,"edgeFogThroughput":1000000,"networkLocations":[{"id":"operator1-COMMON-DEFAULT","name":"operator1-COMMON-DEFAULT","type":"DEFAULT","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":50000,"terminalLinkPacketLoss":1}]},{"id":"zone1","name":"zone1","type":"ZONE","interFogLatency":10,"interFogLatencyVariation":2,"interFogThroughput":1000,"interEdgeLatency":12,"interEdgeLatencyVariation":2,"interEdgeThroughput":1000,"edgeFogLatency":5,"edgeFogLatencyVariation":1,"edgeFogThroughput":1000,"networkLocations":[{"id":"zone1-DEFAULT","name":"zone1-DEFAULT","type":"DEFAULT","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":50000,"terminalLinkPacketLoss":1,"physicalLocations":[{"id":"zone1-edge1","name":"zone1-edge1","type":"EDGE","processes":[{"id":"zone1-edge1-iperf","name":"zone1-edge1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT","commandExe":"/bin/bash","serviceConfig":{"name":"zone1-edge1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]}},{"id":"zone1-edge1-svc","name":"zone1-edge1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone1-edge1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone1-edge1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]}}]}]},{"id":"zone1-poa1","name":"zone1-poa1","type":"POA","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":1000,"physicalLocations":[{"id":"zone1-fog1","name":"zone1-fog1","type":"FOG","processes":[{"id":"zone1-fog1-iperf","name":"zone1-fog1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT;","commandExe":"/bin/bash","serviceConfig":{"name":"zone1-fog1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]}},{"id":"zone1-fog1-svc","name":"zone1-fog1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone1-fog1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone1-fog1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]}}]},{"id":"ue1","name":"ue1","type":"UE","processes":[{"id":"ue1-iperf","name":"ue1-iperf","type":"UE-APP","image":"gophernet/iperf-client","commandArguments":"-c, export; iperf -u -c $IPERF_SERVICE_HOST -p $IPERF_SERVICE_PORT -t 3600 -b 50M;","commandExe":"/bin/bash"}]},{"id":"ue2-ext","name":"ue2-ext","type":"UE","isExternal":true,"processes":[{"id":"ue2-svc","name":"ue2-svc","type":"UE-APP","isExternal":true,"externalConfig":{"ingressServiceMap":[{"name":"svc","port":80,"externalPort":31111,"protocol":"TCP"},{"name":"iperf","port":80,"externalPort":31222,"protocol":"UDP"},{"name":"cloud1-svc","port":80,"externalPort":31112,"protocol":"TCP"},{"name":"cloud1-iperf","port":80,"externalPort":31223,"protocol":"UDP"}]}}]}]},{"id":"zone1-poa2","name":"zone1-poa2","type":"POA","terminalLinkLatency":10,"terminalLinkLatencyVariation":2,"terminalLinkThroughput":50}]},{"id":"zone2","name":"zone2","type":"ZONE","interFogLatency":10,"interFogLatencyVariation":2,"interFogThroughput":1000,"interEdgeLatency":12,"interEdgeLatencyVariation":2,"interEdgeThroughput":1000,"edgeFogLatency":5,"edgeFogLatencyVariation":1,"edgeFogThroughput":1000,"networkLocations":[{"id":"zone2-DEFAULT","name":"zone2-DEFAULT","type":"DEFAULT","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":50000,"terminalLinkPacketLoss":1,"physicalLocations":[{"id":"zone2-edge1","name":"zone2-edge1","type":"EDGE","processes":[{"id":"zone2-edge1-iperf","name":"zone2-edge1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT;","commandExe":"/bin/bash","serviceConfig":{"name":"zone2-edge1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]}},{"id":"zone2-edge1-svc","name":"zone2-edge1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone2-edge1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone2-edge1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]}}]}]},{"id":"zone2-poa1","name":"zone2-poa1","type":"POA","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":20}]}]}]}}`
Kevin Di Lallo
committed
const testScenario_v1_3_0 string = `{"version":"1.3.0","name":"demo1","deployment":{"interDomainLatency":50,"interDomainLatencyVariation":5,"interDomainThroughput":1000,"domains":[{"id":"PUBLIC","name":"PUBLIC","type":"PUBLIC","interZoneLatency":6,"interZoneLatencyVariation":2,"interZoneThroughput":1000000,"zones":[{"id":"PUBLIC-COMMON","name":"PUBLIC-COMMON","type":"COMMON","interFogLatency":2,"interFogLatencyVariation":1,"interFogThroughput":1000000,"interEdgeLatency":3,"interEdgeLatencyVariation":1,"interEdgeThroughput":1000000,"edgeFogLatency":5,"edgeFogLatencyVariation":1,"edgeFogThroughput":1000000,"networkLocations":[{"id":"PUBLIC-COMMON-DEFAULT","name":"PUBLIC-COMMON-DEFAULT","type":"DEFAULT","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":50000,"terminalLinkPacketLoss":1,"physicalLocations":[{"id":"cloud1","name":"cloud1","type":"DC","processes":[{"id":"cloud1-iperf","name":"cloud1-iperf","type":"CLOUD-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT","commandExe":"/bin/bash","serviceConfig":{"name":"cloud1-iperf","ports":[{"protocol":"UDP","port":80}]}},{"id":"cloud1-svc","name":"cloud1-svc","type":"CLOUD-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=cloud1-svc, MGM_APP_ID=cloud1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"cloud1-svc","ports":[{"protocol":"TCP","port":80}]}}]}]}]}]},{"id":"operator1","name":"operator1","type":"OPERATOR","interZoneLatency":15,"interZoneLatencyVariation":3,"interZoneThroughput":1000,"zones":[{"id":"operator1-COMMON","name":"operator1-COMMON","type":"COMMON","interFogLatency":2,"interFogLatencyVariation":1,"interFogThroughput":1000000,"interEdgeLatency":3,"interEdgeLatencyVariation":1,"interEdgeThroughput":1000000,"edgeFogLatency":5,"edgeFogLatencyVariation":1,"edgeFogThroughput":1000000,"networkLocations":[{"id":"operator1-COMMON-DEFAULT","name":"operator1-COMMON-DEFAULT","type":"DEFAULT","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":50000,"terminalLinkPacketLoss":1}]},{"id":"zone1","name":"zone1","type":"ZONE","interFogLatency":10,"interFogLatencyVariation":2,"interFogThroughput":1000,"interEdgeLatency":12,"interEdgeLatencyVariation":2,"interEdgeThroughput":1000,"edgeFogLatency":5,"edgeFogLatencyVariation":1,"edgeFogThroughput":1000,"networkLocations":[{"id":"zone1-DEFAULT","name":"zone1-DEFAULT","type":"DEFAULT","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":50000,"terminalLinkPacketLoss":1,"physicalLocations":[{"id":"zone1-edge1","name":"zone1-edge1","type":"EDGE","processes":[{"id":"zone1-edge1-iperf","name":"zone1-edge1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT","commandExe":"/bin/bash","serviceConfig":{"name":"zone1-edge1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]}},{"id":"zone1-edge1-svc","name":"zone1-edge1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone1-edge1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone1-edge1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]}}]}]},{"id":"zone1-poa1","name":"zone1-poa1","type":"POA","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":1000,"physicalLocations":[{"id":"zone1-fog1","name":"zone1-fog1","type":"FOG","processes":[{"id":"zone1-fog1-iperf","name":"zone1-fog1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT;","commandExe":"/bin/bash","serviceConfig":{"name":"zone1-fog1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]}},{"id":"zone1-fog1-svc","name":"zone1-fog1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone1-fog1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone1-fog1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]}}]},{"id":"ue1","name":"ue1","type":"UE","processes":[{"id":"ue1-iperf","name":"ue1-iperf","type":"UE-APP","image":"gophernet/iperf-client","commandArguments":"-c, export; iperf -u -c $IPERF_SERVICE_HOST -p $IPERF_SERVICE_PORT -t 3600 -b 50M;","commandExe":"/bin/bash"}]},{"id":"ue2-ext","name":"ue2-ext","type":"UE","isExternal":true,"processes":[{"id":"ue2-svc","name":"ue2-svc","type":"UE-APP","isExternal":true,"externalConfig":{"ingressServiceMap":[{"name":"svc","port":80,"externalPort":31111,"protocol":"TCP"},{"name":"iperf","port":80,"externalPort":31222,"protocol":"UDP"},{"name":"cloud1-svc","port":80,"externalPort":31112,"protocol":"TCP"},{"name":"cloud1-iperf","port":80,"externalPort":31223,"protocol":"UDP"}]}}]}]},{"id":"zone1-poa2","name":"zone1-poa2","type":"POA","terminalLinkLatency":10,"terminalLinkLatencyVariation":2,"terminalLinkThroughput":50}]},{"id":"zone2","name":"zone2","type":"ZONE","interFogLatency":10,"interFogLatencyVariation":2,"interFogThroughput":1000,"interEdgeLatency":12,"interEdgeLatencyVariation":2,"interEdgeThroughput":1000,"edgeFogLatency":5,"edgeFogLatencyVariation":1,"edgeFogThroughput":1000,"networkLocations":[{"id":"zone2-DEFAULT","name":"zone2-DEFAULT","type":"DEFAULT","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":50000,"terminalLinkPacketLoss":1,"physicalLocations":[{"id":"zone2-edge1","name":"zone2-edge1","type":"EDGE","processes":[{"id":"zone2-edge1-iperf","name":"zone2-edge1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT;","commandExe":"/bin/bash","serviceConfig":{"name":"zone2-edge1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]}},{"id":"zone2-edge1-svc","name":"zone2-edge1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone2-edge1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone2-edge1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]}}]}]},{"id":"zone2-poa1","name":"zone2-poa1","type":"POA","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":20}]}]}]}}`
const testScenario_v1_4_0 string = `{"version":"1.4.0","name":"demo1","deployment":{"interDomainLatency":50,"interDomainLatencyVariation":5,"interDomainThroughput":1000,"domains":[{"id":"PUBLIC","name":"PUBLIC","type":"PUBLIC","interZoneLatency":6,"interZoneLatencyVariation":2,"interZoneThroughput":1000000,"zones":[{"id":"PUBLIC-COMMON","name":"PUBLIC-COMMON","type":"COMMON","netChar":{"latency":5,"latencyVariation":1,"throughput":1000000},"networkLocations":[{"id":"PUBLIC-COMMON-DEFAULT","name":"PUBLIC-COMMON-DEFAULT","type":"DEFAULT","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":50000,"terminalLinkPacketLoss":1,"physicalLocations":[{"id":"cloud1","name":"cloud1","type":"DC","processes":[{"id":"cloud1-iperf","name":"cloud1-iperf","type":"CLOUD-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT","commandExe":"/bin/bash","serviceConfig":{"name":"cloud1-iperf","ports":[{"protocol":"UDP","port":80}]}},{"id":"cloud1-svc","name":"cloud1-svc","type":"CLOUD-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=cloud1-svc, MGM_APP_ID=cloud1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"cloud1-svc","ports":[{"protocol":"TCP","port":80}]}}]}]}]}]},{"id":"operator1","name":"operator1","type":"OPERATOR","interZoneLatency":15,"interZoneLatencyVariation":3,"interZoneThroughput":1000,"zones":[{"id":"operator1-COMMON","name":"operator1-COMMON","type":"COMMON","netChar":{"latency":5,"latencyVariation":1,"throughput":1000000},"networkLocations":[{"id":"operator1-COMMON-DEFAULT","name":"operator1-COMMON-DEFAULT","type":"DEFAULT","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":50000,"terminalLinkPacketLoss":1}]},{"id":"zone1","name":"zone1","type":"ZONE","netChar":{"latency":5,"latencyVariation":1,"throughput":1000},"networkLocations":[{"id":"zone1-DEFAULT","name":"zone1-DEFAULT","type":"DEFAULT","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":50000,"terminalLinkPacketLoss":1,"physicalLocations":[{"id":"zone1-edge1","name":"zone1-edge1","type":"EDGE","processes":[{"id":"zone1-edge1-iperf","name":"zone1-edge1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT","commandExe":"/bin/bash","serviceConfig":{"name":"zone1-edge1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]}},{"id":"zone1-edge1-svc","name":"zone1-edge1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone1-edge1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone1-edge1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]}}]}]},{"id":"zone1-poa1","name":"zone1-poa1","type":"POA","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":1000,"physicalLocations":[{"id":"zone1-fog1","name":"zone1-fog1","type":"FOG","processes":[{"id":"zone1-fog1-iperf","name":"zone1-fog1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT;","commandExe":"/bin/bash","serviceConfig":{"name":"zone1-fog1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]}},{"id":"zone1-fog1-svc","name":"zone1-fog1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone1-fog1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone1-fog1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]}}]},{"id":"ue1","name":"ue1","type":"UE","processes":[{"id":"ue1-iperf","name":"ue1-iperf","type":"UE-APP","image":"gophernet/iperf-client","commandArguments":"-c, export; iperf -u -c $IPERF_SERVICE_HOST -p $IPERF_SERVICE_PORT -t 3600 -b 50M;","commandExe":"/bin/bash"}]},{"id":"ue2-ext","name":"ue2-ext","type":"UE","isExternal":true,"processes":[{"id":"ue2-svc","name":"ue2-svc","type":"UE-APP","isExternal":true,"externalConfig":{"ingressServiceMap":[{"name":"svc","port":80,"externalPort":31111,"protocol":"TCP"},{"name":"iperf","port":80,"externalPort":31222,"protocol":"UDP"},{"name":"cloud1-svc","port":80,"externalPort":31112,"protocol":"TCP"},{"name":"cloud1-iperf","port":80,"externalPort":31223,"protocol":"UDP"}]}}]}]},{"id":"zone1-poa2","name":"zone1-poa2","type":"POA","terminalLinkLatency":10,"terminalLinkLatencyVariation":2,"terminalLinkThroughput":50}]},{"id":"zone2","name":"zone2","type":"ZONE","netChar":{"latency":5,"latencyVariation":1,"throughput":1000},"networkLocations":[{"id":"zone2-DEFAULT","name":"zone2-DEFAULT","type":"DEFAULT","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":50000,"terminalLinkPacketLoss":1,"physicalLocations":[{"id":"zone2-edge1","name":"zone2-edge1","type":"EDGE","processes":[{"id":"zone2-edge1-iperf","name":"zone2-edge1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT;","commandExe":"/bin/bash","serviceConfig":{"name":"zone2-edge1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]}},{"id":"zone2-edge1-svc","name":"zone2-edge1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone2-edge1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone2-edge1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]}}]}]},{"id":"zone2-poa1","name":"zone2-poa1","type":"POA","terminalLinkLatency":1,"terminalLinkLatencyVariation":1,"terminalLinkThroughput":20}]}]}]}}`
const testScenario_v1_5_0 string = `{"version":"1.5.0","name":"demo1","deployment":{"netChar":{"latency":50,"latencyVariation":5,"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000},"domains":[{"id":"PUBLIC","name":"PUBLIC","type":"PUBLIC","netChar":{"latency":6,"latencyVariation":2,"throughputDl":1000000,"throughputUl":1000000},"zones":[{"id":"PUBLIC-COMMON","name":"PUBLIC-COMMON","type":"COMMON","netChar":{"latency":5,"latencyVariation":1,"throughputDl":1000000,"throughputUl":1000000},"networkLocations":[{"id":"PUBLIC-COMMON-DEFAULT","name":"PUBLIC-COMMON-DEFAULT","type":"DEFAULT","netChar":{"latency":1,"latencyVariation":1,"throughputDl":50000,"throughputUl":50000,"packetLoss":1},"physicalLocations":[{"id":"cloud1","name":"cloud1","type":"DC","processes":[{"id":"cloud1-iperf","name":"cloud1-iperf","type":"CLOUD-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT","commandExe":"/bin/bash","serviceConfig":{"name":"cloud1-iperf","ports":[{"protocol":"UDP","port":80}]},"netChar":{}},{"id":"cloud1-svc","name":"cloud1-svc","type":"CLOUD-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=cloud1-svc, MGM_APP_ID=cloud1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"cloud1-svc","ports":[{"protocol":"TCP","port":80}]},"netChar":{}}],"netChar":{}}]}]}]},{"id":"operator1","name":"operator1","type":"OPERATOR","netChar":{"latency":15,"latencyVariation":3,"throughputDl":1000,"throughputUl":1000},"zones":[{"id":"operator1-COMMON","name":"operator1-COMMON","type":"COMMON","netChar":{"latency":5,"latencyVariation":1,"throughputDl":1000000,"throughputUl":1000000},"networkLocations":[{"id":"operator1-COMMON-DEFAULT","name":"operator1-COMMON-DEFAULT","type":"DEFAULT","netChar":{"latency":1,"latencyVariation":1,"throughputDl":50000,"throughputUl":50000,"packetLoss":1}}]},{"id":"zone1","name":"zone1","type":"ZONE","netChar":{"latency":5,"latencyVariation":1,"throughputDl":1000,"throughputUl":1000},"networkLocations":[{"id":"zone1-DEFAULT","name":"zone1-DEFAULT","type":"DEFAULT","netChar":{"latency":1,"latencyVariation":1,"throughputDl":50000,"throughputUl":50000,"packetLoss":1},"physicalLocations":[{"id":"zone1-edge1","name":"zone1-edge1","type":"EDGE","processes":[{"id":"zone1-edge1-iperf","name":"zone1-edge1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT","commandExe":"/bin/bash","serviceConfig":{"name":"zone1-edge1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]},"netChar":{}},{"id":"zone1-edge1-svc","name":"zone1-edge1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone1-edge1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone1-edge1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]},"netChar":{}}],"netChar":{}}]},{"id":"zone1-poa1","name":"zone1-poa1","type":"POA","netChar":{"latency":1,"latencyVariation":1,"throughputDl":1000,"throughputUl":1000},"physicalLocations":[{"id":"zone1-fog1","name":"zone1-fog1","type":"FOG","processes":[{"id":"zone1-fog1-iperf","name":"zone1-fog1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT;","commandExe":"/bin/bash","serviceConfig":{"name":"zone1-fog1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]},"netChar":{}},{"id":"zone1-fog1-svc","name":"zone1-fog1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone1-fog1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone1-fog1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]},"netChar":{}}],"netChar":{}},{"id":"ue1","name":"ue1","type":"UE","processes":[{"id":"ue1-iperf","name":"ue1-iperf","type":"UE-APP","image":"gophernet/iperf-client","commandArguments":"-c, export; iperf -u -c $IPERF_SERVICE_HOST -p $IPERF_SERVICE_PORT -t 3600 -b 50M;","commandExe":"/bin/bash","netChar":{}}],"netChar":{}},{"id":"ue2-ext","name":"ue2-ext","type":"UE","isExternal":true,"processes":[{"id":"ue2-svc","name":"ue2-svc","type":"UE-APP","isExternal":true,"externalConfig":{"ingressServiceMap":[{"name":"svc","port":80,"externalPort":31111,"protocol":"TCP"},{"name":"iperf","port":80,"externalPort":31222,"protocol":"UDP"},{"name":"cloud1-svc","port":80,"externalPort":31112,"protocol":"TCP"},{"name":"cloud1-iperf","port":80,"externalPort":31223,"protocol":"UDP"}]},"netChar":{}}],"netChar":{}}]},{"id":"zone1-poa2","name":"zone1-poa2","type":"POA","netChar":{"latency":10,"latencyVariation":2,"throughputDl":50,"throughputUl":50}}]},{"id":"zone2","name":"zone2","type":"ZONE","netChar":{"latency":5,"latencyVariation":1,"throughputDl":1000,"throughputUl":1000},"networkLocations":[{"id":"zone2-DEFAULT","name":"zone2-DEFAULT","type":"DEFAULT","netChar":{"latency":1,"latencyVariation":1,"throughputDl":50000,"throughputUl":50000,"packetLoss":1},"physicalLocations":[{"id":"zone2-edge1","name":"zone2-edge1","type":"EDGE","processes":[{"id":"zone2-edge1-iperf","name":"zone2-edge1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT;","commandExe":"/bin/bash","serviceConfig":{"name":"zone2-edge1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]},"netChar":{}},{"id":"zone2-edge1-svc","name":"zone2-edge1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone2-edge1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone2-edge1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]},"netChar":{}}],"netChar":{}}]},{"id":"zone2-poa1","name":"zone2-poa1","type":"POA","netChar":{"latency":1,"latencyVariation":1,"throughputDl":20,"throughputUl":20}}]}]}]}}`
const testScenario_v1_5_3 string = `{"version":"1.5.3","name":"demo1","deployment":{"netChar":{"latency":50,"latencyVariation":5,"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000},"domains":[{"id":"PUBLIC","name":"PUBLIC","type":"PUBLIC","netChar":{"latency":6,"latencyVariation":2,"throughputDl":1000000,"throughputUl":1000000},"zones":[{"id":"PUBLIC-COMMON","name":"PUBLIC-COMMON","type":"COMMON","netChar":{"latency":5,"latencyVariation":1,"throughputDl":1000000,"throughputUl":1000000},"networkLocations":[{"id":"PUBLIC-COMMON-DEFAULT","name":"PUBLIC-COMMON-DEFAULT","type":"DEFAULT","netChar":{"latency":1,"latencyVariation":1,"throughputDl":50000,"throughputUl":50000,"packetLoss":1},"physicalLocations":[{"id":"cloud1","name":"cloud1","type":"DC","connected":true,"processes":[{"id":"cloud1-iperf","name":"cloud1-iperf","type":"CLOUD-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT","commandExe":"/bin/bash","serviceConfig":{"name":"cloud1-iperf","ports":[{"protocol":"UDP","port":80}]},"netChar":{}},{"id":"cloud1-svc","name":"cloud1-svc","type":"CLOUD-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=cloud1-svc, MGM_APP_ID=cloud1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"cloud1-svc","ports":[{"protocol":"TCP","port":80}]},"netChar":{}}],"netChar":{}}]}]}]},{"id":"operator1","name":"operator1","type":"OPERATOR","netChar":{"latency":15,"latencyVariation":3,"throughputDl":1000,"throughputUl":1000},"zones":[{"id":"operator1-COMMON","name":"operator1-COMMON","type":"COMMON","netChar":{"latency":5,"latencyVariation":1,"throughputDl":1000000,"throughputUl":1000000},"networkLocations":[{"id":"operator1-COMMON-DEFAULT","name":"operator1-COMMON-DEFAULT","type":"DEFAULT","netChar":{"latency":1,"latencyVariation":1,"throughputDl":50000,"throughputUl":50000,"packetLoss":1}}]},{"id":"zone1","name":"zone1","type":"ZONE","netChar":{"latency":5,"latencyVariation":1,"throughputDl":1000,"throughputUl":1000},"networkLocations":[{"id":"zone1-DEFAULT","name":"zone1-DEFAULT","type":"DEFAULT","netChar":{"latency":1,"latencyVariation":1,"throughputDl":50000,"throughputUl":50000,"packetLoss":1},"physicalLocations":[{"id":"zone1-edge1","name":"zone1-edge1","type":"EDGE","connected":true,"processes":[{"id":"zone1-edge1-iperf","name":"zone1-edge1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT","commandExe":"/bin/bash","serviceConfig":{"name":"zone1-edge1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]},"netChar":{}},{"id":"zone1-edge1-svc","name":"zone1-edge1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone1-edge1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone1-edge1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]},"netChar":{}}],"netChar":{}}]},{"id":"zone1-poa1","name":"zone1-poa1","type":"POA","netChar":{"latency":1,"latencyVariation":1,"throughputDl":1000,"throughputUl":1000},"physicalLocations":[{"id":"zone1-fog1","name":"zone1-fog1","type":"FOG","connected":true,"processes":[{"id":"zone1-fog1-iperf","name":"zone1-fog1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT;","commandExe":"/bin/bash","serviceConfig":{"name":"zone1-fog1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]},"netChar":{}},{"id":"zone1-fog1-svc","name":"zone1-fog1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone1-fog1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone1-fog1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]},"netChar":{}}],"netChar":{}},{"id":"ue1","name":"ue1","type":"UE","connected":true,"wireless":true,"processes":[{"id":"ue1-iperf","name":"ue1-iperf","type":"UE-APP","image":"gophernet/iperf-client","commandArguments":"-c, export; iperf -u -c $IPERF_SERVICE_HOST -p $IPERF_SERVICE_PORT -t 3600 -b 50M;","commandExe":"/bin/bash","netChar":{}}],"netChar":{}},{"id":"ue2-ext","name":"ue2-ext","type":"UE","isExternal":true,"connected":true,"wireless":true,"processes":[{"id":"ue2-svc","name":"ue2-svc","type":"UE-APP","isExternal":true,"externalConfig":{"ingressServiceMap":[{"name":"svc","port":80,"externalPort":31111,"protocol":"TCP"},{"name":"iperf","port":80,"externalPort":31222,"protocol":"UDP"},{"name":"cloud1-svc","port":80,"externalPort":31112,"protocol":"TCP"},{"name":"cloud1-iperf","port":80,"externalPort":31223,"protocol":"UDP"}]},"netChar":{}}],"netChar":{}}]},{"id":"zone1-poa2","name":"zone1-poa2","type":"POA","netChar":{"latency":10,"latencyVariation":2,"throughputDl":50,"throughputUl":50}}]},{"id":"zone2","name":"zone2","type":"ZONE","netChar":{"latency":5,"latencyVariation":1,"throughputDl":1000,"throughputUl":1000},"networkLocations":[{"id":"zone2-DEFAULT","name":"zone2-DEFAULT","type":"DEFAULT","netChar":{"latency":1,"latencyVariation":1,"throughputDl":50000,"throughputUl":50000,"packetLoss":1},"physicalLocations":[{"id":"zone2-edge1","name":"zone2-edge1","type":"EDGE","connected":true,"processes":[{"id":"zone2-edge1-iperf","name":"zone2-edge1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT;","commandExe":"/bin/bash","serviceConfig":{"name":"zone2-edge1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]},"netChar":{}},{"id":"zone2-edge1-svc","name":"zone2-edge1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone2-edge1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone2-edge1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]},"netChar":{}}],"netChar":{}}]},{"id":"zone2-poa1","name":"zone2-poa1","type":"POA","netChar":{"latency":1,"latencyVariation":1,"throughputDl":20,"throughputUl":20}}]}]}]}}`
const testScenario_v1_6_6 string = `{"version":"1.6.6","name":"demo1","deployment":{"netChar":{"latency":50,"latencyVariation":5,"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000},"domains":[{"id":"PUBLIC","name":"PUBLIC","type":"PUBLIC","netChar":{"latency":6,"latencyVariation":2,"throughputDl":1000000,"throughputUl":1000000},"zones":[{"id":"PUBLIC-COMMON","name":"PUBLIC-COMMON","type":"COMMON","netChar":{"latency":5,"latencyVariation":1,"throughputDl":1000000,"throughputUl":1000000},"networkLocations":[{"id":"PUBLIC-COMMON-DEFAULT","name":"PUBLIC-COMMON-DEFAULT","type":"DEFAULT","netChar":{"latency":1,"latencyVariation":1,"throughputDl":50000,"throughputUl":50000,"packetLoss":1},"physicalLocations":[{"id":"cloud1","name":"cloud1","type":"DC","connected":true,"processes":[{"id":"cloud1-iperf","name":"cloud1-iperf","type":"CLOUD-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT","commandExe":"/bin/bash","serviceConfig":{"name":"cloud1-iperf","ports":[{"protocol":"UDP","port":80}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}},{"id":"cloud1-svc","name":"cloud1-svc","type":"CLOUD-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=cloud1-svc, MGM_APP_ID=cloud1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"cloud1-svc","ports":[{"protocol":"TCP","port":80}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}],"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}]}]}]},{"id":"operator1","name":"operator1","type":"OPERATOR","netChar":{"latency":15,"latencyVariation":3,"throughputDl":1000,"throughputUl":1000},"zones":[{"id":"operator1-COMMON","name":"operator1-COMMON","type":"COMMON","netChar":{"latency":5,"latencyVariation":1,"throughputDl":1000000,"throughputUl":1000000},"networkLocations":[{"id":"operator1-COMMON-DEFAULT","name":"operator1-COMMON-DEFAULT","type":"DEFAULT","netChar":{"latency":1,"latencyVariation":1,"throughputDl":50000,"throughputUl":50000,"packetLoss":1}}]},{"id":"zone1","name":"zone1","type":"ZONE","netChar":{"latency":5,"latencyVariation":1,"throughputDl":1000,"throughputUl":1000},"networkLocations":[{"id":"zone1-DEFAULT","name":"zone1-DEFAULT","type":"DEFAULT","netChar":{"latency":1,"latencyVariation":1,"throughputDl":50000,"throughputUl":50000,"packetLoss":1},"physicalLocations":[{"id":"zone1-edge1","name":"zone1-edge1","type":"EDGE","connected":true,"processes":[{"id":"zone1-edge1-iperf","name":"zone1-edge1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT","commandExe":"/bin/bash","serviceConfig":{"name":"zone1-edge1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}},{"id":"zone1-edge1-svc","name":"zone1-edge1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone1-edge1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone1-edge1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}],"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}]},{"id":"zone1-poa1","name":"zone1-poa1","type":"POA","netChar":{"latency":1,"latencyVariation":1,"throughputDl":1000,"throughputUl":1000},"physicalLocations":[{"id":"zone1-fog1","name":"zone1-fog1","type":"FOG","connected":true,"processes":[{"id":"zone1-fog1-iperf","name":"zone1-fog1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT;","commandExe":"/bin/bash","serviceConfig":{"name":"zone1-fog1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}},{"id":"zone1-fog1-svc","name":"zone1-fog1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone1-fog1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone1-fog1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}],"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}},{"id":"ue1","name":"ue1","type":"UE","connected":true,"wireless":true,"processes":[{"id":"ue1-iperf","name":"ue1-iperf","type":"UE-APP","image":"gophernet/iperf-client","commandArguments":"-c, export; iperf -u -c $IPERF_SERVICE_HOST -p $IPERF_SERVICE_PORT -t 3600 -b 50M;","commandExe":"/bin/bash","netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}],"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}},{"id":"ue2-ext","name":"ue2-ext","type":"UE","isExternal":true,"connected":true,"wireless":true,"processes":[{"id":"ue2-svc","name":"ue2-svc","type":"UE-APP","isExternal":true,"externalConfig":{"ingressServiceMap":[{"name":"svc","port":80,"externalPort":31111,"protocol":"TCP"},{"name":"iperf","port":80,"externalPort":31222,"protocol":"UDP"},{"name":"cloud1-svc","port":80,"externalPort":31112,"protocol":"TCP"},{"name":"cloud1-iperf","port":80,"externalPort":31223,"protocol":"UDP"}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}],"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}]},{"id":"zone1-poa2","name":"zone1-poa2","type":"POA","netChar":{"latency":10,"latencyVariation":2,"throughputDl":50,"throughputUl":50}}]},{"id":"zone2","name":"zone2","type":"ZONE","netChar":{"latency":5,"latencyVariation":1,"throughputDl":1000,"throughputUl":1000},"networkLocations":[{"id":"zone2-DEFAULT","name":"zone2-DEFAULT","type":"DEFAULT","netChar":{"latency":1,"latencyVariation":1,"throughputDl":50000,"throughputUl":50000,"packetLoss":1},"physicalLocations":[{"id":"zone2-edge1","name":"zone2-edge1","type":"EDGE","connected":true,"processes":[{"id":"zone2-edge1-iperf","name":"zone2-edge1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT;","commandExe":"/bin/bash","serviceConfig":{"name":"zone2-edge1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}},{"id":"zone2-edge1-svc","name":"zone2-edge1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone2-edge1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone2-edge1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}],"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}]},{"id":"zone2-poa1","name":"zone2-poa1","type":"POA","netChar":{"latency":1,"latencyVariation":1,"throughputDl":20,"throughputUl":20}}]}]}]}}`
const testScenario_v1_6_8 string = `{"version":"1.6.8","name":"demo1","deployment":{"netChar":{"latency":50,"latencyVariation":5,"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000},"connectivity":{"model":"OPEN"},"domains":[{"id":"PUBLIC","name":"PUBLIC","type":"PUBLIC","netChar":{"latency":6,"latencyVariation":2,"throughputDl":1000000,"throughputUl":1000000},"zones":[{"id":"PUBLIC-COMMON","name":"PUBLIC-COMMON","type":"COMMON","netChar":{"latency":5,"latencyVariation":1,"throughputDl":1000000,"throughputUl":1000000},"networkLocations":[{"id":"PUBLIC-COMMON-DEFAULT","name":"PUBLIC-COMMON-DEFAULT","type":"DEFAULT","netChar":{"latency":1,"latencyVariation":1,"throughputDl":50000,"throughputUl":50000,"packetLoss":1},"physicalLocations":[{"id":"cloud1","name":"cloud1","type":"DC","connected":true,"processes":[{"id":"cloud1-iperf","name":"cloud1-iperf","type":"CLOUD-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT","commandExe":"/bin/bash","serviceConfig":{"name":"cloud1-iperf","ports":[{"protocol":"UDP","port":80}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}},{"id":"cloud1-svc","name":"cloud1-svc","type":"CLOUD-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=cloud1-svc, MGM_APP_ID=cloud1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"cloud1-svc","ports":[{"protocol":"TCP","port":80}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}],"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}]}]}]},{"id":"operator1","name":"operator1","type":"OPERATOR","netChar":{"latency":15,"latencyVariation":3,"throughputDl":1000,"throughputUl":1000},"zones":[{"id":"operator1-COMMON","name":"operator1-COMMON","type":"COMMON","netChar":{"latency":5,"latencyVariation":1,"throughputDl":1000000,"throughputUl":1000000},"networkLocations":[{"id":"operator1-COMMON-DEFAULT","name":"operator1-COMMON-DEFAULT","type":"DEFAULT","netChar":{"latency":1,"latencyVariation":1,"throughputDl":50000,"throughputUl":50000,"packetLoss":1}}]},{"id":"zone1","name":"zone1","type":"ZONE","netChar":{"latency":5,"latencyVariation":1,"throughputDl":1000,"throughputUl":1000},"networkLocations":[{"id":"zone1-DEFAULT","name":"zone1-DEFAULT","type":"DEFAULT","netChar":{"latency":1,"latencyVariation":1,"throughputDl":50000,"throughputUl":50000,"packetLoss":1},"physicalLocations":[{"id":"zone1-edge1","name":"zone1-edge1","type":"EDGE","connected":true,"processes":[{"id":"zone1-edge1-iperf","name":"zone1-edge1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT","commandExe":"/bin/bash","serviceConfig":{"name":"zone1-edge1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}},{"id":"zone1-edge1-svc","name":"zone1-edge1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone1-edge1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone1-edge1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}],"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}]},{"id":"zone1-poa1","name":"zone1-poa1","type":"POA","netChar":{"latency":1,"latencyVariation":1,"throughputDl":1000,"throughputUl":1000},"physicalLocations":[{"id":"zone1-fog1","name":"zone1-fog1","type":"FOG","connected":true,"processes":[{"id":"zone1-fog1-iperf","name":"zone1-fog1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT;","commandExe":"/bin/bash","serviceConfig":{"name":"zone1-fog1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}},{"id":"zone1-fog1-svc","name":"zone1-fog1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone1-fog1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone1-fog1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}],"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}},{"id":"ue1","name":"ue1","type":"UE","connected":true,"wireless":true,"processes":[{"id":"ue1-iperf","name":"ue1-iperf","type":"UE-APP","image":"gophernet/iperf-client","commandArguments":"-c, export; iperf -u -c $IPERF_SERVICE_HOST -p $IPERF_SERVICE_PORT -t 3600 -b 50M;","commandExe":"/bin/bash","netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}],"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}},{"id":"ue2-ext","name":"ue2-ext","type":"UE","isExternal":true,"connected":true,"wireless":true,"processes":[{"id":"ue2-svc","name":"ue2-svc","type":"UE-APP","isExternal":true,"externalConfig":{"ingressServiceMap":[{"name":"svc","port":80,"externalPort":31111,"protocol":"TCP"},{"name":"iperf","port":80,"externalPort":31222,"protocol":"UDP"},{"name":"cloud1-svc","port":80,"externalPort":31112,"protocol":"TCP"},{"name":"cloud1-iperf","port":80,"externalPort":31223,"protocol":"UDP"}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}],"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}]},{"id":"zone1-poa2","name":"zone1-poa2","type":"POA","netChar":{"latency":10,"latencyVariation":2,"throughputDl":50,"throughputUl":50}}]},{"id":"zone2","name":"zone2","type":"ZONE","netChar":{"latency":5,"latencyVariation":1,"throughputDl":1000,"throughputUl":1000},"networkLocations":[{"id":"zone2-DEFAULT","name":"zone2-DEFAULT","type":"DEFAULT","netChar":{"latency":1,"latencyVariation":1,"throughputDl":50000,"throughputUl":50000,"packetLoss":1},"physicalLocations":[{"id":"zone2-edge1","name":"zone2-edge1","type":"EDGE","connected":true,"processes":[{"id":"zone2-edge1-iperf","name":"zone2-edge1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT;","commandExe":"/bin/bash","serviceConfig":{"name":"zone2-edge1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}},{"id":"zone2-edge1-svc","name":"zone2-edge1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone2-edge1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone2-edge1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}],"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}]},{"id":"zone2-poa1","name":"zone2-poa1","type":"POA","netChar":{"latency":1,"latencyVariation":1,"throughputDl":20,"throughputUl":20}}]}]}]}}`
const testScenario string = `{"name":"demo1","deployment":{"netChar":{"latency":50,"latencyVariation":5,"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000},"connectivity":{"model":"OPEN"},"domains":[{"id":"PUBLIC","name":"PUBLIC","type":"PUBLIC","netChar":{"latency":6,"latencyVariation":2,"throughputDl":1000000,"throughputUl":1000000},"zones":[{"id":"PUBLIC-COMMON","name":"PUBLIC-COMMON","type":"COMMON","netChar":{"latency":5,"latencyVariation":1,"throughputDl":1000000,"throughputUl":1000000},"networkLocations":[{"id":"PUBLIC-COMMON-DEFAULT","name":"PUBLIC-COMMON-DEFAULT","type":"DEFAULT","netChar":{"latency":1,"latencyVariation":1,"throughputDl":50000,"throughputUl":50000,"packetLoss":1},"physicalLocations":[{"id":"cloud1","name":"cloud1","type":"DC","connected":true,"processes":[{"id":"cloud1-iperf","name":"cloud1-iperf","type":"CLOUD-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT","commandExe":"/bin/bash","serviceConfig":{"name":"cloud1-iperf","ports":[{"protocol":"UDP","port":80}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}},{"id":"cloud1-svc","name":"cloud1-svc","type":"CLOUD-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=cloud1-svc, MGM_APP_ID=cloud1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"cloud1-svc","ports":[{"protocol":"TCP","port":80}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}],"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}]}]}]},{"id":"operator1","name":"operator1","type":"OPERATOR","netChar":{"latency":15,"latencyVariation":3,"throughputDl":1000,"throughputUl":1000},"zones":[{"id":"operator1-COMMON","name":"operator1-COMMON","type":"COMMON","netChar":{"latency":5,"latencyVariation":1,"throughputDl":1000000,"throughputUl":1000000},"networkLocations":[{"id":"operator1-COMMON-DEFAULT","name":"operator1-COMMON-DEFAULT","type":"DEFAULT","netChar":{"latency":1,"latencyVariation":1,"throughputDl":50000,"throughputUl":50000,"packetLoss":1}}]},{"id":"zone1","name":"zone1","type":"ZONE","netChar":{"latency":5,"latencyVariation":1,"throughputDl":1000,"throughputUl":1000},"networkLocations":[{"id":"zone1-DEFAULT","name":"zone1-DEFAULT","type":"DEFAULT","netChar":{"latency":1,"latencyVariation":1,"throughputDl":50000,"throughputUl":50000,"packetLoss":1},"physicalLocations":[{"id":"zone1-edge1","name":"zone1-edge1","type":"EDGE","connected":true,"processes":[{"id":"zone1-edge1-iperf","name":"zone1-edge1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT","commandExe":"/bin/bash","serviceConfig":{"name":"zone1-edge1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}},{"id":"zone1-edge1-svc","name":"zone1-edge1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone1-edge1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone1-edge1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}],"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}]},{"id":"zone1-poa1","name":"zone1-poa1","type":"POA","netChar":{"latency":1,"latencyVariation":1,"throughputDl":1000,"throughputUl":1000},"physicalLocations":[{"id":"zone1-fog1","name":"zone1-fog1","type":"FOG","connected":true,"processes":[{"id":"zone1-fog1-iperf","name":"zone1-fog1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT;","commandExe":"/bin/bash","serviceConfig":{"name":"zone1-fog1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}},{"id":"zone1-fog1-svc","name":"zone1-fog1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone1-fog1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone1-fog1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}],"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}},{"id":"ue1","name":"ue1","type":"UE","connected":true,"wireless":true,"processes":[{"id":"ue1-iperf","name":"ue1-iperf","type":"UE-APP","image":"gophernet/iperf-client","commandArguments":"-c, export; iperf -u -c $IPERF_SERVICE_HOST -p $IPERF_SERVICE_PORT -t 3600 -b 50M;","commandExe":"/bin/bash","netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}],"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}},{"id":"ue2-ext","name":"ue2-ext","type":"UE","isExternal":true,"connected":true,"wireless":true,"processes":[{"id":"ue2-svc","name":"ue2-svc","type":"UE-APP","isExternal":true,"externalConfig":{"ingressServiceMap":[{"name":"svc","port":80,"externalPort":31111,"protocol":"TCP"},{"name":"iperf","port":80,"externalPort":31222,"protocol":"UDP"},{"name":"cloud1-svc","port":80,"externalPort":31112,"protocol":"TCP"},{"name":"cloud1-iperf","port":80,"externalPort":31223,"protocol":"UDP"}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}],"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}]},{"id":"zone1-poa2","name":"zone1-poa2","type":"POA","netChar":{"latency":10,"latencyVariation":2,"throughputDl":50,"throughputUl":50}}]},{"id":"zone2","name":"zone2","type":"ZONE","netChar":{"latency":5,"latencyVariation":1,"throughputDl":1000,"throughputUl":1000},"networkLocations":[{"id":"zone2-DEFAULT","name":"zone2-DEFAULT","type":"DEFAULT","netChar":{"latency":1,"latencyVariation":1,"throughputDl":50000,"throughputUl":50000,"packetLoss":1},"physicalLocations":[{"id":"zone2-edge1","name":"zone2-edge1","type":"EDGE","connected":true,"processes":[{"id":"zone2-edge1-iperf","name":"zone2-edge1-iperf","type":"EDGE-APP","image":"gophernet/iperf-server","commandArguments":"-c, export; iperf -s -p $IPERF_SERVICE_PORT;","commandExe":"/bin/bash","serviceConfig":{"name":"zone2-edge1-iperf","meSvcName":"iperf","ports":[{"protocol":"UDP","port":80}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}},{"id":"zone2-edge1-svc","name":"zone2-edge1-svc","type":"EDGE-APP","image":"meep-docker-registry:30001/demo-server","environment":"MGM_GROUP_NAME=svc, MGM_APP_ID=zone2-edge1-svc, MGM_APP_PORT=80","serviceConfig":{"name":"zone2-edge1-svc","meSvcName":"svc","ports":[{"protocol":"TCP","port":80}]},"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}],"netChar":{"latencyDistribution":"Normal","throughputDl":1000,"throughputUl":1000}}]},{"id":"zone2-poa1","name":"zone2-poa1","type":"POA","netChar":{"latency":1,"latencyVariation":1,"throughputDl":20,"throughputUl":20}}]}]}]}}`
const latestTestScenario string = testScenario_v1_6_8
func TestNewModel(t *testing.T) {
fmt.Println("--- ", t.Name())
log.MeepTextLogInit(t.Name())
// Switch to a different table for testing
redisTable = modelRedisTestTable
// Keep this one first...
fmt.Println("Invalid Redis DB address")
Kevin Di Lallo
committed
cfg := ModelCfg{Name: modelName, Namespace: moduleNamespace, Module: "test-mod", DbAddr: "ExpectedFailure-InvalidDbLocation"}
t.Fatalf("Should report error on invalid Redis db")
Kevin Di Lallo
committed
cfg = ModelCfg{Name: modelName, Namespace: moduleNamespace, Module: "", DbAddr: modelRedisAddr}
t.Fatalf("Should report error on invalid module")
Kevin Di Lallo
committed
cfg = ModelCfg{Name: modelName, Namespace: moduleNamespace, Module: "test-mod", DbAddr: modelRedisAddr}
t.Fatalf("Unable to create model")
cfg = ModelCfg{Name: "", Module: "test-mod", DbAddr: modelRedisAddr}
_, err = NewModel(cfg)
t.Fatalf("Should not allow creating model without a name")
fmt.Println("--- ", t.Name())
log.MeepTextLogInit(t.Name())
// Switch to a different table for testing
redisTable = modelRedisTestTable
Kevin Di Lallo
committed
cfg := ModelCfg{Name: modelName, Namespace: moduleNamespace, Module: "test-mod", DbAddr: modelRedisAddr}
t.Fatalf("Unable to create model")
t.Fatalf("Service map unexpected")
t.Fatalf("Error setting model")
t.Fatalf("SetScenario failed")
t.Fatalf("Error getting scenario")
t.Fatalf("Error getting scenario")
// t.Fatalf("GetModel failed")
fmt.Println("GetSvcMap - existing")
svcMap = m.GetServiceMaps()
if svcMap == nil {
t.Fatalf("Service map expected")
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
func TestGetSetActiveElements(t *testing.T) {
fmt.Println("--- ", t.Name())
log.MeepTextLogInit(t.Name())
// Switch to a different table for testing
redisTable = modelRedisTestTable
cfg := ModelCfg{Name: modelName, Namespace: moduleNamespace, Module: "test-mod", DbAddr: modelRedisAddr}
m, err := NewModel(cfg)
if err != nil {
t.Fatalf("Unable to create model")
}
fmt.Println("Set Model")
err = m.SetScenario([]byte(testScenario))
if err != nil {
t.Fatalf("Error setting model")
}
if m.scenario.Name != "demo1" {
t.Fatalf("SetScenario failed")
}
var filter, badFilter NodeFindFilter
filter.ZoneName = "zone1"
badFilter.ZoneName = "DO NOT EXIST"
filter.ProcessType = "EDGE-APP"
//success path
fmt.Println("Get Domains")
respDomain := m.GetDomainNodesByFilter(&filter)
if len(respDomain.Domains) != 1 {
t.Fatalf("Failed to get expected number of domains")
}
fmt.Println("Get Zones")
respZone := m.GetZoneNodesByFilter(&filter)
if len(respZone.Zones) != 1 {
t.Fatalf("Failed to get expected number of zones")
}
fmt.Println("Get Network Locations")
respNl := m.GetNetworkLocationNodesByFilter(&filter)
if len(respNl.NetworkLocations) != 2 {
t.Fatalf("Failed to get expected number of network locations")
}
fmt.Println("Get Physical Locations")
respPl := m.GetPhysicalLocationNodesByFilter(&filter)
if len(respPl.PhysicalLocations) != 2 {
t.Fatalf("Failed to get expected number of physical locations")
}
fmt.Println("Get Processes")
respProc := m.GetProcessNodesByFilter(&filter)
if len(respProc.Processes) != 4 {
t.Fatalf("Failed to get expected number of processes")
}
//failure path
fmt.Println("Get Domains")
respDomain = m.GetDomainNodesByFilter(&badFilter)
if len(respDomain.Domains) != 0 {
t.Fatalf("Failed to get expected number of domains")
}
fmt.Println("Get Zones")
respZone = m.GetZoneNodesByFilter(&badFilter)
if len(respZone.Zones) != 0 {
t.Fatalf("Failed to get expected number of zones")
}
fmt.Println("Get Network Locations")
respNl = m.GetNetworkLocationNodesByFilter(&badFilter)
if len(respNl.NetworkLocations) != 0 {
t.Fatalf("Failed to get expected number of network locations")
}
fmt.Println("Get Physical Locations")
respPl = m.GetPhysicalLocationNodesByFilter(&badFilter)
if len(respPl.PhysicalLocations) != 0 {
t.Fatalf("Failed to get expected number of physical locations")
}
fmt.Println("Get Processes")
respProc = m.GetProcessNodesByFilter(&badFilter)
if len(respProc.Processes) != 0 {
t.Fatalf("Failed to get expected number of processes")
}
}
func TestActivateDeactivate(t *testing.T) {
fmt.Println("--- ", t.Name())
log.MeepTextLogInit(t.Name())
// Switch to a different table for testing
redisTable = modelRedisTestTable
Kevin Di Lallo
committed
cfg := ModelCfg{Name: modelName, Namespace: moduleNamespace, Module: "test-mod", DbAddr: modelRedisAddr}
t.Fatalf("Unable to create model")
t.Fatalf("Error setting model")
t.Fatalf("SetScenario failed")
}
fmt.Println("Activate model")
err = m.Activate()
if err != nil {
t.Fatalf("Error activating model")
t.Fatalf("Error updating model")
}
fmt.Println("Deactivate model")
err = m.Deactivate()
if err != nil {
t.Fatalf("Error deactivating model")
}
}
func TestMoveNode(t *testing.T) {
fmt.Println("--- ", t.Name())
log.MeepTextLogInit(t.Name())
// Switch to a different table for testing
redisTable = modelRedisTestTable
Kevin Di Lallo
committed
cfg := ModelCfg{Name: modelName, Namespace: moduleNamespace, Module: "test-mod", DbAddr: modelRedisAddr}
t.Fatalf("Unable to create model")
t.Fatalf("Error setting model")
t.Fatalf("SetScenario failed")
old, new, err := m.MoveNode("ue1", "zone2-poa1", nil)
t.Fatalf("Error moving UE")
t.Fatalf("Move Node - wrong origin Location " + old)
t.Fatalf("Move Node - wrong destination Location " + new)
old, new, err = m.MoveNode("ue2-ext", "zone2-poa1", nil)
t.Fatalf("Error moving UE")
t.Fatalf("Move Node - wrong origin Location " + old)
t.Fatalf("Move Node - wrong destination Location " + new)
old, new, err = m.MoveNode("ue1", "zone1-poa1", nil)
t.Fatalf("Error moving UE")
t.Fatalf("Move Node - wrong origin Location " + old)
t.Fatalf("Move Node - wrong destination Location " + new)
old, new, err = m.MoveNode("ue2-ext", "zone1-poa1", nil)
t.Fatalf("Error moving UE")
t.Fatalf("Move Node - wrong origin Location " + old)
t.Fatalf("Move Node - wrong destination Location " + new)
old, new, err = m.MoveNode("ue2-ext", "zone2-poa1", nil)
t.Fatalf("Error moving UE")
t.Fatalf("Move Node - wrong origin Location " + old)
t.Fatalf("Move Node - wrong destination Location " + new)
old, new, err = m.MoveNode("ue1", "zone2-poa1", nil)
t.Fatalf("Error moving UE")
t.Fatalf("Move Node - wrong origin Location " + old)
t.Fatalf("Move Node - wrong destination Location " + new)
old, new, err = m.MoveNode("ue1", "zone1-poa1", nil)
t.Fatalf("Error moving UE")
t.Fatalf("Move Node - wrong origin Location " + old)
t.Fatalf("Move Node - wrong destination Location " + new)
fmt.Println("Move edge node zone1-edge1 to a new zone")
old, new, err = m.MoveNode("zone1-edge1", "zone2", nil)
if err != nil {
t.Fatalf("Error moving EDGE node")
}
if old != "zone1-DEFAULT" {
t.Fatalf("Move Node - wrong origin Location " + old)
}
if new != "zone2-DEFAULT" {
t.Fatalf("Move Node - wrong destination Location " + new)
}
_, _, err = m.MoveNode("zone1-edge1-iperf", "zone2-edge2", nil)
t.Fatalf("Moving Edge-App part of mobility group should not be allowed")
}
fmt.Println("Move zone1-edge1-iperf")
// Remove mobility group
node := m.nodeMap.FindByName("zone1-edge1-iperf")
if node == nil {
t.Fatalf("unable to find node")
proc := node.object.(*dataModel.Process)
old, new, err = m.MoveNode("zone1-edge1-iperf", "zone2-edge1", nil)
t.Fatalf("Error moving Edge-App")
t.Fatalf("Move Node - wrong origin Location " + old)
t.Fatalf("Move Node - wrong destination Location " + new)
_, _, err = m.MoveNode("Not-a-UE", "zone1-poa1", nil)
t.Fatalf("Error moving UE - inexisting UE")
_, _, err = m.MoveNode("ue1", "Not-a-poa", nil)
t.Fatalf("Error moving UE - inexisting PoA")
}
}
func TestUpdateNetChar(t *testing.T) {
fmt.Println("--- ", t.Name())
log.MeepTextLogInit(t.Name())
// Switch to a different table for testing
redisTable = modelRedisTestTable
Kevin Di Lallo
committed
cfg := ModelCfg{Name: modelName, Namespace: moduleNamespace, Module: "test-mod", DbAddr: modelRedisAddr}
t.Fatalf("Unable to create model")
t.Fatalf("Error setting model")
t.Fatalf("SetScenario failed")
var nc dataModel.EventNetworkCharacteristicsUpdate
var netChar dataModel.NetworkCharacteristics
netChar.Latency = 1
netChar.LatencyVariation = 2
netChar.LatencyDistribution = "Normal"
netChar.ThroughputDl = 3
netChar.ThroughputUl = 5
netChar.PacketLoss = 4
nc.NetChar = &netChar
err = m.UpdateNetChar(&nc, nil)
t.Fatalf("Update " + nc.ElementType + " failed")
if m.scenario.Deployment.NetChar.Latency != 1 {
t.Fatalf("Update " + nc.ElementType + " latency failed")
if m.scenario.Deployment.NetChar.LatencyVariation != 2 {
t.Fatalf("Update " + nc.ElementType + " jitter failed")
if m.scenario.Deployment.NetChar.LatencyDistribution != "Normal" {
t.Fatalf("Update " + nc.ElementType + " distribution failed")
}
if m.scenario.Deployment.NetChar.ThroughputDl != 3 {
t.Fatalf("Update " + nc.ElementType + " throughputDl failed")
if m.scenario.Deployment.NetChar.ThroughputUl != 5 {
t.Fatalf("Update " + nc.ElementType + " throughputUl failed")
}
if m.scenario.Deployment.NetChar.PacketLoss != 4 {
t.Fatalf("Update " + nc.ElementType + " packet loss failed")
err = m.UpdateNetChar(&nc, nil)
t.Fatalf("Update " + nc.ElementType + " failed")
d := n.object.(*dataModel.Domain)
if d.NetChar.Latency != 1 {
t.Fatalf("Update " + nc.ElementType + " latency failed")
if d.NetChar.LatencyVariation != 2 {
t.Fatalf("Update " + nc.ElementType + " jitter failed")
if d.NetChar.ThroughputDl != 3 {
t.Fatalf("Update " + nc.ElementType + " throughput failed")
}
if d.NetChar.ThroughputUl != 5 {
t.Fatalf("Update " + nc.ElementType + " throughput failed")
if d.NetChar.PacketLoss != 4 {
t.Fatalf("Update " + nc.ElementType + " packet loss failed")
err = m.UpdateNetChar(&nc, nil)
t.Fatalf("Update " + nc.ElementType + " failed")
z := n.object.(*dataModel.Zone)
if z.NetChar.Latency != 1 {
t.Fatalf("Update " + nc.ElementType + " latency failed")
if z.NetChar.LatencyVariation != 2 {
t.Fatalf("Update " + nc.ElementType + " jitter failed")
if z.NetChar.ThroughputDl != 3 {
t.Fatalf("Update " + nc.ElementType + " throughputDl failed")
}
if z.NetChar.ThroughputUl != 5 {
t.Fatalf("Update " + nc.ElementType + " throughputUl failed")
if z.NetChar.PacketLoss != 4 {
t.Fatalf("Update " + nc.ElementType + " packet loss failed")
err = m.UpdateNetChar(&nc, nil)
t.Fatalf("Update " + nc.ElementType + " failed")
nl := n.object.(*dataModel.NetworkLocation)
if nl.NetChar.Latency != 1 {
t.Fatalf("Update " + nc.ElementType + " latency failed")
if nl.NetChar.LatencyVariation != 2 {
t.Fatalf("Update " + nc.ElementType + " jitter failed")
if nl.NetChar.ThroughputDl != 3 {
t.Fatalf("Update " + nc.ElementType + " throughputDl failed")
}
if nl.NetChar.ThroughputUl != 5 {
t.Fatalf("Update " + nc.ElementType + " throughputUl failed")
if nl.NetChar.PacketLoss != 4 {
t.Fatalf("Update " + nc.ElementType + " packet loss failed")
err = m.UpdateNetChar(&nc, nil)
t.Fatalf("Update " + nc.ElementType + " failed")
pl := n.object.(*dataModel.PhysicalLocation)
if pl.NetChar.Latency != 1 {
t.Fatalf("Update " + nc.ElementType + " latency failed")
if pl.NetChar.LatencyVariation != 2 {
t.Fatalf("Update " + nc.ElementType + " jitter failed")
if pl.NetChar.ThroughputDl != 3 {
t.Fatalf("Update " + nc.ElementType + " throughputDl failed")
}
if pl.NetChar.ThroughputUl != 5 {
t.Fatalf("Update " + nc.ElementType + " throughputUl failed")
if pl.NetChar.PacketLoss != 4 {
t.Fatalf("Update " + nc.ElementType + " packet loss failed")
err = m.UpdateNetChar(&nc, nil)
t.Fatalf("Update " + nc.ElementType + " failed")
pl = n.object.(*dataModel.PhysicalLocation)
if pl.NetChar.Latency != 1 {
t.Fatalf("Update " + nc.ElementType + " latency failed")
if pl.NetChar.LatencyVariation != 2 {
t.Fatalf("Update " + nc.ElementType + " jitter failed")
if pl.NetChar.ThroughputDl != 3 {
t.Fatalf("Update " + nc.ElementType + " throughputDl failed")
if pl.NetChar.ThroughputUl != 5 {
t.Fatalf("Update " + nc.ElementType + " throughputUl failed")
}
if pl.NetChar.PacketLoss != 4 {
t.Fatalf("Update " + nc.ElementType + " packet loss failed")
err = m.UpdateNetChar(&nc, nil)
t.Fatalf("Update " + nc.ElementType + " failed")
pl = n.object.(*dataModel.PhysicalLocation)
if pl.NetChar.Latency != 1 {
t.Fatalf("Update " + nc.ElementType + " latency failed")
if pl.NetChar.LatencyVariation != 2 {
t.Fatalf("Update " + nc.ElementType + " jitter failed")
if pl.NetChar.ThroughputDl != 3 {
t.Fatalf("Update " + nc.ElementType + " throughputDl failed")
if pl.NetChar.ThroughputUl != 5 {
t.Fatalf("Update " + nc.ElementType + " throughputUl failed")
}
if pl.NetChar.PacketLoss != 4 {
t.Fatalf("Update " + nc.ElementType + " packet loss failed")
err = m.UpdateNetChar(&nc, nil)
t.Fatalf("Update " + nc.ElementType + " failed")
pl = n.object.(*dataModel.PhysicalLocation)
if pl.NetChar.Latency != 1 {
t.Fatalf("Update " + nc.ElementType + " latency failed")
if pl.NetChar.LatencyVariation != 2 {
t.Fatalf("Update " + nc.ElementType + " jitter failed")
if pl.NetChar.ThroughputDl != 3 {
t.Fatalf("Update " + nc.ElementType + " throughputDl failed")
}
if pl.NetChar.ThroughputUl != 5 {
t.Fatalf("Update " + nc.ElementType + " throughputUl failed")
if pl.NetChar.PacketLoss != 4 {
t.Fatalf("Update " + nc.ElementType + " packet loss failed")
err = m.UpdateNetChar(&nc, nil)
t.Fatalf("Update " + nc.ElementType + " failed")
proc := n.object.(*dataModel.Process)
if proc.NetChar.Latency != 1 {
t.Fatalf("Update " + nc.ElementType + " latency failed")
if proc.NetChar.LatencyVariation != 2 {
t.Fatalf("Update " + nc.ElementType + " jitter failed")
if proc.NetChar.ThroughputDl != 3 {
t.Fatalf("Update " + nc.ElementType + " throughputDl failed")
}
if proc.NetChar.ThroughputUl != 5 {
t.Fatalf("Update " + nc.ElementType + " throughputUl failed")
if proc.NetChar.PacketLoss != 4 {
t.Fatalf("Update " + nc.ElementType + " packet loss failed")
err = m.UpdateNetChar(&nc, nil)
t.Fatalf("Update " + nc.ElementType + " failed")
proc = n.object.(*dataModel.Process)
if proc.NetChar.Latency != 1 {
t.Fatalf("Update " + nc.ElementType + " latency failed")
if proc.NetChar.LatencyVariation != 2 {
t.Fatalf("Update " + nc.ElementType + " jitter failed")
if proc.NetChar.ThroughputDl != 3 {
t.Fatalf("Update " + nc.ElementType + " throughputDl failed")
}
if proc.NetChar.ThroughputUl != 5 {
t.Fatalf("Update " + nc.ElementType + " throughputUl failed")
if proc.NetChar.PacketLoss != 4 {
t.Fatalf("Update " + nc.ElementType + " packet loss failed")
err = m.UpdateNetChar(&nc, nil)
t.Fatalf("Update " + nc.ElementType + " failed")
proc = n.object.(*dataModel.Process)
if proc.NetChar.Latency != 1 {
t.Fatalf("Update " + nc.ElementType + " latency failed")
if proc.NetChar.LatencyVariation != 2 {
t.Fatalf("Update " + nc.ElementType + " jitter failed")
if proc.NetChar.ThroughputDl != 3 {
t.Fatalf("Update " + nc.ElementType + " throughputDl failed")
if proc.NetChar.ThroughputUl != 5 {
t.Fatalf("Update " + nc.ElementType + " throughputUl failed")
}
if proc.NetChar.PacketLoss != 4 {
t.Fatalf("Update " + nc.ElementType + " packet loss failed")
err = m.UpdateNetChar(&nc, nil)
t.Fatalf("Update " + nc.ElementType + " should fail")
}
nc.ElementName = "ue1"
nc.ElementType = "Not-a-Type"
err = m.UpdateNetChar(&nc, nil)
if err == nil {
t.Fatalf("Unsupported type should fail")
func TestListenModel(t *testing.T) {
fmt.Println("--- ", t.Name())
log.MeepTextLogInit(t.Name())
// Switch to a different table for testing
redisTable = modelRedisTestTable
fmt.Println("Create Publisher")
Kevin Di Lallo
committed
cfg := ModelCfg{Name: modelName, Namespace: moduleNamespace, Module: moduleName + "-Pub", DbAddr: modelRedisAddr}
mPub, err := NewModel(cfg)
t.Fatalf("Unable to create model")
t.Fatalf("Scenario name should be empty")
Kevin Di Lallo
committed
err = mPub.Activate()
if err != nil {
t.Fatalf("Failed to activate model")
Kevin Di Lallo
committed
}
time.Sleep(50 * time.Millisecond)
fmt.Println("Set Model")
err = mPub.SetScenario([]byte(testScenario))
time.Sleep(50 * time.Millisecond)
if err != nil {
t.Fatalf("Error setting model")
t.Fatalf("Scenario name should be demo1")
}
// create listener after model has been published to test initialization
Kevin Di Lallo
committed
cfg = ModelCfg{Name: "Active", Namespace: moduleNamespace, Module: moduleName + "-Lis", DbAddr: modelRedisAddr}
mLis, err := NewModel(cfg)
t.Fatalf("Unable to create model")
t.Fatalf("Scenario name should be empty")
fmt.Println("Sync listener")
mLis.UpdateScenario()
lis, _ := mLis.GetScenario()
pub, _ := mPub.GetScenario()
t.Fatalf("Published model different than received one")
t.Fatalf("Scenario name should be demo1")
old, new, err := mPub.MoveNode("ue1", "zone2-poa1", nil)
t.Fatalf("Error moving UE")
t.Fatalf("Move Node - wrong origin Location " + old)
t.Fatalf("Move Node - wrong destination Location " + new)
parent := n.parent.(*dataModel.NetworkLocation)
t.Fatalf("Published model not as expected")
}
//UpdateNetChar
fmt.Println("Update net-char")
var nc dataModel.EventNetworkCharacteristicsUpdate
var netChar dataModel.NetworkCharacteristics
netChar.Latency = 1
netChar.LatencyVariation = 2
netChar.LatencyDistribution = "Normal"
netChar.ThroughputDl = 3
netChar.ThroughputUl = 5
netChar.PacketLoss = 4
nc.NetChar = &netChar
err = mPub.UpdateNetChar(&nc, nil)
t.Fatalf("Update " + nc.ElementType + " failed")
if mLis.scenario.Deployment.NetChar.Latency != 1 {
t.Fatalf("Update " + nc.ElementType + " latency failed")
if mLis.scenario.Deployment.NetChar.LatencyVariation != 2 {
t.Fatalf("Update " + nc.ElementType + " jitter failed")
if mLis.scenario.Deployment.NetChar.LatencyDistribution != "Normal" {
t.Fatalf("Update " + nc.ElementType + " distribution failed")
}
if mLis.scenario.Deployment.NetChar.ThroughputDl != 3 {
t.Fatalf("Update " + nc.ElementType + " throughputDl failed")
}
if mLis.scenario.Deployment.NetChar.ThroughputUl != 5 {
t.Fatalf("Update " + nc.ElementType + " throughputUl failed")
if mLis.scenario.Deployment.NetChar.PacketLoss != 4 {
t.Fatalf("Update " + nc.ElementType + " packet loss failed")
Kevin Di Lallo
committed
err = mPub.Deactivate()
if err != nil {
t.Fatalf("Failed to deactivate")
lis, _ = mLis.GetScenario()
if string(lis) != "{}" {
t.Fatalf("Deployment should be nil")
t.Fatalf("Scenario name should be demo1")
t.Fatalf("Scenario name should be empty")
Kevin Di Lallo
committed
err = mPub.Activate()
if err != nil {
t.Fatalf("Failed to activate")
t.Fatalf("Scenario name should be demo1")
t.Fatalf("Scenario name should be demo1")
func TestGetters(t *testing.T) {
fmt.Println("--- ", t.Name())
log.MeepTextLogInit(t.Name())
// Switch to a different table for testing
redisTable = modelRedisTestTable
fmt.Println("Create Model")
Kevin Di Lallo
committed
cfg := ModelCfg{Name: modelName, Namespace: moduleNamespace, Module: moduleName, DbAddr: modelRedisAddr}
t.Fatalf("Unable to create model")
}
fmt.Println("Get Node Names (empty)")
l := m.GetNodeNames("")
if len(l) != 0 {
t.Fatalf("Node name list should be empty")
}
fmt.Println("Set Model")
err = m.SetScenario([]byte(testScenario))
if err != nil {
t.Fatalf("Error setting model")
}
fmt.Println("Get Node Names")
l = m.GetNodeNames("ANY")
if len(l) != 30 {
t.Fatalf("Node name list should not be empty")
}
fmt.Println(l)
fmt.Println(len(l))
fmt.Println("Get UE Node Names")
l = m.GetNodeNames("UE")
if len(l) != 2 {
t.Fatalf("UE node name list should be 2")
}
fmt.Println(l)
fmt.Println(len(l))
fmt.Println("Get POA Node Names")
l = m.GetNodeNames("POA")
if len(l) != 3 {
t.Fatalf("POA node name list should be 3")
}
fmt.Println(l)
fmt.Println(len(l))
fmt.Println("Get Zone Node Names")
l = m.GetNodeNames("ZONE")
if len(l) != 2 {
t.Fatalf("Zone node name list should be 2")
fmt.Println("Get UE + POA Node Names")
l = m.GetNodeNames("UE", "POA")
if len(l) != 5 {
t.Fatalf("UE + POA node name list should be 5")
}
fmt.Println(l)
fmt.Println(len(l))
fmt.Println("Get UE + POA + ZONE Node Names")
l = m.GetNodeNames("UE", "POA", "ZONE")
if len(l) != 7 {
t.Fatalf("UE + POA + ZONE node name list should be 10")
}
fmt.Println(l)
fmt.Println(len(l))
fmt.Println("Get invalid node")
n := m.GetNode("NOT-A-NODE")
if n != nil {
t.Fatalf("Node should not exist")
}
fmt.Println("Get ue1 node")
n = m.GetNode("ue1")
if n == nil {
t.Fatalf("Failed getting ue1 node")
pl, ok := n.(*dataModel.PhysicalLocation)
t.Fatalf("ue1 has wrong type %T -- expected *model.PhysicalLocation", n)
t.Fatalf("Could not find ue1")
}
fmt.Println("Get edges")
edges := m.GetEdges()
if len(edges) != 28 {
t.Fatalf("Missing edges - expected 28")
t.Fatalf("UE1 edge - expected zone1-poa1 -- got %s", edges["ue1"])
t.Fatalf("Zone1 edge - expected operator1 -- got %s", edges["zone1"])
// Node Type
fmt.Println("Get node type for invalid node")
nodeType := m.GetNodeType("NOT-A-NODE")
if nodeType != "" {
t.Fatalf("Node type should be empty")
}
fmt.Println("Get node type for OPERATOR")
nodeType = m.GetNodeType("operator1")
if nodeType != "OPERATOR" {
t.Fatalf("Invalid node type")
}
fmt.Println("Get node type for ZONE")
nodeType = m.GetNodeType("zone1")
if nodeType != "ZONE" {
t.Fatalf("Invalid node type")
}
fmt.Println("Get node type for POA")
nodeType = m.GetNodeType("zone1-poa1")
if nodeType != "POA" {
t.Fatalf("Invalid node type")
}
fmt.Println("Get node type for FOG")
nodeType = m.GetNodeType("zone1-fog1")
if nodeType != "FOG" {
t.Fatalf("Invalid node type")
}
fmt.Println("Get node type for UE")
nodeType = m.GetNodeType("ue1")
if nodeType != "UE" {
t.Fatalf("Invalid node type")
}
fmt.Println("Get node type for UE-APP")
nodeType = m.GetNodeType("ue1-iperf")
if nodeType != "UE-APP" {
t.Fatalf("Invalid node type")
}
fmt.Println("Get node type for EDGE-APP")
nodeType = m.GetNodeType("zone1-edge1-svc")
if nodeType != "EDGE-APP" {
t.Fatalf("Invalid node type")
}
// Node Context