Manage the forwarder process.

class pyzor.forwarder.Forwarder(forwarding_client, remote_servers, max_queue_size=10000)

Bases: object

Forwards digest to remote pyzor servers

queue_forward_request(digest, whitelist=False)

If forwarding is enabled, insert a digest into the forwarding queue if whitelist is True, the digest will be forwarded as whitelist request if the queue is full, the digest is dropped


start the forwarding thread


disable forwarding and tell the forwarding thread to end itself