The ceilometer.polling.manager Module¶

class ceilometer.polling.manager.AgentManager(worker_id, conf, namespaces=None)[source]¶

Bases: cotyledon._service.Service

construct_group_id(discovery_group_id)[source]¶

discover(discovery=None, discovery_cache=None)[source]¶

interval_task(task)[source]¶

join_partitioning_groups()[source]¶

keystone¶

run()[source]¶

Method representing the service activity

If not implemented the process will just wait to receive an ending signal.

This method is ran into the thread and can block or return as needed

Any exceptions raised by this method will be logged and the worker will exit with status 1.

setup_polling_tasks()[source]¶

start_polling_tasks()[source]¶

stop_pollsters_tasks()[source]¶

terminate()[source]¶

Gracefully shutdown the service

This method will be executed when the Service has to shutdown cleanly.

If not implemented the process will just end with status 0.

To customize the exit code, the SystemExit exception can be used.

Any exceptions raised by this method will be logged and the worker will exit with status 1.

exception ceilometer.polling.manager.PollingException(message, cfg)[source]¶

Bases: ceilometer.agent.ConfigException

class ceilometer.polling.manager.PollingManager(conf)[source]¶

Bases: ceilometer.agent.ConfigManagerBase

Polling Manager to handle polling definition

class ceilometer.polling.manager.PollingSource(cfg)[source]¶

Bases: ceilometer.agent.Source

Represents a source of pollsters

In effect it is a set of pollsters emitting samples for a set of matching meters. Each source encapsulates meter name matching, polling interval determination, optional resource enumeration or discovery.

get_interval()[source]¶

support_meter(meter_name)[source]¶

class ceilometer.polling.manager.PollingTask(agent_manager)[source]¶

Bases: object

Polling task for polling samples and notifying.

A polling task can be invoked periodically or only once.

add(pollster, source)[source]¶

poll_and_notify()[source]¶

Polling sample and notify.

class ceilometer.polling.manager.Resources(agent_manager)[source]¶

Bases: object

get(discovery_cache=None)[source]¶

static key(source_name, pollster)[source]¶

setup(source)[source]¶

ceilometer.polling.manager.hash_of_set(s)[source]¶

ceilometer.polling.manager.iter_random(iterable)[source]¶

Iter over iterable in a random fashion.