Warning
This documentation is for an old version of IPython. You can find docs for newer versions here.
A multi-heart Heartbeat system using PUB and ROUTER sockets. pings are sent out on the PUB, and hearts are tracked based on their DEALER identities.
Authors:
Bases: object
A basic heart object for responding to a HeartMonitor. This is a simple wrapper with defaults for the most common Device model for responding to heartbeats.
It simply builds a threadsafe zmq.FORWARDER Device, defaulting to using SUB/DEALER for in/out.
You can specify the DEALER’s IDENTITY via the optional heart_id argument.
Bases: IPython.config.configurable.LoggingConfigurable
A basic HeartMonitor class pingstream: a PUB stream pongstream: an ROUTER stream period: the period of the heartbeat in milliseconds
add a new handler for heart failure
add a new handler for new hearts
a heart just beat