/usr/local/lib64/python3.6/site-packages/aiohttp/__pycache__
Edit: /usr/local/lib64/python3.6/site-packages/aiohttp/__pycache__/tracing.cpython-36.pyc (14857B)
3
8%EgI; @ s d dl mZ d dlmZmZmZmZmZ d dlZd dl m
Z
d dl m Z d dl
mZ ddlmZ erdd lmZ dd
lmZ ed d d
ZG dd dee Zd5ZG d!d dZejd d d d"G d#d dZejd d d d"G d$d d Zejd d d d"G d%d d Z ejd d d d"G d&d dZ ejd d d d"G d'd dZ ejd d d d"G d(d d Z ejd d d d"G d)d dZ ejd d d d"G d*d dZ!ejd d d d"G d+d dZ"ejd d d d"G d,d dZ#ejd d d d"G d-d dZ$ejd d d d"G d.d dZ%ejd d d d"G d/d dZ&ejd d d d"G d0d dZ'ejd d d d"G d1d d Z(ejd d d d"G d2d d Z)G d3d4 d4Z*dS )6 )SimpleNamespace)
TYPE_CHECKING AwaitableOptionalTypeTypeVarN)Signal) CIMultiDict)URL )ClientResponse)
ClientSession)Protocol_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 ;/usr/local/lib64/python3.6/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 TraceResponseChunkReceivedParams TraceRequestHeadersSentParamsc @ sl e Zd ZdZefee ddddZd
)r r r r rC o s
zTraceConfig.freezez0Signal[_SignalCallback[TraceRequestStartParams]]c C s | j S )N)r/ )r r r r on_request_start s z TraceConfig.on_request_startz4Signal[_SignalCallback[TraceRequestChunkSentParams]]c C s | j S )N)r0 )r r r r on_request_chunk_sent s z!TraceConfig.on_request_chunk_sentz9Signal[_SignalCallback[TraceResponseChunkReceivedParams]]c C s | j S )N)r1 )r r r r on_response_chunk_received s z&TraceConfig.on_response_chunk_receivedz.Signal[_SignalCallback[TraceRequestEndParams]]c C s | j S )N)r2 )r r r r on_request_end s zTraceConfig.on_request_endz4Signal[_SignalCallback[TraceRequestExceptionParams]]c C s | j S )N)r3 )r r r r on_request_exception s z TraceConfig.on_request_exceptionz3Signal[_SignalCallback[TraceRequestRedirectParams]]c C s | j S )N)r4 )r r r r on_request_redirect s z TraceConfig.on_request_redirectz9Signal[_SignalCallback[TraceConnectionQueuedStartParams]]c C s | j S )N)r5 )r r r r on_connection_queued_start s z&TraceConfig.on_connection_queued_startz7Signal[_SignalCallback[TraceConnectionQueuedEndParams]]c C s | j S )N)r6 )r r r r on_connection_queued_end s z$TraceConfig.on_connection_queued_endz9Signal[_SignalCallback[TraceConnectionCreateStartParams]]c C s | j S )N)r7 )r r r r on_connection_create_start s z&TraceConfig.on_connection_create_startz7Signal[_SignalCallback[TraceConnectionCreateEndParams]]c C s | j S )N)r8 )r r r r on_connection_create_end s z$TraceConfig.on_connection_create_endz7Signal[_SignalCallback[TraceConnectionReuseconnParams]]c C s | j S )N)r9 )r r r r on_connection_reuseconn s z#TraceConfig.on_connection_reuseconnz7Signal[_SignalCallback[TraceDnsResolveHostStartParams]]c C s | j S )N)r: )r r r r on_dns_resolvehost_start s z$TraceConfig.on_dns_resolvehost_startz5Signal[_SignalCallback[TraceDnsResolveHostEndParams]]c C s | j S )N)r; )r r r r on_dns_resolvehost_end s z"TraceConfig.on_dns_resolvehost_endz/Signal[_SignalCallback[TraceDnsCacheHitParams]]c C s | j S )N)r< )r r r r on_dns_cache_hit s z TraceConfig.on_dns_cache_hitz0Signal[_SignalCallback[TraceDnsCacheMissParams]]c C s | j S )N)r= )r r r r on_dns_cache_miss s z TraceConfig.on_dns_cache_missz6Signal[_SignalCallback[TraceRequestHeadersSentParams]]c C s | j S )N)r> )r r r r on_request_headers_sent s z#TraceConfig.on_request_headers_sent)N)r r r __doc__r r r@ r rB rC propertyrD rE rF rG rH rI rJ rK rL rM rN rO rP rQ rR rS r r r r r 0 sL
5)Z auto_attribsfrozenslotsc @ s e Zd ZU dZeeddS )r z0Parameters sent by the `on_request_start` signalzCIMultiDict[str]N) r r r rT strmethodr
urlheadersr r r r r s
c @ s e Zd ZU dZeee dS )r+ z5Parameters sent by the `on_request_chunk_sent` signalN)
r r r rT rX rY r
rZ byteschunkr r r r r+ s
c @ s e Zd ZU dZeee dS )r, z:Parameters sent by the `on_response_chunk_received` signalN)
r r r rT rX rY r
rZ r\ r] r r r r r, s
c @ s" e Zd ZU dZeede
dS )r z.Parameters sent by the `on_request_end` signalzCIMultiDict[str]N) r r r rT rX rY r
rZ r[ r responser r r r r s
c @ s" e Zd ZU dZeede
dS )r z4Parameters sent by the `on_request_exception` signalzCIMultiDict[str]N) r r r rT rX rY r
rZ r[
BaseException exceptionr r r r r s
c @ s" e Zd ZU dZeede
dS )r* z3Parameters sent by the `on_request_redirect` signalzCIMultiDict[str]N) r r r rT rX rY r
rZ r[ r r^ r r r r r* s
c @ s e Zd ZdZdS )r! z:Parameters sent by the `on_connection_queued_start` signalN)r r r rT r r r r r! s c @ s e Zd ZdZdS )r" z8Parameters sent by the `on_connection_queued_end` signalN)r r r rT r r r r r" s c @ s e Zd ZdZdS )r# z:Parameters sent by the `on_connection_create_start` signalN)r r r rT r r r r r# s c @ s e Zd ZdZdS )r$ z8Parameters sent by the `on_connection_create_end` signalN)r r r rT r r r r r$ " s c @ s e Zd ZdZdS )r% z7Parameters sent by the `on_connection_reuseconn` signalN)r r r rT r r r r r% ' s c @ s e Zd ZU dZedS )r& z8Parameters sent by the `on_dns_resolvehost_start` signalN)r r r rT rX hostr r r r r& , s
c @ s e Zd ZU dZedS )r' z6Parameters sent by the `on_dns_resolvehost_end` signalN)r r r rT rX ra r r r r r' 3 s
c @ s e Zd ZU dZedS )r( z0Parameters sent by the `on_dns_cache_hit` signalN)r r r rT rX ra r r r r r( : s
c @ s e Zd ZU dZedS )r) z1Parameters sent by the `on_dns_cache_miss` signalN)r r r rT rX ra r r r r r) A s
c @ s e Zd ZU dZeeddS )r- z7Parameters sent by the `on_request_headers_sent` signalzCIMultiDict[str]N) r r r rT rX rY r
rZ r[ r r r r r- H s
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+Zeedddd,d-ZdS ).TracezInternal dependency holder class.
Used to keep together the main dependencies used
at the moment of send a signal.
r
N)session trace_configrB r c C s || _ || _|| _d S )N)
_trace_config_trace_config_ctx_session)r rc rd rB r r r r@ X s zTrace.__init__zCIMultiDict[str])rY rZ r[ r c s$ | j jj| j| jt|||I d H S )N)re rD sendrg rf r )r rY rZ r[ r r r send_request_startb s zTrace.send_request_start)rY rZ r] r c s$ | j jj| j| jt|||I d H S )N)re rE rh rg rf r+ )r rY rZ r] r r r send_request_chunk_sentk s z Trace.send_request_chunk_sentc s$ | j jj| j| jt|||I d H S )N)re rF rh rg rf r, )r rY rZ r] r r r send_response_chunk_receivedt s z"Trace.send_response_chunk_received)rY rZ r[ r^ r c s& | j jj| j| jt||||I d H S )N)re rG rh rg rf r )r rY rZ r[ r^ r r r send_request_end} s zTrace.send_request_end)rY rZ r[ r` r c s& | j jj| j| jt||||I d H S )N)re rH rh rg rf r )r rY rZ r[ r` r r r send_request_exception s z Trace.send_request_exceptionc s& | j jj| j| jt||||I d H S )N)re r4 rh rg rf r* )r rY rZ r[ r^ r r r send_request_redirect s zTrace.send_request_redirect)r c s | j jj| j| jt I d H S )N)re rJ rh rg rf r! )r r r r send_connection_queued_start s z"Trace.send_connection_queued_startc s | j jj| j| jt I d H S )N)re rK rh rg rf r" )r r r r send_connection_queued_end s z Trace.send_connection_queued_endc s | j jj| j| jt I d H S )N)re rL rh rg rf r# )r r r r send_connection_create_start s z"Trace.send_connection_create_startc s | j jj| j| jt I d H S )N)re rM rh rg rf r$ )r r r r send_connection_create_end s z Trace.send_connection_create_endc s | j jj| j| jt I d H S )N)re rN rh rg rf r% )r r r r send_connection_reuseconn s z Trace.send_connection_reuseconn)ra r c s | j jj| j| jt|I d H S )N)re rO rh rg rf r& )r ra r r r send_dns_resolvehost_start s z Trace.send_dns_resolvehost_startc s | j jj| j| jt|I d H S )N)re rP rh rg rf r' )r ra r r r send_dns_resolvehost_end s z Trace.send_dns_resolvehost_endc s | j jj| j| jt|I d H S )N)re rQ rh rg rf r( )r ra r r r send_dns_cache_hit s zTrace.send_dns_cache_hitc s | j jj| j| jt|I d H S )N)re rR rh rg rf r) )r ra r r r send_dns_cache_miss s zTrace.send_dns_cache_missc s$ | j jj| j| jt|||I d H S )N)re r> rh rg rf r- )r rY rZ r[ r r r send_request_headers s zTrace.send_request_headers) r r r rT r r r@ rX r
ri r\ rj rk r rl r_ rm rn ro rp rq rr rs rt ru rv rw rx r r r r rb Q sJ rb )r r r r r! r" r# r$ r% r& r' r( r) r* r+ r, r- )+typesr typingr r r r r attrZ aiosignalr Z multidictr Zyarlr
Z
client_reqrepr clientr
Ztypedefsr r r __all__r sr r+ r, r r r* r! r" r# r$ r% r& r' r( r) r- rb r r r r s^ +