The ceilometer.collector ModuleΒΆ
-
class
ceilometer.collector.CollectorEndpoint(dispatcher_manager, requeue_on_error)[source] Bases:
object-
sample(ctxt, publisher_id, event_type, payload, metadata)[source] RPC endpoint for notification messages
When another service sends a notification over the message bus, this method receives it.
-
-
class
ceilometer.collector.CollectorService(threads=1000)[source] Bases:
ceilometer.openstack.common.service.ServiceListener for the collector service.
-
record_metering_data(context, data)[source] RPC endpoint for messages we send to ourselves.
When the notification messages are re-published through the RPC publisher, this method receives them for processing.
-
start()[source] Bind the UDP socket and handle incoming data.
-
start_udp()[source]
-
stop()[source]
-
-
class
ceilometer.collector.EventEndpoint(dispatcher_manager)[source] Bases:
ceilometer.collector.CollectorEndpoint-
sample(ctxt, publisher_id, event_type, payload, metadata)[source]
-
-
class
ceilometer.collector.SampleEndpoint(dispatcher_manager)[source] Bases:
ceilometer.collector.CollectorEndpoint