openstack
/
ceilometer
Code Issues Proposed changes

Merge "pipeline: simplfy classes"

This commit is contained in:
Zuul 2018-09-13 09:13:26 +00:00 committed by Gerrit Code Review
parent c1de345bcd 152fbec8f1
commit 3d77ddd8e0
4 changed files with 10 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
ceilometer/pipeline/base.py
View File

@ -335,14 +335,10 @@ class NotificationEndpoint(object):
# for the generic notification exchange we have to consume all its
# queues
class MainNotificationEndpoint(NotificationEndpoint):
"""Listens to queues on all priority levels and clears by default."""
audit = NotificationEndpoint._consume_and_drop
critical = NotificationEndpoint._consume_and_drop
debug = NotificationEndpoint._consume_and_drop
error = NotificationEndpoint._consume_and_drop
info = NotificationEndpoint._consume_and_drop
sample = NotificationEndpoint._consume_and_drop
warn = NotificationEndpoint._consume_and_drop
audit = _consume_and_drop
critical = _consume_and_drop
debug = _consume_and_drop
error = _consume_and_drop
info = _consume_and_drop
sample = _consume_and_drop
warn = _consume_and_drop

2
ceilometer/pipeline/event.py
View File

@ -22,7 +22,7 @@ from ceilometer.pipeline import base
LOG = log.getLogger(__name__)
class EventEndpoint(base.MainNotificationEndpoint):
class EventEndpoint(base.NotificationEndpoint):
event_types = []

2
ceilometer/pipeline/sample.py
View File

@ -19,7 +19,7 @@ from ceilometer.pipeline import base
LOG = log.getLogger(__name__)
class SampleEndpoint(base.MainNotificationEndpoint):
class SampleEndpoint(base.NotificationEndpoint):
def info(self, notifications):
"""Convert message at info level to Ceilometer sample.

2
doc/source/contributor/plugins.rst
View File

@ -92,7 +92,7 @@ pipelines based on a given configuration file. Pipelines are required to define
`Source` and `Sink` permutations to describe how to process notification.
Additionally, it must set ``get_main_endpoints`` which provides endpoints to be
added to the main queue listener in the notification agent. This main queue
endpoint inherits :class:`ceilometer.pipeline.base.MainNotificationEndpoint`
endpoint inherits :class:`ceilometer.pipeline.base.NotificationEndpoint`
and defines which notification priorities to listen, normalises the data,
and redirects the data for pipeline processing.