The ceilometer.pipeline.event Module

The ceilometer.pipeline.event Module

class ceilometer.pipeline.event.EventEndpoint(conf, publisher)[source]

Bases: ceilometer.pipeline.base.MainNotificationEndpoint

error(notifications)[source]

Convert message at error level to Ceilometer Event.

Parameters:notifications – list of notifications
event_types = []
info(notifications)[source]

Convert message at info level to Ceilometer Event.

Parameters:notifications – list of notifications
process_notifications(priority, notifications)[source]
class ceilometer.pipeline.event.EventPipeline(conf, source, sink)[source]

Bases: ceilometer.pipeline.base.Pipeline

Represents a pipeline for Events.

default_grouping_key = ['event_type']
publish_data(events)[source]
serializer(event)[source]
supported(event)[source]
class ceilometer.pipeline.event.EventPipelineManager(conf, partition=False)[source]

Bases: ceilometer.pipeline.base.PipelineManager

get_interim_endpoints()[source]
get_main_endpoints()[source]
pm_pipeline

alias of EventPipeline

pm_sink

alias of EventSink

pm_source

alias of EventSource

pm_type = 'event'
class ceilometer.pipeline.event.EventSink(conf, cfg, transformer_manager, publisher_manager)[source]

Bases: ceilometer.pipeline.base.Sink

publish_events(events)[source]
class ceilometer.pipeline.event.EventSource(cfg)[source]

Bases: ceilometer.pipeline.base.PipelineSource

Represents a source of events.

In effect it is a set of notification handlers capturing events for a set of matching notifications.

support_event(event_name)[source]
class ceilometer.pipeline.event.InterimEventEndpoint(conf, publisher, pipe_name)[source]

Bases: ceilometer.pipeline.base.NotificationEndpoint

process_notifications(priority, notifications)[source]
sample(notifications)[source]
Creative Commons Attribution 3.0 License

Except where otherwise noted, this document is licensed under Creative Commons Attribution 3.0 License. See all OpenStack Legal Documents.