84905b7441be644f4ba6fa7f6fe5bd98bd04750e
[osm/MON.git] / osm_mon / test / collector / test_collector.py
1 # -*- coding: utf-8 -*-
2
3 # Copyright 2018 Whitestack, LLC
4 # *************************************************************
5
6 # This file is part of OSM Monitoring module
7 # All Rights Reserved to Whitestack, LLC
8
9 # Licensed under the Apache License, Version 2.0 (the "License"); you may
10 # not use this file except in compliance with the License. You may obtain
11 # a copy of the License at
12
13 # http://www.apache.org/licenses/LICENSE-2.0
14
15 # Unless required by applicable law or agreed to in writing, software
16 # distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
17 # WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
18 # License for the specific language governing permissions and limitations
19 # under the License.
20 # For those usages not covered by the Apache License, Version 2.0 please
21 # contact: bdiaz@whitestack.com or glavado@whitestack.com
22 ##
23 import asyncio
24 import random
25 import unittest
26
27 from mock import mock
28
29 from osm_mon.collector.collector import MonCollector
30
31
32 class MonCollectorTest(unittest.TestCase):
33 def setUp(self):
34 super().setUp()
35 self.loop = asyncio.new_event_loop()
36 asyncio.set_event_loop(None)
37
38 def test_generate_vca_vdu_name(self):
39 vdur_name = 'test-juju-metrics01-1-ubuntuvdu1-1'
40 expected = 'test-juju-metricsab-b-ubuntuvdub'
41 result = self.loop.run_until_complete(MonCollector._generate_vca_vdu_name(vdur_name))
42 self.assertEqual(result, expected)
43
44 @mock.patch.object(random, 'randint')
45 def test_generate_read_metric_payload(self, randint):
46 randint.return_value = 1
47 metric_name = 'cpu_utilization'
48 nsr_id = 'test_id'
49 vdu_name = 'test_vdu'
50 vnf_member_index = 1
51 expected_payload = {
52 'correlation_id': 1,
53 'metric_name': metric_name,
54 'ns_id': nsr_id,
55 'vnf_member_index': vnf_member_index,
56 'vdu_name': vdu_name,
57 'collection_period': 1,
58 'collection_unit': 'DAY',
59 }
60 result = self.loop.run_until_complete(
61 MonCollector._generate_read_metric_payload(metric_name, nsr_id, vdu_name, vnf_member_index))
62 self.assertEqual(result, expected_payload)