The ceilometer.service_base Module

class ceilometer.service_base.BaseService(threads=1000)[source]

Bases: oslo_service.service.Service

clear_pipeline_validation_status()[source]

Clears pipeline validation status flags.

get_pipeline_hash(p_type={'source': <class 'ceilometer.pipeline.SampleSource'>, 'pipeline': <class 'ceilometer.pipeline.SamplePipeline'>, 'sink': <class 'ceilometer.pipeline.SampleSink'>})[source]
get_pipeline_mtime(p_type={'source': <class 'ceilometer.pipeline.SampleSource'>, 'pipeline': <class 'ceilometer.pipeline.SamplePipeline'>, 'sink': <class 'ceilometer.pipeline.SampleSink'>})[source]
init_pipeline_refresh()[source]

Initializes pipeline refresh state.

pipeline_changed(p_type={'source': <class 'ceilometer.pipeline.SampleSource'>, 'pipeline': <class 'ceilometer.pipeline.SamplePipeline'>, 'sink': <class 'ceilometer.pipeline.SampleSink'>})[source]

Returns hash of changed pipeline else False.

refresh_pipeline()[source]

Refreshes appropriate pipeline, then delegates to agent.

reload_pipeline()[source]

Reload pipeline in the agents.

set_pipeline_hash(_hash, p_type={'source': <class 'ceilometer.pipeline.SampleSource'>, 'pipeline': <class 'ceilometer.pipeline.SamplePipeline'>, 'sink': <class 'ceilometer.pipeline.SampleSink'>})[source]
set_pipeline_mtime(mtime, p_type={'source': <class 'ceilometer.pipeline.SampleSource'>, 'pipeline': <class 'ceilometer.pipeline.SamplePipeline'>, 'sink': <class 'ceilometer.pipeline.SampleSink'>})[source]