publisher.py 文件源码

def __init__(self,
                 logger,
                 path,
                 tchannel,
                 deployment_str,
                 headers,
                 timeout_seconds,
                 reconfigure_interval_seconds):
        self.logger = logger
        self.path = path
        self.tchannel = tchannel
        self.deployment_str = deployment_str
        self.headers = headers
        self.timeout_seconds = timeout_seconds
        self.task_queue = queue.Queue()
        self.workers = {}
        self.reconfigure_signal = threading.Event()
        self.reconfigure_interval_seconds = reconfigure_interval_seconds
        self.reconfigure_thread = None