/opt/alt/python38/lib64/python3.8/site-packages/aiohttp/__pycache__
Edit: /opt/alt/python38/lib64/python3.8/site-packages/aiohttp/__pycache__/tracing.cpython-38.pyc (14312B)
U
'7`8 @ s d dl mZ d dlmZmZmZmZmZ d dlZd dl m
Z
d dl m Z ddl
mZ ddlmZ erd d lmZ dd
lmZ ed d d
ZG dd dee ZdZG dd dZejd d d dG dd dZejd d d dG dd dZejd d d dG dd dZ ejd d d dG dd dZ ejd d d dG d d d Z ejd d d dG d d d Z ejd d d dG d d! d!Z ejd d d dG d"d# d#Z!ejd d d dG d$d% d%Z"ejd d d dG d&d' d'Z#ejd d d dG d(d) d)Z$ejd d d dG d*d+ d+Z%ejd d d dG d,d- d-Z&ejd d d dG d.d/ d/Z'ejd d d dG d0d1 d1Z(G d2d3 d3Z)dS )4 )SimpleNamespace)
TYPE_CHECKING AwaitableOptionalTypeTypeVarN) CIMultiDict)URL )ClientResponse)Signal)Protocol)
ClientSession_ParamT_contraT)
contravariantc @ s$ e Zd Zeeeed dddZdS )_SignalCallbackN) _SignalCallback__client_session!_SignalCallback__trace_config_ctx_SignalCallback__paramsreturnc C s d S N )selfr r r r r B/opt/alt/python38/lib64/python3.8/site-packages/aiohttp/tracing.py__call__ s z_SignalCallback.__call__)__name__
__module__ __qualname__r r r r r r r r r r s
r ) TraceConfigTraceRequestStartParamsTraceRequestEndParamsTraceRequestExceptionParams TraceConnectionQueuedStartParams TraceConnectionQueuedEndParams TraceConnectionCreateStartParams TraceConnectionCreateEndParams TraceConnectionReuseconnParams TraceDnsResolveHostStartParams TraceDnsResolveHostEndParamsTraceDnsCacheHitParamsTraceDnsCacheMissParamsTraceRequestRedirectParamsTraceRequestChunkSentParams TraceResponseChunkReceivedParamsc @ sZ e Zd ZdZefee ddddZd9ee edddZdd d
d Z e
d d d
dZ e
dd ddZ e
dd ddZ
e
dd ddZe
dd ddZe
dd d d Ze
d d d d Ze
d!d d"d#Ze
d$d d%d&Ze
d'd d(d)Ze
d*d d+d,Ze
d-d d.d/Ze
d0d d1d2Ze
d3d d4d5Ze
d6d d7d8ZdS ):r zJFirst-class used to trace requests launched via ClientSession
objects.N)trace_config_ctx_factoryr c C s 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_trace_config_ctx_factory)r r. r r r __init__4 s\ zTraceConfig.__init__)trace_request_ctxr c C s | j |dS )z( Return a new trace_config_ctx instance )r@ )r> )r r@ r r r trace_config_ctxg s z TraceConfig.trace_config_ctxr c C s | j | j | j | j | j | j | j | j | j | j
| j | j | j
| j | j d S r )r/ freezer0 r1 r2 r3 r4 r5 r6 r7 r8 r9 r: r; r< r= r r r r rC m s
zTraceConfig.freezez0Signal[_SignalCallback[TraceRequestStartParams]]c C s | j S r )r/ rD r r r on_request_start~ s z TraceConfig.on_request_startz4Signal[_SignalCallback[TraceRequestChunkSentParams]]c C s | j S r )r0 rD r r r on_request_chunk_sent s z!TraceConfig.on_request_chunk_sentz9Signal[_SignalCallback[TraceResponseChunkReceivedParams]]c C s | j S r )r1 rD r r r on_response_chunk_received s z&TraceConfig.on_response_chunk_receivedz.Signal[_SignalCallback[TraceRequestEndParams]]c C s | j S r )r2 rD r r r on_request_end s zTraceConfig.on_request_endz4Signal[_SignalCallback[TraceRequestExceptionParams]]c C s | j S r )r3 rD r r r on_request_exception s z TraceConfig.on_request_exceptionz3Signal[_SignalCallback[TraceRequestRedirectParams]]c C s | j S r )r4 rD r r r on_request_redirect s z TraceConfig.on_request_redirectz9Signal[_SignalCallback[TraceConnectionQueuedStartParams]]c C s | j S r )r5 rD r r r on_connection_queued_start s z&TraceConfig.on_connection_queued_startz7Signal[_SignalCallback[TraceConnectionQueuedEndParams]]c C s | j S r )r6 rD r r r on_connection_queued_end s z$TraceConfig.on_connection_queued_endz9Signal[_SignalCallback[TraceConnectionCreateStartParams]]c C s | j S r )r7 rD r r r on_connection_create_start s z&TraceConfig.on_connection_create_startz7Signal[_SignalCallback[TraceConnectionCreateEndParams]]c C s | j S r )r8 rD r r r on_connection_create_end s z$TraceConfig.on_connection_create_endz7Signal[_SignalCallback[TraceConnectionReuseconnParams]]c C s | j S r )r9 rD r r r on_connection_reuseconn s z#TraceConfig.on_connection_reuseconnz7Signal[_SignalCallback[TraceDnsResolveHostStartParams]]c C s | j S r )r: rD r r r on_dns_resolvehost_start s z$TraceConfig.on_dns_resolvehost_startz5Signal[_SignalCallback[TraceDnsResolveHostEndParams]]c C s | j S r )r; rD r r r on_dns_resolvehost_end s z"TraceConfig.on_dns_resolvehost_endz/Signal[_SignalCallback[TraceDnsCacheHitParams]]c C s | j S r )r< rD r r r on_dns_cache_hit s z TraceConfig.on_dns_cache_hitz0Signal[_SignalCallback[TraceDnsCacheMissParams]]c C s | j S r )r= rD r r r on_dns_cache_miss s z TraceConfig.on_dns_cache_miss)N)r r r __doc__r r r? r rA rC propertyrE rF rG rH rI rJ rK rL rM rN rO rP rQ rR rS r r r r r 0 sj 4 r )Z auto_attribsfrozenslotsc @ s* e Zd ZU dZeed< eed< ded< dS )r z1 Parameters sent by the `on_request_start` signalmethodurlCIMultiDict[str]headersN)r r r rT str__annotations__r r r r r r s
r c @ s* e Zd ZU dZeed< eed< eed< dS )r, z6 Parameters sent by the `on_request_chunk_sent` signalrX rY chunkNr r r rT r\ r] r bytesr r r r r, s
r, c @ s* e Zd ZU dZeed< eed< eed< dS )r- z; Parameters sent by the `on_response_chunk_received` signalrX rY r^ Nr_ r r r r r- s
r- c @ s2 e Zd ZU dZeed< eed< ded< eed< dS )r z/ Parameters sent by the `on_request_end` signalrX rY rZ r[ responseNr r r rT r\ r] r r r r r r r s
r c @ s2 e Zd ZU dZeed< eed< ded< eed< dS )r! z5 Parameters sent by the `on_request_exception` signalrX rY rZ r[ exceptionN)r r r rT r\ r] r
BaseExceptionr r r r r! s
r! c @ s2 e Zd ZU dZeed< eed< ded< eed< dS )r+ z4 Parameters sent by the `on_request_redirect` signalrX rY rZ r[ ra Nrb r r r r r+ s
r+ c @ s e Zd ZdZdS )r" z; Parameters sent by the `on_connection_queued_start` signalNr r r rT r r r r r"
s r" c @ s e Zd ZdZdS )r# z9 Parameters sent by the `on_connection_queued_end` signalNre r r r r r# s r# c @ s e Zd ZdZdS )r$ z; Parameters sent by the `on_connection_create_start` signalNre r r r r r$ s r$ c @ s e Zd ZdZdS )r% z9 Parameters sent by the `on_connection_create_end` signalNre r r r r r% s r% c @ s e Zd ZdZdS )r& z8 Parameters sent by the `on_connection_reuseconn` signalNre r r r r r& s r& c @ s e Zd ZU dZeed< dS )r' z9 Parameters sent by the `on_dns_resolvehost_start` signalhostNr r r rT r\ r] r r r r r' # s
r' c @ s e Zd ZU dZeed< dS )r( z7 Parameters sent by the `on_dns_resolvehost_end` signalrf Nrg r r r r r( * s
r( c @ s e Zd ZU dZeed< dS )r) z1 Parameters sent by the `on_dns_cache_hit` signalrf Nrg r r r r r) 1 s
r) c @ s e Zd ZU dZeed< dS )r* z2 Parameters sent by the `on_dns_cache_miss` signalrf Nrg r r r r r* 8 s
r* c @ s( e Zd ZdZdeeddddZeedddd d
Z eee
dd d d
Z eee
dd ddZ eede
ddddZeededdddZeede
ddddZddddZdddd Zddd d Zddd d Zddd!d"Zedd#d$d%Zedd#d&d'Zedd#d(d)Zedd#d*d+ZdS ),TracezcInternal class used to keep together the main dependencies used
at the moment of send a signal.r N)session trace_configrA r c C s || _ || _|| _d S r )
_trace_config_trace_config_ctx_session)r ri rj rA r r r r? C s zTrace.__init__rZ )rX rY r[ r c s$ | j j| j| jt|||I d H S r )rk rE sendrm rl r )r rX rY r[ r r r send_request_startM s
zTrace.send_request_start)rX rY r^ r c s$ | j j| j| jt|||I d H S r )rk rF rn rm rl r, r rX rY r^ r r r send_request_chunk_sentV s
z Trace.send_request_chunk_sentc s$ | j j| j| jt|||I d H S r )rk rG rn rm rl r- rp r r r send_response_chunk_received_ s
z"Trace.send_response_chunk_received)rX rY r[ ra r c s& | j j| j| jt||||I d H S r )rk rH rn rm rl r r rX rY r[ ra r r r send_request_endh s
zTrace.send_request_end)rX rY r[ rc r c s& | j j| j| jt||||I d H S r )rk rI rn rm rl r! )r rX rY r[ rc r r r send_request_exceptionu s
z Trace.send_request_exceptionc s& | j j| j| jt||||I d H S r )rk r4 rn rm rl r+ rs r r r send_request_redirect s
zTrace.send_request_redirectrB c s | j j| j| jt I d H S r )rk rK rn rm rl r" rD r r r send_connection_queued_start s
z"Trace.send_connection_queued_startc s | j j| j| jt I d H S r )rk rL rn rm rl r# rD r r r send_connection_queued_end s
z Trace.send_connection_queued_endc s | j j| j| jt I d H S r )rk rM rn rm rl r$ rD r r r send_connection_create_start s
z"Trace.send_connection_create_startc s | j j| j| jt I d H S r )rk rN rn rm rl r% rD r r r send_connection_create_end s
z Trace.send_connection_create_endc s | j j| j| jt I d H S r )rk rO rn rm rl r& rD r r r send_connection_reuseconn s
z Trace.send_connection_reuseconn)rf r c s | j j| j| jt|I d H S r )rk rP rn rm rl r' r rf r r r send_dns_resolvehost_start s
z Trace.send_dns_resolvehost_startc s | j j| j| jt|I d H S r )rk rQ rn rm rl r( r| r r r send_dns_resolvehost_end s
z Trace.send_dns_resolvehost_endc s | j j| j| jt|I d H S r )rk rR rn rm rl r) r| r r r send_dns_cache_hit s
zTrace.send_dns_cache_hitc s | j j| j| jt|I d H S r )rk rS rn rm rl r* r| r r r send_dns_cache_miss s
zTrace.send_dns_cache_miss)r r r rT r r r? r\ r ro r` rq rr r rt rd ru rv rw rx ry rz r{ r} r~ r r r r r r rh ? s`
rh )*typesr typingr r r r r attrZ multidictr Zyarlr Z
client_reqrepr Zsignalsr Ztyping_extensionsr
Zclientr r r __all__r sr r, r- r r! r+ r" r# r$ r% r& r' r( r) r* rh r r r r
sZ
"