Set a Frame option. See the 0MQ API documentation for zmq_msg_set for details on specific options. .. versionadded:: libzmq-

Set a context option. See the 0MQ API documentation for zmq_ctx_set for details on specific options. .. versionadde

Set the Formatter for this handler. If no level is provided, the same format is used for all levels. This will overwrite all selectiv

Set the root topic for this handler. This value is prepended to all messages published by this handler, and it defaults to the empty

Enqueue setsockopt(opt, value) for mon_socket See zmq.Socket.setsockopt for details.

Enqueue setsockopt(opt, value) for out_socket See zmq.Socket.setsockopt for details.

Shadow an existing pyczmq context ctx is the FFI `zctx_t *` pointer .. versionadded:: 14.1

Start ZAP authentication

store an object and (optionally) event for zero-copy

Terminate a context with a timeout

Unbind from an address (undoes a call to bind). .. versionadded:: libzmq-3.2 .. versionadded:: 13.0 Parameters

Return the integer errno of the most recent zmq error.

Return the version of ZeroMQ itself as a 3-tuple of ints.

Context class fixture Override in modules to specify a different class (e.g. zmq.green)

Add a weakref to a socket for Context.destroy / reference counting

CURVE ZAP authentication

Nothing to do for GSSAPI, which has already been handled by an external service.

PLAIN ZAP authentication

Context manager to unbind on exit .. versionadded:: 20.0

one-time extract buffer from zmq_msg for Frames created by recv

thorough check of whether the socket has been closed, even if by another entity (e.g. ctx.destroy). Only used by the `closed` property.

thorough check of whether the socket has been closed, even if by another entity (e.g. ctx.destroy). Only used by the `closed` propert

Cleanup sockets we created

Context manager to disconnect on exit .. versionadded:: 20.0

Return content of obj as bytes

Stop poller from watching an io_state.

override if getattr should do something other than call self.get

Find the ``zmq.Context`` from ``args`` and ``kwargs`` at call time. First, if there is an keyword argument named ``context`` and it

Returns three elements tuple with socket descriptors ready for gevent.select.select

Dispatch IO events to _handle_recv, etc.

This method is the actual handler for IOLoop, that gets called whenever an event on my socket is posted. It dispatches to _handle_recv, etc.

initialize the ioloop event handler

context manager for libs directory on $PATH Works around mysterious issue where os.add_dll_directory does not resolve imports (conda-forge Py

inner C function for monitored_queue

Like parse_monitor_msg, but awaitable Given awaitable message, return awaitable for the parsed monitor message.

Receive a message and return a copy

Receive a message in a non-copying manner and return a Frame.

translate zmq.POLLIN/OUT/ERR event masks into IOLoop.READ/WRITE/ERROR

Remove a socket for Context.destroy / reference counting

Send a Frame on this socket in a non-copy manner.

Send a Frame on this socket in a non-copy manner.

override if setattr should do something other than call self.set

simple wrapper for stopping an Event, allowing for method rename in gevent 1.0

Try passwordless login with paramiko.

Unschedule callback for a raw socket

Schedule callback for a raw socket

Inserts a document (dictionary) into mongo database table

Enqueue ZMQ address for binding on ctrl_socket. See zmq.Socket.bind for details.

Enqueue ZMQ address for binding on mon_socket. See zmq.Socket.bind for details.

Enqueue ZMQ address for binding on out_socket. See zmq.Socket.bind for details.

Configure CURVE authentication for a given domain. CURVE authentication using a callback function validating the client public key ac

Enqueue ZMQ address for connecting on mon_socket. See zmq.Socket.connect for details.

Return the User-Id corresponding to a CURVE client's public key Default implementation uses the z85-encoding of the public key. Over

Default to just /usr/local/include:/usr/include

Download license files for bundled dependencies

Generate client and server CURVE certificate files

Generate CFFI backend extension C code Called during build

Attempts to return a single document from database table that matches each key/value in keys dictionary.