Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
Repository URL to install this package:
|
Version:
0.1.3 ▾
|
odigos
/
etc
/
odigos-vmagent
/
instrumentations
/
python
/
opamp
/
__pycache__
/
http_client.cpython-311.pyc
|
|---|
§
O>gN5 ã ó d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ d dlm Z d dl
m Z m Z m
Z
mZ d dlmZmZmZ d dlmZ ej d¦ « Ze j e j e j dZ G d d
¦ « Z G d d ¦ « Z dS )
é N)Úuuid7)ÚResourceAttributes)Ú"_SUPPRESS_HTTP_INSTRUMENTATION_KEYÚattachÚdetachÚ set_value)Ú opamp_pb2Ú anyvalue_pb2Úutils)ÚAgentHealthStatusÚodigos)ÚODIGOS_WORKLOAD_NAMESPACEÚODIGOS_CONTAINER_NAMEÚODIGOS_POD_NAMEc ó e Zd Zdej fdZddefdZd Zde ddfd Z
de ddfd
Z d d Z d Z
dej fd
Zdej fdZdej fdZd dede de dej fdZdej dej fdZd Zdde fdZdej defdZdS ) ÚOpAMPHTTPClientÚ conditionc ó6 t j d¦ « | _ t j d¦ « | _ d| j d| _ i | _ d| _ || _ || _ d| _ t ¦ « ¦ « | _ d | _
d | _ d S )NÚODIGOS_OPAMP_SERVER_HOSTÚ ODIGOS_INSTRUMENTATION_DEVICE_IDzhttp://z /v1/opampTr )ÚosÚgetenvÚ server_hostÚinstrumentation_device_idÚ
server_urlÚresource_attributesÚrunningr ÚeventÚnext_sequence_numr Ú__str__Ú instance_uidÚremote_config_statusÚsampler)Úselfr r s ú8/tmp/pip-target-qlpkiub5/lib/python/opamp/http_client.pyÚ__init__zOpAMPHTTPClient.__init__ s Ý 9Ð%?Ñ@Ô@ÔÝ)+¬Ð3UÑ)VÔ)VÔ&Ø? DÔ$4Ð?Ð?Ð?Ø#%Ô Ø Ø"Ø
Ø!"Ô Ý !GGOOÑ -Ô -ÔØ$(Ô!Ø ó NÚpython_version_supportedc óZ |snt j j dt j j dt j j }d| d}| |¬¦ « | j ¦ « d S t j | j
dd¬¦ « | _ | j ¦ « d S )Nú.z;Opentelemetry SDK require Python in version 3.8 or higher [z is not supported]©Ú
error_messageÚOpAMPClientThreadT)ÚtargetÚnameÚdaemon)
ÚsysÚ version_infoÚmajorÚminorÚmicroÚ+send_unsupported_version_disconnect_messager ÚsetÚ threadingÚThreadÚrunÚ
client_threadÚstart)r$ r( Úpython_versionr, s r% r< zOpAMPHTTPClient.start- s² Ø'ð å #Ô 0Ô 6Ð jÐ j½Ô9IÔ9OÐ jÐ jÕRUÔRbÔRhÐ jÐ jNØ |ÐZhÐ |Ð |Ð |Mð
× <Ò <È=Ð <Ñ YÔ YÐ YØ JNNÑ Ô Ð Ø Få &Ô -°T´XÐDWÐ`dÐ eÑ eÔ eÔØ Ô× Ò Ñ"Ô"Ð"Ð"Ð"r' c óà | ¦ « s| j ¦ « d S | ¦ « | j ¦ « | ¦ « d S # t
$ ro}| t |¦ « ¬¦ « }| |¦ « | j ¦ « t j
¦ « Y d }~d S d }~ww xY w)Nr+ ) Úmandatory_env_vars_setr r7 Ú send_first_message_with_retryÚworkerÚ ExceptionÚ$get_agent_failure_disconnect_messageÚstrÚ send_agent_to_server_messager1 Úexit)r$ ÚeÚfailure_messages r% r: zOpAMPHTTPClient.run; så ð Ø×.Ò.Ñ0Ô0ð
Ø
Ñ Ô Ð Øà × .Ò .Ñ 0Ô 0Ð 0Ø JNNÑ Ô Ð à KKMMMMMøåð ð ð à "× GÒ GÕVYÐZ[ÑV\ÔV\Ð GÑ ]Ô ]OØ × -Ò -¨oÑ >Ô >Ð >ð
JNNÑ Ô Ð Ý HJJJJJJJJJøøøøð øøøs -A4 ±AA4 Á4
C-Á>A$C(Ã(C-r, Úreturnc ó
t j ¦ « }| ¦ « }|j |¦ « | d|t j j ¬¦ « }|j |¦ « |S ©NF©Úcomponent_healthÚ
last_errorÚstatus)
r Ú
AgentToServerÚget_agent_disconnectÚagent_disconnectÚCopyFromÚget_agent_healthr Ú
AGENT_FAILUREÚvalueÚhealth)r$ r, Úagent_failure_messagerR Ú agent_healths r% rC z4OpAMPHTTPClient.get_agent_failure_disconnect_messageO s Ý )Ô 7Ñ 9Ô 9Ð à ×4Ò4Ñ6Ô6ÐØ Ô.×7Ò7Ð8HÑIÔIÐIà×,Ò,¸eÐP]Õfwô gFô gLÐ,ñ Mô M Ø Ô$×-Ò-¨lÑ;Ô;Ð;à$Ð$r' c ó t j ¦ « }| ¦ « }|j |¦ « | ¦ « }|j |¦ « | d|t j j
¬¦ « }|j |¦ « | |¦ « d S rK )
r rP Úget_agent_descriptionÚagent_descriptionrS rQ rR rT r ÚUNSUPPORTED_RUNTIME_VERSIONrV rW rE )r$ r, Úfirst_disconnect_messager\ rR rY s r% r6 z;OpAMPHTTPClient.send_unsupported_version_disconnect_messageZ sÇ Ý#,Ô#:Ñ#<Ô#<Ð à × 6Ò 6Ñ 8Ô 8Ðà Ô2×;Ò;Ð<MÑNÔNÐNà ×4Ò4Ñ6Ô6ÐØ Ô1×:Ò:Ð;KÑLÔLÐLà×,Ò,¸eÐP]Õfwô gTô gZÐ,ñ [ô [ Ø Ô'×0Ò0° Ñ>Ô>Ð>à ×)Ò)Ð*BÑCÔCÐCÐCÐCr' c óÀ d}d}t d|dz ¦ « D ]3} | ddt j j ¬¦ « }| ¦ « }| t j ||¬¦ « ¦ « }| ¦ « r
|
|¦ « t j |t ¦ « | _ | dt j j ¬ ¦ « }| t j |¬
¦ « ¦ « d S n# t $ r
}Y d }~nd }~ww xY w||k rt# j |¦ « 5t! d | d ¦ « )
Né é é Fz&Python OpenTelemetry agent is startingrL ©r\ rW T©rM rO )rW z2Error sending first message to OpAMP server after z attempts)ÚrangerT r ÚSTARTINGrV r[ rE r rP Ú
ListFieldsÚupdate_remote_config_statusr Ú*parse_first_message_to_resource_attributesÚ opamp_loggerr ÚHEALTHYrB ÚtimeÚsleep)r$ Ú max_retriesÚdelayÚattemptrY r\ Ú first_message_server_to_agentrG s r% r@ z-OpAMPHTTPClient.send_first_message_with_retryi s½ Ø Øå Q ¨a¡Ñ0Ô0ð "ñ "Gð
à #× 4Ò 4Àeð YAõ J[ô Jdô JjÐ 4ñ kô k Ø$(×$>Ò$>Ñ$@Ô$@Ð!Ø04×0QÒ0QÕR[ÔRið }Nð Wcð Sdñ Sdô Sdñ 1eô 1eÐ-ð 1×;Ò;Ñ=Ô=ð
Ø×4Ò4Ð5RÑSÔSÐSÝ/4Ô/_Ð`}õ @Lñ 0Mô 0MDÔ,ð $(×#8Ò#8È$ÕWhÔWpÔWvÐ#8Ñ#wÔ#wLØ×5Ò5µiÔ6MÐUaÐ6bÑ6bÔ6bÑcÔcÐcð FFð
øõ ð
ð
ð
àøøøøð
øøøð Ò$Ð$Ý
5Ñ!Ô!Ð!ùõ ÐcÈ[ÐcÐcÐcÑdÔdÐds C:DÄ
D.Ä)D.c óH | j r| j 5 | ¦ « }| |¦ « r |j t
j z rz| ¦ « }| dt j
j ¬¦ « }t j ||¬¦ « }|
|¦ « }| |¦ « n # t j $ r
}Y d }~nd }~ww xY w| j d¦ « d d d ¦ « n # 1 swxY w Y | j °d S d S )NTrd rc é )r r Úsend_heartbeatrh Úflagsr Ú"ServerToAgentFlags_ReportFullStater[ rT r rk rV rP rE Úrequests_odigosÚRequestExceptionÚwait)r$ Úserver_to_agentr\ rY Úagent_to_serverrG s r% rA zOpAMPHTTPClient.worker s
Ølñ (Ø ð
(ð
(ðØ&*×&9Ò&9Ñ&;Ô&;OØ×7Ò7¸ÑHÔHð à ð 'Ô,yÔ/[Ñ[ð Jð -1×,FÒ,FÑ,HÔ,HÐ)Ø'+×'<Ò'<ÈdÕ[lÔ[tÔ[zÐ'<Ñ'{Ô'{ Ý*3Ô*AÐTeÐnzÐ*{Ñ*{Ô*{à*.×*KÒ*KÈOÑ*\Ô*\à ×8Ò8¸ ÑIÔIÐIøøå&Ô7ð ð ð àDDDDøøøøðøøøð ×#Ò# BÑ'Ô'Ð'ð-
(ð
(ð
(ñ
(ô
(ð
(ð
(ð
(ð
(ð
(ð
(øøøð
(ð
(ð
(ð
(ð lñ (ð (ð (ð (ð (s5 D
B8C Ã
D
à C$ÃD
à C$Ã$ D
Ä
DÄDc ó t j | j ¬¦ « }| |¦ « S # t j $ r }Y d }~d S d }~ww xY w)N)r" )r rP r" rE rw rx )r$ r{ rG s r% rt z OpAMPHTTPClient.send_heartbeat§ s` ð Ý 'Ô 5È4ÔKdÐ eÑ eÔ eOØ×4Ò4°_ÑEÔEÐ EøÝ Ô/ð ð ð à DDDDDøøøøð øøøs .1 ±A ÁA c ó t j t j t j | j ¬¦ « ¬¦ « t j t j t j t j ¦ « ¬¦ « ¬¦ « t j t j t j d¬¦ « ¬¦ « g}t ¦ « D ]b\ }}t j
|¦ « }|r<| t j |t j |¬¦ « ¬¦ « ¦ « ct j |g ¬¦ « S )N)Ú string_value)ÚkeyrV )Ú int_valueÚpython)Úidentifying_attributesÚnon_identifying_attributes)r
ÚKeyValuer ÚSERVICE_INSTANCE_IDÚAnyValuer! Ú PROCESS_PIDr ÚgetpidÚTELEMETRY_SDK_LANGUAGEÚenv_var_mappingsÚitemsÚenvironÚgetÚappendr ÚAgentDescription)r$ r Úenv_varÚ
attribute_keyrV s r% r[ z%OpAMPHTTPClient.get_agent_description° s< å Ô !Ý&Ô:Ý"Ô+¸Ô9JÐKÑKÔKð
ñ
ô
õ
Ô !Ý&Ô2Ý"Ô+µb´i±k´kÐBÑBÔBð
ñ
ô
õ
Ô !Ý&Ô=Ý"Ô+¸ÐBÑBÔBð
ñ
ô
ð
"
Ð õ '7×&<Ò&<Ñ&>Ô&>ð ð Ñ "G]ÝJNN 7Ñ+Ô+EØð
Ø&×-Ò-Ý Ô)Ø )Ý *Ô 3ÀÐ GÑ GÔ Gðñ ô ñô ð øõ Ô)Ø#9Ø')ð
ñ
ô
ð
r' c ó( t j ¦ « S ©N)r ÚAgentDisconnect)r$ s r% rQ z$OpAMPHTTPClient.get_agent_disconnectÐ s ÝÔ(Ñ*Ô*Ð*r' rM rN rO c ób t j ¦ « }|||_ |||_ |||_ |S r )r ÚComponentHealthÚhealthyrN rO )r$ rM rN rO rW s r% rT z OpAMPHTTPClient.get_agent_healthÓ sA ÝÔ*ñ
ô
à Ð 'Ø -FNØ Ð !Ø *FÔ Ø Ð Ø "FMà
r' Úmessagec ó | j d¦ « |_ | j |_ | j r |j | j ¦ « | xj dz
c_ | ¦ « }d| j d} t t t d¦ « ¦ « }t j | j
||d¬¦ « }| ¦ « np# t j $ r% t! j ¦ « cY t% |¦ « S t j $ r,}t! j ¦ « cY d }~t% |¦ « S d }~ww xY w t% |¦ « n# t% |¦ « w xY wt! j ¦ « } | |j ¦ « n*# t, $ r }t! j ¦ « cY d }~S d }~ww xY w|S )Nzutf-8rb zapplication/x-protobuf)z Content-TypezX-Odigos-DeviceIdTr` )ÚdataÚheadersÚtimeout)r! Úencoder Ú sequence_numr" rS ÚSerializeToStringr r r r rw Úpostr Úraise_for_statusÚTimeoutr Ú
ServerToAgentr ÚConnectionErrorÚParseFromStringÚcontentÚNotImplementedError)r$ r Ú
message_bytesr Ú
agent_messageÚresponserG rz s r% rE z,OpAMPHTTPClient.send_agent_to_server_messageà s à #Ô 0× 7Ò 7¸Ñ @Ô @Ô Ø #Ô 5Ô Ø Ô $ð MØ Ô (× 1Ò 1°$Ô2KÑ LÔ LÐ Là Ð Ô !Ñ#Ð Ô Ø ×1Ò1Ñ3Ô3
ð 5Ø!%Ô!?ð
ð
ð
"Ý "¥9Õ-OÐQUÑ#VÔ#VÑ WÔ WMÝ&Ô+¨D¬OÀ-ÐY`ÐjkÐlÑlÔlHØ × %Ò %Ñ 'Ô 'Ð 'Ð 'øÝ Ô&ð -ð -ð -å Ô*Ñ,Ô,Ð ,Ð ,õ
=Ñ !Ô !Ð !Ð !õ Ô.ð -ð -ð -å Ô*Ñ,Ô,Ð ,Ð ,Ð ,Ð ,Ð ,å =Ñ !Ô !Ð !Ð !øøøøð -øøøð
(õ
=Ñ !Ô !Ð !Ð !øF=Ñ !Ô !Ð !Ð !øøøå#Ô1Ñ3Ô3ð -Ø × +Ò +¨HÔ,<Ñ =Ô =Ð =Ð =øÝ"ð -ð -ð -å Ô*Ñ,Ô,Ð ,Ð ,Ð ,Ð ,Ð ,Ð ,øøøøð -øøøð Ð sa ÂAC ÃE Ã"EÃ7E ÄEÄD=Ä(EÄ)E Ä=EÅE ÅE'Å>F Æ
G Æ#F;Æ5G Æ;G c ób | j | j d}| ¦ « D ]
\ }}|s dS dS )N)r r FT)r r r )r$ Úmandatory_env_varsr rV s r% r? z&OpAMPHTTPClient.mandatory_env_vars_set sW à(,Ô(8Ø04Ô0Nð
ð
Ðð
1× 6Ò 6Ñ 8Ô 8ð ð NGUØð
à uuð
ð tr' Úcustom_failure_messagec ó® d| _ |r| |¬¦ « }nN| ddt j j ¬¦ « }t
j t
j ¦ « |¬¦ « }| j 5 | j
¦ « d d d ¦ « n # 1 swxY w Y | j ¦ « |
|¦ « d S )NFr+ zPython runtime is exitingrL )rR rW )r rC rT r Ú
TERMINATEDrV r rP r r Ú
notify_allr; ÚjoinrE )r$ r Údisconnect_messagerY s r% ÚshutdownzOpAMPHTTPClient.shutdown s" Ø à !ð |Ø!%×!JÒ!JÐYoÐ!JÑ!pÔ!pÐ Ð à ×0Ò0À%ÐToõ yJô yUô y[Ð0ñ \ô \LÝ!*Ô!8Í)ÔJcÑJeÔJeÐnzÐ!{Ñ!{Ô!{Ð à
^ð (ð (Ø N× %Ò %Ñ 'Ô 'Ð 'ð (ð (ð (ñ (ô (ð (ð (ð (ð (ð (ð (øøøð (ð (ð (ð (à Ô× Ò Ñ!Ô!Ð!à ×)Ò)Ð*<Ñ=Ô=Ð=Ð=Ð=s Á6B  B Â#B rz c ó | d¦ « r*|j j }t j |¬¦ « }|| _ dS dS )NÚ
remote_config)Úlast_remote_config_hashTF)ÚHasFieldrµ Ú config_hashr ÚRemoteConfigStatusr" )r$ rz Úremote_config_hashr" s r% rh z+OpAMPHTTPClient.update_remote_config_status sK Ø × #Ò # OÑ 4Ô 4ð Ø!0Ô!>Ô!JÐ Ý#,Ô#?ÐXjÐ#kÑ#kÔ#kÐ Ø(<DÔ %Ø4àur' r )rI N)NNN) Ú__name__Ú
__module__Ú __qualname__r8 Ú Conditionr& Úboolr< r: rD rC r6 r@ rA r r£ rt r r[ r rQ r rT rP rE r? r³ rh © r' r% r r sì ð ¨Ô)<ð ð ð ð ð #ð #¨dð #ð #ð #ð #ð ð ð ð( %À#ð %È$ð %ð %ð %ð %ð
DÈð
DÐQUð
Dð
Dð
Dð
Dð !eð !eð !eð !eðH(ð (ð (ð4 Ô 7ð ð ð ð ð
yÔ'Að
ð
ð
ð
ð@+ iÔ&?ð +ð +ð +ð +ð
ð
°ð
È3ð
Ð_bð
Ðnwô oHð
ð
ð
ð
ð" °IÔ4Kð " ÐPYÔPgð " ð " ð " ð " ðH ð ð ð
>ð
>¨sð
>ð
>ð
>ð
>ð ¸9Ô;Rð ÐW[ð ð ð ð ð ð r' r c ó e Zd Zd ZddZdS )ÚMockOpAMPClientc ó@ ddi| _ | ¦ « d S )Nz odigos.opampÚdisabled)r r7 )r$ r ÚargsÚkwargss r% r& zMockOpAMPClient.__init__. s Ø$2°JÐ#?Ô Ø
r' Nc ó d S r rÀ )r$ r s r% r³ zMockOpAMPClient.shutdown2 s Ø r' r )r» r¼ r½ r& r³ rÀ r' r% r r - s7 ðð ð ð
ð
ð
ð
ð
ð
r' r ) r r1 rl r8 rw ÚloggingÚuuid_extensionsr Ú opentelemetry.semconv.resourcer Úopentelemetry.contextr r r r Úopampr r
r Úopamp.health_statusr Ú getLoggerrj ÚK8S_NAMESPACE_NAMEÚK8S_CONTAINER_NAMEÚ K8S_POD_NAMEr r r rÀ r' r% ú<module>rÒ sk ðØ Ø
Ø Ø Ð Ð Ð Ø Ð Ð Ð Ø à !Ð !Ð !Ð !Ð !Ð !Ø =Ð =Ð =Ð =Ð =Ð =ðð ð ð ð ð ð ð ð ð ð ð ð 1Ð 0Ð 0Ð 0Ð 0Ð 0Ð 0Ð 0Ð 0Ð 0Ø 1Ð 1Ð 1Ð 1Ð 1Ð 1ð !wÔ Ñ*Ô* ð "4Ô!FØ /Ô BØ)Ô6ðð Ð ð Ið Ið Ið Ið Iñ Iô Ið Ið^
ð
ð
ð
ð
ñ
ô
ð
ð
ð
r'