Remove aodh intree tempest plugin
* https://review.openstack.org/#/c/526298/ moves the aodh tempest tests and configurations in ceileometer. So we are removing the intree tempest tests from aodh. Change-Id: I972c53eb7c3f2b6d717220a5732b9b1fc0d33a9d
This commit is contained in:
parent
57b50bc20e
commit
649d289465
@ -33,6 +33,10 @@
|
||||
run: playbooks/legacy/aodh-dsvm-tempest-plugin-mysql/run.yaml
|
||||
post-run: playbooks/legacy/aodh-dsvm-tempest-plugin-mysql/post.yaml
|
||||
timeout: 7800
|
||||
# Disabling this job in order to remove aodh tempest plugin as they are
|
||||
# moved to telemetry-tempest-plugin, It will be reenabled once this patch
|
||||
# get's merged.
|
||||
voting: false
|
||||
required-projects:
|
||||
- openstack-infra/devstack-gate
|
||||
- openstack/aodh
|
||||
@ -44,6 +48,10 @@
|
||||
run: playbooks/legacy/aodh-dsvm-tempest-plugin-postgresql/run.yaml
|
||||
post-run: playbooks/legacy/aodh-dsvm-tempest-plugin-postgresql/post.yaml
|
||||
timeout: 7800
|
||||
# Disabling this job in order to remove aodh tempest plugin as they are
|
||||
# moved to telemetry-tempest-plugin, It will be reenabled once this patch
|
||||
# get's merged.
|
||||
voting: false
|
||||
required-projects:
|
||||
- openstack-infra/devstack-gate
|
||||
- openstack/aodh
|
||||
|
@ -1,64 +0,0 @@
|
||||
# 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.
|
||||
|
||||
from tempest import config
|
||||
from tempest.lib.common.utils import data_utils
|
||||
from tempest.lib import exceptions as lib_exc
|
||||
import tempest.test
|
||||
|
||||
from aodh.tests.tempest.service import client
|
||||
|
||||
CONF = config.CONF
|
||||
|
||||
|
||||
class BaseAlarmingTest(tempest.test.BaseTestCase):
|
||||
"""Base test case class for all Alarming API tests."""
|
||||
|
||||
credentials = ['primary']
|
||||
client_manager = client.Manager
|
||||
|
||||
@classmethod
|
||||
def skip_checks(cls):
|
||||
super(BaseAlarmingTest, cls).skip_checks()
|
||||
if not CONF.service_available.aodh_plugin:
|
||||
raise cls.skipException("Aodh support is required")
|
||||
|
||||
@classmethod
|
||||
def setup_clients(cls):
|
||||
super(BaseAlarmingTest, cls).setup_clients()
|
||||
cls.alarming_client = cls.os_primary.alarming_client
|
||||
|
||||
@classmethod
|
||||
def resource_setup(cls):
|
||||
super(BaseAlarmingTest, cls).resource_setup()
|
||||
cls.alarm_ids = []
|
||||
|
||||
@classmethod
|
||||
def create_alarm(cls, **kwargs):
|
||||
body = cls.alarming_client.create_alarm(
|
||||
name=data_utils.rand_name('telemetry_alarm'),
|
||||
type='threshold', **kwargs)
|
||||
cls.alarm_ids.append(body['alarm_id'])
|
||||
return body
|
||||
|
||||
@staticmethod
|
||||
def cleanup_resources(method, list_of_ids):
|
||||
for resource_id in list_of_ids:
|
||||
try:
|
||||
method(resource_id)
|
||||
except lib_exc.NotFound:
|
||||
pass
|
||||
|
||||
@classmethod
|
||||
def resource_cleanup(cls):
|
||||
cls.cleanup_resources(cls.alarming_client.delete_alarm, cls.alarm_ids)
|
||||
super(BaseAlarmingTest, cls).resource_cleanup()
|
@ -1,94 +0,0 @@
|
||||
# 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.
|
||||
|
||||
from tempest.lib.common.utils import data_utils
|
||||
from tempest.lib import decorators
|
||||
from tempest.lib import exceptions as lib_exc
|
||||
|
||||
from aodh.tests.tempest.api import base
|
||||
|
||||
|
||||
class TelemetryAlarmingAPITest(base.BaseAlarmingTest):
|
||||
|
||||
@classmethod
|
||||
def resource_setup(cls):
|
||||
super(TelemetryAlarmingAPITest, cls).resource_setup()
|
||||
cls.rule = {'meter_name': 'cpu_util',
|
||||
'comparison_operator': 'gt',
|
||||
'threshold': 80.0,
|
||||
'period': 70}
|
||||
for i in range(2):
|
||||
cls.create_alarm(threshold_rule=cls.rule)
|
||||
|
||||
@decorators.idempotent_id('1c918e06-210b-41eb-bd45-14676dd77cd7')
|
||||
def test_alarm_list(self):
|
||||
# List alarms
|
||||
alarm_list = self.alarming_client.list_alarms()
|
||||
|
||||
# Verify created alarm in the list
|
||||
fetched_ids = [a['alarm_id'] for a in alarm_list]
|
||||
missing_alarms = [a for a in self.alarm_ids if a not in fetched_ids]
|
||||
self.assertEqual(0, len(missing_alarms),
|
||||
"Failed to find the following created alarm(s)"
|
||||
" in a fetched list: %s" %
|
||||
', '.join(str(a) for a in missing_alarms))
|
||||
|
||||
@decorators.idempotent_id('1297b095-39c1-4e74-8a1f-4ae998cedd68')
|
||||
def test_create_update_get_delete_alarm(self):
|
||||
# Create an alarm
|
||||
alarm_name = data_utils.rand_name('telemetry_alarm')
|
||||
body = self.alarming_client.create_alarm(
|
||||
name=alarm_name, type='threshold', threshold_rule=self.rule)
|
||||
self.assertEqual(alarm_name, body['name'])
|
||||
alarm_id = body['alarm_id']
|
||||
self.assertDictContainsSubset(self.rule, body['threshold_rule'])
|
||||
# Update alarm with new rule and new name
|
||||
new_rule = {'meter_name': 'cpu',
|
||||
'comparison_operator': 'eq',
|
||||
'threshold': 70.0,
|
||||
'period': 60}
|
||||
alarm_name_updated = data_utils.rand_name('telemetry-alarm-update')
|
||||
body = self.alarming_client.update_alarm(
|
||||
alarm_id,
|
||||
threshold_rule=new_rule,
|
||||
name=alarm_name_updated,
|
||||
type='threshold')
|
||||
self.assertEqual(alarm_name_updated, body['name'])
|
||||
self.assertDictContainsSubset(new_rule, body['threshold_rule'])
|
||||
# Get and verify details of an alarm after update
|
||||
body = self.alarming_client.show_alarm(alarm_id)
|
||||
self.assertEqual(alarm_name_updated, body['name'])
|
||||
self.assertDictContainsSubset(new_rule, body['threshold_rule'])
|
||||
# Get history for the alarm and verify the same
|
||||
body = self.alarming_client.show_alarm_history(alarm_id)
|
||||
self.assertEqual("rule change", body[0]['type'])
|
||||
self.assertIn(alarm_name_updated, body[0]['detail'])
|
||||
self.assertEqual("creation", body[1]['type'])
|
||||
self.assertIn(alarm_name, body[1]['detail'])
|
||||
# Delete alarm and verify if deleted
|
||||
self.alarming_client.delete_alarm(alarm_id)
|
||||
self.assertRaises(lib_exc.NotFound,
|
||||
self.alarming_client.show_alarm, alarm_id)
|
||||
|
||||
@decorators.idempotent_id('aca49486-70bb-4016-87e0-f6131374f742')
|
||||
def test_set_get_alarm_state(self):
|
||||
alarm_states = ['ok', 'alarm', 'insufficient data']
|
||||
alarm = self.create_alarm(threshold_rule=self.rule)
|
||||
# Set alarm state and verify
|
||||
new_state =\
|
||||
[elem for elem in alarm_states if elem != alarm['state']][0]
|
||||
state = self.alarming_client.alarm_set_state(alarm['alarm_id'],
|
||||
new_state)
|
||||
self.assertEqual(new_state, state.data)
|
||||
# Get alarm state and verify
|
||||
state = self.alarming_client.show_alarm_state(alarm['alarm_id'])
|
||||
self.assertEqual(new_state, state.data)
|
@ -1,71 +0,0 @@
|
||||
# Copyright 2015 GlobalLogic. All rights reserved.
|
||||
#
|
||||
# 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.
|
||||
|
||||
from oslo_utils import uuidutils
|
||||
from tempest.lib.common.utils import data_utils
|
||||
from tempest.lib import decorators
|
||||
from tempest.lib import exceptions as lib_exc
|
||||
|
||||
from aodh.tests.tempest.api import base
|
||||
|
||||
|
||||
class TelemetryAlarmingNegativeTest(base.BaseAlarmingTest):
|
||||
"""Negative tests for show_alarm, update_alarm, show_alarm_history tests
|
||||
|
||||
** show non-existent alarm
|
||||
** show the deleted alarm
|
||||
** delete deleted alarm
|
||||
** update deleted alarm
|
||||
"""
|
||||
|
||||
@decorators.attr(type=['negative'])
|
||||
@decorators.idempotent_id('668743d5-08ad-4480-b2b8-15da34f81e7e')
|
||||
def test_get_non_existent_alarm(self):
|
||||
# get the non-existent alarm
|
||||
non_existent_id = uuidutils.generate_uuid()
|
||||
self.assertRaises(lib_exc.NotFound, self.alarming_client.show_alarm,
|
||||
non_existent_id)
|
||||
|
||||
@decorators.attr(type=['negative'])
|
||||
@decorators.idempotent_id('ef45000d-0a72-4781-866d-4cb7bf2582ae')
|
||||
def test_get_update_show_history_delete_deleted_alarm(self):
|
||||
# get, update and delete the deleted alarm
|
||||
alarm_name = data_utils.rand_name('telemetry_alarm')
|
||||
rule = {'meter_name': 'cpu',
|
||||
'comparison_operator': 'eq',
|
||||
'threshold': 100.0,
|
||||
'period': 90}
|
||||
body = self.alarming_client.create_alarm(
|
||||
name=alarm_name,
|
||||
type='threshold',
|
||||
threshold_rule=rule)
|
||||
alarm_id = body['alarm_id']
|
||||
self.alarming_client.delete_alarm(alarm_id)
|
||||
# get the deleted alarm
|
||||
self.assertRaises(lib_exc.NotFound, self.alarming_client.show_alarm,
|
||||
alarm_id)
|
||||
|
||||
# update the deleted alarm
|
||||
updated_alarm_name = data_utils.rand_name('telemetry_alarm_updated')
|
||||
updated_rule = {'meter_name': 'cpu_new',
|
||||
'comparison_operator': 'eq',
|
||||
'threshold': 70,
|
||||
'period': 50}
|
||||
self.assertRaises(lib_exc.NotFound, self.alarming_client.update_alarm,
|
||||
alarm_id, threshold_rule=updated_rule,
|
||||
name=updated_alarm_name,
|
||||
type='threshold')
|
||||
# delete the deleted alarm
|
||||
self.assertRaises(lib_exc.NotFound, self.alarming_client.delete_alarm,
|
||||
alarm_id)
|
@ -1,36 +0,0 @@
|
||||
#
|
||||
# Copyright 2012 OpenStack Foundation
|
||||
#
|
||||
# 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.
|
||||
|
||||
from oslo_config import cfg
|
||||
|
||||
service_option = [
|
||||
cfg.BoolOpt("aodh_plugin",
|
||||
default=True,
|
||||
help="Whether or not Aodh is expected to be available"),
|
||||
]
|
||||
|
||||
alarming_group = cfg.OptGroup(name='alarming_plugin',
|
||||
title='Alarming Service Options')
|
||||
|
||||
AlarmingGroup = [
|
||||
cfg.StrOpt('catalog_type',
|
||||
default='alarming',
|
||||
help="Catalog type of the Alarming service."),
|
||||
cfg.StrOpt('endpoint_type',
|
||||
default='publicURL',
|
||||
choices=['public', 'admin', 'internal',
|
||||
'publicURL', 'adminURL', 'internalURL'],
|
||||
help="The endpoint type to use for the alarming service."),
|
||||
]
|
@ -1,47 +0,0 @@
|
||||
#
|
||||
# Copyright 2015 NEC Corporation.
|
||||
#
|
||||
# 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 os
|
||||
|
||||
from tempest import config
|
||||
from tempest.test_discover import plugins
|
||||
|
||||
import aodh
|
||||
from aodh.tests.tempest import config as tempest_config
|
||||
|
||||
|
||||
class AodhTempestPlugin(plugins.TempestPlugin):
|
||||
|
||||
def load_tests(self):
|
||||
base_path = os.path.split(os.path.dirname(
|
||||
os.path.abspath(aodh.__file__)))[0]
|
||||
test_dir = "aodh/tests/tempest"
|
||||
full_test_dir = os.path.join(base_path, test_dir)
|
||||
return full_test_dir, base_path
|
||||
|
||||
def register_opts(self, conf):
|
||||
config.register_opt_group(conf,
|
||||
config.service_available_group,
|
||||
tempest_config.service_option)
|
||||
config.register_opt_group(conf,
|
||||
tempest_config.alarming_group,
|
||||
tempest_config.AlarmingGroup)
|
||||
|
||||
def get_opt_lists(self):
|
||||
return [
|
||||
(tempest_config.alarming_group.name,
|
||||
tempest_config.AlarmingGroup),
|
||||
('service_available', tempest_config.service_option)
|
||||
]
|
@ -1,126 +0,0 @@
|
||||
# Copyright 2014 OpenStack Foundation
|
||||
# All Rights Reserved.
|
||||
#
|
||||
# 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.
|
||||
|
||||
from six.moves.urllib import parse as urllib
|
||||
from tempest import config
|
||||
from tempest.lib.common import rest_client
|
||||
from tempest import manager
|
||||
import ujson
|
||||
|
||||
CONF = config.CONF
|
||||
|
||||
|
||||
class AlarmingClient(rest_client.RestClient):
|
||||
|
||||
version = '2'
|
||||
uri_prefix = "v2"
|
||||
|
||||
def deserialize(self, body):
|
||||
return ujson.loads(body.replace("\n", ""))
|
||||
|
||||
def serialize(self, body):
|
||||
return ujson.dumps(body)
|
||||
|
||||
def list_alarms(self, query=None):
|
||||
uri = '%s/alarms' % self.uri_prefix
|
||||
uri_dict = {}
|
||||
if query:
|
||||
uri_dict = {'q.field': query[0],
|
||||
'q.op': query[1],
|
||||
'q.value': query[2]}
|
||||
if uri_dict:
|
||||
uri += "?%s" % urllib.urlencode(uri_dict)
|
||||
resp, body = self.get(uri)
|
||||
self.expected_success(200, resp.status)
|
||||
body = self.deserialize(body)
|
||||
return rest_client.ResponseBodyList(resp, body)
|
||||
|
||||
def show_alarm(self, alarm_id):
|
||||
uri = '%s/alarms/%s' % (self.uri_prefix, alarm_id)
|
||||
resp, body = self.get(uri)
|
||||
self.expected_success(200, resp.status)
|
||||
body = self.deserialize(body)
|
||||
return rest_client.ResponseBody(resp, body)
|
||||
|
||||
def show_alarm_history(self, alarm_id):
|
||||
uri = "%s/alarms/%s/history" % (self.uri_prefix, alarm_id)
|
||||
resp, body = self.get(uri)
|
||||
self.expected_success(200, resp.status)
|
||||
body = self.deserialize(body)
|
||||
return rest_client.ResponseBodyList(resp, body)
|
||||
|
||||
def delete_alarm(self, alarm_id):
|
||||
uri = "%s/alarms/%s" % (self.uri_prefix, alarm_id)
|
||||
resp, body = self.delete(uri)
|
||||
self.expected_success(204, resp.status)
|
||||
if body:
|
||||
body = self.deserialize(body)
|
||||
return rest_client.ResponseBody(resp, body)
|
||||
|
||||
def create_alarm(self, **kwargs):
|
||||
uri = "%s/alarms" % self.uri_prefix
|
||||
body = self.serialize(kwargs)
|
||||
resp, body = self.post(uri, body)
|
||||
self.expected_success(201, resp.status)
|
||||
body = self.deserialize(body)
|
||||
return rest_client.ResponseBody(resp, body)
|
||||
|
||||
def update_alarm(self, alarm_id, **kwargs):
|
||||
uri = "%s/alarms/%s" % (self.uri_prefix, alarm_id)
|
||||
body = self.serialize(kwargs)
|
||||
resp, body = self.put(uri, body)
|
||||
self.expected_success(200, resp.status)
|
||||
body = self.deserialize(body)
|
||||
return rest_client.ResponseBody(resp, body)
|
||||
|
||||
def show_alarm_state(self, alarm_id):
|
||||
uri = "%s/alarms/%s/state" % (self.uri_prefix, alarm_id)
|
||||
resp, body = self.get(uri)
|
||||
self.expected_success(200, resp.status)
|
||||
body = self.deserialize(body)
|
||||
return rest_client.ResponseBodyData(resp, body)
|
||||
|
||||
def alarm_set_state(self, alarm_id, state):
|
||||
uri = "%s/alarms/%s/state" % (self.uri_prefix, alarm_id)
|
||||
body = self.serialize(state)
|
||||
resp, body = self.put(uri, body)
|
||||
self.expected_success(200, resp.status)
|
||||
body = self.deserialize(body)
|
||||
return rest_client.ResponseBodyData(resp, body)
|
||||
|
||||
|
||||
class Manager(manager.Manager):
|
||||
|
||||
default_params = {
|
||||
'disable_ssl_certificate_validation':
|
||||
CONF.identity.disable_ssl_certificate_validation,
|
||||
'ca_certs': CONF.identity.ca_certificates_file,
|
||||
'trace_requests': CONF.debug.trace_requests
|
||||
}
|
||||
|
||||
alarming_params = {
|
||||
'service': CONF.alarming_plugin.catalog_type,
|
||||
'region': CONF.identity.region,
|
||||
'endpoint_type': CONF.alarming_plugin.endpoint_type,
|
||||
}
|
||||
alarming_params.update(default_params)
|
||||
|
||||
def __init__(self, credentials=None, service=None):
|
||||
super(Manager, self).__init__(credentials)
|
||||
self.set_alarming_client()
|
||||
|
||||
def set_alarming_client(self):
|
||||
self.alarming_client = AlarmingClient(self.auth_provider,
|
||||
**self.alarming_params)
|
@ -42,7 +42,7 @@
|
||||
set -x
|
||||
export PYTHONUNBUFFERED=true
|
||||
export DEVSTACK_GATE_TEMPEST=1
|
||||
export DEVSTACK_GATE_TEMPEST_REGEX="^aodh\."
|
||||
export DEVSTACK_GATE_TEMPEST_REGEX="ceilometer.tests.tempest.aodh"
|
||||
export DEVSTACK_GATE_TEMPEST_ALL_PLUGINS=1
|
||||
export PROJECTS="openstack/aodh $PROJECTS"
|
||||
export AODH_BACKEND=mysql
|
||||
|
@ -43,7 +43,7 @@
|
||||
set -x
|
||||
export PYTHONUNBUFFERED=true
|
||||
export DEVSTACK_GATE_TEMPEST=1
|
||||
export DEVSTACK_GATE_TEMPEST_REGEX="^aodh\."
|
||||
export DEVSTACK_GATE_TEMPEST_REGEX="ceilometer.tests.tempest.aodh"
|
||||
export DEVSTACK_GATE_TEMPEST_ALL_PLUGINS=1
|
||||
export PROJECTS="openstack/aodh $PROJECTS"
|
||||
export AODH_BACKEND=postgresql
|
||||
|
@ -52,7 +52,6 @@ test =
|
||||
fixtures>=1.3.1
|
||||
mock>=1.0
|
||||
sqlalchemy-utils
|
||||
tempest>=11.0.0 # Apache-2.0
|
||||
testrepository>=0.0.18
|
||||
testresources>=0.2.4 # Apache-2.0/BSD
|
||||
gabbi>=1.30.0 # Apache-2.0
|
||||
@ -114,9 +113,6 @@ oslo.config.opts.defaults =
|
||||
oslo.policy.policies =
|
||||
aodh = aodh.api.policies:list_rules
|
||||
|
||||
tempest.test_plugins =
|
||||
aodh_tests = aodh.tests.tempest.plugin:AodhTempestPlugin
|
||||
|
||||
[build_sphinx]
|
||||
all_files = 1
|
||||
build-dir = doc/build
|
||||
|
Loading…
x
Reference in New Issue
Block a user