E! d dl mZ d dlmZmZmZmZmZ d dlZd dl m
Z
d dl m Z d dl
mZ ddlmZ er-dd lmZ dd
lmZ ed d
Z G d dee ZdZ G d d Z ej d d d G d d Z ej d d d G d d Z ej d d d G d d Z ej d d d G d d Z ej d d d G d d Z ej d d d G d d Z ej d d d G d d! Z ej d d d G d" d# Z! ej d d d G d$ d% Z" ej d d d G d& d' Z# ej d d d G d( d) Z$ ej d d d G d* d+ Z% ej d d d G d, d- Z& ej d d d G d. d/ Z' ej d d d G d0 d1 Z( ej d d d G d2 d3 Z) G d4 d5 Z*dS )6 )SimpleNamespace)
TYPE_CHECKING AwaitableOptionalTypeTypeVarN)Signal) CIMultiDict)URL )ClientResponse)
ClientSession)Protocol_ParamT_contraT)
contravariantc 2 e Zd Zdedededed fdZdS )_SignalCallback _SignalCallback__client_session!_SignalCallback__trace_config_ctx_SignalCallback__paramsreturnNc d S N )selfr r r s q/builddir/build/BUILD/imunify360-venv-2.6.2/opt/imunify360/venv/lib64/python3.11/site-packages/aiohttp/tracing.py__call__z_SignalCallback.__call__ s
C )__name__
__module__ __qualname__r r r r r r r r r r sR + !0 %
t_ r r ) TraceConfigTraceRequestStartParamsTraceRequestEndParamsTraceRequestExceptionParams TraceConnectionQueuedStartParams TraceConnectionQueuedEndParams TraceConnectionCreateStartParams TraceConnectionCreateEndParams TraceConnectionReuseconnParams TraceDnsResolveHostStartParams TraceDnsResolveHostEndParamsTraceDnsCacheHitParamsTraceDnsCacheMissParamsTraceRequestRedirectParamsTraceRequestChunkSentParams TraceResponseChunkReceivedParams TraceRequestHeadersSentParamsc
e Zd ZdZefdee ddfdZ d)dee defdZd*dZ e
d+d
Z e
d,d Z e
d-d Z
e
d.d Ze
d/d Ze
d0d Ze
d1d Ze
d2d Ze
d3d Ze
d4d Ze
d5d Ze
d6d Ze
d7d" Ze
d8d$ Ze
d9d& Ze
d:d( ZdS );r" zFFirst-class used to trace requests launched via ClientSession objects.trace_config_ctx_factoryr Nc t | | _ t | | _ t | | _ t | | _ t | | _ t | | _ t | | _ t | | _ t | | _ t | | _
t | | _ t | | _ t | | _
t | | _ t | | _ t | | _ || _ d S r )r _on_request_start_on_request_chunk_sent_on_response_chunk_received_on_request_end_on_request_exception_on_request_redirect_on_connection_queued_start_on_connection_queued_end_on_connection_create_start_on_connection_create_end_on_connection_reuseconn_on_dns_resolvehost_start_on_dns_resolvehost_end_on_dns_cache_hit_on_dns_cache_miss_on_request_headers_sent_trace_config_ctx_factory)r r4 s r __init__zTraceConfig.__init__3 sK
4LL
4LL
#
4LL
( PV P
P
4LL
"
4LL
!
4LL
(
4LL
&
4LL
(
4LL
&
4LL
%
4LL
&
4LL
$
4LL
4LL
4LL
% *B&&&r trace_request_ctxc . | | S )z&Return a new trace_config_ctx instance)rH )rF )r rH s r trace_config_ctxz TraceConfig.trace_config_ctxi s --@Q-RRRr c & | j | j | j | j | j | j | j | j | j | j
| j | j | j
| j | j | j d S r )r6 freezer7 r8 r9 r: r; r< r= r> r? r@ rA rB rC rD rE r s r rL zTraceConfig.freezeo sX %%''' #**,,, (//111 ##%%% "))+++ !((*** (//111 &--/// (//111 &--/// %,,... &--/// $++--- %%''' &&((( %,,.....r 0Signal[_SignalCallback[TraceRequestStartParams]]c | j S r )r6 rM s r on_request_startz TraceConfig.on_request_start %%r 4Signal[_SignalCallback[TraceRequestChunkSentParams]]c | j S r )r7 rM s r on_request_chunk_sentz!TraceConfig.on_request_chunk_sent s
**r 9Signal[_SignalCallback[TraceResponseChunkReceivedParams]]c | j S r )r8 rM s r on_response_chunk_receivedz&TraceConfig.on_response_chunk_received
//r .Signal[_SignalCallback[TraceRequestEndParams]]c | j S r )r9 rM s r on_request_endzTraceConfig.on_request_end s ##r 4Signal[_SignalCallback[TraceRequestExceptionParams]]c | j S r )r: rM s r on_request_exceptionz TraceConfig.on_request_exception s
))r 3Signal[_SignalCallback[TraceRequestRedirectParams]]c | j S r )r; rM s r on_request_redirectz TraceConfig.on_request_redirect s
((r 9Signal[_SignalCallback[TraceConnectionQueuedStartParams]]c | j S r )r< rM s r on_connection_queued_startz&TraceConfig.on_connection_queued_start rX r 7Signal[_SignalCallback[TraceConnectionQueuedEndParams]]c | j S r )r= rM s r on_connection_queued_endz$TraceConfig.on_connection_queued_end
--r 9Signal[_SignalCallback[TraceConnectionCreateStartParams]]c | j S r )r> rM s r on_connection_create_startz&TraceConfig.on_connection_create_start rX r 7Signal[_SignalCallback[TraceConnectionCreateEndParams]]c | j S r )r? rM s r on_connection_create_endz$TraceConfig.on_connection_create_end rh r 7Signal[_SignalCallback[TraceConnectionReuseconnParams]]c | j S r )r@ rM s r on_connection_reuseconnz#TraceConfig.on_connection_reuseconn
,,r 7Signal[_SignalCallback[TraceDnsResolveHostStartParams]]c | j S r )rA rM s r on_dns_resolvehost_startz$TraceConfig.on_dns_resolvehost_start rh r 5Signal[_SignalCallback[TraceDnsResolveHostEndParams]]c | j S r )rB rM s r on_dns_resolvehost_endz"TraceConfig.on_dns_resolvehost_end s
++r /Signal[_SignalCallback[TraceDnsCacheHitParams]]c | j S r )rC rM s r on_dns_cache_hitz TraceConfig.on_dns_cache_hit rQ r 0Signal[_SignalCallback[TraceDnsCacheMissParams]]c | j S r )rD rM s r on_dns_cache_missz TraceConfig.on_dns_cache_miss s &&r 6Signal[_SignalCallback[TraceRequestHeadersSentParams]]c | j S r )rE rM s r on_request_headers_sentz#TraceConfig.on_request_headers_sent rr r r r N)r rN )r rR )r rU )r rY )r r\ )r r_ )r rb )r re )r ri )r rl )r ro )r rs )r rv )r ry )r r| )r r )r r r! __doc__r r rG r rJ rL propertyrP rT rW r[ r^ ra rd rg rk rn rq ru rx r{ r~ r r r r r" r" 0 s PP AP4B 4B(,_(=4B
4B 4B 4B 4Bn >BS S!)/!:S S S S S / / / /$ & & & X& + ?+ + + X+
0 D0 0 0 X0
$ $ $ X$ * ?* * * X*
) >) ) ) X)
0 D0 0 0 X0
. B. . . X.
0 D0 0 0 X0
. B. . . X.
- B- - - X-
. B. . . X.
, @, , , X,
& & & X& ' ' ' X' - A- - - X- - -r r" ) auto_attribsfrozenslotsc 2 e Zd ZU dZeed< eed< ded< dS )r# z0Parameters sent by the `on_request_start` signalmethodurlCIMultiDict[str]headersNr r r! r str__annotations__r r r r r# r# s6 :: KKK HHH
r r# c 2 e Zd ZU dZeed< eed< eed< dS )r0 z5Parameters sent by the `on_request_chunk_sent` signalr r chunkNr r r! r r r r bytesr r r r0 r0 s1 ?? KKK HHH LLLLLr r0 c 2 e Zd ZU dZeed< eed< eed< dS )r1 z:Parameters sent by the `on_response_chunk_received` signalr r r Nr r r r r1 r1 s1 DD KKK HHH LLLLLr r1 c < e Zd ZU dZeed< eed< ded< eed< dS )r$ z.Parameters sent by the `on_request_end` signalr r r r responseNr r r! r r r r r
r r r r$ r$ sB 88 KKK HHH
r r$ c < e Zd ZU dZeed< eed< ded< eed< dS )r% z4Parameters sent by the `on_request_exception` signalr r r r exceptionN)r r r! r r r r
BaseExceptionr r r r% r% sB >> KKK HHH
r r% c < e Zd ZU dZeed< eed< ded< eed< dS )r/ z3Parameters sent by the `on_request_redirect` signalr r r r r Nr r r r r/ r/ sB == KKK HHH
r r/ c e Zd ZdZdS )r& z:Parameters sent by the `on_connection_queued_start` signalNr r r! r r r r r& r& DDDDr r& c e Zd ZdZdS )r' z8Parameters sent by the `on_connection_queued_end` signalNr r r r r' r' BBBBr r' c e Zd ZdZdS )r( z:Parameters sent by the `on_connection_create_start` signalNr r r r r( r( r r r( c e Zd ZdZdS )r) z8Parameters sent by the `on_connection_create_end` signalNr r r r r) r) " r r r) c e Zd ZdZdS )r* z7Parameters sent by the `on_connection_reuseconn` signalNr r r r r* r* ' s AAAAr r* c e Zd ZU dZeed< dS )r+ z8Parameters sent by the `on_dns_resolvehost_start` signalhostNr r r! r r r r r r r+ r+ , s BB
IIIIIr r+ c e Zd ZU dZeed< dS )r, z6Parameters sent by the `on_dns_resolvehost_end` signalr Nr r r r r, r, 3 s @@
IIIIIr r, c e Zd ZU dZeed< dS )r- z0Parameters sent by the `on_dns_cache_hit` signalr Nr r r r r- r- : s ::
IIIIIr r- c e Zd ZU dZeed< dS )r. z1Parameters sent by the `on_dns_cache_miss` signalr Nr r r r r. r. A s ;;
IIIIIr r. c 2 e Zd ZU dZeed< eed< ded< dS )r2 z7Parameters sent by the `on_request_headers_sent` signalr r r r Nr r r r r2 r2 H s6 AA KKK HHH
r r2 c
F e Zd ZdZdddededdfdZd ed
ed d ddfd
Z d ed
ede
ddfdZ d ed
ede
ddfdZ d ed
ed d de
ddf
dZd ed
ed d deddf
dZd ed
ed d de
ddf
dZd!dZd!dZd!dZd!dZd!dZdeddfd Zdeddfd Zdeddfd Zdeddfd Zd ed
ed d ddfd ZdS )"TracezInternal dependency holder class.
Used to keep together the main dependencies used
at the moment of send a signal.
sessionr trace_configrJ r Nc 0 || _ || _ || _ d S r )
_trace_config_trace_config_ctx_session)r r r rJ s r rG zTrace.__init__X s *!1
r r r r r c K | j j | j | j t ||| d {V S r )r rP sendr r r# r r r r s r send_request_startzTrace.send_request_startb s^ '8== M " #FC 9 9
r r c K | j j | j | j t ||| d {V S r )r rT r r r r0 r r r r s r send_request_chunk_sentz Trace.send_request_chunk_sentk s^ '=BB M " 'U ; ;
r c K | j j | j | j t ||| d {V S r )r rW r r r r1 r s r send_response_chunk_receivedz"Trace.send_response_chunk_receivedt s^ 'BGG M " ,VS% @ @
r r c
K | j j | j | j t |||| d {V S r )r r[ r r r r$ r r r r r s r send_request_endzTrace.send_request_end} s` '6;; M " !&#w A A
r r c
K | j j | j | j t |||| d {V S r )r r^ r r r r% )r r r r r s r send_request_exceptionz Trace.send_request_exception s` '<AA M " 'Wi H H
r c
K | j j | j | j t |||| d {V S r )r r; r r r r/ r s r send_request_redirectzTrace.send_request_redirect s` '<AA M " &vsGX F F
r c K | j j | j | j t d {V S r )r rd r r r r& rM s r send_connection_queued_startz"Trace.send_connection_queued_start U 'BGG M413S3U3U
r c K | j j | j | j t d {V S r )r rg r r r r' rM s r send_connection_queued_endz Trace.send_connection_queued_end U '@EE M413Q3S3S
r c K | j j | j | j t d {V S r )r rk r r r r( rM s r send_connection_create_startz"Trace.send_connection_create_start r r c K | j j | j | j t d {V S r )r rn r r r r) rM s r send_connection_create_endz Trace.send_connection_create_end r r c K | j j | j | j t d {V S r )r rq r r r r* rM s r send_connection_reuseconnz Trace.send_connection_reuseconn sU '?DD M413Q3S3S
r r c K | j j | j | j t | d {V S r )r ru r r r r+ r r s r send_dns_resolvehost_startz Trace.send_dns_resolvehost_start sX '@EE M413QRV3W3W
r c K | j j | j | j t | d {V S r )r rx r r r r, r s r send_dns_resolvehost_endz Trace.send_dns_resolvehost_end sX '>CC M413OPT3U3U
r c K | j j | j | j t | d {V S r )r r{ r r r r- r s r send_dns_cache_hitzTrace.send_dns_cache_hit sW '8== M413I$3O3O
r c K | j j | j | j t | d {V S r )r r~ r r r r. r s r send_dns_cache_misszTrace.send_dns_cache_miss sW '9>> M413J43P3P
r c K | j j | j | j t ||| d {V S r )r rE r r r r2 r s r send_request_headerszTrace.send_request_headers s^ '@EE M " )&#w ? ?
r r ) r r r! r r" r rG r r r r r r r
r r r r r r r r r r r r r r r r r r r Q s " *
#
.@
#
,1
#
,1
$
!
$
!
$
!
S
T
3
4
S
T
c
d
#
.@
r r )+typesr typingr r r r r attr aiosignalr multidictr
yarlr
client_reqrepr
clientr typedefsr r r __all__r" sr# r0 r1 r$ r% r/ r& r' r( r) r* r+ r, r- r. r2 r r r r r s ! ! ! ! ! ! D D D D D D D D D D D D D D ! ! ! ! ! ! ) ) ) ) ) )
%%%%%%"""""" W -TBBBN (>2 *g- g- g- g- g- g- g- g-T T$d333 43 T$d333 43 T$d333 43 T$d333 43 T$d333 43 T$d333 43 T$d333E E E E E E E 43E T$d333C C C C C C C 43C T$d333E E E E E E E 43E T$d333C C C C C C C 43C T$d333B B B B B B B 43B T$d333 43 T$d333 43 T$d333 43 T$d333 43 T$d333 43 G
G
G
G
G
G
G
G
G
G
r