diff options
Diffstat (limited to 'ceilometer/profiler/notifications.py')
-rw-r--r-- | ceilometer/profiler/notifications.py | 56 |
1 files changed, 56 insertions, 0 deletions
diff --git a/ceilometer/profiler/notifications.py b/ceilometer/profiler/notifications.py new file mode 100644 index 00000000..f1735b72 --- /dev/null +++ b/ceilometer/profiler/notifications.py @@ -0,0 +1,56 @@ +# Copyright 2014: Mirantis Inc. +# 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. + +import oslo.messaging + +from ceilometer import plugin +from ceilometer import sample + + +class ProfilerNotifications(plugin.NotificationBase): + + event_types = ["profiler.*"] + + def get_targets(self, conf): + """Return a sequence of oslo.messaging.Target defining the exchange and + topics to be connected for this plugin. + + :param conf: Configuration. + """ + targets = [] + exchanges = [ + conf.nova_control_exchange, + conf.cinder_control_exchange, + conf.glance_control_exchange, + conf.neutron_control_exchange, + conf.heat_control_exchange + ] + + for exchange in exchanges: + targets.extend(oslo.messaging.Target(topic=topic, + exchange=exchange) + for topic in conf.notification_topics) + return targets + + def process_notification(self, message): + yield sample.Sample.from_notification( + name=message["payload"]["name"], + type=sample.TYPE_GAUGE, + volume=1, + unit="trace", + user_id=message["payload"].get("user_id"), + project_id=message["payload"].get("project_id"), + resource_id="profiler-%s" % message["payload"]["base_id"], + message=message) |