HealthStatusReceiver#

class akkits.HealthStatusReceiver(context, sock_addr)#

Bases: akkits.receivers._Receiver

Health status receiver.

Messages are decoded using decode_health_status().

context#

ZMQ Context.

Type

zmq.Context

socket#

ZMQ Socket.

Type

zmq.Socket

__init__(context, sock_addr)#

Creates the receiver.

Parameters

  • context (zmq.Context) – ZMQ Context.

  • sock_addr (str) – Socket address.

recv()#

Receives and decodes the flatbuffer message.

Note that this is a blocking call that waits until a message arrives.

Returns

data (Dict[str, Any]) – A data dictionary.