The ceilometer.pipeline
Module¶
-
class
ceilometer.pipeline.
EventPipeline
(source, sink)[source]¶ Bases:
ceilometer.pipeline.Pipeline
Represents a pipeline for Events.
-
class
ceilometer.pipeline.
EventPipelineTransportManager
[source]¶ Bases:
ceilometer.pipeline._PipelineTransportManager
-
class
ceilometer.pipeline.
EventSink
(cfg, transformer_manager)[source]¶ Bases:
ceilometer.pipeline.Sink
-
class
ceilometer.pipeline.
EventSource
(cfg)[source]¶ Bases:
ceilometer.pipeline.Source
Represents a source of events.
In effect it is a set of notification handlers capturing events for a set of matching notifications.
-
class
ceilometer.pipeline.
Pipeline
(source, sink)[source]¶ Bases:
object
Represents a coupling between a sink and a corresponding source.
-
exception
ceilometer.pipeline.
PipelineException
(message, pipeline_cfg)[source]¶ Bases:
exceptions.Exception
-
class
ceilometer.pipeline.
PipelineManager
(cfg, transformer_manager, p_type={'source': <class 'ceilometer.pipeline.SampleSource'>, 'pipeline': <class 'ceilometer.pipeline.SamplePipeline'>, 'sink': <class 'ceilometer.pipeline.SampleSink'>})[source]¶ Bases:
object
Pipeline Manager
Pipeline manager sets up pipelines according to config file
Usually only one pipeline manager exists in the system.
-
class
ceilometer.pipeline.
PollingManager
(cfg)[source]¶ Bases:
object
Polling Manager
Polling manager sets up polling according to config file.
-
class
ceilometer.pipeline.
SamplePipeline
(source, sink)[source]¶ Bases:
ceilometer.pipeline.Pipeline
Represents a pipeline for Samples.
-
class
ceilometer.pipeline.
SamplePipelineTransportManager
[source]¶ Bases:
ceilometer.pipeline._PipelineTransportManager
-
class
ceilometer.pipeline.
SampleSink
(cfg, transformer_manager)[source]¶ Bases:
ceilometer.pipeline.Sink
-
class
ceilometer.pipeline.
SampleSource
(cfg)[source]¶ Bases:
ceilometer.pipeline.Source
Represents a source of samples.
In effect it is a set of pollsters and/or notification handlers emitting samples for a set of matching meters. Each source encapsulates meter name matching, polling interval determination, optional resource enumeration or discovery, and mapping to one or more sinks for publication.
-
class
ceilometer.pipeline.
Sink
(cfg, transformer_manager)[source]¶ Bases:
object
Represents a sink for the transformation and publication of data.
Each sink config is concerned only with the transformation rules and publication conduits for data.
In effect, a sink describes a chain of handlers. The chain starts with zero or more transformers and ends with one or more publishers.
The first transformer in the chain is passed data from the corresponding source, takes some action such as deriving rate of change, performing unit conversion, or aggregating, before passing the modified data to next step.
The subsequent transformers, if any, handle the data similarly.
At the end of the chain, publishers publish the data. The exact publishing method depends on publisher type, for example, pushing into data storage via the message bus providing guaranteed delivery, or for loss-tolerant data UDP may be used.
If no transformers are included in the chain, the publishers are passed data directly from the sink which are published unchanged.
-
class
ceilometer.pipeline.
Source
(cfg)[source]¶ Bases:
object
Represents a source of samples or events.