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.2 ▾
|
odigos
/
etc
/
odigos-vmagent
/
instrumentations
/
python
/
opamp
/
__pycache__
/
http_client.cpython-311.pyc
|
|---|
§
Øg³2 ã óÚ 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¦ « Z G d d ¦ « Z G d
d ¦ « ZdS ) é N)Úuuid7)ÚResourceAttributes)Ú"_SUPPRESS_HTTP_INSTRUMENTATION_KEYÚattachÚdetachÚ set_value)Ú opamp_pb2Ú anyvalue_pb2Úutils)ÚAgentHealthStatusÚodigosc ó 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-6culloxw/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" r9 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 r4 Ú send_first_message_with_retryÚworkerÚ ExceptionÚ$get_agent_failure_disconnect_messageÚstrÚ send_agent_to_server_messager. Úexit)r! ÚeÚfailure_messages r" r7 zOpAMPHTTPClient.run4 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_messagerO Ú agent_healths r" r@ z4OpAMPHTTPClient.get_agent_failure_disconnect_messageH 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 rH )
r rM Úget_agent_descriptionÚagent_descriptionrP rN rO rQ r ÚUNSUPPORTED_RUNTIME_VERSIONrS rT rB )r! r) Úfirst_disconnect_messagerY rO rV s r" r3 z;OpAMPHTTPClient.send_unsupported_version_disconnect_messageS 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 startingrI ©rY rT T©rJ rL )rT z2Error sending first message to OpAMP server after z attempts)ÚrangerQ r ÚSTARTINGrS rX rB r rM Ú
ListFieldsÚupdate_remote_config_statusr Ú*parse_first_message_to_resource_attributesÚ opamp_loggerr ÚHEALTHYr? ÚtimeÚsleep)r! Ú max_retriesÚdelayÚattemptrV rY Ú first_message_server_to_agentrD s r" r= z-OpAMPHTTPClient.send_first_message_with_retryb 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 )NTra r` é )r r Úsend_heartbeatre Úflagsr Ú"ServerToAgentFlags_ReportFullStaterX rQ r rh rS rM rB Úrequests_odigosÚRequestExceptionÚwait)r! Úserver_to_agentrY rV Úagent_to_serverrD s r" r> 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 rM r rB rt ru )r! rx rD s r" rq 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 j |g ¬¦ « S )N)Ú string_value)ÚkeyrS )Ú int_valueÚpython)Úidentifying_attributesÚnon_identifying_attributes) r
ÚKeyValuer ÚSERVICE_INSTANCE_IDÚAnyValuer Ú PROCESS_PIDr ÚgetpidÚTELEMETRY_SDK_LANGUAGEr ÚAgentDescription)r! r s r" rX z%OpAMPHTTPClient.get_agent_description© s½ å Ô !Ý&Ô:Ý"Ô+¸Ô9JÐKÑKÔKð
ñ
ô
õ
Ô !Ý&Ô2Ý"Ô+µb´i±k´kÐBÑBÔBð
ñ
ô
õ
Ô !Ý&Ô=Ý"Ô+¸ÐBÑBÔBð
ñ
ô
ð
"
Ð õ Ô)Ø#9Ø')ð
ñ
ô
ð
r$ c ó( t j ¦ « S ©N)r ÚAgentDisconnect)r! s r" rN z$OpAMPHTTPClient.get_agent_disconnect¾ s ÝÔ(Ñ*Ô*Ð*r$ rJ rK rL c ób t j ¦ « }|||_ |||_ |||_ |S r )r ÚComponentHealthÚhealthyrK rL )r! rJ rK rL rT s r" rQ 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-8r_ zapplication/x-protobuf)z Content-TypezX-Odigos-DeviceIdTr] )ÚdataÚheadersÚtimeout)r Úencoder Ú sequence_numr rP ÚSerializeToStringr r r r rt Úpostr Úraise_for_statusÚTimeoutr Ú
ServerToAgentr ÚConnectionErrorÚParseFromStringÚcontentÚNotImplementedError)r! r Ú
message_bytesr Ú
agent_messageÚresponserD rw s r" rB 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 Úitems)r! Úmandatory_env_varsÚenv_varrS 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 exitingrI )rO rT )r r@ rQ r Ú
TERMINATEDrS r rM r r Ú
notify_allr8 ÚjoinrB )r! r¥ Údisconnect_messagerV 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 rw c ó | d¦ « r*|j j }t j |¬¦ « }|| _ dS dS )NÚ
remote_config)Úlast_remote_config_hashTF)ÚHasFieldr Ú config_hashr ÚRemoteConfigStatusr )r! rw Úremote_config_hashr s r" re z+OpAMPHTTPClient.update_remote_config_status sK Ø × #Ò # OÑ 4Ô 4ð Ø!0Ô!>Ô!JÐ Ý#,Ô#?ÐXjÐ#kÑ#kÔ#kÐ Ø(<DÔ %Ø4àur$ r )rF N)NNN) Ú__name__Ú
__module__Ú __qualname__r5 Ú Conditionr# Úboolr9 r7 rA r@ r3 r= r> r r rq r rX r rN r rQ rM rB r< r« re © 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 r4 )r! r ÚargsÚkwargss r" r# zMockOpAMPClient.__init__ s Ø$2°JÐ#?Ô Ø
r$ Nc ó d S r r¸ )r! r¥ s r" r« zMockOpAMPClient.shutdown s Ø r$ r )r³ r´ rµ r# r« r¸ r$ r" rº rº s7 ðð ð ð
ð
ð
ð
ð
ð
r$ rº )r r. ri r5 rt ÚloggingÚuuid_extensionsr Ú opentelemetry.semconv.resourcer Úopentelemetry.contextr r r r Úopampr r
r Úopamp.health_statusr Ú getLoggerrg r rº r¸ r$ r" ú<module>rÇ sJ ðØ Ø
Ø Ø Ð Ð Ð Ø Ð Ð Ð Ø à !Ð !Ð !Ð !Ð !Ð !Ø =Ð =Ð =Ð =Ð =Ð =ðð ð ð ð ð ð ð ð ð ð ð ð 1Ð 0Ð 0Ð 0Ð 0Ð 0Ð 0Ð 0Ð 0Ð 0Ø 1Ð 1Ð 1Ð 1Ð 1Ð 1ð !wÔ Ñ*Ô* ð~ð ~ð ~ð ~ð ~ñ ~ô ~ð ~ðH
ð
ð
ð
ð
ñ
ô
ð
ð
ð
r$