File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/zmq/utils/__pycache__/monitor.cpython-310.pyc
Back
o ;j� � @ s� d Z ddlmZ ddlZddlmZmZmZ ddlZddl Zddl m Z G dd� de�Z d d d �Z d dd�Ze d d dd��Ze d d!dd��Z d d"d d�Zd dgZdS )#zJModule holding utility and convenience functions for zmq event monitoring.� )� annotationsN)� Awaitable� TypedDict�overload)�_check_versionc @ s& e Zd ZU ded< ded< ded< dS )�_MonitorMessage�int�event�value�bytes�endpointN)�__name__� __module__� __qualname__�__annotations__� r r �E/opt/saltstack/salt/lib/python3.10/site-packages/zmq/utils/monitor.pyr s r �msg� list[bytes]�returnc C s^ t | �dkst | d �dkrtd| � ���t�d| d �\}}t�|�t�|�| d d�}|S )a� decode zmq_monitor event messages. Parameters ---------- msg : list(bytes) zmq multipart message that has arrived on a monitor PAIR socket. First frame is:: 16 bit event id 32 bit event value no padding Second frame is the endpoint as a bytestring Returns ------- event : dict event description as dict with the keys `event`, `value`, and `endpoint`. � r � z Invalid event message format: z=hi� )r r r )�len� RuntimeError�struct�unpack�zmq�Event)r Zevent_idr r r r r �parse_monitor_message s �r � awaitable_msg�Awaitable[list[bytes]]c � s �| I dH }t |�S )zyLike parse_monitor_msg, but awaitable Given awaitable message, return awaitable for the parsed monitor message. N)r )r r r r r �_parse_monitor_msg_async6 s � r" �socket�zmq.asyncio.Socket�flagsr �Awaitable[_MonitorMessage]c C � d S �Nr �r# r% r r r �recv_monitor_messageC � r* �zmq.Socket[bytes]c C r' r( r r) r r r r* J r+ � zmq.Socket�,_MonitorMessage | Awaitable[_MonitorMessage]c C s. t dd� | �|�}t|t�rt|�S t|�S )u� Receive and decode the given raw message from the monitoring socket and return a dict. Requires libzmq ≥ 4.0 The returned dict will have the following entries: event : int the event id as described in `libzmq.zmq_socket_monitor` value : int the event value associated with the event, see `libzmq.zmq_socket_monitor` endpoint : str the affected endpoint .. versionchanged:: 23.1 Support for async sockets added. When called with a async socket, returns an awaitable for the monitor message. Parameters ---------- socket : zmq.Socket The PAIR socket (created by other.get_monitor_socket()) on which to recv the message flags : int standard zmq recv flags Returns ------- event : dict event description as dict with the keys `event`, `value`, and `endpoint`. )� r zlibzmq event API)r Zrecv_multipart� isinstancer r" r )r# r% r r r r r* Q s " )r r r r )r r! r r )r )r# r$ r% r r r& )r# r, r% r r r )r# r- r% r r r. )�__doc__� __future__r r �typingr r r r Z zmq.asyncioZ zmq.errorr r r r" r* �__all__r r r r �<module> s& �� � /
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings