Yassine Lamgarchal | 0563876 | 2013-12-27 20:10:32 +0100 | [diff] [blame] | 1 | # Licensed under the Apache License, Version 2.0 (the "License"); you may |
| 2 | # not use this file except in compliance with the License. You may obtain |
| 3 | # a copy of the License at |
| 4 | # |
| 5 | # http://www.apache.org/licenses/LICENSE-2.0 |
| 6 | # |
| 7 | # Unless required by applicable law or agreed to in writing, software |
| 8 | # distributed under the License is distributed on an "AS IS" BASIS, WITHOUT |
| 9 | # WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the |
| 10 | # License for the specific language governing permissions and limitations |
| 11 | # under the License. |
| 12 | |
Vadim Rovachev | 7bcea35 | 2013-12-26 15:56:17 +0400 | [diff] [blame] | 13 | import time |
| 14 | |
Doug Hellmann | 583ce2c | 2015-03-11 14:55:46 +0000 | [diff] [blame] | 15 | from oslo_utils import timeutils |
Masayuki Igawa | bfa0760 | 2015-01-20 18:47:17 +0900 | [diff] [blame] | 16 | from tempest_lib import exceptions as lib_exc |
| 17 | |
Joseph Lanoux | 2a15fe6 | 2015-07-31 14:09:58 +0000 | [diff] [blame] | 18 | from tempest.common import compute |
Fei Long Wang | d39431f | 2015-05-14 11:30:48 +1200 | [diff] [blame] | 19 | from tempest.common.utils import data_utils |
Yassine Lamgarchal | 0563876 | 2013-12-27 20:10:32 +0100 | [diff] [blame] | 20 | from tempest import config |
vrovachev | 95a16cc | 2014-02-04 15:29:48 +0400 | [diff] [blame] | 21 | from tempest import exceptions |
Yassine Lamgarchal | 0563876 | 2013-12-27 20:10:32 +0100 | [diff] [blame] | 22 | import tempest.test |
| 23 | |
| 24 | CONF = config.CONF |
| 25 | |
| 26 | |
| 27 | class BaseTelemetryTest(tempest.test.BaseTestCase): |
| 28 | |
| 29 | """Base test case class for all Telemetry API tests.""" |
| 30 | |
Andrea Frittoli | b21de6c | 2015-02-06 20:12:38 +0000 | [diff] [blame] | 31 | credentials = ['primary'] |
| 32 | |
Yassine Lamgarchal | 0563876 | 2013-12-27 20:10:32 +0100 | [diff] [blame] | 33 | @classmethod |
Rohan Kanade | d114a13 | 2015-02-07 11:11:16 +0530 | [diff] [blame] | 34 | def skip_checks(cls): |
| 35 | super(BaseTelemetryTest, cls).skip_checks() |
Yassine Lamgarchal | 0563876 | 2013-12-27 20:10:32 +0100 | [diff] [blame] | 36 | if not CONF.service_available.ceilometer: |
| 37 | raise cls.skipException("Ceilometer support is required") |
Vadim Rovachev | 7bcea35 | 2013-12-26 15:56:17 +0400 | [diff] [blame] | 38 | |
Rohan Kanade | d114a13 | 2015-02-07 11:11:16 +0530 | [diff] [blame] | 39 | @classmethod |
| 40 | def setup_credentials(cls): |
| 41 | cls.set_network_resources() |
| 42 | super(BaseTelemetryTest, cls).setup_credentials() |
Rohan Kanade | d114a13 | 2015-02-07 11:11:16 +0530 | [diff] [blame] | 43 | |
| 44 | @classmethod |
| 45 | def setup_clients(cls): |
| 46 | super(BaseTelemetryTest, cls).setup_clients() |
| 47 | cls.telemetry_client = cls.os.telemetry_client |
| 48 | cls.servers_client = cls.os.servers_client |
| 49 | cls.flavors_client = cls.os.flavors_client |
| 50 | cls.image_client = cls.os.image_client |
| 51 | cls.image_client_v2 = cls.os.image_client_v2 |
| 52 | |
| 53 | @classmethod |
| 54 | def resource_setup(cls): |
| 55 | super(BaseTelemetryTest, cls).resource_setup() |
Vadim Rovachev | 7bcea35 | 2013-12-26 15:56:17 +0400 | [diff] [blame] | 56 | cls.nova_notifications = ['memory', 'vcpus', 'disk.root.size', |
| 57 | 'disk.ephemeral.size'] |
Vadim Rovachev | 80ee4e1 | 2014-02-05 16:59:07 +0400 | [diff] [blame] | 58 | |
gord chung | e10a3e4 | 2015-06-13 00:36:59 -0400 | [diff] [blame] | 59 | cls.glance_notifications = ['image.size'] |
Vadim Rovachev | 80ee4e1 | 2014-02-05 16:59:07 +0400 | [diff] [blame] | 60 | |
| 61 | cls.glance_v2_notifications = ['image.download', 'image.serve'] |
| 62 | |
Vadim Rovachev | 7bcea35 | 2013-12-26 15:56:17 +0400 | [diff] [blame] | 63 | cls.server_ids = [] |
vrovachev | 95a16cc | 2014-02-04 15:29:48 +0400 | [diff] [blame] | 64 | cls.alarm_ids = [] |
Vadim Rovachev | 80ee4e1 | 2014-02-05 16:59:07 +0400 | [diff] [blame] | 65 | cls.image_ids = [] |
vrovachev | 95a16cc | 2014-02-04 15:29:48 +0400 | [diff] [blame] | 66 | |
| 67 | @classmethod |
| 68 | def create_alarm(cls, **kwargs): |
David Kranz | 20d06f4 | 2015-02-09 14:54:15 -0500 | [diff] [blame] | 69 | body = cls.telemetry_client.create_alarm( |
vrovachev | 95a16cc | 2014-02-04 15:29:48 +0400 | [diff] [blame] | 70 | name=data_utils.rand_name('telemetry_alarm'), |
| 71 | type='threshold', **kwargs) |
Vadim Rovachev | 80ee4e1 | 2014-02-05 16:59:07 +0400 | [diff] [blame] | 72 | cls.alarm_ids.append(body['alarm_id']) |
David Kranz | 20d06f4 | 2015-02-09 14:54:15 -0500 | [diff] [blame] | 73 | return body |
vrovachev | 95a16cc | 2014-02-04 15:29:48 +0400 | [diff] [blame] | 74 | |
| 75 | @classmethod |
Vadim Rovachev | 7bcea35 | 2013-12-26 15:56:17 +0400 | [diff] [blame] | 76 | def create_server(cls): |
Joseph Lanoux | 2a15fe6 | 2015-07-31 14:09:58 +0000 | [diff] [blame] | 77 | tenant_network = cls.get_tenant_network() |
| 78 | body, server = compute.create_test_server( |
| 79 | cls.os, |
| 80 | tenant_network=tenant_network, |
| 81 | name=data_utils.rand_name('ceilometer-instance'), |
Vadim Rovachev | 7bcea35 | 2013-12-26 15:56:17 +0400 | [diff] [blame] | 82 | wait_until='ACTIVE') |
Vadim Rovachev | 80ee4e1 | 2014-02-05 16:59:07 +0400 | [diff] [blame] | 83 | cls.server_ids.append(body['id']) |
David Kranz | 0fb1429 | 2015-02-11 15:55:20 -0500 | [diff] [blame] | 84 | return body |
Vadim Rovachev | 80ee4e1 | 2014-02-05 16:59:07 +0400 | [diff] [blame] | 85 | |
| 86 | @classmethod |
| 87 | def create_image(cls, client): |
David Kranz | a5299eb | 2015-01-15 17:24:05 -0500 | [diff] [blame] | 88 | body = client.create_image( |
Vadim Rovachev | 80ee4e1 | 2014-02-05 16:59:07 +0400 | [diff] [blame] | 89 | data_utils.rand_name('image'), container_format='bare', |
| 90 | disk_format='raw', visibility='private') |
John Warren | 6620725 | 2015-07-31 15:51:02 -0400 | [diff] [blame] | 91 | # TODO(jswarren) Move ['image'] up to initial body value assignment |
| 92 | # once both v1 and v2 glance clients include the full response |
| 93 | # object. |
| 94 | if 'image' in body: |
| 95 | body = body['image'] |
Vadim Rovachev | 80ee4e1 | 2014-02-05 16:59:07 +0400 | [diff] [blame] | 96 | cls.image_ids.append(body['id']) |
David Kranz | a5299eb | 2015-01-15 17:24:05 -0500 | [diff] [blame] | 97 | return body |
Vadim Rovachev | 7bcea35 | 2013-12-26 15:56:17 +0400 | [diff] [blame] | 98 | |
| 99 | @staticmethod |
| 100 | def cleanup_resources(method, list_of_ids): |
| 101 | for resource_id in list_of_ids: |
vrovachev | 95a16cc | 2014-02-04 15:29:48 +0400 | [diff] [blame] | 102 | try: |
Vadim Rovachev | 7bcea35 | 2013-12-26 15:56:17 +0400 | [diff] [blame] | 103 | method(resource_id) |
Masayuki Igawa | bfa0760 | 2015-01-20 18:47:17 +0900 | [diff] [blame] | 104 | except lib_exc.NotFound: |
vrovachev | 95a16cc | 2014-02-04 15:29:48 +0400 | [diff] [blame] | 105 | pass |
Vadim Rovachev | 7bcea35 | 2013-12-26 15:56:17 +0400 | [diff] [blame] | 106 | |
| 107 | @classmethod |
Andrea Frittoli | c76d04d | 2014-09-15 13:14:54 +0100 | [diff] [blame] | 108 | def resource_cleanup(cls): |
Vadim Rovachev | 7bcea35 | 2013-12-26 15:56:17 +0400 | [diff] [blame] | 109 | cls.cleanup_resources(cls.telemetry_client.delete_alarm, cls.alarm_ids) |
| 110 | cls.cleanup_resources(cls.servers_client.delete_server, cls.server_ids) |
Vadim Rovachev | 80ee4e1 | 2014-02-05 16:59:07 +0400 | [diff] [blame] | 111 | cls.cleanup_resources(cls.image_client.delete_image, cls.image_ids) |
Andrea Frittoli | c76d04d | 2014-09-15 13:14:54 +0100 | [diff] [blame] | 112 | super(BaseTelemetryTest, cls).resource_cleanup() |
Vadim Rovachev | 7bcea35 | 2013-12-26 15:56:17 +0400 | [diff] [blame] | 113 | |
| 114 | def await_samples(self, metric, query): |
| 115 | """ |
| 116 | This method is to wait for sample to add it to database. |
| 117 | There are long time delays when using Postgresql (or Mysql) |
| 118 | database as ceilometer backend |
| 119 | """ |
| 120 | timeout = CONF.compute.build_timeout |
| 121 | start = timeutils.utcnow() |
| 122 | while timeutils.delta_seconds(start, timeutils.utcnow()) < timeout: |
David Kranz | 20d06f4 | 2015-02-09 14:54:15 -0500 | [diff] [blame] | 123 | body = self.telemetry_client.list_samples(metric, query) |
Vadim Rovachev | 7bcea35 | 2013-12-26 15:56:17 +0400 | [diff] [blame] | 124 | if body: |
David Kranz | 20d06f4 | 2015-02-09 14:54:15 -0500 | [diff] [blame] | 125 | return body |
Vadim Rovachev | 7bcea35 | 2013-12-26 15:56:17 +0400 | [diff] [blame] | 126 | time.sleep(CONF.compute.build_interval) |
| 127 | |
| 128 | raise exceptions.TimeoutException( |
| 129 | 'Sample for metric:%s with query:%s has not been added to the ' |
| 130 | 'database within %d seconds' % (metric, query, |
| 131 | CONF.compute.build_timeout)) |
gordon chung | ee23ddb | 2015-02-11 20:05:07 -0500 | [diff] [blame] | 132 | |
| 133 | |
| 134 | class BaseTelemetryAdminTest(BaseTelemetryTest): |
| 135 | """Base test case class for admin Telemetry API tests.""" |
| 136 | |
| 137 | credentials = ['primary', 'admin'] |
| 138 | |
| 139 | @classmethod |
| 140 | def setup_clients(cls): |
| 141 | super(BaseTelemetryAdminTest, cls).setup_clients() |
| 142 | cls.telemetry_admin_client = cls.os_adm.telemetry_client |
| 143 | |
| 144 | def await_events(self, query): |
| 145 | timeout = CONF.compute.build_timeout |
| 146 | start = timeutils.utcnow() |
| 147 | while timeutils.delta_seconds(start, timeutils.utcnow()) < timeout: |
| 148 | body = self.telemetry_admin_client.list_events(query) |
| 149 | if body: |
| 150 | return body |
| 151 | time.sleep(CONF.compute.build_interval) |
| 152 | |
| 153 | raise exceptions.TimeoutException( |
| 154 | 'Event with query:%s has not been added to the ' |
| 155 | 'database within %d seconds' % (query, CONF.compute.build_timeout)) |