ezmsg.zmq.repreq#

Classes

class ZMQRep(*args, settings=None, **kwargs)[source]#

Bases: Unit

Parameters:

settings (Settings | None)

OUTPUT = OutputStream:unlocated[<class 'ezmsg.zmq.util.ZMQMessage'>](self.num_buffers=32, self.force_tcp=False)#
SETTINGS#

alias of ZMQRepSettings

STATE#

alias of ZMQRepState

initialize()[source]#

Runs when the Unit is instantiated. This is called from within the same process this unit will live. This lifecycle hook can be overridden. It can be run as async functions by simply adding the async keyword when overriding.

Return type:

None

shutdown()[source]#

Runs when the Unit terminates. This is called from within the same process this unit will live. This lifecycle hook can be overridden. It can be run as async functions by simply adding the async keyword when overriding.

Return type:

None

async zmq_rep()[source]#
Return type:

None

async send_reqs()[source]#
Return type:

AsyncGenerator

class ZMQRepSettings(addr: str)[source]#

Bases: Settings

Parameters:

addr (str)

addr: str#
__init__(addr)#
Parameters:

addr (str)

Return type:

None

class ZMQRepState[source]#

Bases: State

context: Context#
socket: Socket#
queue: Queue#
class ZMQReq(*args, settings=None, **kwargs)[source]#

Bases: Unit

Parameters:

settings (Settings | None)

INPUT = InputStream:unlocated[<class 'ezmsg.zmq.util.ZMQMessage'>]()#
OUTPUT = OutputStream:unlocated[<class 'ezmsg.zmq.util.ZMQMessage'>](self.num_buffers=32, self.force_tcp=False)#
SETTINGS#

alias of ZMQReqSettings

STATE#

alias of ZMQReqState

initialize()[source]#

Runs when the Unit is instantiated. This is called from within the same process this unit will live. This lifecycle hook can be overridden. It can be run as async functions by simply adding the async keyword when overriding.

Return type:

None

shutdown()[source]#

Runs when the Unit terminates. This is called from within the same process this unit will live. This lifecycle hook can be overridden. It can be run as async functions by simply adding the async keyword when overriding.

Return type:

None

async send_req(msg)[source]#
Parameters:

msg (ZMQMessage)

Return type:

None

class ZMQReqSettings(addr: str)[source]#

Bases: Settings

Parameters:

addr (str)

addr: str#
__init__(addr)#
Parameters:

addr (str)

Return type:

None

class ZMQReqState[source]#

Bases: State

context: Context#
socket: Socket#
monitor: Socket#
class ZMQRepSettings(addr: str)[source]#

Bases: Settings

Parameters:

addr (str)

addr: str#
__init__(addr)#
Parameters:

addr (str)

Return type:

None

class ZMQRepState[source]#

Bases: State

context: Context#
socket: Socket#
queue: Queue#
class ZMQRep(*args, settings=None, **kwargs)[source]#

Bases: Unit

Parameters:

settings (Settings | None)

OUTPUT = OutputStream:unlocated[<class 'ezmsg.zmq.util.ZMQMessage'>](self.num_buffers=32, self.force_tcp=False)#
SETTINGS#

alias of ZMQRepSettings

STATE#

alias of ZMQRepState

initialize()[source]#

Runs when the Unit is instantiated. This is called from within the same process this unit will live. This lifecycle hook can be overridden. It can be run as async functions by simply adding the async keyword when overriding.

Return type:

None

shutdown()[source]#

Runs when the Unit terminates. This is called from within the same process this unit will live. This lifecycle hook can be overridden. It can be run as async functions by simply adding the async keyword when overriding.

Return type:

None

async zmq_rep()[source]#
Return type:

None

async send_reqs()[source]#
Return type:

AsyncGenerator

class ZMQReqSettings(addr: str)[source]#

Bases: Settings

Parameters:

addr (str)

addr: str#
__init__(addr)#
Parameters:

addr (str)

Return type:

None

class ZMQReqState[source]#

Bases: State

context: Context#
socket: Socket#
monitor: Socket#
class ZMQReq(*args, settings=None, **kwargs)[source]#

Bases: Unit

Parameters:

settings (Settings | None)

INPUT = InputStream:unlocated[<class 'ezmsg.zmq.util.ZMQMessage'>]()#
OUTPUT = OutputStream:unlocated[<class 'ezmsg.zmq.util.ZMQMessage'>](self.num_buffers=32, self.force_tcp=False)#
SETTINGS#

alias of ZMQReqSettings

STATE#

alias of ZMQReqState

initialize()[source]#

Runs when the Unit is instantiated. This is called from within the same process this unit will live. This lifecycle hook can be overridden. It can be run as async functions by simply adding the async keyword when overriding.

Return type:

None

shutdown()[source]#

Runs when the Unit terminates. This is called from within the same process this unit will live. This lifecycle hook can be overridden. It can be run as async functions by simply adding the async keyword when overriding.

Return type:

None

async send_req(msg)[source]#
Parameters:

msg (ZMQMessage)

Return type:

None