nsq/reader.py
def query_lookupd(self):
        """
        Trigger a query of the configured ``nsq_lookupd_http_addresses``.
        """
        endpoint = self.lookupd_http_addresses[self.lookupd_query_index]
        self.lookupd_query_index = (self.lookupd_query_index + 1) % len(self.lookupd_http_addresses)

        # urlsplit() is faulty if scheme not present
        if '://' not in endpoint:
            endpoint = 'http://' + endpoint

        scheme, netloc, path, query, fragment = urlparse.urlsplit(endpoint)

        if not path or path == "/":
            path = "/lookup"

        params = parse_qs(query)
        params['topic'] = self.topic
        query = urlencode(_utf8_params(params), doseq=1)
        lookupd_url = urlparse.urlunsplit((scheme, netloc, path, query, fragment))

        req = tornado.httpclient.HTTPRequest(
            lookupd_url, method='GET',
            headers={'Accept': 'application/vnd.nsq; version=1.0'},
            connect_timeout=self.lookupd_connect_timeout,
            request_timeout=self.lookupd_request_timeout)
        callback = functools.partial(self._finish_query_lookupd, lookupd_url=lookupd_url)
        self.http_client.fetch(req, callback=callback)
def query_lookupd(self):
        endpoint = self.lookupd_http_addresses[self.lookupd_query_index]
        self.lookupd_query_index = (self.lookupd_query_index + 1) % len(self.lookupd_http_addresses)

        # urlsplit() is faulty if scheme not present
        if '://' not in endpoint:
            endpoint = 'http://' + endpoint

        scheme, netloc, path, query, fragment = urlparse.urlsplit(endpoint)

        if not path or path == "/":
            path = "/lookup"

        params = parse_qs(query)
        params['topic'] = self.topic
        query = urlencode(_utf8_params(params), doseq=1)
        lookupd_url = urlparse.urlunsplit((scheme, netloc, path, query, fragment))

        req = tornado.httpclient.HTTPRequest(
            lookupd_url, method='GET',
            headers={'Accept': 'application/vnd.nsq; version=1.0'},
            connect_timeout=self.lookupd_connect_timeout,
            request_timeout=self.lookupd_request_timeout)
        callback = functools.partial(self._finish_query_lookupd, lookupd_url=lookupd_url)
        self.http_client.fetch(req, callback=callback)
def query_lookupd ( self ) : endpoint = self . lookupd_http_addresses [ self . lookupd_query_index ] self . lookupd_query_index = ( self . lookupd_query_index + 1 ) % len ( self . lookupd_http_addresses ) # urlsplit() is faulty if scheme not present if '://' not in endpoint : endpoint = 'http://' + endpoint scheme , netloc , path , query , fragment = urlparse . urlsplit ( endpoint ) if not path or path == "/" : path = "/lookup" params = parse_qs ( query ) params [ 'topic' ] = self . topic query = urlencode ( _utf8_params ( params ) , doseq = 1 ) lookupd_url = urlparse . urlunsplit ( ( scheme , netloc , path , query , fragment ) ) req = tornado . httpclient . HTTPRequest ( lookupd_url , method = 'GET' , headers = { 'Accept' : 'application/vnd.nsq; version=1.0' } , connect_timeout = self . lookupd_connect_timeout , request_timeout = self . lookupd_request_timeout ) callback = functools . partial ( self . _finish_query_lookupd , lookupd_url = lookupd_url ) self . http_client . fetch ( req , callback = callback )
Trigger a query of the configured ``nsq_lookupd_http_addresses``.
Trigger a query of the configured nsq_lookupd_http_addresses .