Ë
    °BvhZ  ã                   ó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    úe/RAG/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 r   )r   r.   r   s    r   Ú!create_messaging_publish_messagesr0   –   s#   € à×ÑÜ'ØOØð  ó ð r   zmessaging.receive.durationÚMESSAGING_RECEIVE_DURATIONc                 ó2   — | j                  t        dd¬«      S r+   )r   r1   r   s    r   Ú!create_messaging_receive_durationr3   ¥   r-   r   zmessaging.receive.messagesÚMESSAGING_RECEIVE_MESSAGESc                 ó2   — | j                  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ðð°ð ¸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   