Nsqlookupd client

class gnsq.LookupdClient(host='localhost', port=4161, **kwargs)

Low level http client for nsqlookupd.

Parameters:

• host – nsqlookupd host address (default: localhost)
• port – nsqlookupd http port (default: 4161)
• useragent – useragent sent to nsqlookupd (default: <client_library_name>/<version>)
• connection_class – override the http connection class

channels(topic)

Returns all known channels of a topic.

create_channel(topic, channel)

Add a channel to nsqlookupd’s registry.

create_topic(topic)

Add a topic to nsqlookupd’s registry.

delete_channel(topic, channel)

Deletes an existing channel of an existing topic.

delete_topic(topic)

Deletes an existing topic.

classmethod from_url(url, **kwargs)

Create a client from a url.

info()

Returns version information.

lookup(topic)

Returns producers for a topic.

nodes()

Returns all known nsqd.

ping()

Monitoring endpoint.

Returns:should return “OK”, otherwise raises an exception.

tombstone_topic(topic, node)

Tombstones a specific producer of an existing topic.

topics()

Returns all known topics.

class gnsq.Lookupd(address='http://localhost:4161/', **kwargs)

Use LookupdClient instead.

Deprecated since version 1.0.0.

base_url

Use LookupdClient.address instead.

Deprecated since version 1.0.0.

tombstone_topic_producer(topic, node)

Use LookupdClient.tombstone_topic() instead.

Deprecated since version 1.0.0.