o
    PD©i}1  ã                   @   sò  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`„ d`eƒZ3G dadb„ dbeƒZ4G dcdd„ ddeƒZ5G dedf„ dfeƒZ6G dgdh„ 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_nameÚ2MESSAGING_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                   @   s.   e Zd ZdZ	 dZ	 dZ	 dZ	 dZ	 dZdS )ÚMessagingOperationTypeValuesÚpublishÚcreateÚreceiveÚprocessÚsettleÚdeliverN)	Ú__name__Ú
__module__Ú__qualname__ÚPUBLISHÚCREATEÚRECEIVEÚPROCESSÚSETTLEÚDELIVER© rB   rB   úz/var/www/Datamplify/venv/lib/python3.10/site-packages/opentelemetry/semconv/_incubating/attributes/messaging_attributes.pyr2   1  s    r2   c                   @   s   e Zd ZdZ	 dZdS )Ú'MessagingRocketmqConsumptionModelValuesÚ
clusteringÚbroadcastingN)r9   r:   r;   Ú
CLUSTERINGÚBROADCASTINGrB   rB   rB   rC   rD   @  s
    rD   c                   @   ó"   e Zd ZdZ	 dZ	 dZ	 dZdS )Ú"MessagingRocketmqMessageTypeValuesÚnormalÚfifoÚdelayÚtransactionN)r9   r:   r;   ÚNORMALÚFIFOÚDELAYÚTRANSACTIONrB   rB   rB   rC   rJ   G  ó    rJ   c                   @   rI   )Ú*MessagingServicebusDispositionStatusValuesÚcompleteÚabandonÚdead_letterÚdeferN)r9   r:   r;   ÚCOMPLETEÚABANDONÚDEAD_LETTERÚDEFERrB   rB   rB   rC   rT   R  rS   rT   c                   @   sL   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S )ÚMessagingSystemValuesÚactivemqÚaws_sqsÚ	eventgridÚ	eventhubsÚ
servicebusÚ
gcp_pubsubÚjmsÚkafkaÚrabbitmqÚrocketmqÚpulsarN)r9   r:   r;   ÚACTIVEMQÚAWS_SQSÚ	EVENTGRIDÚ	EVENTHUBSÚ
SERVICEBUSÚ
GCP_PUBSUBÚJMSÚKAFKAÚRABBITMQÚROCKETMQÚPULSARrB   rB   rB   rC   r]   ]  s.    r]   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.   r/   r0   r1   r2   rD   rJ   rT   r]   rB   rB   rB   rC   Ú<module>   sî   
ÿ
ÿ
ÿ
ÿ
ÿ
ÿ
ÿ
ÿ
ÿ
ÿ
ÿ
ÿ
ÿ
ÿ
ÿ
ÿ
ÿ
ÿ
ÿ
ÿ