The ceilometer.collector Module

class ceilometer.collector.CollectorEndpoint(dispatcher_manager)

Bases: object

sample(messages)

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)

Bases: oslo_service.service.Service

Listener for the collector service.

record_metering_data(context, data)

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()

Bind the UDP socket and handle incoming data.

start_udp()

stop()

class ceilometer.collector.EventEndpoint(dispatcher_manager)

Bases: ceilometer.collector.CollectorEndpoint

class ceilometer.collector.SampleEndpoint(dispatcher_manager)

Bases: ceilometer.collector.CollectorEndpoint