Functions
def	socket_set_hwm (socket, hwm=-1)

def	dump (msg_or_socket)

def	set_id (zsocket)

def	zpipe (ctx)

def	encode_message (parts)

def	decode_message (encoded)

def	serverish_recv (sock, args, kwds)

def	serverish_send (sock, cid, msg, args, kwds)

def	clientish_recv (sock, args, kwds)

def	clientish_send (sock, msg, args, kwds)

Function Documentation

◆ clientish_recv()

def zio.domo.zhelpers.clientish_recv	(	sock,
		args,
		kwds
	)

Receive a message via a clientish socket

Definition at line 175 of file zhelpers.py.

◆ clientish_send()

def zio.domo.zhelpers.clientish_send	(	sock,
		msg,
		args,
		kwds
	)

Send a message via a clientish socket

Definition at line 191 of file zhelpers.py.

◆ decode_message()

def zio.domo.zhelpers.decode_message ( encoded )

Decode parts in a CZMQ-compatible way.

This provides the inverse function of encode_message() with the
exception that each part in the returned list is of type bytes,
an not zmq.Frame.

Definition at line 101 of file zhelpers.py.

◆ dump()

def zio.domo.zhelpers.dump ( msg_or_socket )

Receives all message parts from socket, printing each frame neatly

Definition at line 23 of file zhelpers.py.

◆ encode_message()

def zio.domo.zhelpers.encode_message ( parts )

Encode parts in a CZMQ-compatible (zmsg_decode()/zmsg_encode())
way.

A part may be either a PyZMQ zmq.Frame or bytes.

Parts are serialized to bytes and prefixing with a size.  Parts
smaller than 255 bytes are prefixed with a 1-byte size value.
Larger parts are prefixed by a fixed 1-byte value of 0xFF and a
4-byte size value.

Definition at line 75 of file zhelpers.py.

◆ serverish_recv()

def zio.domo.zhelpers.serverish_recv	(	sock,
		args,
		kwds
	)

Return a message from a serverish socket.

The socket may be of type ROUTER or SERVER.  Return list of
[id,msg]

Definition at line 134 of file zhelpers.py.

◆ serverish_send()

def zio.domo.zhelpers.serverish_send	(	sock,
		cid,
		msg,
		args,
		kwds
	)

Send a message via a serverish socket.

Definition at line 156 of file zhelpers.py.

◆ set_id()

def zio.domo.zhelpers.set_id ( zsocket )

Set simple random printable identity on socket

Definition at line 44 of file zhelpers.py.

◆ socket_set_hwm()

def zio.domo.zhelpers.socket_set_hwm	(	socket,
		hwm = `-1`
	)

libzmq 2/3/4 compatible sethwm

Definition at line 15 of file zhelpers.py.

◆ zpipe()

def zio.domo.zhelpers.zpipe ( ctx )

build inproc pipe for talking to threads

mimic pipe used in czmq zthread_fork.

Returns a pair of PAIRs connected via inproc

Definition at line 50 of file zhelpers.py.

Functions