INNER CODE UNIT · Python

query

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

    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])
        log.info('server=%s', server)
        resolver = AsyncResolver(configure=False,
                                 num_workers=4)
        resolver.nameservers = [server]

View source record →