An implementation of
Connection that utilizes
This implementation assumes all eventlet monkey patching is active. It is not tested with partial patching.
Called once by Cluster.connect(). This should be used by implementations to set up any resources that will be shared across connections.
cls._timeout_watcher runs in this loop forever. It is usually waiting for the next timeout on the cls._new_timer Event. When new timers are added, that event is set so that the watcher can wake up and possibly set an earlier timeout.