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]¶

Return a sequence of Counter instances for the given message.

Parameters:	message – Message to process.

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]¶

Publish data from pipeline.

serializer(event)[source]¶

Serialize data for interim transport. Pass if no partitioning.

supported(event)[source]¶

Attribute to filter on. Pass if no partitioning.

class ceilometer.pipeline.event.EventPipelineManager(conf, partition=False)[source]¶

Bases: ceilometer.pipeline.base.PipelineManager

get_interim_endpoints()[source]¶

Return endpoints for interim pipeline queues.

get_main_endpoints()[source]¶

Return endpoints for main queue.

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]¶

Return a sequence of Counter instances for the given message.

Parameters:	message – Message to process.

sample(notifications)[source]¶