§
    Yþj^  ã                   óh  — U d dl mZ d dlmZmZmZ dZeed<   	 dedefd„ZdZ	eed	<   	 dedefd
„Z
dZeed<   	 dedefd„ZdZeed<   	 dedefd„ZdZeed<   	 dedefd„ZdZeed<   	 dedefd„ZdZeed<   	 dedefd„ZdZeed<   	 dedefd„ZdZeed<   	 dedefd„Zd Zeed!<   	 dedefd"„Zd#S )$é    )ÚFinal)ÚCounterÚ	HistogramÚMeterz"messaging.client.consumed.messagesÚ"MESSAGING_CLIENT_CONSUMED_MESSAGESÚmeterÚreturnc                 ó<   — |                       t          dd¬¦  «        S )z9Number of messages that were delivered to the applicationz:Number of messages that were delivered to the application.ú	{message}©ÚnameÚdescriptionÚunit)Úcreate_counterr   ©r   s    úx/var/www/FlaskApp/flask-venv/lib/python3.11/site-packages/opentelemetry/semconv/_incubating/metrics/messaging_metrics.pyÚ)create_messaging_client_consumed_messagesr      s(   € à×ÒÝ/ØPØð  ñ ô ð ó    z#messaging.client.operation.durationÚ#MESSAGING_CLIENT_OPERATION_DURATIONc                 ó<   — |                       t          dd¬¦  «        S )zJDuration of messaging operation initiated by a producer or consumer clientzKDuration of messaging operation initiated by a producer or consumer client.Úsr   )Úcreate_histogramr   r   s    r   Ú*create_messaging_client_operation_durationr   )   s(   € à×!Ò!Ý0ØaØð "ñ ô ð r   z#messaging.client.published.messagesÚ#MESSAGING_CLIENT_PUBLISHED_MESSAGESc                 ó<   — |                       t          dd¬¦  «        S ©z8Deprecated. Use `messaging.client.sent.messages` insteadz9Deprecated. Use `messaging.client.sent.messages` instead.r   r   )r   r   r   s    r   Ú*create_messaging_client_published_messagesr   :   s(   € à×ÒÝ0ØOØð  ñ ô ð r   zmessaging.client.sent.messagesÚMESSAGING_CLIENT_SENT_MESSAGESc                 ó<   — |                       t          dd¬¦  «        S )z;Number of messages producer attempted to send to the brokerz<Number of messages producer attempted to send to the broker.r   r   )r   r   r   s    r   Ú%create_messaging_client_sent_messagesr    L   s(   € à×ÒÝ+ØRØð  ñ ô ð r   zmessaging.process.durationÚMESSAGING_PROCESS_DURATIONc                 ó<   — |                       t          dd¬¦  «        S )z Duration of processing operationz!Duration of processing operation.r   r   )r   r!   r   s    r   Ú!create_messaging_process_durationr#   ^   s(   € à×!Ò!Ý'Ø7Øð "ñ ô ð r   zmessaging.process.messagesÚMESSAGING_PROCESS_MESSAGESc                 ó<   — |                       t          dd¬¦  «        S ©z<Deprecated. Use `messaging.client.consumed.messages` insteadz=Deprecated. Use `messaging.client.consumed.messages` instead.r   r   )r   r$   r   s    r   Ú!create_messaging_process_messagesr'   m   ó(   € à×ÒÝ'ØSØð  ñ ô ð r   zmessaging.publish.durationÚMESSAGING_PUBLISH_DURATIONc                 ó<   — |                       t          dd¬¦  «        S ©z=Deprecated. Use `messaging.client.operation.duration` insteadz>Deprecated. Use `messaging.client.operation.duration` instead.r   r   )r   r)   r   s    r   Ú!create_messaging_publish_durationr,   |   ó(   € à×!Ò!Ý'ØTØð "ñ ô ð r   zmessaging.publish.messagesÚMESSAGING_PUBLISH_MESSAGESc                 ó<   — |                       t          dd¬¦  «        S r   )r   r.   r   s    r   Ú!create_messaging_publish_messagesr0   ‹   s(   € à×ÒÝ'ØOØð  ñ ô ð r   zmessaging.receive.durationÚMESSAGING_RECEIVE_DURATIONc                 ó<   — |                       t          dd¬¦  «        S r+   )r   r1   r   s    r   Ú!create_messaging_receive_durationr3   š   r-   r   zmessaging.receive.messagesÚMESSAGING_RECEIVE_MESSAGESc                 ó<   — |                       t          dd¬¦  «        S r&   )r   r4   r   s    r   Ú!create_messaging_receive_messagesr6   ©   r(   r   N)Útypingr   Úopentelemetry.metricsr   r   r   r   Ú__annotations__r   r   r   r   r   r   r    r!   r#   r$   r'   r)   r,   r.   r0   r1   r3   r4   r6   © r   r   ú<module>r;      s§  ðð
 Ð Ð Ð Ð Ð Ð à ;Ð ;Ð ;Ð ;Ð ;Ð ;Ð ;Ð ;Ð ;Ð ;ð )ð # Eð ð ñ ðð°Uð ¸wð ð ð ð ð *ð $ Uð ð ñ ðð°eð À	ð ð ð ð ð *ð $ Uð ð ñ ðð
°eð Àð ð ð ð ð )IÐ  Ð HÐ HÑ Hðð°ð ¸7ð ð ð ð ð %AÐ ˜EÐ @Ð @Ñ @ðð¨Uð °yð ð ð ð ð %AÐ ˜EÐ @Ð @Ñ @ðð
¨Uð °wð ð ð ð ð %AÐ ˜EÐ @Ð @Ñ @ðð
¨Uð °yð ð ð ð ð %AÐ ˜EÐ @Ð @Ñ @ðð
¨Uð °wð ð ð ð ð %AÐ ˜EÐ @Ð @Ñ @ðð
¨Uð °yð ð ð ð ð %AÐ ˜EÐ @Ð @Ñ @ðð
¨Uð °wð ð ð ð ð ð r   