summaryrefslogtreecommitdiff
path: root/ceilometerclient/tests/v2/test_shell.py
diff options
context:
space:
mode:
authorChris Dent <chdent@redhat.com>2015-03-12 13:31:06 +0000
committerChris Dent <chdent@redhat.com>2015-03-13 12:01:04 +0000
commitd9d8cc614eccaffefdfd4aa4f536745f0aabc5e3 (patch)
tree8ab56748455532a93e06fe98edddad60a423db15 /ceilometerclient/tests/v2/test_shell.py
parente727d22bf1fc4ff613699560717e4aa460f60b73 (diff)
downloadpython-ceilometerclient-d9d8cc614eccaffefdfd4aa4f536745f0aabc5e3.tar.gz
Move unit tests into their own subdirectory
This is in preparation of moving functional tests currently in tempest in-tree. No surprises in this change: * move files * update the local imports Same number of tests run, all still pass. Change-Id: Ibfeac44421c5f36740b1377868f5ec469b2893f5
Diffstat (limited to 'ceilometerclient/tests/v2/test_shell.py')
-rw-r--r--ceilometerclient/tests/v2/test_shell.py1175
1 files changed, 0 insertions, 1175 deletions
diff --git a/ceilometerclient/tests/v2/test_shell.py b/ceilometerclient/tests/v2/test_shell.py
deleted file mode 100644
index 921bded..0000000
--- a/ceilometerclient/tests/v2/test_shell.py
+++ /dev/null
@@ -1,1175 +0,0 @@
-# Copyright Ericsson AB 2014. All rights reserved
-#
-# Authors: Balazs Gibizer <balazs.gibizer@ericsson.com>
-# Ildiko Vancsa <ildiko.vancsa@ericsson.com>
-#
-# 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.
-
-import re
-import sys
-
-import mock
-import six
-from testtools import matchers
-
-from ceilometerclient import exc
-from ceilometerclient import shell as base_shell
-from ceilometerclient.tests import test_shell
-from ceilometerclient.tests import utils
-from ceilometerclient.v2 import alarms
-from ceilometerclient.v2 import events
-from ceilometerclient.v2 import samples
-from ceilometerclient.v2 import shell as ceilometer_shell
-from ceilometerclient.v2 import statistics
-
-
-class ShellAlarmStateCommandsTest(utils.BaseTestCase):
-
- ALARM_ID = 'foobar'
-
- def setUp(self):
- super(ShellAlarmStateCommandsTest, self).setUp()
- self.cc = mock.Mock()
- self.cc.alarms = mock.Mock()
- self.args = mock.Mock()
- self.args.alarm_id = self.ALARM_ID
-
- def test_alarm_state_get(self):
- ceilometer_shell.do_alarm_state_get(self.cc, self.args)
- self.cc.alarms.get_state.assert_called_once_with(self.ALARM_ID)
- self.assertFalse(self.cc.alarms.set_state.called)
-
- def test_alarm_state_set(self):
- self.args.state = 'ok'
- ceilometer_shell.do_alarm_state_set(self.cc, self.args)
- self.cc.alarms.set_state.assert_called_once_with(self.ALARM_ID, 'ok')
- self.assertFalse(self.cc.alarms.get_state.called)
-
-
-class ShellAlarmHistoryCommandTest(utils.BaseTestCase):
-
- ALARM_ID = '768ff714-8cfb-4db9-9753-d484cb33a1cc'
- FULL_DETAIL = ('{"alarm_actions": [], '
- '"user_id": "8185aa72421a4fd396d4122cba50e1b5", '
- '"name": "scombo", '
- '"timestamp": "2013-10-03T08:58:33.647912", '
- '"enabled": true, '
- '"state_timestamp": "2013-10-03T08:58:33.647912", '
- '"rule": {"operator": "or", "alarm_ids": '
- '["062cc907-3a9f-4867-ab3b-fa83212b39f7"]}, '
- '"alarm_id": "768ff714-8cfb-4db9-9753-d484cb33a1cc", '
- '"state": "insufficient data", '
- '"insufficient_data_actions": [], '
- '"repeat_actions": false, '
- '"ok_actions": [], '
- '"project_id": "57d04f24d0824b78b1ea9bcecedbda8f", '
- '"type": "combination", '
- '"description": "Combined state of alarms '
- '062cc907-3a9f-4867-ab3b-fa83212b39f7"}')
- ALARM_HISTORY = [{'on_behalf_of': '57d04f24d0824b78b1ea9bcecedbda8f',
- 'user_id': '8185aa72421a4fd396d4122cba50e1b5',
- 'event_id': 'c74a8611-6553-4764-a860-c15a6aabb5d0',
- 'timestamp': '2013-10-03T08:59:28.326000',
- 'detail': '{"state": "alarm"}',
- 'alarm_id': '768ff714-8cfb-4db9-9753-d484cb33a1cc',
- 'project_id': '57d04f24d0824b78b1ea9bcecedbda8f',
- 'type': 'state transition'},
- {'on_behalf_of': '57d04f24d0824b78b1ea9bcecedbda8f',
- 'user_id': '8185aa72421a4fd396d4122cba50e1b5',
- 'event_id': 'c74a8611-6553-4764-a860-c15a6aabb5d0',
- 'timestamp': '2013-10-03T08:59:28.326000',
- 'detail': '{"description": "combination of one"}',
- 'alarm_id': '768ff714-8cfb-4db9-9753-d484cb33a1cc',
- 'project_id': '57d04f24d0824b78b1ea9bcecedbda8f',
- 'type': 'rule change'},
- {'on_behalf_of': '57d04f24d0824b78b1ea9bcecedbda8f',
- 'user_id': '8185aa72421a4fd396d4122cba50e1b5',
- 'event_id': '4fd7df9e-190d-4471-8884-dc5a33d5d4bb',
- 'timestamp': '2013-10-03T08:58:33.647000',
- 'detail': FULL_DETAIL,
- 'alarm_id': '768ff714-8cfb-4db9-9753-d484cb33a1cc',
- 'project_id': '57d04f24d0824b78b1ea9bcecedbda8f',
- 'type': 'creation'}]
- TIMESTAMP_RE = (' +\| (\d{4})-(\d{2})-(\d{2})T'
- '(\d{2})\:(\d{2})\:(\d{2})\.(\d{6}) \| +')
-
- def setUp(self):
- super(ShellAlarmHistoryCommandTest, self).setUp()
- self.cc = mock.Mock()
- self.cc.alarms = mock.Mock()
- self.args = mock.Mock()
- self.args.alarm_id = self.ALARM_ID
-
- @mock.patch('sys.stdout', new=six.StringIO())
- def _do_test_alarm_history(self, raw_query=None, parsed_query=None):
- self.args.query = raw_query
- history = [alarms.AlarmChange(mock.Mock(), change)
- for change in self.ALARM_HISTORY]
- self.cc.alarms.get_history.return_value = history
-
- ceilometer_shell.do_alarm_history(self.cc, self.args)
- self.cc.alarms.get_history.assert_called_once_with(
- q=parsed_query,
- alarm_id=self.ALARM_ID
- )
- out = sys.stdout.getvalue()
- required = [
- '.*creation%sname: scombo.*' % self.TIMESTAMP_RE,
- '.*rule change%sdescription: combination of one.*' %
- self.TIMESTAMP_RE,
- '.*state transition%sstate: alarm.*' % self.TIMESTAMP_RE,
- ]
- for r in required:
- self.assertThat(out, matchers.MatchesRegex(r, re.DOTALL))
-
- def test_alarm_all_history(self):
- self._do_test_alarm_history()
-
- def test_alarm_constrained_history(self):
- parsed_query = [dict(field='timestamp',
- value='2013-10-03T08:59:28',
- op='gt',
- type='')]
- self._do_test_alarm_history(raw_query='timestamp>2013-10-03T08:59:28',
- parsed_query=parsed_query)
-
-
-class ShellAlarmCommandTest(utils.BaseTestCase):
-
- ALARM_ID = '768ff714-8cfb-4db9-9753-d484cb33a1cc'
- ALARM = {"alarm_actions": ["log://"],
- "ok_actions": [],
- "description": "instance running hot",
- "timestamp": "2013-11-20T10:38:42.206952",
- "enabled": True,
- "state_timestamp": "2013-11-19T17:20:44",
- "threshold_rule": {"meter_name": "cpu_util",
- "evaluation_periods": 3,
- "period": 600,
- "statistic": "avg",
- "threshold": 99.0,
- "query": [{"field": "resource_id",
- "value": "INSTANCE_ID",
- "op": "eq"}],
- "comparison_operator": "gt"},
- "time_constraints": [{"name": "cons1",
- "description": "desc1",
- "start": "0 11 * * *",
- "duration": 300,
- "timezone": ""},
- {"name": "cons2",
- "description": "desc2",
- "start": "0 23 * * *",
- "duration": 600,
- "timezone": ""}],
- "alarm_id": ALARM_ID,
- "state": "insufficient data",
- "severity": "low",
- "insufficient_data_actions": [],
- "repeat_actions": True,
- "user_id": "528d9b68fa774689834b5c04b4564f8a",
- "project_id": "ed9d4e2be2a748bc80108053cf4598f5",
- "type": "threshold",
- "name": "cpu_high"}
-
- THRESHOLD_ALARM_CLI_ARGS = [
- '--name', 'cpu_high',
- '--description', 'instance running hot',
- '--meter-name', 'cpu_util',
- '--threshold', '70.0',
- '--comparison-operator', 'gt',
- '--statistic', 'avg',
- '--period', '600',
- '--evaluation-periods', '3',
- '--alarm-action', 'log://',
- '--alarm-action', 'http://example.com/alarm/state',
- '--query', 'resource_id=INSTANCE_ID'
- ]
-
- def setUp(self):
- super(ShellAlarmCommandTest, self).setUp()
- self.cc = mock.Mock()
- self.cc.alarms = mock.Mock()
- self.args = mock.Mock()
- self.args.alarm_id = self.ALARM_ID
-
- @mock.patch('sys.stdout', new=six.StringIO())
- def _do_test_alarm_update_repeat_actions(self, method, repeat_actions):
- self.args.threshold = 42.0
- if repeat_actions is not None:
- self.args.repeat_actions = repeat_actions
- alarm = [alarms.Alarm(mock.Mock(), self.ALARM)]
- self.cc.alarms.get.return_value = alarm
- self.cc.alarms.update.return_value = alarm[0]
-
- method(self.cc, self.args)
- args, kwargs = self.cc.alarms.update.call_args
- self.assertEqual(self.ALARM_ID, args[0])
- self.assertEqual(42.0, kwargs.get('threshold'))
- if repeat_actions is not None:
- self.assertEqual(repeat_actions, kwargs.get('repeat_actions'))
- else:
- self.assertNotIn('repeat_actions', kwargs)
-
- def test_alarm_update_repeat_actions_untouched(self):
- method = ceilometer_shell.do_alarm_update
- self._do_test_alarm_update_repeat_actions(method, None)
-
- def test_alarm_update_repeat_actions_set(self):
- method = ceilometer_shell.do_alarm_update
- self._do_test_alarm_update_repeat_actions(method, True)
-
- def test_alarm_update_repeat_actions_clear(self):
- method = ceilometer_shell.do_alarm_update
- self._do_test_alarm_update_repeat_actions(method, False)
-
- def test_alarm_combination_update_repeat_actions_untouched(self):
- method = ceilometer_shell.do_alarm_combination_update
- self._do_test_alarm_update_repeat_actions(method, None)
-
- def test_alarm_combination_update_repeat_actions_set(self):
- method = ceilometer_shell.do_alarm_combination_update
- self._do_test_alarm_update_repeat_actions(method, True)
-
- def test_alarm_combination_update_repeat_actions_clear(self):
- method = ceilometer_shell.do_alarm_combination_update
- self._do_test_alarm_update_repeat_actions(method, False)
-
- def test_alarm_threshold_update_repeat_actions_untouched(self):
- method = ceilometer_shell.do_alarm_threshold_update
- self._do_test_alarm_update_repeat_actions(method, None)
-
- def test_alarm_threshold_update_repeat_actions_set(self):
- method = ceilometer_shell.do_alarm_threshold_update
- self._do_test_alarm_update_repeat_actions(method, True)
-
- def test_alarm_threshold_update_repeat_actions_clear(self):
- method = ceilometer_shell.do_alarm_threshold_update
- self._do_test_alarm_update_repeat_actions(method, False)
-
- @mock.patch('sys.stdout', new=six.StringIO())
- def test_alarm_threshold_create_args(self):
- argv = ['alarm-threshold-create'] + self.THRESHOLD_ALARM_CLI_ARGS
- self._test_alarm_threshold_action_args('create', argv)
-
- def test_alarm_threshold_update_args(self):
- argv = ['alarm-threshold-update', 'x'] + self.THRESHOLD_ALARM_CLI_ARGS
- self._test_alarm_threshold_action_args('update', argv)
-
- @mock.patch('sys.stdout', new=six.StringIO())
- def _test_alarm_threshold_action_args(self, action, argv):
- shell = base_shell.CeilometerShell()
- _, args = shell.parse_args(argv)
-
- alarm = alarms.Alarm(mock.Mock(), self.ALARM)
- getattr(self.cc.alarms, action).return_value = alarm
-
- func = getattr(ceilometer_shell, 'do_alarm_threshold_' + action)
- func(self.cc, args)
- _, kwargs = getattr(self.cc.alarms, action).call_args
- self._check_alarm_threshold_args(kwargs)
-
- def _check_alarm_threshold_args(self, kwargs):
- self.assertEqual('cpu_high', kwargs.get('name'))
- self.assertEqual('instance running hot', kwargs.get('description'))
- actions = ['log://', 'http://example.com/alarm/state']
- self.assertEqual(actions, kwargs.get('alarm_actions'))
- self.assertIn('threshold_rule', kwargs)
- rule = kwargs['threshold_rule']
- self.assertEqual('cpu_util', rule.get('meter_name'))
- self.assertEqual(70.0, rule.get('threshold'))
- self.assertEqual('gt', rule.get('comparison_operator'))
- self.assertEqual('avg', rule.get('statistic'))
- self.assertEqual(600, rule.get('period'))
- self.assertEqual(3, rule.get('evaluation_periods'))
- query = dict(field='resource_id', type='',
- value='INSTANCE_ID', op='eq')
- self.assertEqual([query], rule['query'])
-
- @mock.patch('sys.stdout', new=six.StringIO())
- def test_alarm_create_time_constraints(self):
- shell = base_shell.CeilometerShell()
- argv = ['alarm-threshold-create',
- '--name', 'cpu_high',
- '--meter-name', 'cpu_util',
- '--threshold', '70.0',
- '--time-constraint',
- 'name=cons1;start="0 11 * * *";duration=300',
- '--time-constraint',
- 'name=cons2;start="0 23 * * *";duration=600',
- ]
- _, args = shell.parse_args(argv)
-
- alarm = alarms.Alarm(mock.Mock(), self.ALARM)
- self.cc.alarms.create.return_value = alarm
-
- ceilometer_shell.do_alarm_threshold_create(self.cc, args)
- _, kwargs = self.cc.alarms.create.call_args
- time_constraints = [dict(name='cons1', start='0 11 * * *',
- duration='300'),
- dict(name='cons2', start='0 23 * * *',
- duration='600')]
- self.assertEqual(time_constraints, kwargs['time_constraints'])
-
-
-class ShellSampleListCommandTest(utils.BaseTestCase):
-
- METER = 'cpu_util'
- SAMPLE_VALUES = (
- ("cpu_util",
- "5dcf5537-3161-4e25-9235-407e1385bd35",
- "2013-10-15T05:50:30",
- "%",
- 0.261666666667,
- "gauge",
- "86536501-b2c9-48f6-9c6a-7a5b14ba7482"),
- ("cpu_util",
- "87d197e9-9cf6-4c25-bc66-1b1f4cedb52f",
- "2013-10-15T05:50:29",
- "%",
- 0.261666666667,
- "gauge",
- "fe2a91ec-602b-4b55-8cba-5302ce3b916e",),
- ("cpu_util",
- "5dcf5537-3161-4e25-9235-407e1385bd35",
- "2013-10-15T05:40:30",
- "%",
- 0.251247920133,
- "gauge",
- "52768bcb-b4e9-4db9-a30c-738c758b6f43"),
- ("cpu_util",
- "87d197e9-9cf6-4c25-bc66-1b1f4cedb52f",
- "2013-10-15T05:40:29",
- "%",
- 0.26,
- "gauge",
- "31ae614a-ac6b-4fb9-b106-4667bae03308"),
- )
-
- OLD_SAMPLES = [
- dict(counter_name=s[0],
- resource_id=s[1],
- timestamp=s[2],
- counter_unit=s[3],
- counter_volume=s[4],
- counter_type=s[5])
- for s in SAMPLE_VALUES
- ]
-
- SAMPLES = [
- dict(meter=s[0],
- resource_id=s[1],
- timestamp=s[2],
- unit=s[3],
- volume=s[4],
- type=s[5],
- id=s[6])
- for s in SAMPLE_VALUES
- ]
-
- def setUp(self):
- super(ShellSampleListCommandTest, self).setUp()
- self.cc = mock.Mock()
- self.cc.samples = mock.Mock()
- self.cc.new_samples = mock.Mock()
- self.args = mock.Mock()
- self.args.query = None
- self.args.limit = None
-
- @mock.patch('sys.stdout', new=six.StringIO())
- def test_old_sample_list(self):
- self.args.meter = self.METER
- sample_list = [samples.OldSample(mock.Mock(), sample)
- for sample in self.OLD_SAMPLES]
- self.cc.samples.list.return_value = sample_list
-
- ceilometer_shell.do_sample_list(self.cc, self.args)
- self.cc.samples.list.assert_called_once_with(
- meter_name=self.METER,
- q=None,
- limit=None)
-
- self.assertEqual('''\
-+--------------------------------------+----------+-------+----------------\
-+------+---------------------+
-| Resource ID | Name | Type | Volume \
-| Unit | Timestamp |
-+--------------------------------------+----------+-------+----------------\
-+------+---------------------+
-| 5dcf5537-3161-4e25-9235-407e1385bd35 | cpu_util | gauge | 0.261666666667 \
-| % | 2013-10-15T05:50:30 |
-| 87d197e9-9cf6-4c25-bc66-1b1f4cedb52f | cpu_util | gauge | 0.261666666667 \
-| % | 2013-10-15T05:50:29 |
-| 5dcf5537-3161-4e25-9235-407e1385bd35 | cpu_util | gauge | 0.251247920133 \
-| % | 2013-10-15T05:40:30 |
-| 87d197e9-9cf6-4c25-bc66-1b1f4cedb52f | cpu_util | gauge | 0.26 \
-| % | 2013-10-15T05:40:29 |
-+--------------------------------------+----------+-------+----------------\
-+------+---------------------+
-''', sys.stdout.getvalue())
-
- @mock.patch('sys.stdout', new=six.StringIO())
- def test_sample_list(self):
- self.args.meter = None
- sample_list = [samples.Sample(mock.Mock(), sample)
- for sample in self.SAMPLES]
- self.cc.new_samples.list.return_value = sample_list
-
- ceilometer_shell.do_sample_list(self.cc, self.args)
- self.cc.new_samples.list.assert_called_once_with(
- q=None,
- limit=None)
-
- self.assertEqual('''\
-+--------------------------------------+--------------------------------------\
-+----------+-------+----------------+------+---------------------+
-| ID | Resource ID \
-| Name | Type | Volume | Unit | Timestamp |
-+--------------------------------------+--------------------------------------\
-+----------+-------+----------------+------+---------------------+
-| 86536501-b2c9-48f6-9c6a-7a5b14ba7482 | 5dcf5537-3161-4e25-9235-407e1385bd35 \
-| cpu_util | gauge | 0.261666666667 | % | 2013-10-15T05:50:30 |
-| fe2a91ec-602b-4b55-8cba-5302ce3b916e | 87d197e9-9cf6-4c25-bc66-1b1f4cedb52f \
-| cpu_util | gauge | 0.261666666667 | % | 2013-10-15T05:50:29 |
-| 52768bcb-b4e9-4db9-a30c-738c758b6f43 | 5dcf5537-3161-4e25-9235-407e1385bd35 \
-| cpu_util | gauge | 0.251247920133 | % | 2013-10-15T05:40:30 |
-| 31ae614a-ac6b-4fb9-b106-4667bae03308 | 87d197e9-9cf6-4c25-bc66-1b1f4cedb52f \
-| cpu_util | gauge | 0.26 | % | 2013-10-15T05:40:29 |
-+--------------------------------------+--------------------------------------\
-+----------+-------+----------------+------+---------------------+
-''', sys.stdout.getvalue())
-
-
-class ShellSampleShowCommandTest(utils.BaseTestCase):
-
- SAMPLE = {
- "user_id": None,
- "resource_id": "9b651dfd-7d30-402b-972e-212b2c4bfb05",
- "timestamp": "2014-11-03T13:37:46",
- "meter": "image",
- "volume": 1.0,
- "source": "openstack",
- "recorded_at": "2014-11-03T13:37:46.994458",
- "project_id": "2cc3a7bb859b4bacbeab0aa9ca673033",
- "type": "gauge",
- "id": "98b5f258-635e-11e4-8bdd-0025647390c1",
- "unit": "image",
- "metadata": {
- "name": "cirros-0.3.2-x86_64-uec",
- }
- }
-
- def setUp(self):
- super(ShellSampleShowCommandTest, self).setUp()
- self.cc = mock.Mock()
- self.cc.new_samples = mock.Mock()
- self.args = mock.Mock()
- self.args.sample_id = "98b5f258-635e-11e4-8bdd-0025647390c1"
-
- @mock.patch('sys.stdout', new=six.StringIO())
- def test_sample_show(self):
- sample = samples.Sample(mock.Mock(), self.SAMPLE)
- self.cc.new_samples.get.return_value = sample
-
- ceilometer_shell.do_sample_show(self.cc, self.args)
- self.cc.new_samples.get.assert_called_once_with(
- "98b5f258-635e-11e4-8bdd-0025647390c1")
-
- self.assertEqual('''\
-+-------------+--------------------------------------+
-| Property | Value |
-+-------------+--------------------------------------+
-| id | 98b5f258-635e-11e4-8bdd-0025647390c1 |
-| metadata | {"name": "cirros-0.3.2-x86_64-uec"} |
-| meter | image |
-| project_id | 2cc3a7bb859b4bacbeab0aa9ca673033 |
-| recorded_at | 2014-11-03T13:37:46.994458 |
-| resource_id | 9b651dfd-7d30-402b-972e-212b2c4bfb05 |
-| source | openstack |
-| timestamp | 2014-11-03T13:37:46 |
-| type | gauge |
-| unit | image |
-| user_id | None |
-| volume | 1.0 |
-+-------------+--------------------------------------+
-''', sys.stdout.getvalue())
-
-
-class ShellSampleCreateCommandTest(utils.BaseTestCase):
-
- METER = 'instance'
- METER_TYPE = 'gauge'
- RESOURCE_ID = '0564c64c-3545-4e34-abfb-9d18e5f2f2f9'
- SAMPLE_VOLUME = '1'
- METER_UNIT = 'instance'
- SAMPLE = [{
- u'counter_name': u'instance',
- u'user_id': u'21b442b8101d407d8242b6610e0ed0eb',
- u'resource_id': u'0564c64c-3545-4e34-abfb-9d18e5f2f2f9',
- u'timestamp': u'2014-01-10T03: 05: 33.951170',
- u'message_id': u'1247cbe6-79a4-11e3-a296-000c294c58e2',
- u'source': u'384260c6987b451d8290e66e1f108082: openstack',
- u'counter_unit': u'instance',
- u'counter_volume': 1.0,
- u'project_id': u'384260c6987b451d8290e66e1f108082',
- u'resource_metadata': {},
- u'counter_type': u'gauge'
- }]
-
- def setUp(self):
- super(ShellSampleCreateCommandTest, self).setUp()
- self.cc = mock.Mock()
- self.cc.samples = mock.Mock()
- self.args = mock.Mock()
- self.args.meter_name = self.METER
- self.args.meter_type = self.METER_TYPE
- self.args.meter_unit = self.METER_UNIT
- self.args.resource_id = self.RESOURCE_ID
- self.args.sample_volume = self.SAMPLE_VOLUME
-
- @mock.patch('sys.stdout', new=six.StringIO())
- def test_sample_create(self):
- ret_sample = [samples.OldSample(mock.Mock(), sample)
- for sample in self.SAMPLE]
- self.cc.samples.create.return_value = ret_sample
-
- ceilometer_shell.do_sample_create(self.cc, self.args)
-
- self.assertEqual('''\
-+-------------------+---------------------------------------------+
-| Property | Value |
-+-------------------+---------------------------------------------+
-| message_id | 1247cbe6-79a4-11e3-a296-000c294c58e2 |
-| name | instance |
-| project_id | 384260c6987b451d8290e66e1f108082 |
-| resource_id | 0564c64c-3545-4e34-abfb-9d18e5f2f2f9 |
-| resource_metadata | {} |
-| source | 384260c6987b451d8290e66e1f108082: openstack |
-| timestamp | 2014-01-10T03: 05: 33.951170 |
-| type | gauge |
-| unit | instance |
-| user_id | 21b442b8101d407d8242b6610e0ed0eb |
-| volume | 1.0 |
-+-------------------+---------------------------------------------+
-''', sys.stdout.getvalue())
-
-
-class ShellQuerySamplesCommandTest(utils.BaseTestCase):
-
- SAMPLE = [{u'id': u'b55d1526-9929-11e3-a3f6-02163e5df1e6',
- u'metadata': {
- u'name1': u'value1',
- u'name2': u'value2'},
- u'meter': 'instance',
- u'project_id': u'35b17138-b364-4e6a-a131-8f3099c5be68',
- u'resource_id': u'bd9431c1-8d69-4ad3-803a-8d4a6b89fd36',
- u'source': u'openstack',
- u'timestamp': u'2014-02-19T05:50:16.673604',
- u'type': u'gauge',
- u'unit': u'instance',
- u'volume': 1,
- u'user_id': 'efd87807-12d2-4b38-9c70-5f5c2ac427ff'}]
-
- QUERY = {"filter": {"and": [{"=": {"source": "openstack"}},
- {">": {"timestamp": "2014-02-19T05:50:16"}}]},
- "orderby": [{"timestamp": "desc"}, {"volume": "asc"}],
- "limit": 10}
-
- def setUp(self):
- super(ShellQuerySamplesCommandTest, self).setUp()
- self.cc = mock.Mock()
- self.args = mock.Mock()
- self.args.filter = self.QUERY["filter"]
- self.args.orderby = self.QUERY["orderby"]
- self.args.limit = self.QUERY["limit"]
-
- @mock.patch('sys.stdout', new=six.StringIO())
- def test_query(self):
- ret_sample = [samples.Sample(mock.Mock(), sample)
- for sample in self.SAMPLE]
- self.cc.query_samples.query.return_value = ret_sample
-
- ceilometer_shell.do_query_samples(self.cc, self.args)
-
- self.assertEqual('''\
-+--------------------------------------+----------+-------+--------+---------\
--+----------------------------+
-| Resource ID | Meter | Type | Volume | Unit \
- | Timestamp |
-+--------------------------------------+----------+-------+--------+---------\
--+----------------------------+
-| bd9431c1-8d69-4ad3-803a-8d4a6b89fd36 | instance | gauge | 1 | instance\
- | 2014-02-19T05:50:16.673604 |
-+--------------------------------------+----------+-------+--------+---------\
--+----------------------------+
-''', sys.stdout.getvalue())
-
-
-class ShellQueryAlarmsCommandTest(utils.BaseTestCase):
-
- ALARM = [{"alarm_actions": ["http://site:8000/alarm"],
- "alarm_id": "768ff714-8cfb-4db9-9753-d484cb33a1cc",
- "combination_rule": {
- "alarm_ids": [
- "739e99cb-c2ec-4718-b900-332502355f38",
- "153462d0-a9b8-4b5b-8175-9e4b05e9b856"],
- "operator": "or"},
- "description": "An alarm",
- "enabled": True,
- "insufficient_data_actions": ["http://site:8000/nodata"],
- "name": "SwiftObjectAlarm",
- "ok_actions": ["http://site:8000/ok"],
- "project_id": "c96c887c216949acbdfbd8b494863567",
- "repeat_actions": False,
- "state": "ok",
- "severity": "critical",
- "state_timestamp": "2014-02-20T10:37:15.589860",
- "threshold_rule": None,
- "timestamp": "2014-02-20T10:37:15.589856",
- "time_constraints": [{"name": "test", "start": "0 23 * * *",
- "duration": 10800}],
- "type": "combination",
- "user_id": "c96c887c216949acbdfbd8b494863567"}]
-
- QUERY = {"filter": {"and": [{"!=": {"state": "ok"}},
- {"=": {"type": "combination"}}]},
- "orderby": [{"state_timestamp": "desc"}],
- "limit": 10}
-
- def setUp(self):
- super(ShellQueryAlarmsCommandTest, self).setUp()
- self.cc = mock.Mock()
- self.args = mock.Mock()
- self.args.filter = self.QUERY["filter"]
- self.args.orderby = self.QUERY["orderby"]
- self.args.limit = self.QUERY["limit"]
-
- @mock.patch('sys.stdout', new=six.StringIO())
- def test_query(self):
- ret_alarm = [alarms.Alarm(mock.Mock(), alarm)
- for alarm in self.ALARM]
- self.cc.query_alarms.query.return_value = ret_alarm
-
- ceilometer_shell.do_query_alarms(self.cc, self.args)
-
- self.assertEqual('''\
-+--------------------------------------+------------------+-------+----------+\
----------+------------+-------------------------------------------------------\
------------------------------------------------+-------------------------------\
--+
-| Alarm ID | Name | State | Severity \
-| Enabled | Continuous | Alarm condition \
- | Time constraints \
- |
-+--------------------------------------+------------------+-------+----------+\
----------+------------+-------------------------------------------------------\
------------------------------------------------+--------------------------------+
-| 768ff714-8cfb-4db9-9753-d484cb33a1cc | SwiftObjectAlarm | ok | critical \
-| True | False | combinated states (OR) of \
-739e99cb-c2ec-4718-b900-332502355f38, 153462d0-a9b8-4b5b-8175-9e4b05e9b856 |\
- test at 0 23 * * * for 10800s |
-+--------------------------------------+------------------+-------+----------+\
----------+------------+-------------------------------------------------------\
------------------------------------------------+------------------------------\
---+
-''', sys.stdout.getvalue())
-
- @mock.patch('sys.stdout', new=six.StringIO())
- def test_time_constraints_compatibility(self):
- # client should be backwards compatible
- alarm_without_tc = dict(self.ALARM[0])
- del alarm_without_tc['time_constraints']
-
- # NOTE(nsaje): Since we're accessing a nonexisting key in the resource,
- # the resource is looking it up with the manager (which is a mock).
- manager_mock = mock.Mock()
- del manager_mock.get
- ret_alarm = [alarms.Alarm(manager_mock, alarm_without_tc)]
- self.cc.query_alarms.query.return_value = ret_alarm
-
- ceilometer_shell.do_query_alarms(self.cc, self.args)
-
- self.assertEqual('''\
-+--------------------------------------+------------------+-------+----------+\
----------+------------+-------------------------------------------------------\
------------------------------------------------+------------------+
-| Alarm ID | Name | State | Severity \
-| Enabled | Continuous | Alarm condition \
- | Time constraints |
-+--------------------------------------+------------------+-------+----------+\
----------+------------+-------------------------------------------------------\
------------------------------------------------+------------------+
-| 768ff714-8cfb-4db9-9753-d484cb33a1cc | SwiftObjectAlarm | ok | critical \
-| True | False | combinated states (OR) of \
-739e99cb-c2ec-4718-b900-332502355f38, 153462d0-a9b8-4b5b-8175-9e4b05e9b856 \
-| None |
-+--------------------------------------+------------------+-------+----------+\
----------+------------+-------------------------------------------------------\
------------------------------------------------+------------------+
-''', sys.stdout.getvalue())
-
-
-class ShellQueryAlarmHistoryCommandTest(utils.BaseTestCase):
-
- ALARM_HISTORY = [{"alarm_id": "e8ff32f772a44a478182c3fe1f7cad6a",
- "event_id": "c74a8611-6553-4764-a860-c15a6aabb5d0",
- "detail":
- "{\"threshold\": 42.0, \"evaluation_periods\": 4}",
- "on_behalf_of": "92159030020611e3b26dde429e99ee8c",
- "project_id": "b6f16144010811e387e4de429e99ee8c",
- "timestamp": "2014-03-11T16:02:58.376261",
- "type": "rule change",
- "user_id": "3e5d11fda79448ac99ccefb20be187ca"
- }]
-
- QUERY = {"filter": {"and": [{">": {"timestamp": "2014-03-11T16:02:58"}},
- {"=": {"type": "rule change"}}]},
- "orderby": [{"timestamp": "desc"}],
- "limit": 10}
-
- def setUp(self):
- super(ShellQueryAlarmHistoryCommandTest, self).setUp()
- self.cc = mock.Mock()
- self.args = mock.Mock()
- self.args.filter = self.QUERY["filter"]
- self.args.orderby = self.QUERY["orderby"]
- self.args.limit = self.QUERY["limit"]
-
- @mock.patch('sys.stdout', new=six.StringIO())
- def test_query(self):
- ret_alarm_history = [alarms.AlarmChange(mock.Mock(), alarm_history)
- for alarm_history in self.ALARM_HISTORY]
- self.cc.query_alarm_history.query.return_value = ret_alarm_history
-
- ceilometer_shell.do_query_alarm_history(self.cc, self.args)
-
- self.assertEqual('''\
-+----------------------------------+--------------------------------------+-\
-------------+----------------------------------------------+----------------\
-------------+
-| Alarm ID | Event ID | \
-Type | Detail | Timestamp \
- |
-+----------------------------------+--------------------------------------+-\
-------------+----------------------------------------------+----------------\
-------------+
-| e8ff32f772a44a478182c3fe1f7cad6a | c74a8611-6553-4764-a860-c15a6aabb5d0 | \
-rule change | {"threshold": 42.0, "evaluation_periods": 4} | 2014-03-11T16:0\
-2:58.376261 |
-+----------------------------------+--------------------------------------+-\
-------------+----------------------------------------------+----------------\
-------------+
-''', sys.stdout.getvalue())
-
-
-class ShellStatisticsTest(utils.BaseTestCase):
- def setUp(self):
- super(ShellStatisticsTest, self).setUp()
- self.cc = mock.Mock()
- self.displays = {
- 'duration': 'Duration',
- 'duration_end': 'Duration End',
- 'duration_start': 'Duration Start',
- 'period': 'Period',
- 'period_end': 'Period End',
- 'period_start': 'Period Start',
- 'groupby': 'Group By',
- 'avg': 'Avg',
- 'count': 'Count',
- 'max': 'Max',
- 'min': 'Min',
- 'sum': 'Sum',
- 'stddev': 'Standard deviation',
- 'cardinality': 'Cardinality'
- }
- self.args = mock.Mock()
- self.args.meter_name = 'instance'
- self.args.aggregate = []
- self.args.groupby = None
- self.args.query = None
-
- def test_statistics_list_simple(self):
- samples = [
- {u'count': 135,
- u'duration_start': u'2013-02-04T10:51:42',
- u'min': 1.0,
- u'max': 1.0,
- u'duration_end':
- u'2013-02-05T15:46:09',
- u'duration': 1734.0,
- u'avg': 1.0,
- u'sum': 135.0},
- ]
- fields = [
- 'period',
- 'period_start',
- 'period_end',
- 'max',
- 'min',
- 'avg',
- 'sum',
- 'count',
- 'duration',
- 'duration_start',
- 'duration_end',
- ]
- statistics_ret = [
- statistics.Statistics(mock.Mock(), sample) for sample in samples
- ]
- self.cc.statistics.list.return_value = statistics_ret
- with mock.patch('ceilometerclient.v2.shell.utils.print_list') as pmock:
- ceilometer_shell.do_statistics(self.cc, self.args)
- pmock.assert_called_with(
- statistics_ret,
- fields,
- [self.displays[f] for f in fields]
- )
-
- def test_statistics_list_groupby(self):
- samples = [
- {u'count': 135,
- u'duration_start': u'2013-02-04T10:51:42',
- u'min': 1.0,
- u'max': 1.0,
- u'duration_end':
- u'2013-02-05T15:46:09',
- u'duration': 1734.0,
- u'avg': 1.0,
- u'sum': 135.0,
- u'groupby': {u'resource_id': u'foo'}
- },
- {u'count': 12,
- u'duration_start': u'2013-02-04T10:51:42',
- u'min': 1.0,
- u'max': 1.0,
- u'duration_end':
- u'2013-02-05T15:46:09',
- u'duration': 1734.0,
- u'avg': 1.0,
- u'sum': 12.0,
- u'groupby': {u'resource_id': u'bar'}
- },
- ]
- fields = [
- 'period',
- 'period_start',
- 'period_end',
- 'groupby',
- 'max',
- 'min',
- 'avg',
- 'sum',
- 'count',
- 'duration',
- 'duration_start',
- 'duration_end',
- ]
- self.args.groupby = 'resource_id'
- statistics_ret = [
- statistics.Statistics(mock.Mock(), sample) for sample in samples
- ]
- self.cc.statistics.list.return_value = statistics_ret
- with mock.patch('ceilometerclient.v2.shell.utils.print_list') as pmock:
- ceilometer_shell.do_statistics(self.cc, self.args)
- pmock.assert_called_with(
- statistics_ret,
- fields,
- [self.displays[f] for f in fields],
- )
-
- def test_statistics_list_aggregates(self):
- samples = [
- {u'aggregate': {u'cardinality/resource_id': 4.0, u'count': 2.0},
- u'count': 2,
- u'duration': 0.442451,
- u'duration_end': u'2014-03-12T14:00:21.774154',
- u'duration_start': u'2014-03-12T14:00:21.331703',
- u'groupby': None,
- u'period': 0,
- u'period_end': u'2014-03-12T14:00:21.774154',
- u'period_start': u'2014-03-12T14:00:21.331703',
- u'unit': u'instance',
- },
- ]
- fields = [
- 'period',
- 'period_start',
- 'period_end',
- 'count',
- 'cardinality/resource_id',
- 'duration',
- 'duration_start',
- 'duration_end',
- ]
- self.args.aggregate = ['count', 'cardinality<-resource_id']
- statistics_ret = [
- statistics.Statistics(mock.Mock(), sample) for sample in samples
- ]
- self.cc.statistics.list.return_value = statistics_ret
- with mock.patch('ceilometerclient.v2.shell.utils.print_list') as pmock:
- ceilometer_shell.do_statistics(self.cc, self.args)
- pmock.assert_called_with(
- statistics_ret,
- fields,
- [self.displays.get(f, f) for f in fields],
- )
-
-
-class ShellEmptyIdTest(utils.BaseTestCase):
- """Test empty field which will cause calling incorrect rest uri."""
-
- def _test_entity_action_with_empty_values(self, entity,
- *args, **kwargs):
- positional = kwargs.pop('positional', False)
- for value in ('', ' ', ' ', '\t'):
- self._test_entity_action_with_empty_value(entity, value,
- positional, *args)
-
- def _test_entity_action_with_empty_value(self, entity, value,
- positional, *args):
- new_args = [value] if positional else ['--%s' % entity, value]
- argv = list(args) + new_args
- shell = base_shell.CeilometerShell()
- with mock.patch('ceilometerclient.exc.CommandError') as e:
- e.return_value = exc.BaseException()
- self.assertRaises(exc.BaseException, shell.parse_args, argv)
- entity = entity.replace('-', '_')
- e.assert_called_with('%s should not be empty' % entity)
-
- def _test_alarm_action_with_empty_ids(self, method, *args):
- args = [method] + list(args)
- self._test_entity_action_with_empty_values('alarm_id',
- positional=True, *args)
-
- def test_alarm_show_with_empty_id(self):
- self._test_alarm_action_with_empty_ids('alarm-show')
-
- def test_alarm_update_with_empty_id(self):
- self._test_alarm_action_with_empty_ids('alarm-update')
-
- def test_alarm_threshold_update_with_empty_id(self):
- self._test_alarm_action_with_empty_ids('alarm-threshold-update')
-
- def test_alarm_combination_update_with_empty_id(self):
- self._test_alarm_action_with_empty_ids('alarm-combination-update')
-
- def test_alarm_delete_with_empty_id(self):
- self._test_alarm_action_with_empty_ids('alarm-delete')
-
- def test_alarm_state_get_with_empty_id(self):
- self._test_alarm_action_with_empty_ids('alarm-state-get')
-
- def test_alarm_state_set_with_empty_id(self):
- args = ['alarm-state-set', '--state', 'ok']
- self._test_alarm_action_with_empty_ids(*args)
-
- def test_alarm_history_with_empty_id(self):
- self._test_alarm_action_with_empty_ids('alarm-history')
-
- def test_event_show_with_empty_message_id(self):
- args = ['event-show']
- self._test_entity_action_with_empty_values('message_id', *args)
-
- def test_resource_show_with_empty_id(self):
- args = ['resource-show']
- self._test_entity_action_with_empty_values('resource_id', *args)
-
- def test_sample_list_with_empty_meter(self):
- args = ['sample-list']
- self._test_entity_action_with_empty_values('meter', *args)
-
- def test_sample_create_with_empty_meter(self):
- args = ['sample-create', '-r', 'x', '--meter-type', 'gauge',
- '--meter-unit', 'B', '--sample-volume', '1']
- self._test_entity_action_with_empty_values('meter-name', *args)
-
- def test_statistics_with_empty_meter(self):
- args = ['statistics']
- self._test_entity_action_with_empty_values('meter', *args)
-
- def test_trait_description_list_with_empty_event_type(self):
- args = ['trait-description-list']
- self._test_entity_action_with_empty_values('event_type', *args)
-
- def test_trait_list_with_empty_event_type(self):
- args = ['trait-list', '--trait_name', 'x']
- self._test_entity_action_with_empty_values('event_type', *args)
-
- def test_trait_list_with_empty_trait_name(self):
- args = ['trait-list', '--event_type', 'x']
- self._test_entity_action_with_empty_values('trait_name', *args)
-
-
-class ShellObsoletedArgsTest(utils.BaseTestCase):
- """Test arguments that have been obsoleted."""
-
- def _test_entity_obsoleted(self, entity, value, positional, *args):
- new_args = [value] if positional else ['--%s' % entity, value]
- argv = list(args) + new_args
- shell = base_shell.CeilometerShell()
- with mock.patch('sys.stdout', new_callable=six.StringIO) as stdout:
- shell.parse_args(argv)
- self.assertIn('obsolete', stdout.getvalue())
-
- def test_obsolete_alarm_id(self):
- for method in ['alarm-show', 'alarm-update', 'alarm-threshold-update',
- 'alarm-combination-update', 'alarm-delete',
- 'alarm-state-get', 'alarm-history']:
- self._test_entity_obsoleted('alarm_id', 'abcde', False, method)
-
-
-class ShellEventListCommandTest(utils.BaseTestCase):
-
- EVENTS = [
- {
- "traits": [],
- "generated": "2015-01-12T04:03:25.741471",
- "message_id": "fb2bef58-88af-4380-8698-e0f18fcf452d",
- "event_type": "compute.instance.create.start",
- "traits": [{
- "name": "state",
- "type": "string",
- "value": "building",
- }],
- },
- {
- "traits": [],
- "generated": "2015-01-12T04:03:28.452495",
- "message_id": "9b20509a-576b-4995-acfa-1a24ee5cf49f",
- "event_type": "compute.instance.create.end",
- "traits": [{
- "name": "state",
- "type": "string",
- "value": "active",
- }],
- },
- ]
-
- def setUp(self):
- super(ShellEventListCommandTest, self).setUp()
- self.cc = mock.Mock()
- self.args = mock.Mock()
- self.args.query = None
- self.args.no_traits = None
-
- @mock.patch('sys.stdout', new=six.StringIO())
- def test_event_list(self):
- ret_events = [events.Event(mock.Mock(), event)
- for event in self.EVENTS]
- self.cc.events.list.return_value = ret_events
- ceilometer_shell.do_event_list(self.cc, self.args)
- self.assertEqual('''\
-+--------------------------------------+-------------------------------+\
-----------------------------+-------------------------------+
-| Message ID | Event Type |\
- Generated | Traits |
-+--------------------------------------+-------------------------------+\
-----------------------------+-------------------------------+
-| fb2bef58-88af-4380-8698-e0f18fcf452d | compute.instance.create.start |\
- 2015-01-12T04:03:25.741471 | +-------+--------+----------+ |
-| | |\
- | | name | type | value | |
-| | |\
- | +-------+--------+----------+ |
-| | |\
- | | state | string | building | |
-| | |\
- | +-------+--------+----------+ |
-| 9b20509a-576b-4995-acfa-1a24ee5cf49f | compute.instance.create.end |\
- 2015-01-12T04:03:28.452495 | +-------+--------+--------+ |
-| | |\
- | | name | type | value | |
-| | |\
- | +-------+--------+--------+ |
-| | |\
- | | state | string | active | |
-| | |\
- | +-------+--------+--------+ |
-+--------------------------------------+-------------------------------+\
-----------------------------+-------------------------------+
-''', sys.stdout.getvalue())
-
- @mock.patch('sys.stdout', new=six.StringIO())
- def test_event_list_no_traits(self):
- self.args.no_traits = True
- ret_events = [events.Event(mock.Mock(), event)
- for event in self.EVENTS]
- self.cc.events.list.return_value = ret_events
- ceilometer_shell.do_event_list(self.cc, self.args)
- self.assertEqual('''\
-+--------------------------------------+-------------------------------\
-+----------------------------+
-| Message ID | Event Type \
-| Generated |
-+--------------------------------------+-------------------------------\
-+----------------------------+
-| fb2bef58-88af-4380-8698-e0f18fcf452d | compute.instance.create.start \
-| 2015-01-12T04:03:25.741471 |
-| 9b20509a-576b-4995-acfa-1a24ee5cf49f | compute.instance.create.end \
-| 2015-01-12T04:03:28.452495 |
-+--------------------------------------+-------------------------------\
-+----------------------------+
-''', sys.stdout.getvalue())
-
-
-class ShellShadowedArgsTest(test_shell.ShellTestBase):
-
- def _test_project_id_alarm(self, command, args, method):
- self.make_env(test_shell.FAKE_V2_ENV)
- cli_args = [
- '--os-project-id', '0ba30185ddf44834914a0b859d244c56',
- '--debug', command,
- '--project-id', 'the-project-id-i-want-to-set',
- '--name', 'project-id-test'] + args
- with mock.patch.object(alarms.AlarmManager, method) as mocked:
- base_shell.main(cli_args)
- args, kwargs = mocked.call_args
- self.assertEqual('the-project-id-i-want-to-set',
- kwargs.get('project_id'))
-
- def test_project_id_threshold_alarm(self):
- cli_args = ['--meter-name', 'cpu', '--threshold', '90']
- self._test_project_id_alarm('alarm-create', cli_args, 'create')
- self._test_project_id_alarm('alarm-threshold-create',
- cli_args, 'create')
- cli_args += ['--alarm_id', '437b7ed0-3733-4054-a877-e9a297b8be85']
- self._test_project_id_alarm('alarm-update', cli_args, 'update')
- self._test_project_id_alarm('alarm-threshold-update',
- cli_args, 'update')
-
- def test_project_id_combination_alarm(self):
- cli_args = ['--alarm_ids', 'fb16a05a-669d-414e-8bbe-93aa381df6a8',
- '--alarm_ids', 'b189bcca-0a7b-49a9-a244-a927ac291881']
- self._test_project_id_alarm('alarm-combination-create',
- cli_args, 'create')
- cli_args += ['--alarm_id', '437b7ed0-3733-4054-a877-e9a297b8be85']
- self._test_project_id_alarm('alarm-combination-update',
- cli_args, 'update')
-
- @mock.patch.object(samples.OldSampleManager, 'create')
- def test_project_id_sample_create(self, mocked):
- self.make_env(test_shell.FAKE_V2_ENV)
- cli_args = [
- '--os-project-id', '0ba30185ddf44834914a0b859d244c56',
- '--debug', 'sample-create',
- '--project-id', 'the-project-id-i-want-to-set',
- '--resource-id', 'b666633d-9bb6-4e05-89c0-ee5a8752fb0b',
- '--meter-name', 'cpu',
- '--meter-type', 'cumulative',
- '--meter-unit', 'ns',
- '--sample-volume', '10086',
- ]
- base_shell.main(cli_args)
- args, kwargs = mocked.call_args
- self.assertEqual('the-project-id-i-want-to-set',
- kwargs.get('project_id'))