ef63f8c2cb
This is to add missing ws separator between words. Change-Id: Iad9e39b33e7c7c613f833468fbb13cdd3ec2cb96
78 lines
3.2 KiB
Python
78 lines
3.2 KiB
Python
# 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 rally.common import logging
|
|
from rally.task import validation
|
|
|
|
from rally_openstack import consts
|
|
from rally_openstack import scenario
|
|
from rally_openstack.scenarios.ceilometer import utils
|
|
|
|
|
|
"""Scenarios for Ceilometer Stats API."""
|
|
|
|
|
|
@validation.add("required_services",
|
|
services=[consts.Service.CEILOMETER])
|
|
@validation.add("required_platform", platform="openstack", users=True)
|
|
@scenario.configure(name="CeilometerStats.create_meter_and_get_stats",
|
|
platform="openstack")
|
|
class CreateMeterAndGetStats(utils.CeilometerScenario):
|
|
|
|
@logging.log_deprecated("Use 'get_stats' method, now samples are created "
|
|
"in context", "0.1.2")
|
|
def run(self, **kwargs):
|
|
"""Create a meter and fetch its statistics.
|
|
|
|
Meter is first created and then statistics is fetched for the same
|
|
using GET /v2/meters/(meter_name)/statistics.
|
|
|
|
:param kwargs: contains optional arguments to create a meter
|
|
"""
|
|
meter = self._create_meter(**kwargs)
|
|
self._get_stats(meter.counter_name)
|
|
|
|
|
|
@validation.add("required_services",
|
|
services=[consts.Service.CEILOMETER])
|
|
@validation.add("required_contexts", contexts=("ceilometer"))
|
|
@validation.add("required_platform", platform="openstack", users=True)
|
|
@scenario.configure(name="CeilometerStats.get_stats", platform="openstack")
|
|
class GetStats(utils.CeilometerScenario):
|
|
|
|
def run(self, meter_name, filter_by_user_id=False,
|
|
filter_by_project_id=False, filter_by_resource_id=False,
|
|
metadata_query=None, period=None, groupby=None, aggregates=None):
|
|
"""Fetch statistics for certain meter.
|
|
|
|
Statistics is fetched for the using
|
|
GET /v2/meters/(meter_name)/statistics.
|
|
|
|
:param meter_name: meter to take statistic for
|
|
:param filter_by_user_id: flag for query by user_id
|
|
:param filter_by_project_id: flag for query by project_id
|
|
:param filter_by_resource_id: flag for query by resource_id
|
|
:param metadata_query: dict with metadata fields and values for query
|
|
:param period: the length of the time range covered by these stats
|
|
:param groupby: the fields used to group the samples
|
|
:param aggregates: name of function for samples aggregation
|
|
|
|
:returns: list of statistics data
|
|
"""
|
|
query = self._make_general_query(filter_by_project_id,
|
|
filter_by_user_id,
|
|
filter_by_resource_id,
|
|
metadata_query)
|
|
self._get_stats(meter_name, query, period, groupby, aggregates)
|