File: //opt/alt/python37/lib64/python3.7/site-packages/aiohttp/__pycache__/tracing.cpython-37.opt-1.pyc
B
�k�a�; � @ s� 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 d
�ZG dd� dee �ZdZG dd� d�Zejd d d d�G dd� d��Zejd d d d�G dd� d��Zejd d d d�G dd� d��Z ejd d d d�G dd� d��Z ejd d d d�G d d � d ��Z ejd d d d�G d d � d ��Z ejd d d d�G d d!� d!��Z ejd d d d�G d"d#� d#��Z!ejd d d d�G d$d%� d%��Z"ejd d d d�G d&d'� d'��Z#ejd d d d�G d(d)� d)��Z$ejd d d d�G d*d+� d+��Z%ejd d d d�G d,d-� d-��Z&ejd d d d�G d.d/� d/��Z'ejd d d d�G d0d1� d1��Z(ejd d d d�G d2d3� d3��Z)G d4d5� d5�Z*dS )6� )�SimpleNamespace)�
TYPE_CHECKING� Awaitable�Optional�Type�TypeVarN)�Signal)� CIMultiDict)�URL� )�ClientResponse)�
ClientSession)�Protocol�_ParamT_contraT)Z
contravariantc @ s$ e Zd Zeeeed d�dd�ZdS )�_SignalCallbackN)� _SignalCallback__client_session�!_SignalCallback__trace_config_ctx�_SignalCallback__params�returnc C s d S )N� )�selfr r r r r �B/opt/alt/python37/lib64/python3.7/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 )� TraceConfig�TraceRequestStartParams�TraceRequestEndParams�TraceRequestExceptionParams� TraceConnectionQueuedStartParams� TraceConnectionQueuedEndParams� TraceConnectionCreateStartParams� TraceConnectionCreateEndParams� TraceConnectionReuseconnParams� TraceDnsResolveHostStartParams� TraceDnsResolveHostEndParams�TraceDnsCacheHitParams�TraceDnsCacheMissParams�TraceRequestRedirectParams�TraceRequestChunkSentParams� TraceResponseChunkReceivedParams� TraceRequestHeadersSentParamsc @ sl e Zd ZdZefee dd�dd�Zd<ee ed�dd�Zdd �d
d �Z e
d d �d
d��Z e
dd �dd��Z e
dd �dd��Z
e
dd �dd��Ze
dd �dd��Ze
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 �d1d2��Ze
d3d �d4d5��Ze
d6d �d7d8��Ze
d9d �d:d;��ZdS )=r zFFirst-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 | �| _t | �| _|| _d S )N)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 r- r r r �__init__3 sB zTraceConfig.__init__)�trace_request_ctxr c C s | j |d�S )z&Return a new trace_config_ctx instance)r@ )r> )r r@ r r r �trace_config_ctxi s z TraceConfig.trace_config_ctx)r c C s� | j �� | j�� | j�� | j�� | j�� | j�� | j�� | j�� | j �� | j
�� | j �� | j �� | j
�� | j�� | j�� | j�� d S )N)r. �freezer/ r0 r1 r2 r3 r4 r5 r6 r7 r8 r9 r: r; r< r= )r r r r rB 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)r/ )r r r r �on_request_chunk_sent� s z!TraceConfig.on_request_chunk_sentz9Signal[_SignalCallback[TraceResponseChunkReceivedParams]]c C s | j S )N)r0 )r r r r �on_response_chunk_received� s z&TraceConfig.on_response_chunk_receivedz.Signal[_SignalCallback[TraceRequestEndParams]]c C s | j S )N)r1 )r r r r �on_request_end� s zTraceConfig.on_request_endz4Signal[_SignalCallback[TraceRequestExceptionParams]]c C s | j S )N)r2 )r r r r �on_request_exception� s z TraceConfig.on_request_exceptionz3Signal[_SignalCallback[TraceRequestRedirectParams]]c C s | j S )N)r3 )r r r r �on_request_redirect� s z TraceConfig.on_request_redirectz9Signal[_SignalCallback[TraceConnectionQueuedStartParams]]c C s | j S )N)r4 )r r r r �on_connection_queued_start� s z&TraceConfig.on_connection_queued_startz7Signal[_SignalCallback[TraceConnectionQueuedEndParams]]c C s | j S )N)r5 )r r r r �on_connection_queued_end� s z$TraceConfig.on_connection_queued_endz9Signal[_SignalCallback[TraceConnectionCreateStartParams]]c C s | j S )N)r6 )r r r r �on_connection_create_start� s z&TraceConfig.on_connection_create_startz7Signal[_SignalCallback[TraceConnectionCreateEndParams]]c C s | j S )N)r7 )r r r r �on_connection_create_end� s z$TraceConfig.on_connection_create_endz7Signal[_SignalCallback[TraceConnectionReuseconnParams]]c C s | j S )N)r8 )r r r r �on_connection_reuseconn� s z#TraceConfig.on_connection_reuseconnz7Signal[_SignalCallback[TraceDnsResolveHostStartParams]]c C s | j S )N)r9 )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 rA rB �propertyrC rD rE rF rG rH rI rJ rK rL rM rN rO rP rQ rR r r r r r 0 sL
5r )Z auto_attribs�frozen�slotsc @ s* e Zd ZU dZeed< eed< ded< dS )r z0Parameters sent by the `on_request_start` signal�method�urlzCIMultiDict[str]�headersN)r r r rS �str�__annotations__r
r r r r r � s
r c @ s* e Zd ZU dZeed< eed< eed< dS )r* z5Parameters sent by the `on_request_chunk_sent` signalrW rX �chunkN)r r r rS rZ 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` signalrW rX r\ N)r r r rS rZ r[ r
r] 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` signalrW rX zCIMultiDict[str]rY �responseN)r r r rS rZ r[ r
r r r r r r � s
r c @ s2 e Zd ZU dZeed< eed< ded< eed< dS )r z4Parameters sent by the `on_request_exception` signalrW rX zCIMultiDict[str]rY � exceptionN)r r r rS rZ r[ r
�
BaseExceptionr r r r r � s
r c @ s2 e Zd ZU dZeed< eed< ded< eed< dS )r) z3Parameters sent by the `on_request_redirect` signalrW rX zCIMultiDict[str]rY r^ N)r r r rS rZ r[ r
r r r r r r) s
r) c @ s e Zd ZdZdS )r z:Parameters sent by the `on_connection_queued_start` signalN)r r r rS r r r r r s r c @ s e Zd ZdZdS )r! z8Parameters sent by the `on_connection_queued_end` signalN)r r r rS r r r r r! s r! c @ s e Zd ZdZdS )r" z:Parameters sent by the `on_connection_create_start` signalN)r r r rS r r r r r" s r" c @ s e Zd ZdZdS )r# z8Parameters sent by the `on_connection_create_end` signalN)r r r rS r r r r r# " s r# c @ s e Zd ZdZdS )r$ z7Parameters sent by the `on_connection_reuseconn` signalN)r r r rS r r r r r$ ' s r$ c @ s e Zd ZU dZeed< dS )r% z8Parameters sent by the `on_dns_resolvehost_start` signal�hostN)r r r rS rZ r[ r r r r r% , s
r% c @ s e Zd ZU dZeed< dS )r& z6Parameters sent by the `on_dns_resolvehost_end` signalra N)r r r rS rZ r[ r r r r r& 3 s
r& c @ s e Zd ZU dZeed< dS )r' z0Parameters sent by the `on_dns_cache_hit` signalra N)r r r rS rZ r[ r r r r r' : s
r' c @ s e Zd ZU dZeed< dS )r( z1Parameters sent by the `on_dns_cache_miss` signalra N)r r r rS rZ r[ r r r r r( A s
r( c @ s* e Zd ZU dZeed< eed< ded< dS )r, z7Parameters sent by the `on_request_headers_sent` signalrW rX zCIMultiDict[str]rY N)r r r rS rZ r[ r
r r r r r, H s
r, c @ s< e Zd ZdZdeedd�dd�Zeeddd�d d
�Z eee
dd �d d
�Z eee
dd �dd�Z eede
dd�dd�Zeededd�dd�Zeede
dd�dd�Zdd�dd�Zdd�dd �Zdd�d d �Zdd�d d �Zdd�d!d"�Zedd#�d$d%�Zedd#�d&d'�Zedd#�d(d)�Zedd#�d*d+�Zeeddd�d,d-�ZdS ).�Tracez�Internal dependency holder 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 )N)�
_trace_config�_trace_config_ctx�_session)r rc rd rA r r r r? X s zTrace.__init__zCIMultiDict[str])rW rX rY r c � s$ | j j�| j| jt|||��I d H S )N)re rC �sendrg rf r )r rW rX rY r r r �send_request_startb s zTrace.send_request_start)rW rX r\ r c � s$ | j j�| j| jt|||��I d H S )N)re rD rh rg rf r* )r rW rX r\ r r r �send_request_chunk_sentk s z Trace.send_request_chunk_sentc � s$ | j j�| j| jt|||��I d H S )N)re rE rh rg rf r+ )r rW rX r\ r r r � send_response_chunk_receivedt s z"Trace.send_response_chunk_received)rW rX rY r^ r c � s& | j j�| j| jt||||��I d H S )N)re rF rh rg rf r )r rW rX rY r^ r r r �send_request_end} s zTrace.send_request_end)rW rX rY r_ r c � s& | j j�| j| jt||||��I d H S )N)re rG rh rg rf r )r rW rX rY r_ r r r �send_request_exception� s z Trace.send_request_exceptionc � s& | j j�| j| jt||||��I d H S )N)re r3 rh rg rf r) )r rW rX rY r^ r r r �send_request_redirect� s zTrace.send_request_redirect)r c � s | j j�| j| jt� �I d H S )N)re rI rh rg rf r )r r r r � send_connection_queued_start� s z"Trace.send_connection_queued_startc � s | j j�| j| jt� �I d H S )N)re rJ rh rg rf r! )r r r r �send_connection_queued_end� s z Trace.send_connection_queued_endc � s | j j�| j| jt� �I d H S )N)re rK rh rg rf r" )r r r r � send_connection_create_start� s z"Trace.send_connection_create_startc � s | j j�| j| jt� �I d H S )N)re rL rh rg rf r# )r r r r �send_connection_create_end� s z Trace.send_connection_create_endc � s | j j�| j| jt� �I d H S )N)re rM rh rg rf r$ )r r r r �send_connection_reuseconn� s z Trace.send_connection_reuseconn)ra r c � s | j j�| j| jt|��I d H S )N)re rN rh rg rf r% )r ra r r r �send_dns_resolvehost_start� s z Trace.send_dns_resolvehost_startc � s | j j�| j| jt|��I d H S )N)re rO rh rg rf r& )r ra r r r �send_dns_resolvehost_end� s z Trace.send_dns_resolvehost_endc � s | j j�| j| jt|��I d H S )N)re rP rh rg rf r' )r ra r r r �send_dns_cache_hit� s zTrace.send_dns_cache_hitc � s | j j�| j| jt|��I d H S )N)re rQ rh rg rf r( )r ra r r r �send_dns_cache_miss� s zTrace.send_dns_cache_missc � s$ | j j�| j| jt|||��I d H S )N)re r= rh rg rf r, )r rW rX rY r r r �send_request_headers� s zTrace.send_request_headers) r r r rS r r r? rZ 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 )+�typesr �typingr r r r r �attrZ aiosignalr Z multidictr Zyarlr
Z
client_reqrepr Zclientr
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 �<module> s> +