The ceilometer.pipeline.sample Module

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