bQj0|UddlmZddlmZdZeed< 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^< d_Z3eed`< GdadbeZ4GdcddeZ5GdedfeZ6GdgdheZ7GdidjeZ8yk)l)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.cluster.idMESSAGING_KAFKA_CLUSTER_IDzmessaging.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__CREATESENDRECEIVEPROCESSSETTLEDELIVERPUBLISH/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/opentelemetry/semconv/_incubating/attributes/messaging_attributes.pyr5r5sC Fk DVGzG; F+G,G)rHr5ceZdZdZ dZy)'MessagingRocketmqConsumptionModelValues clustering broadcastingN)r=r>r? CLUSTERING BROADCASTINGrGrHrIrKrKsJ'!L)rHrKc"eZdZdZ dZ dZ dZy)"MessagingRocketmqMessageTypeValuesnormalfifodelay transactionN)r=r>r?NORMALFIFODELAY TRANSACTIONrGrHrIrQrQs" F D EKrHrQc"eZdZdZ dZ dZ dZy)*MessagingServicebusDispositionStatusValuescompleteabandon dead_letterdeferN)r=r>r?COMPLETEABANDON DEAD_LETTERDEFERrGrHrIr[r[$s"HGK/ ErHr[cReZdZdZ dZ dZ dZ dZ dZ dZ dZ d Z d Z d Z d Zy )MessagingSystemValuesactivemqzaws.snsaws_sqs eventgrid eventhubs servicebus gcp_pubsubjmskafkarabbitmqrocketmqpulsarN)r=r>r?ACTIVEMQAWS_SNSAWS_SQS EVENTGRID EVENTHUBS SERVICEBUS GCP_PUBSUBJMSKAFKARABBITMQROCKETMQPULSARrGrHrIrere/sbHG3G,IIJJ C EHH FrHreN)9enumrtypingrr__annotations__rrrr r r r r rrrrrrrrrrrrrrrrrrr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3r5rKrQr[rerGrHrIrs'FuF 3U2(GuF *KJ%AE@ -Q"EP2['Z )IH *KJ2['Z-Q"EP-Q"EP4_)5^4_)5^.S#UR8g-uf4_)5^%AE@ )IH0W%uV&CUB )IH,O!5N!98&CUB ,O!5N*KJ 5e43U2#=%<#=%< 5a*E`2['Z*KJ/U$eT6c+Ub8g-uf+M %L*KJ)IH*KJ'EeD=q2Ep2['Z6c+Ub5a*E`-%, *4*"*d*DrH