jina.peapods.runtimes.zmq.base

class jina.peapods.runtimes.zmq.base.ZMQRuntime(args)[source]

Bases: jina.peapods.runtimes.base.BaseRuntime, abc.ABC

Runtime procedure leveraging ZMQ.

cancel()[source]

Send cancel control message.

property status

Send get status control message.

Returns

control message.

property is_ready

Check if status is ready.

Return type

bool

Returns

True if status is ready else False.

class jina.peapods.runtimes.zmq.base.ZMQManyRuntime(args)[source]

Bases: jina.peapods.runtimes.base.BaseRuntime, abc.ABC

Multiple Runtime leveraging ZMQ.

cancel()[source]

Send cancel control messages to all control address.

property status

Send get status control messages to all control address.

Returns

received messages

property is_ready

Check if all the status are ready.

Return type

bool

Returns

True if all status are ready else False