g1lUddlmZddlmZdZeed< dZeed< dZeed< d Zeed < d Z eed < d Z eed< dZ eed< dZ eed< dZ eed< dZeed< dZeed< dZeed< dZeed< dZeed< dZeed < d!Zeed"< d#Zeed$< d%Zeed&< d'Zeed(< d)Zeed*< d+Zeed,< d-Zeed.< d/Zeed0< d1Zeed2< d3Zeed4< d5Zeed6< d7Zeed8< d9Z eed:< d;Z!eed<< d=Z"eed>< d?Z#eed@< dAZ$eedB< dCZ%eedD< dEZ&eedF< dGZ'eedH< dIZ(eedJ< dKZ)eedL< dMZ*eedN< dOZ+eedP< dQZ,eedR< dSZ-eedT< dUZ.eedV< dWZ/eedX< dYZ0eedZ< d[Z1eed\< d]Z2eed^< Gd_d`eZ3GdadbeZ4GdcddeZ5GdedfeZ6GdgdheZ7yi)j)Enum)Finalzmessaging.batch.message_countMESSAGING_BATCH_MESSAGE_COUNTzmessaging.client.idMESSAGING_CLIENT_IDzmessaging.consumer.group.nameMESSAGING_CONSUMER_GROUP_NAMEzmessaging.destination.anonymousMESSAGING_DESTINATION_ANONYMOUSzmessaging.destination.nameMESSAGING_DESTINATION_NAMEz"messaging.destination.partition.id"MESSAGING_DESTINATION_PARTITION_IDz'messaging.destination.subscription.name'MESSAGING_DESTINATION_SUBSCRIPTION_NAMEzmessaging.destination.templateMESSAGING_DESTINATION_TEMPLATEzmessaging.destination.temporaryMESSAGING_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_KEYzmessaging.kafka.consumer.groupMESSAGING_KAFKA_CONSUMER_GROUPz%messaging.kafka.destination.partition%MESSAGING_KAFKA_DESTINATION_PARTITIONzmessaging.kafka.message.keyMESSAGING_KAFKA_MESSAGE_KEYzmessaging.kafka.message.offsetMESSAGING_KAFKA_MESSAGE_OFFSETz!messaging.kafka.message.tombstone!MESSAGING_KAFKA_MESSAGE_TOMBSTONEzmessaging.kafka.offsetMESSAGING_KAFKA_OFFSETzmessaging.message.body.sizeMESSAGING_MESSAGE_BODY_SIZEz!messaging.message.conversation_id!MESSAGING_MESSAGE_CONVERSATION_IDzmessaging.message.envelope.sizeMESSAGING_MESSAGE_ENVELOPE_SIZEzmessaging.message.idMESSAGING_MESSAGE_IDzmessaging.operationMESSAGING_OPERATIONzmessaging.operation.nameMESSAGING_OPERATION_NAMEzmessaging.operation.typeMESSAGING_OPERATION_TYPEz*messaging.rabbitmq.destination.routing_key*MESSAGING_RABBITMQ_DESTINATION_ROUTING_KEYz'messaging.rabbitmq.message.delivery_tag'MESSAGING_RABBITMQ_MESSAGE_DELIVERY_TAGzmessaging.rocketmq.client_groupMESSAGING_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_GROUPzmessaging.rocketmq.message.keysMESSAGING_ROCKETMQ_MESSAGE_KEYSzmessaging.rocketmq.message.tagMESSAGING_ROCKETMQ_MESSAGE_TAGzmessaging.rocketmq.message.typeMESSAGING_ROCKETMQ_MESSAGE_TYPEzmessaging.rocketmq.namespaceMESSAGING_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_TIMEzmessaging.systemMESSAGING_SYSTEMc4eZdZdZ dZ dZ dZ dZ dZ dZ y) MessagingOperationTypeValuescreatesendreceiveprocesssettledeliverpublishN) __name__ __module__ __qualname__CREATESENDRECEIVEPROCESSSETTLEDELIVERPUBLISHv/var/www/openai/venv/lib/python3.12/site-packages/opentelemetry/semconv/_incubating/attributes/messaging_attributes.pyr4r41sC Fk DVGzG; F+G,G)rGr4ceZdZdZ dZy)'MessagingRocketmqConsumptionModelValues clustering broadcastingN)r<r=r> CLUSTERING BROADCASTINGrFrGrHrJrJBsJ'!L)rGrJc"eZdZdZ dZ dZ dZy)"MessagingRocketmqMessageTypeValuesnormalfifodelay transactionN)r<r=r>NORMALFIFODELAY TRANSACTIONrFrGrHrPrPIs" F D EKrGrPc"eZdZdZ dZ dZ dZy)*MessagingServicebusDispositionStatusValuescompleteabandon dead_letterdeferN)r<r=r>COMPLETEABANDON DEAD_LETTERDEFERrFrGrHrZrZTs"HGK/ ErGrZcLeZdZdZ dZ dZ dZ dZ dZ dZ dZ d Z d Z d Z y ) MessagingSystemValuesactivemqaws_sqs eventgrid eventhubs servicebus gcp_pubsubjmskafkarabbitmqrocketmqpulsarN)r<r=r>ACTIVEMQAWS_SQS EVENTGRID EVENTHUBS SERVICEBUS GCP_PUBSUBJMSKAFKARABBITMQROCKETMQPULSARrFrGrHrdrd_sZHG,IIJJ C EHH FrGrdN)8enumrtypingrr__annotations__rrrr r r r r rrrrrrrrrrrrrrrrrrr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2r4rJrPrZrdrFrGrHr~s'FuF 3U2(GuF *KJ%AE@)#E .( )IH *KJ .( )#E )#E 0*5 0*5 *$U 4.u 0*5)IH ,&u&CUB )IH,O!5N!98&CUB ,O!5N*KJ 5e43U2#=%<#=%< 1+E .(*KJ +%e 2,U 4.u+M %L*KJ)IH*KJ'EeD 93E .( 2,U 1+E-%, *4*"*d*DrG