octp_server.py 文件源码

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

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

        return co