collector.py 文件源码

def __init__(self, contestant_ip_format, worker_ip_format, reboot_delay, ethers_manager):
        self.contestant_ip_format = contestant_ip_format
        self.worker_ip_format = worker_ip_format
        self.reboot_delay = reboot_delay
        self.ethers_manager = ethers_manager
        self.reboot_string = 0

        gevent.spawn(self.reboot_loop)

        self.router = Map([
            Rule('/contestant', methods=['GET'], endpoint='contestant'),
            Rule('/worker', methods=['GET'], endpoint='worker'),
            Rule('/reboot_timestamp', methods=['GET'], endpoint='reboot_timestamp')
        ])