File: //opt/saltstack/salt/lib/python3.10/site-packages/aiohttp/__pycache__/tracing.cpython-310.pyc
o
;j�8 � @ s� d dl mZ d dlmZmZmZ d dlZd dlmZ d dl m
Z
d dl m Z ddl
mZ erAdd lmZ ed
d d �Zeeeef Zd
ZG dd� d�Zejd d d d�G dd� d��Zejd d d d�G dd� d��Zejd d d d�G dd� d��Zejd d d d�G dd� d��Zejd d d d�G dd� d��Zejd d d d�G dd � d ��Zejd 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/d0� d0��Z%G d1d2� d2�Z&dS )3� )�SimpleNamespace)�
TYPE_CHECKING�Any�TypeVarN)�Signal)� CIMultiDict)�URL� )�ClientResponse)�
ClientSession�_ParamT_contraT)�
contravariant)� TraceConfig�TraceRequestStartParams�TraceRequestEndParams�TraceRequestExceptionParams� TraceConnectionQueuedStartParams� TraceConnectionQueuedEndParams� TraceConnectionCreateStartParams� TraceConnectionCreateEndParams� TraceConnectionReuseconnParams� TraceDnsResolveHostStartParams� TraceDnsResolveHostEndParams�TraceDnsCacheHitParams�TraceDnsCacheMissParams�TraceRequestRedirectParams�TraceRequestChunkSentParams� TraceResponseChunkReceivedParams� TraceRequestHeadersSentParamsc @ sX e Zd ZdZefdee ddfdd�Zd<dedefdd �Zd=d
d �Z e
d>d
d��Z e
d?dd��Z e
d@dd��Z
e
dAdd��Ze
dBdd��Ze
dCd d ��Ze
dDd d ��Ze
!dEd"d#��Ze
$dFd%d&��Ze
'dGd(d)��Ze
*dHd+d,��Ze
-dId.d/��Ze
0dJd1d2��Ze
dKd4d5��Ze
dLd7d8��Ze
9dMd:d;��ZdS )Nr zFFirst-class used to trace requests launched via ClientSession objects.�trace_config_ctx_factory�returnNc 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)�selfr � r4 �C/opt/saltstack/salt/lib/python3.10/site-packages/aiohttp/tracing.py�__init__* s<
��
���������
�
zTraceConfig.__init__�trace_request_ctxc C s | j |d�S )z&Return a new trace_config_ctx instance)r7 )r2 )r3 r7 r4 r4 r5 �trace_config_ctxX s z TraceConfig.trace_config_ctxc C s� | j �� | j�� | j�� | j�� | j�� | j�� | j�� | j�� | j �� | j
�� | j �� | j �� | j
�� | j�� | j�� | j�� d S r! )r" �freezer# r$ r% r& r' r( r) r* r+ r, r- r. r/ r0 r1 �r3 r4 r4 r5 r9 \ s
zTraceConfig.freeze�'_TracingSignal[TraceRequestStartParams]c C � | j S r! )r" r: r4 r4 r5 �on_request_startn � z TraceConfig.on_request_start�+_TracingSignal[TraceRequestChunkSentParams]c C r< r! )r# r: r4 r4 r5 �on_request_chunk_sentr � z!TraceConfig.on_request_chunk_sent�0_TracingSignal[TraceResponseChunkReceivedParams]c C r< r! )r$ r: r4 r4 r5 �on_response_chunk_receivedx rA z&TraceConfig.on_response_chunk_received�%_TracingSignal[TraceRequestEndParams]c C r< r! )r% r: r4 r4 r5 �on_request_end~ r> zTraceConfig.on_request_end�+_TracingSignal[TraceRequestExceptionParams]c C r< r! )r& r: r4 r4 r5 �on_request_exception� rA z TraceConfig.on_request_exception�*_TracingSignal[TraceRequestRedirectParams]c C r< r! )r' r: r4 r4 r5 �on_request_redirect� rA z TraceConfig.on_request_redirect�0_TracingSignal[TraceConnectionQueuedStartParams]c C r< r! )r( r: r4 r4 r5 �on_connection_queued_start� rA z&TraceConfig.on_connection_queued_start�._TracingSignal[TraceConnectionQueuedEndParams]c C r< r! )r) r: r4 r4 r5 �on_connection_queued_end� rA z$TraceConfig.on_connection_queued_end�0_TracingSignal[TraceConnectionCreateStartParams]c C r< r! )r* r: r4 r4 r5 �on_connection_create_start� rA z&TraceConfig.on_connection_create_start�._TracingSignal[TraceConnectionCreateEndParams]c C r< r! )r+ r: r4 r4 r5 �on_connection_create_end� rA z$TraceConfig.on_connection_create_end�._TracingSignal[TraceConnectionReuseconnParams]c C r< r! )r, r: r4 r4 r5 �on_connection_reuseconn� rA z#TraceConfig.on_connection_reuseconn�._TracingSignal[TraceDnsResolveHostStartParams]c C r< r! )r- r: r4 r4 r5 �on_dns_resolvehost_start� rA z$TraceConfig.on_dns_resolvehost_start�,_TracingSignal[TraceDnsResolveHostEndParams]c C r< r! )r. r: r4 r4 r5 �on_dns_resolvehost_end� rA z"TraceConfig.on_dns_resolvehost_end�&_TracingSignal[TraceDnsCacheHitParams]c C r< r! )r/ r: r4 r4 r5 �on_dns_cache_hit� r> z TraceConfig.on_dns_cache_hit�'_TracingSignal[TraceDnsCacheMissParams]c C r< r! )r0 r: r4 r4 r5 �on_dns_cache_miss� r> z TraceConfig.on_dns_cache_miss�-_TracingSignal[TraceRequestHeadersSentParams]c C r< r! )r1 r: r4 r4 r5 �on_request_headers_sent� rA z#TraceConfig.on_request_headers_sentr! �r N)r r; )r r? )r rB )r rD )r rF )r rH )r rJ )r rL )r rN )r rP )r rR )r rT )r rV )r rX )r rZ )r r\ )�__name__�
__module__� __qualname__�__doc__r �typer6 r r8 r9 �propertyr= r@ rC rE rG rI rK rM rO rQ rS rU rW rY r[ r] r4 r4 r4 r5 r ' s� ��
�.
� � � � � � � � � � � �r )Z auto_attribs�frozen�slotsc @ �* e Zd ZU dZeed< eed< ded< dS )r z0Parameters sent by the `on_request_start` signal�method�url�CIMultiDict[str]�headersN�r_ r` ra rb �str�__annotations__r r4 r4 r4 r5 r � �
r c @ �* e Zd ZU dZeed< eed< eed< dS )r z5Parameters sent by the `on_request_chunk_sent` signalrh ri �chunkN�r_ r` ra rb rm rn r �bytesr4 r4 r4 r5 r � ro r c @ rp )r z:Parameters sent by the `on_response_chunk_received` signalrh ri rq Nrr r4 r4 r4 r5 r � ro r c @ �2 e Zd ZU dZeed< eed< ded< eed< dS )r z.Parameters sent by the `on_request_end` signalrh ri rj rk �responseN�r_ r` ra rb rm rn r r
r4 r4 r4 r5 r � �
r c @ rt )r z4Parameters sent by the `on_request_exception` signalrh ri rj rk � exceptionN)r_ r` ra rb rm rn r �
BaseExceptionr4 r4 r4 r5 r � rw r c @ rt )r z3Parameters sent by the `on_request_redirect` signalrh ri rj rk ru Nrv r4 r4 r4 r5 r � rw r c @ � e Zd ZdZdS )r z:Parameters sent by the `on_connection_queued_start` signalN�r_ r` ra rb r4 r4 r4 r5 r � r c @ rz )r z8Parameters sent by the `on_connection_queued_end` signalNr{ r4 r4 r4 r5 r r| r c @ rz )r z:Parameters sent by the `on_connection_create_start` signalNr{ r4 r4 r4 r5 r
r| r c @ rz )r z8Parameters sent by the `on_connection_create_end` signalNr{ r4 r4 r4 r5 r r| r c @ rz )r z7Parameters sent by the `on_connection_reuseconn` signalNr{ r4 r4 r4 r5 r r| r c @ � e Zd ZU dZeed< dS )r z8Parameters sent by the `on_dns_resolvehost_start` signal�hostN�r_ r` ra rb rm rn r4 r4 r4 r5 r �
r c @ r} )r z6Parameters sent by the `on_dns_resolvehost_end` signalr~ Nr r4 r4 r4 r5 r r� r c @ r} )r z0Parameters sent by the `on_dns_cache_hit` signalr~ Nr r4 r4 r4 r5 r ' r� r c @ r} )r z1Parameters sent by the `on_dns_cache_miss` signalr~ Nr r4 r4 r4 r5 r . r� r c @ rg )r z7Parameters sent by the `on_request_headers_sent` signalrh ri rj rk Nrl r4 r4 r4 r5 r 5 ro r c
@ sf e Zd ZdZdddededdfdd �Zd
ed ed d
ddfdd�Z d
ed ede
ddfdd�Z d
ed ede
ddfdd�Z d
ed ed d
de
ddf
dd�Zd
ed ed d
deddf
dd�Zd
ed ed d
de
ddf
dd �Zd2d d �Zd2d d �Zd2d!d"�Zd2d#d$�Zd2d%d&�Zd'eddfd(d)�Zd'eddfd*d+�Zd'eddfd,d-�Zd'eddfd.d/�Zd
ed ed d
ddfd0d1�ZdS )3�Tracez�Internal dependency holder class.
Used to keep together the main dependencies used
at the moment of send a signal.
�sessionr � trace_configr8 r Nc C s || _ || _|| _d S r! )�
_trace_config�_trace_config_ctx�_session)r3 r� r� r8 r4 r4 r5 r6 E s
zTrace.__init__rh ri rk rj c � �& �| j j�| j| jt|||��I d H S r! )r� r= �sendr� r� r �r3 rh ri rk r4 r4 r5 �send_request_startO � �
�zTrace.send_request_startrq c � r� r! )r� r@ r� r� r� r �r3 rh ri rq r4 r4 r5 �send_request_chunk_sentX r� z Trace.send_request_chunk_sentc � r� r! )r� rC r� r� r� r r� r4 r4 r5 � send_response_chunk_receiveda r� z"Trace.send_response_chunk_receivedru c � �( �| j j�| j| jt||||��I d H S r! )r� rE r� r� r� r �r3 rh ri rk ru r4 r4 r5 �send_request_endj � �
�zTrace.send_request_endrx c � r� r! )r� rG r� r� r� r )r3 rh ri rk rx r4 r4 r5 �send_request_exceptionw r� z Trace.send_request_exceptionc � r� r! )r� r' r� r� r� r r� r4 r4 r5 �send_request_redirect� r� zTrace.send_request_redirectc � � �| j j�| j| jt� �I d H S r! )r� rK r� r� r� r r: r4 r4 r5 � send_connection_queued_start� � �
�z"Trace.send_connection_queued_startc � r� r! )r� rM r� r� r� r r: r4 r4 r5 �send_connection_queued_end� r� z Trace.send_connection_queued_endc � r� r! )r� rO r� r� r� r r: r4 r4 r5 � send_connection_create_start� r� z"Trace.send_connection_create_startc � r� r! )r� rQ r� r� r� r r: r4 r4 r5 �send_connection_create_end� r� z Trace.send_connection_create_endc � r� r! )r� rS r� r� r� r r: r4 r4 r5 �send_connection_reuseconn� r� z Trace.send_connection_reuseconnr~ c � �" �| j j�| j| jt|��I d H S r! )r� rU r� r� r� r �r3 r~ r4 r4 r5 �send_dns_resolvehost_start� � �
�z Trace.send_dns_resolvehost_startc � r� r! )r� rW r� r� r� r r� r4 r4 r5 �send_dns_resolvehost_end� r� z Trace.send_dns_resolvehost_endc � r� r! )r� rY r� r� r� r r� r4 r4 r5 �send_dns_cache_hit� r� zTrace.send_dns_cache_hitc � r� r! )r� r[ r� r� r� r r� r4 r4 r5 �send_dns_cache_miss� r� zTrace.send_dns_cache_missc � r� r! )r� r1 r� r� r� r r� r4 r4 r5 �send_request_headers� r� zTrace.send_request_headersr^ ) r_ r` ra rb r r r6 rm r r� rs r� r� r
r� ry r� r� r� r� r� r� r� r� r� r� r� r� r4 r4 r4 r5 r� > s� ���
�
���
� ���
� ���
� ����
�
����
�
����
�
����r� )'�typesr �typingr r r �attrZ aiosignalr Z multidictr Zyarlr Z
client_reqrepr
�clientr r Z_TracingSignal�__all__r �sr r r r r r r r r r r r r r r r r� r4 r4 r4 r5 �<module> s^ !