octp_server.py 文件源码

def _start_heartbeat(self):
        """
        Start heartbeat coroutine for watch status of etcd.
        :return:
        :rtype: gevent.Greenlet
        """

        co = gevent.spawn(self._heartbeat_handler)
        log.info('watcher_handler(%s) started.', co)

        return co

    #### coroutine handler ####