o piZ@sfUddlmZddlmZmZmZdZeed< dedefddZd Z eed < dedefd d Z d Z eed< dedefddZ dZ eed< dedefddZdZeed< dedefddZdZeed< dedefddZdZeed< dedefdd Zd!Zeed"< dedefd#d$Zd%Zeed&< dedefd'd(Zd)Zeed*< dedefd+d,Zd-S).)Final)Counter HistogramMeterz"messaging.client.consumed.messages"MESSAGING_CLIENT_CONSUMED_MESSAGESmeterreturncC|jtdddS)z9Number of messages that were delivered to the applicationz:Number of messages that were delivered to the application. {message}name descriptionunit)create_counterrrro/home/ubuntu/.local/lib/python3.10/site-packages/opentelemetry/semconv/_incubating/metrics/messaging_metrics.py)create_messaging_client_consumed_messages rz#messaging.client.operation.duration#MESSAGING_CLIENT_OPERATION_DURATIONcCr )zJDuration of messaging operation initiated by a producer or consumer clientzKDuration of messaging operation initiated by a producer or consumer client.sr )create_histogramrrrrr*create_messaging_client_operation_duration4rrz#messaging.client.published.messages#MESSAGING_CLIENT_PUBLISHED_MESSAGEScCr z8Deprecated. Use `messaging.client.sent.messages` insteadz9Deprecated. Use `messaging.client.sent.messages` instead.r r )rrrrrr*create_messaging_client_published_messagesErrzmessaging.client.sent.messagesMESSAGING_CLIENT_SENT_MESSAGEScCr )z;Number of messages producer attempted to send to the brokerzDeprecated. Use `messaging.client.operation.duration` instead.rr )rr#rrrr!create_messaging_publish_durationrr%zmessaging.publish.messagesMESSAGING_PUBLISH_MESSAGEScCr r)rr&rrrr!create_messaging_publish_messagesrr'zmessaging.receive.durationMESSAGING_RECEIVE_DURATIONcCr r$)rr(rrrr!create_messaging_receive_durationrr)zmessaging.receive.messagesMESSAGING_RECEIVE_MESSAGEScCr r!)rr*rrrr!create_messaging_receive_messagesrr+N)typingropentelemetry.metricsrrrr__annotations__rrrrrrrrrr r"r#r%r&r'r(r)r*r+rrrrsF