INNER CODE UNIT · Python
AsyncResolver
kubernetes/k8s.io · dns/check-zone.py:43
class AsyncResolver(Resolver):
"""
Create an DNS resolver using an async pool of workers
"""
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
"""