The ceilometer.pipeline.sample Module¶

class ceilometer.pipeline.sample.InterimSampleEndpoint(conf, publisher, pipe_name)[source]¶

Bases: ceilometer.pipeline.base.NotificationEndpoint

process_notifications(priority, notifications)[source]¶

sample(notifications)[source]¶

class ceilometer.pipeline.sample.SampleEndpoint(conf, publisher)[source]¶

Bases: ceilometer.pipeline.base.MainNotificationEndpoint

build_sample(notification)[source]¶

Build sample from provided notification.

info(notifications)[source]¶

Convert message at info level to Ceilometer sample.

Parameters:	notifications – list of notifications

process_notifications(priority, notifications)[source]¶

sample(notifications)[source]¶

Convert message at sample level to Ceilometer Event.

Parameters:	notifications – list of notifications

class ceilometer.pipeline.sample.SamplePipeline(conf, source, sink)[source]¶

Bases: ceilometer.pipeline.base.Pipeline

Represents a pipeline for Samples.

default_grouping_key = ['resource_id']¶

publish_data(samples)[source]¶

serializer(sample)[source]¶

supported(sample)[source]¶

class ceilometer.pipeline.sample.SamplePipelineManager(conf, partition=False)[source]¶

Bases: ceilometer.pipeline.base.PipelineManager

get_interim_endpoints()[source]¶

get_main_endpoints()[source]¶

static get_transform_manager()[source]¶

pm_pipeline¶

alias of SamplePipeline

pm_sink¶

alias of SampleSink

pm_source¶

alias of SampleSource

pm_type = 'sample'¶

class ceilometer.pipeline.sample.SampleSink(conf, cfg, transformer_manager, publisher_manager)[source]¶

Bases: ceilometer.pipeline.base.Sink

flush()[source]¶

Flush data after all samples have been injected to pipeline.

publish_samples(samples)[source]¶

class ceilometer.pipeline.sample.SampleSource(cfg)[source]¶

Bases: ceilometer.pipeline.base.PipelineSource

Represents a source of samples.

In effect it is a set of notification handlers processing samples for a set of matching meters. Each source encapsulates meter name matching and mapping to one or more sinks for publication.

support_meter(meter_name)[source]¶