
    Yj/                        U d dl mZ d dlmZ dZeed<   	 dZeed<   	 dZeed<   	 d	Zeed
<   	 dZ	eed<   	 dZ
eed<   	 dZeed<   	 dZeed<   	 dZeed<   	 dZeed<   	 dZeed<   	 dZeed<   	 dZeed<   	 dZeed<   	 dZeed <   	 d!Zeed"<   	 d#Zeed$<   	 d%Zeed&<   	 d'Zeed(<   	 d)Zeed*<   	 d+Zeed,<   	 d-Zeed.<   	 d/Zeed0<   	 d1Zeed2<   	 d3Zeed4<   	 d5Zeed6<   	 d7Zeed8<   	 d9Z eed:<   	 d;Z!eed<<   	 d=Z"eed><   	 d?Z#eed@<   	 dAZ$eedB<   	 dCZ%eedD<   	 dEZ&eedF<   	 dGZ'eedH<   	 dIZ(eedJ<   	 dKZ)eedL<   	 dMZ*eedN<   	 dOZ+eedP<   	 dQZ,eedR<   	 dSZ-eedT<   	 dUZ.eedV<   	 dWZ/eedX<   	 dYZ0eedZ<   	 d[Z1eed\<   	 d]Z2eed^<   	  G d_ d`e          Z3 G da dbe          Z4 G dc dde          Z5 G de dfe          Z6 G dg dhe          Z7diS )j    )Enum)Finalzmessaging.batch.message_countMESSAGING_BATCH_MESSAGE_COUNTzmessaging.client.idMESSAGING_CLIENT_IDzmessaging.consumer.group.nameMESSAGING_CONSUMER_GROUP_NAMEzmessaging.destination.anonymousMESSAGING_DESTINATION_ANONYMOUSzmessaging.destination.nameMESSAGING_DESTINATION_NAMEz"messaging.destination.partition.id"MESSAGING_DESTINATION_PARTITION_IDz'messaging.destination.subscription.name'MESSAGING_DESTINATION_SUBSCRIPTION_NAMEzmessaging.destination.templateMESSAGING_DESTINATION_TEMPLATEzmessaging.destination.temporaryMESSAGING_DESTINATION_TEMPORARYz'messaging.destination_publish.anonymous'MESSAGING_DESTINATION_PUBLISH_ANONYMOUSz"messaging.destination_publish.name"MESSAGING_DESTINATION_PUBLISH_NAMEz"messaging.eventhubs.consumer.group"MESSAGING_EVENTHUBS_CONSUMER_GROUPz)messaging.eventhubs.message.enqueued_time)MESSAGING_EVENTHUBS_MESSAGE_ENQUEUED_TIMEz)messaging.gcp_pubsub.message.ack_deadline)MESSAGING_GCP_PUBSUB_MESSAGE_ACK_DEADLINEz#messaging.gcp_pubsub.message.ack_id#MESSAGING_GCP_PUBSUB_MESSAGE_ACK_IDz-messaging.gcp_pubsub.message.delivery_attempt-MESSAGING_GCP_PUBSUB_MESSAGE_DELIVERY_ATTEMPTz)messaging.gcp_pubsub.message.ordering_key)MESSAGING_GCP_PUBSUB_MESSAGE_ORDERING_KEYzmessaging.kafka.consumer.groupMESSAGING_KAFKA_CONSUMER_GROUPz%messaging.kafka.destination.partition%MESSAGING_KAFKA_DESTINATION_PARTITIONzmessaging.kafka.message.keyMESSAGING_KAFKA_MESSAGE_KEYzmessaging.kafka.message.offsetMESSAGING_KAFKA_MESSAGE_OFFSETz!messaging.kafka.message.tombstone!MESSAGING_KAFKA_MESSAGE_TOMBSTONEzmessaging.kafka.offsetMESSAGING_KAFKA_OFFSETzmessaging.message.body.sizeMESSAGING_MESSAGE_BODY_SIZEz!messaging.message.conversation_id!MESSAGING_MESSAGE_CONVERSATION_IDzmessaging.message.envelope.sizeMESSAGING_MESSAGE_ENVELOPE_SIZEzmessaging.message.idMESSAGING_MESSAGE_IDzmessaging.operationMESSAGING_OPERATIONzmessaging.operation.nameMESSAGING_OPERATION_NAMEzmessaging.operation.typeMESSAGING_OPERATION_TYPEz*messaging.rabbitmq.destination.routing_key*MESSAGING_RABBITMQ_DESTINATION_ROUTING_KEYz'messaging.rabbitmq.message.delivery_tag'MESSAGING_RABBITMQ_MESSAGE_DELIVERY_TAGzmessaging.rocketmq.client_groupMESSAGING_ROCKETMQ_CLIENT_GROUPz$messaging.rocketmq.consumption_model$MESSAGING_ROCKETMQ_CONSUMPTION_MODELz+messaging.rocketmq.message.delay_time_level+MESSAGING_ROCKETMQ_MESSAGE_DELAY_TIME_LEVELz-messaging.rocketmq.message.delivery_timestamp-MESSAGING_ROCKETMQ_MESSAGE_DELIVERY_TIMESTAMPz messaging.rocketmq.message.group MESSAGING_ROCKETMQ_MESSAGE_GROUPzmessaging.rocketmq.message.keysMESSAGING_ROCKETMQ_MESSAGE_KEYSzmessaging.rocketmq.message.tagMESSAGING_ROCKETMQ_MESSAGE_TAGzmessaging.rocketmq.message.typeMESSAGING_ROCKETMQ_MESSAGE_TYPEzmessaging.rocketmq.namespaceMESSAGING_ROCKETMQ_NAMESPACEz2messaging.servicebus.destination.subscription_name2MESSAGING_SERVICEBUS_DESTINATION_SUBSCRIPTION_NAMEz'messaging.servicebus.disposition_status'MESSAGING_SERVICEBUS_DISPOSITION_STATUSz+messaging.servicebus.message.delivery_count+MESSAGING_SERVICEBUS_MESSAGE_DELIVERY_COUNTz*messaging.servicebus.message.enqueued_time*MESSAGING_SERVICEBUS_MESSAGE_ENQUEUED_TIMEzmessaging.systemMESSAGING_SYSTEMc                   6    e Zd ZdZ	 dZ	 dZ	 dZ	 dZ	 dZ	 dZ	dS )	MessagingOperationTypeValuescreatesendreceiveprocesssettledeliverpublishN)
__name__
__module____qualname__CREATESENDRECEIVEPROCESSSETTLEDELIVERPUBLISH     ~/var/www/FlaskApp/flask-venv/lib/python3.11/site-packages/opentelemetry/semconv/_incubating/attributes/messaging_attributes.pyr4   r4   #  sN        F kD VG zG;F+G,G))rG   r4   c                       e Zd ZdZ	 dZdS )'MessagingRocketmqConsumptionModelValues
clusteringbroadcastingN)r<   r=   r>   
CLUSTERINGBROADCASTINGrF   rG   rH   rJ   rJ   4  s        J'!L))rG   rJ   c                   $    e Zd ZdZ	 dZ	 dZ	 dZdS )"MessagingRocketmqMessageTypeValuesnormalfifodelaytransactionN)r<   r=   r>   NORMALFIFODELAYTRANSACTIONrF   rG   rH   rP   rP   ;  s-        FDEKrG   rP   c                   $    e Zd ZdZ	 dZ	 dZ	 dZdS )*MessagingServicebusDispositionStatusValuescompleteabandondead_letterdeferN)r<   r=   r>   COMPLETEABANDONDEAD_LETTERDEFERrF   rG   rH   rZ   rZ   F  s-        HGK/ErG   rZ   c                   T    e Zd ZdZ	 dZ	 dZ	 dZ	 dZ	 dZ	 dZ		 dZ
	 d	Z	 d
Z	 dZ	 dZdS )MessagingSystemValuesactivemqzaws.snsaws_sqs	eventgrid	eventhubs
servicebus
gcp_pubsubjmskafkarabbitmqrocketmqpulsarN)r<   r=   r>   ACTIVEMQAWS_SNSAWS_SQS	EVENTGRID	EVENTHUBS
SERVICEBUS
GCP_PUBSUBJMSKAFKARABBITMQROCKETMQPULSARrF   rG   rH   rd   rd   Q  sm        HG3G,IIJJ
CEHHFrG   rd   N)8enumr   typingr   r   __annotations__r   r   r   r	   r
   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r    r!   r"   r#   r$   r%   r&   r'   r(   r)   r*   r+   r,   r-   r.   r/   r0   r1   r2   r4   rJ   rP   rZ   rd   rF   rG   rH   <module>r      s
               'F u F F F
 3 U 2 2 2 (G u F F F
 *K  J J J %A E @ @ @ ) #E   
 . (   
 )I  H H H
 *K  J J J
 . (   
 ) #E   
 ) #E   
 0 *5   
 0 *5   
 * $U   
 4 .u   
 0 *5    )I  H H H
 , &u    &C U B B B
 )I  H H H ,O !5 N N N !9  8 8 8 &C U B B B ,O !5 N N N *K  J J J 5 e 4 4 4 3 U 2 2 2 #= % < < < #= % < < < 1 +E   
 . (    *K  J J J
 + %e   
 2 ,U   
 4 .u    +M  % L L L *K  J J J )I  H H H *K  J J J 'E e D D D
 9 3E   
 . (   
 2 ,U   
 1 +E    - % , , ,* * * * *4 * * *"* * * * *d * * *                  D     rG   