celery.worker.consumer.gossip¶

Worker <-> Worker communication Bootstep.

class celery.worker.consumer.gossip.Gossip(c, without_gossip=False, interval=5.0, heartbeat_interval=2.0, **kwargs)[исходный код]¶

Bootstep consuming events from other workers.

This keeps the logical clock value up to date.

call_task(task)[исходный код]¶

compatible_transport(app)[исходный код]¶

compatible_transports = {'amqp', 'redis'}¶

election(id, topic, action=None)[исходный код]¶

get_consumers(channel)[исходный код]¶

label = 'Gossip'¶

name = 'celery.worker.consumer.gossip.Gossip'¶

on_elect(event)[исходный код]¶

on_elect_ack(event)[исходный код]¶

on_message(prepare, message)[исходный код]¶

on_node_join(worker)[исходный код]¶

on_node_leave(worker)[исходный код]¶

on_node_lost(worker)[исходный код]¶

periodic()[исходный код]¶

register_timer()[исходный код]¶

requires = (step:celery.worker.consumer.mingle.Mingle{(step:celery.worker.consumer.events.Events{(step:celery.worker.consumer.connection.Connection{()},)},)},)¶

start(c)[исходный код]¶