Nsqlookupd client

class gnsq.Lookupd(address='http://localhost:4161/')[source]

Low level client for nsqlookupd.

Parameters:address – nsqlookupd http address (default: http://localhost:4161/)
channels(topic)[source]

Returns all known channels of a topic.

delete_channel(topic, channel)[source]

Deletes an existing channel of an existing topic.

delete_topic(topic)[source]

Deletes an existing topic.

info()[source]

Returns version information.

lookup(topic)[source]

Returns producers for a topic.

nodes()[source]

Returns all known nsqd.

ping()[source]

Monitoring endpoint.

Returns:should return “OK”, otherwise raises an exception.
tombstone_topic_producer(topic, node)[source]

Tombstones a specific producer of an existing topic.

topics()[source]

Returns all known topics.