--- /dev/null
+"""Test the collection of charm metrics.
+ 1. Deploy a charm w/metrics to a unit
+ 2. Collect metrics or wait for collection to run
+ 3. Execute n2vc.GetMetrics()
+ 5. Destroy Juju unit
+"""
+import asyncio
+import functools
+import logging
+import sys
+import time
+import unittest
+from .. import utils
+
+NSD_YAML = """
+nsd:nsd-catalog:
+ nsd:
+ - id: singlecharmvdu-ns
+ name: singlecharmvdu-ns
+ short-name: singlecharmvdu-ns
+ description: NS with 1 VNFs singlecharmvdu-vnf connected by datanet and mgmtnet VLs
+ version: '1.0'
+ logo: osm.png
+ constituent-vnfd:
+ - vnfd-id-ref: singlecharmvdu-vnf
+ member-vnf-index: '1'
+ vld:
+ - id: mgmtnet
+ name: mgmtnet
+ short-name: mgmtnet
+ type: ELAN
+ mgmt-network: 'true'
+ vim-network-name: mgmt
+ vnfd-connection-point-ref:
+ - vnfd-id-ref: singlecharmvdu-vnf
+ member-vnf-index-ref: '1'
+ vnfd-connection-point-ref: vnf-mgmt
+ - vnfd-id-ref: singlecharmvdu-vnf
+ member-vnf-index-ref: '2'
+ vnfd-connection-point-ref: vnf-mgmt
+ - id: datanet
+ name: datanet
+ short-name: datanet
+ type: ELAN
+ vnfd-connection-point-ref:
+ - vnfd-id-ref: singlecharmvdu-vnf
+ member-vnf-index-ref: '1'
+ vnfd-connection-point-ref: vnf-data
+ - vnfd-id-ref: singlecharmvdu-vnf
+ member-vnf-index-ref: '2'
+ vnfd-connection-point-ref: vnf-data
+"""
+
+VNFD_YAML = """
+vnfd:vnfd-catalog:
+ vnfd:
+ - id: singlecharmvdu-vnf
+ name: singlecharmvdu-vnf
+ short-name: singlecharmvdu-vnf
+ version: '1.0'
+ description: A VNF consisting of 2 VDUs w/charms connected to an internal VL, and one VDU with cloud-init
+ logo: osm.png
+ connection-point:
+ - id: vnf-mgmt
+ name: vnf-mgmt
+ short-name: vnf-mgmt
+ type: VPORT
+ - id: vnf-data
+ name: vnf-data
+ short-name: vnf-data
+ type: VPORT
+ mgmt-interface:
+ cp: vnf-mgmt
+ internal-vld:
+ - id: internal
+ name: internal
+ short-name: internal
+ type: ELAN
+ internal-connection-point:
+ - id-ref: mgmtVM-internal
+ - id-ref: dataVM-internal
+ vdu:
+ - id: mgmtVM
+ name: mgmtVM
+ image: xenial
+ count: '1'
+ vm-flavor:
+ vcpu-count: '1'
+ memory-mb: '1024'
+ storage-gb: '10'
+ interface:
+ - name: mgmtVM-eth0
+ position: '1'
+ type: EXTERNAL
+ virtual-interface:
+ type: VIRTIO
+ external-connection-point-ref: vnf-mgmt
+ - name: mgmtVM-eth1
+ position: '2'
+ type: INTERNAL
+ virtual-interface:
+ type: VIRTIO
+ internal-connection-point-ref: mgmtVM-internal
+ internal-connection-point:
+ - id: mgmtVM-internal
+ name: mgmtVM-internal
+ short-name: mgmtVM-internal
+ type: VPORT
+ cloud-init-file: cloud-config.txt
+ vnf-configuration:
+ juju:
+ charm: metrics-ci
+ config-primitive:
+ - name: touch
+ parameter:
+ - name: filename
+ data-type: STRING
+ default-value: '/home/ubuntu/touched'
+"""
+
+
+class PythonTest(unittest.TestCase):
+ n2vc = None
+ charm = None
+
+ def setUp(self):
+ self.log = logging.getLogger()
+ self.log.level = logging.DEBUG
+
+ self.stream_handler = logging.StreamHandler(sys.stdout)
+ self.log.addHandler(self.stream_handler)
+
+ self.loop = asyncio.get_event_loop()
+
+ self.n2vc = utils.get_n2vc()
+
+ # Parse the descriptor
+ self.log.debug("Parsing the descriptor")
+ self.nsd = utils.get_descriptor(NSD_YAML)
+ self.vnfd = utils.get_descriptor(VNFD_YAML)
+
+
+ # Build the charm
+
+ vnf_config = self.vnfd.get("vnf-configuration")
+ if vnf_config:
+ juju = vnf_config['juju']
+ charm = juju['charm']
+
+ self.log.debug("Building charm {}".format(charm))
+ self.charm = utils.build_charm(charm)
+
+ def tearDown(self):
+ self.loop.run_until_complete(self.n2vc.logout())
+ self.log.removeHandler(self.stream_handler)
+
+ def n2vc_callback(self, model_name, application_name, workload_status,\
+ workload_message, task=None):
+ """We pass the vnfd when setting up the callback, so expect it to be
+ returned as a tuple."""
+ self.log.debug("status: {}; task: {}".format(workload_status, task))
+
+ # if workload_status in ["stop_test"]:
+ # # Stop the test
+ # self.log.debug("Stopping the test1")
+ # self.loop.call_soon_threadsafe(self.loop.stop)
+ # return
+
+ if workload_status:
+ if workload_status in ["active"] and not task:
+ # Force a run of the metric collector, so we don't have
+ # to wait for it's normal 5 minute interval run.
+ # NOTE: this shouldn't be done outside of CI
+ utils.collect_metrics(application_name)
+
+ # get the current metrics
+ task = asyncio.ensure_future(
+ self.n2vc.GetMetrics(
+ model_name,
+ application_name,
+ )
+ )
+ task.add_done_callback(
+ functools.partial(
+ self.n2vc_callback,
+ model_name,
+ application_name,
+ "collect_metrics",
+ task,
+ )
+ )
+
+ elif workload_status in ["collect_metrics"]:
+
+ if task:
+ # Check if task returned metrics
+ results = task.result()
+
+ foo = utils.parse_metrics(application_name, results)
+ if 'load' in foo:
+ self.log.debug("Removing charm")
+ task = asyncio.ensure_future(
+ self.n2vc.RemoveCharms(model_name, application_name, self.n2vc_callback)
+ )
+ task.add_done_callback(
+ functools.partial(
+ self.n2vc_callback,
+ model_name,
+ application_name,
+ "stop_test",
+ task,
+ )
+ )
+ return
+
+ # No metrics are available yet, so try again in a minute.
+ self.log.debug("Sleeping for 60 seconds")
+ time.sleep(60)
+ task = asyncio.ensure_future(
+ self.n2vc.GetMetrics(
+ model_name,
+ application_name,
+ )
+ )
+ task.add_done_callback(
+ functools.partial(
+ self.n2vc_callback,
+ model_name,
+ application_name,
+ "collect_metrics",
+ task,
+ )
+ )
+ elif workload_status in ["stop_test"]:
+ # Stop the test
+ self.log.debug("Stopping the test2")
+ self.loop.call_soon_threadsafe(self.loop.stop)
+
+ def test_deploy_application(self):
+ """Deploy proxy charm to a unit."""
+ if self.nsd and self.vnfd:
+ params = {}
+ vnf_index = 0
+
+ def deploy():
+ """An inner function to do the deployment of a charm from
+ either a vdu or vnf.
+ """
+ charm_dir = "{}/builds/{}".format(utils.get_charm_path(), charm)
+
+ # Setting this to an IP that will fail the initial config.
+ # This will be detected in the callback, which will execute
+ # the "config" primitive with the right IP address.
+ # mgmtaddr = self.container.state().network['eth0']['addresses']
+ # params['rw_mgmt_ip'] = mgmtaddr[0]['address']
+
+ # Legacy method is to set the ssh-private-key config
+ # with open(utils.get_juju_private_key(), "r") as f:
+ # pkey = f.readline()
+ # params['ssh-private-key'] = pkey
+
+ ns_name = "default"
+
+ vnf_name = self.n2vc.FormatApplicationName(
+ ns_name,
+ self.vnfd['name'],
+ str(vnf_index),
+ )
+
+ self.loop.run_until_complete(
+ self.n2vc.DeployCharms(
+ ns_name,
+ vnf_name,
+ self.vnfd,
+ charm_dir,
+ params,
+ {},
+ self.n2vc_callback
+ )
+ )
+
+ # Check if the VDUs in this VNF have a charm
+ # for vdu in vnfd['vdu']:
+ # vdu_config = vdu.get('vdu-configuration')
+ # if vdu_config:
+ # juju = vdu_config['juju']
+ # self.assertIsNotNone(juju)
+ #
+ # charm = juju['charm']
+ # self.assertIsNotNone(charm)
+ #
+ # params['initial-config-primitive'] = vdu_config['initial-config-primitive']
+ #
+ # deploy()
+ # vnf_index += 1
+ #
+ # # Check if this VNF has a charm
+ vnf_config = self.vnfd.get("vnf-configuration")
+ if vnf_config:
+ juju = vnf_config['juju']
+ self.assertIsNotNone(juju)
+
+ charm = juju['charm']
+ self.assertIsNotNone(charm)
+
+ if 'initial-config-primitive' in vnf_config:
+ params['initial-config-primitive'] = vnf_config['initial-config-primitive']
+
+ deploy()
+ vnf_index += 1
+
+ self.loop.run_forever()
+ # while self.loop.is_running():
+ # # await asyncio.sleep(1)
+ # time.sleep(1)
projects / osm / N2VC.git / blobdiff