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.10 ▾
|
odigos
/
etc
/
odigos-vmagent
/
instrumentations
/
python
/
opamp
/
__pycache__
/
http_client.cpython-311.pyc
|
|---|
§
|QÄgþ5 ã ó 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 fdZd defdZd Zd de d ed
dfd Z
de d
dfd Z d d
Z d Z
d
ej fdZd
ej fdZd
ej fdZd d ede de d
ej fdZdej d
ej fdZd Zd de d efdZdej d
efdZdS )!ÚOpAMPHTTPClientÚ conditionc ó t j d¦ « | _ d| j d| _ i | _ i | _ d| _ || _ || _ d| _ t ¦ « ¦ « | _ d | _
d | _ d S )NÚODIGOS_OPAMP_SERVER_HOSTzhttp://z /v1/opampTr )ÚosÚgetenvÚ server_hostÚ
server_urlÚresource_attributesÚsignalsÚrunningr ÚeventÚnext_sequence_numr Ú__str__Ú instance_uidÚremote_config_statusÚsampler)Úselfr r s ú8/tmp/pip-target-ix0fus71/lib/python/opamp/http_client.pyÚ__init__zOpAMPHTTPClient.__init__ s Ý 9Ð%?Ñ@Ô@ÔØ? 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 r6 Ú send_first_message_with_retryÚworkerÚ ExceptionÚ$get_agent_failure_disconnect_messageÚstrÚ send_agent_to_server_messager0 Úexit)r# ÚeÚfailure_messages r$ r9 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-Fr+ Úcomponent_healthÚreturnc ó
t j ¦ « }| ¦ « }|j |¦ « | ||t j j ¬¦ « }|j |¦ « |S )N©rH Ú
last_errorÚstatus)
r Ú
AgentToServerÚget_agent_disconnectÚagent_disconnectÚCopyFromÚget_agent_healthr Ú
AGENT_FAILUREÚvalueÚhealth)r# r+ rH Úagent_failure_messagerP Ú agent_healths r$ rB z4OpAMPHTTPClient.get_agent_failure_disconnect_messageO s Ý )Ô 7Ñ 9Ô 9Ð à ×4Ò4Ñ6Ô6ÐØ Ô.×7Ò7Ð8HÑIÔIÐIà×,Ò,Ð>NÐ[hõ rCô rQô rWÐ,ñ Xô X Ø Ô$×-Ò-¨lÑ;Ô;Ð;à$Ð$r& c ó t j ¦ « }| ¦ « }|j |¦ « | ¦ « }|j |¦ « | d|t j j
¬¦ « }|j |¦ « | |¦ « d S )NFrK )
r rN Úget_agent_descriptionÚagent_descriptionrQ rO rP rR r ÚUNSUPPORTED_RUNTIME_VERSIONrT rU rD )r# r+ Úfirst_disconnect_messagerZ rP rW s r$ r5 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}d}t d|dz ¦ « D ]u} | ddt j j ¬¦ « }| ¦ « }| t j ||¬¦ « ¦ « }| ¦ « rÇ|
|¦ « t j |j
j j ¦ « }t j |t" ¦ « | _ t j |t" ¦ « | _ | dt j j ¬ ¦ « }| t j |¬
¦ « ¦ « d S n# t, $ r
}Y d }~nd }~ww xY w||k rt/ j |¦ « wt- d | d ¦ « )
Né é é Fz&Python OpenTelemetry agent is startingrK ©rZ rU T©rH rM )rU z2Error sending first message to OpAMP server after z attempts)ÚrangerR r ÚSTARTINGrT rY rD r rN Ú
ListFieldsÚupdate_remote_config_statusr Úget_sdk_configÚ
remote_configÚconfigÚ
config_mapÚ*parse_first_message_to_resource_attributesÚ opamp_loggerr Úparse_first_message_signalsr ÚHEALTHYrA ÚtimeÚsleep) r# Ú max_retriesÚdelayÚattemptrW rZ Ú first_message_server_to_agentÚ
sdk_configrF 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å!&Ô!5Ð6SÔ6aÔ6hÔ6sÑ!tÔ!tJÝ/4Ô/_Ð`jÕlxÑ/yÔ/yDÔ,Ý#(Ô#DÀZÕQ]Ñ#^Ô#^DLð $(×#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 D<E Å
E0Å+E0c ó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 )NTrb ra é )r r Úsend_heartbeatrf Úflagsr Ú"ServerToAgentFlags_ReportFullStaterY rR r rn rT rN rD Úrequests_odigosÚRequestExceptionÚwait)r# Úserver_to_agentrZ rW Úagent_to_serverrF 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 rN r! rD r{ r| )r# r rF s r$ rx 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)ÚkeyrT )Ú 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_keyrT s r$ rY 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$ rO z$OpAMPHTTPClient.get_agent_disconnectÓ s ÝÔ(Ñ*Ô*Ð*r& rL rM c ób t j ¦ « }|||_ |||_ |||_ |S r )r ÚComponentHealthÚhealthyrL rM )r# rH rL rM rU s r$ rR z OpAMPHTTPClient.get_agent_healthÖ sA ÝÔ*ñ
ô
à Ð 'Ø -FNØ Ð !Ø *FÔ Ø Ð Ø "FMà
r& Úmessagec ó~ | j d¦ « |_ | j |_ | j r |j | j ¦ « | xj dz
c_ | ¦ « }ddi} 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` z Content-Typezapplication/x-protobufTr^ )ÚdataÚheadersÚtimeout)r Úencoder Ú sequence_numr! rQ ÚSerializeToStringr r r r{ Úpostr Úraise_for_statusÚTimeoutr Ú
ServerToAgentr ÚConnectionErrorÚParseFromStringÚcontentÚNotImplementedError)r# r Ú
message_bytesr Ú
agent_messageÚresponserF r~ s r$ rD z,OpAMPHTTPClient.send_agent_to_server_messageã sø à #Ô 0× 7Ò 7¸Ñ @Ô @Ô Ø #Ô 5Ô Ø Ô $ð MØ Ô (× 1Ò 1°$Ô2KÑ LÔ LÐ Là Ð Ô !Ñ#Ð Ô Ø ×1Ò1Ñ3Ô3
ð
Ð 4ð
ð "Ý "¥9Õ-OÐQUÑ#VÔ#VÑ WÔ WMÝ&Ô+¨D¬OÀ-ÐY`ÐjkÐlÑlÔlHØ × %Ò %Ñ 'Ô 'Ð 'Ð 'øÝ Ô&ð -ð -ð -å Ô*Ñ,Ô,Ð ,Ð ,õ
=Ñ !Ô !Ð !Ð !õ Ô.ð -ð -ð -å Ô*Ñ,Ô,Ð ,Ð ,Ð ,Ð ,Ð ,å =Ñ !Ô !Ð !Ð !øøøøð -øøøð
(õ
=Ñ !Ô !Ð !Ð !øF=Ñ !Ô !Ð !Ð !øøøå#Ô1Ñ3Ô3ð -Ø × +Ò +¨HÔ,<Ñ =Ô =Ð =Ð =øÝ"ð -ð -ð -å Ô*Ñ,Ô,Ð ,Ð ,Ð ,Ð ,Ð ,Ð ,øøøøð -øøøð Ð sa Á;AC ÃE Ã"D<Ã1E ÄD<ÄD7Ä"D<Ä#E Ä7D<Ä<E ÅE!Å8F Æ
F:Æ F5Æ/F:Æ5F:c óV d| j i}| ¦ « D ]
\ }}|s dS dS )Nr FT)r r )r# Úmandatory_env_varsr rT s r$ r> z&OpAMPHTTPClient.mandatory_env_vars_set sN à &¨Ô(8ð
Ðð 1× 6Ò 6Ñ 8Ô 8ð ð NGUØð
à uuð
ð tr& Úcustom_failure_messagec ó° d| _ |r| ||¬¦ « }nN| |dt j j ¬¦ « }t
j t
j ¦ « |¬¦ « }| j 5 | j
¦ « d d d ¦ « n # 1 swxY w Y | j ¦ « |
|¦ « d S )NF)r+ rH zPython runtime is exitingrK )rP rU )r rB rR r Ú
TERMINATEDrT r rN r r Ú
notify_allr: ÚjoinrD )r# r± rH Údisconnect_messagerW s r$ ÚshutdownzOpAMPHTTPClient.shutdown s0 Ø à !ð |Ø!%×!JÒ!JÐYoð CSÐ!Jñ "Tô "TÐ Ð à ×0Ò0ÐBRÐ_zõ DUô D`ô DfÐ0ñ gô gLÝ!*Ô!8Í)ÔJcÑJeÔJeÐnzÐ!{Ñ!{Ô!{Ð à
^ð (ð (Ø N× %Ò %Ñ 'Ô 'Ð 'ð (ð (ð (ñ (ô (ð (ð (ð (ð (ð (ð (øøøð (ð (ð (ð (à Ô× Ò Ñ!Ô!Ð!à ×)Ò)Ð*<Ñ=Ô=Ð=Ð=Ð=s Á7B  B!Â$B!r~ c ó | d¦ « r*|j j }t j |¬¦ « }|| _ dS dS )Nrh )Úlast_remote_config_hashTF)ÚHasFieldrh Ú config_hashr ÚRemoteConfigStatusr! )r# r~ Úremote_config_hashr! s r$ rf z+OpAMPHTTPClient.update_remote_config_status! sK Ø × #Ò # OÑ 4Ô 4ð Ø!0Ô!>Ô!JÐ Ý#,Ô#?ÐXjÐ#kÑ#kÔ#kÐ Ø(<DÔ %Ø4àur& r )F)rI N)NNN)NF) Ú__name__Ú
__module__Ú __qualname__r7 Ú Conditionr% Úboolr; r9 rC rB r5 r? r@ r r§ rx r rY r rO r rR rN rD r> r· rf © r& r$ r r s ð ¨Ô)<ð ð ð ð ð #ð #¨dð #ð #ð #ð #ð ð ð ð( %ð %À#ð %ÐY]ð %Ðjnð %ð %ð %ð %ð
DÈð
DÐQUð
Dð
Dð
Dð
Dð $eð $eð $eð $eðN(ð (ð (ð4 Ô 7ð ð ð ð ð
yÔ'Að
ð
ð
ð
ð@+ iÔ&?ð +ð +ð +ð +ð
ð
°ð
È3ð
Ð_bð
Ðnwô oHð
ð
ð
ð
ð! °IÔ4Kð ! ÐPYÔPgð ! ð ! ð ! ð ! ðF
ð
ð
ð
>ð
>¨sð
>ÈTð
>ð
>ð
>ð
>ð ¸9Ô;Rð ÐW[ð ð ð ð ð ð r& r c ó e Zd Zd ZddZdS )ÚMockOpAMPClientc óR ddi| _ ddi| _ | ¦ « d S )Nz odigos.opampÚdisabledÚ traceSignalT)r r r6 )r# r ÚargsÚkwargss r$ r% zMockOpAMPClient.__init__/ s, Ø$2°JÐ#?Ô Ø% tÐ, Ø
r& Nc ó d S r rà )r# r± s r$ r· zMockOpAMPClient.shutdown4 s Ø r& r )r¾ r¿ rÀ r% r· rà r& r$ rÅ rÅ . s7 ðð ð ð
ð
ð
ð
ð
ð
r& rÅ ) r r0 ro r7 r{ ÚloggingÚuuid_extensionsr Ú opentelemetry.semconv.resourcer Úopentelemetry.contextr r r r Úopampr r
r Úopamp.health_statusr Ú getLoggerrl Ú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ðð Ð ð Jð Jð Jð Jð Jñ Jô Jð Jð`
ð
ð
ð
ð
ñ
ô
ð
ð
ð
r&