metrics_bridge_server.py 文件源码

def __init__(self, bind, metrics_server):
        self.server = grpc.server(concurrent.futures.ThreadPoolExecutor(max_workers=1))
        bridge_pb2.add_BridgeServicer_to_server(Servicer(metrics_server), self.server)
        self.server.add_insecure_port('%s:%d' % bind)