dse.io.eventletreactor - eventlet-compatible Connection

class EventletConnection

An implementation of Connection that utilizes eventlet.

This implementation assumes all eventlet monkey patching is active. It is not tested with partial patching.

Class Methods

classmethod

initialize_reactor

()

Called once by Cluster.connect(). This should be used by implementations to set up any resources that will be shared across connections.

classmethod

service_timeouts

()

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.