INNER CODE UNIT · Python

__init__

kubernetes/k8s.io · dns/check-zone.py:48

    def __init__(self, num_workers, *args, **kwargs):
        super(AsyncResolver, self).__init__(*args, **kwargs)
        self.executor = ThreadPoolExecutor(max_workers=num_workers)

    def query(self, *args, **kwargs):
        return self.executor.submit(super(AsyncResolver, self).query, *args,
                                    **kwargs)

def configure_resolvers(dns_servers):
    """
    For each dns_server, configure an an async resolver
    Return a list of a AsyncResolvers
    """
    resolvers = []
    for server in dns_servers:
        # We need to resolve this if it's not an IP
        if not is_ip(server):
            server = unicode(query(server, 'A')[0])

View source record →