o
    PDi                     @   sF  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dZd	Z	eed
< 	 dedefddZ
dZeed< 	 dedefddZdZeed< 	 dedefddZdZeed< 	 dedefddZdZeed< 	 dedefddZdZeed< 	 dedefdd Zd!Zeed"< 	 dedefd#d$Zd%Zeed&< 	 dedefd'd(Zd)S )*    )Final)Counter	HistogramMeterz"messaging.client.consumed.messages"MESSAGING_CLIENT_CONSUMED_MESSAGESmeterreturnc                 C      | j td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    r   t/var/www/Datamplify/venv/lib/python3.10/site-packages/opentelemetry/semconv/_incubating/metrics/messaging_metrics.py)create_messaging_client_consumed_messages    
   r   z#messaging.client.operation.duration#MESSAGING_CLIENT_OPERATION_DURATIONc                 C   r	   )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   r   r   r   *create_messaging_client_operation_duration4   r   r   z#messaging.client.published.messages#MESSAGING_CLIENT_PUBLISHED_MESSAGESc                 C   r	   )z>Number of messages producer attempted to publish to the brokerz?Number of messages producer attempted to publish to the broker.r
   r   )r   r   r   r   r   r   *create_messaging_client_published_messagesH   r   r   zmessaging.process.durationMESSAGING_PROCESS_DURATIONc                 C   r	   )z Duration of processing operationz!Duration of processing operation.r   r   )r   r   r   r   r   r   !create_messaging_process_durationZ   r   r   zmessaging.process.messagesMESSAGING_PROCESS_MESSAGESc                 C   r	   z<Deprecated. Use `messaging.client.consumed.messages` insteadz=Deprecated. Use `messaging.client.consumed.messages` instead.r
   r   )r   r   r   r   r   r   !create_messaging_process_messagesi   r   r   zmessaging.publish.durationMESSAGING_PUBLISH_DURATIONc                 C   r	   z=Deprecated. Use `messaging.client.operation.duration` insteadz>Deprecated. Use `messaging.client.operation.duration` instead.r   r   )r   r    r   r   r   r   !create_messaging_publish_durationx   r   r"   zmessaging.publish.messagesMESSAGING_PUBLISH_MESSAGESc                 C   r	   )z<Deprecated. Use `messaging.client.produced.messages` insteadz=Deprecated. Use `messaging.client.produced.messages` instead.r
   r   )r   r#   r   r   r   r   !create_messaging_publish_messages   r   r$   zmessaging.receive.durationMESSAGING_RECEIVE_DURATIONc                 C   r	   r!   )r   r%   r   r   r   r   !create_messaging_receive_duration   r   r&   zmessaging.receive.messagesMESSAGING_RECEIVE_MESSAGESc                 C   r	   r   )r   r'   r   r   r   r   !create_messaging_receive_messages   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&   r'   r(   r   r   r   r   <module>   s@   
	



						