o i`@sddlZddlmZddlmZddlmZejddGdddZd ee e efd e e effd d Z Gd dde ZeGdddedZeZdS)N) monotonic)Any)SequenceT)frozencseZdZUeed<eed<ejddZeed<ejddZeed<eje dZ e eed <eje dZ e e ed <ejd d d Ze ed <dfdd Zde fddZZS) HttpEndPointmethodpath)default resource_name http.requestoperation_name)default_factoryresponse_body_type response_codeF)initrepr_hashreturnNcsTtd|j|jstd|jd|jtdt|j|jfdS)Nrr  r)super __setattr__rupperr rhashself __class__N/home/ubuntu/.local/lib/python3.10/site-packages/ddtrace/internal/endpoints.py __post_init__szHttpEndPoint.__post_init__cCs|jSN)rrrrr__hash__szHttpEndPoint.__hash__rN)__name__ __module__ __qualname__str__annotations__ dataclassesfieldr r tuplerrrintrr r" __classcell__rrrrrs rlstrcCsdd|DS)NcSs$i|]\}}|dgdfvr||qS)rNr).0kvrrr s$z!_dict_factory..r)r.rrr _dict_factorysr3cs6eZdZUdZiZeeefed<fddZ Z S) SingletonzSingleton Class. _instancescs0||jvrtt|j|i||j|<|j|Sr!)r5rr4__call__)clsargskwargsrrrr6%s  zSingleton.__call__) r$r%r&__doc__r5dicttypeobjectr(r6r-rrrrr4 s r4c@seZdZUdZejeddZeee d<ejdddZ e e d<ejdddZ e e d <ejeddZe e d <ejd ddZee d <dddZ    d dededededeedeed dfddZded efddZdS)!HttpEndPointsCollectiona5A collection of HTTP endpoints that can be modified and flushed to a telemetry payload. The collection collects HTTP endpoints at startup and can be flushed to a telemetry payload. It maintains a maximum size and drops endpoints after a certain time period in case of a hot reload of the server. F)rr endpointsT)r ris_firstgV@drop_time_secondslast_modification_timeimax_size_lengthrNcCs|jd|_t|_dS)z*Reset the collection to its initial state.TN)r?clearr@rrBrrrrreset9s  zHttpEndPointsCollection.resetr r rrrr r rrc Cs~t}||j|jkr||jt||||||ddSt|j|jkr=||_|jt||||||d||_dSdS)z4 Add an endpoint to the collection. )rrr r rrN) rrBrArEr?addrlenrC)rrrr r rr current_timerrr add_endpoint?s6   z$HttpEndPointsCollection.add_endpoint max_lengthcCsXg}|jr!t||kr!|tj|jtd|jr!t||ks |j|d}d|_|S)zX Flush the endpoints to a payload, returning the first `max` endpoints. ) dict_factory)r@r?F)r?rGappendr)asdictpopr3r@)rrJ endpoints_resresrrrflushfs zHttpEndPointsCollection.flushr#)r r rr)r$r%r&r:r)r*setr?rr(r@boolrAfloatrrBrCr,rEr'rrIr;rQrrrrr>+s8    'r>) metaclass)r)timertypingrr dataclassrlistr+r'r;r3r<r4r>endpoint_collectionrrrrs    &  F