Python ZMQ Brew

Source

Install

From wheel

pip install pubkeeper.brew.zmq

From source

git clone git@github.com:pubkeeper/python-brew-zmq
pip install -e python-brew-zmq

Settings

linger (default: 1000)

The linger period determines how long pending messages, which have yet to be sent to a peer, shall linger in memory after a socket is closed.

hwm_size (default: 100000)

The high water mark is a hard limit on the maximum number of outstanding messages ØMQ shall queue in memory for any single peer that the specified socket is communicating with.

max_sockets (default: 1023)

Sets the maximum number of sockets allowed on the context.

max_io_thread_count (default: 1)

Specifies the size of the ØMQ thread pool to handle I/O operations.

ip_address (default: 127.0.0.1)

Address used when creating publishing queues.

socket_max_retry (default: 3)

Maximum number of retries when binding a new socket.

port_manager_min_port (default: 9010)

Minimum port value that a new publisher can be assigned to.

port_manager_max_port (default: 9199)

Maximum port value that a new publisher can be assigned to.

allowed_ip_addresses (default: None)

The IP addresses that are allowed to connect to the publishing end.

publisher_public_keys_dir (default: None)

Used for ZMQ's strongest security model. This is a setting that must be set on the publisher instance. Every subscriber's client public key should go in this directory. The public keys for each client should be paired with the client's secret that is set on that host's 'subscriber_client_secret_cert'.

publisher_server_public_cert (default: None)

publisher_server_secret_cert (default: None)

Publisher's server-like certificates. The instance containing publishers must set its server secret key. All subscriber nodes only need to set the server's public key.

publisher_client_secret_cert (Default: None)

Subscriber's client-like certificates. This client's secret key. This will be paired with the public key that should be copied to the publisher instance's public keys folder.

results matching ""

    No results matching ""