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.Service
Listener 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