Ë
    Ûªgf  ã                   óf  — 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y#)$é    )ÚFinal)ÚCounterÚ	HistogramÚMeterz"messaging.client.consumed.messagesÚ"MESSAGING_CLIENT_CONSUMED_MESSAGESÚmeterÚreturnc                 ó2   — | j                  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    úp/var/www/openai/venv/lib/python3.12/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                 ó2   — | j                  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   4   s#   € à×!Ñ!Ü0ØaØð "ó ð r   z#messaging.client.published.messagesÚ#MESSAGING_CLIENT_PUBLISHED_MESSAGESc                 ó2   — | j                  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   E   s#   € à×ÑÜ0ØOØð  ó ð r   zmessaging.client.sent.messagesÚMESSAGING_CLIENT_SENT_MESSAGESc                 ó2   — | j                  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   W   s#   € à×ÑÜ+ØRØð  ó ð r   zmessaging.process.durationÚMESSAGING_PROCESS_DURATIONc                 ó2   — | j                  t        dd¬«      S )z Duration of processing operationz!Duration of processing operation.r   r   )r   r    r   s    r   Ú!create_messaging_process_durationr"   i   s#   € à×!Ñ!Ü'Ø7Øð "ó ð r   zmessaging.process.messagesÚMESSAGING_PROCESS_MESSAGESc                 ó2   — | j                  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&   x   ó#   € à×ÑÜ'ØSØð  ó ð r   zmessaging.publish.durationÚMESSAGING_PUBLISH_DURATIONc                 ó2   — | j                  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                 ó2   — | j                  t        dd¬«      S )z<Deprecated. Use `messaging.client.produced.messages` insteadz=Deprecated. Use `messaging.client.produced.messages` instead.r   r   )r   r-   r   s    r   Ú!create_messaging_publish_messagesr/   –   r'   r   zmessaging.receive.durationÚMESSAGING_RECEIVE_DURATIONc                 ó2   — | j                  t        dd¬«      S r*   )r   r0   r   s    r   Ú!create_messaging_receive_durationr2   ¥   r,   r   zmessaging.receive.messagesÚMESSAGING_RECEIVE_MESSAGESc                 ó2   — | j                  t        dd¬«      S r%   )r   r3   r   s    r   Ú!create_messaging_receive_messagesr5   ´   r'   r   N)Útypingr   Úopentelemetry.metricsr   r   r   r   Ú__annotations__r   r   r   r   r   r   r   r    r"   r#   r&   r(   r+   r-   r/   r0   r2   r3   r5   © r   r   Ú<module>r:      s•  ðö  ç ;Ñ ;ð )ð # Eó ðð°Uð ¸wó ð *ð $ Uó ðð°eð À	ó ð *ð $ Uó ðð
°eð Àó ð )IÐ  Ó 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   