worker.consumer.gossip

Worker <-> Worker communication Bootstep.

Module Contents

Classes

Gossip(self,c,without_gossip=False,interval=5.0,heartbeat_interval=2.0,**kwargs) Bootstep consuming events from other workers.
class 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.

__init__(c, without_gossip=False, interval=5.0, heartbeat_interval=2.0, **kwargs)
compatible_transport(app)
election(id, topic, action=None)
call_task(task)
on_elect(event)
start(c)
on_elect_ack(event)
on_node_join(worker)
on_node_leave(worker)
on_node_lost(worker)
_call_handlers(handlers, *args, **kwargs)
register_timer()
periodic()
get_consumers(channel)
on_message(prepare, message)