+
    ~j(                        ^ RI Ht ^ RIt^ RIt^ RIt^ RIHt ^ RIHtH	t	H
t
Ht ^RIHt R R lt ! R R	]P                  P                   4      tR# )
    )annotationsN)web)CONTENT_TYPE_LATESTCollectorRegistrygenerate_latestmultiprocess)utilsc                    V ^8  d   QhRRRR/# )   _requestzaiohttp.web_request.Requestreturnzweb.Response )formats   "y/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/livekit/agents/telemetry/http_server.py__annotate__r      s      7 L     c                   "   R  R lp\         P                  ! 4       pVP                  RV4      G Rj  xL
 p\        P                  ! VR\
        R\        \        V4      4      /R7      #  L65i)c                   V ^8  d   QhRR/# )r   r   bytesr   )r   s   "r   r   metrics.<locals>.__annotate__   s     	% 	%% 	%r   c                     R \         P                  9   d.   \        RR7      p \        P                  ! V 4       \        V 4      # \        4       # )PROMETHEUS_MULTIPROC_DIRT)auto_describe)osenvironr   r   MultiProcessCollectorr   )registrys    r   _get_metricsmetrics.<locals>._get_metrics   s<    %3(t<H..x8"8,, #$$r   NzContent-TypezContent-Length)bodyheaders)asyncioget_running_looprun_in_executorr   Responser   strlen)r   r   loopdatas   &   r   metricsr*      s_     	% ##%D%%dL99D<<!46FCPTIW  :s   1A,A*7A,c                  .   a  ] tR t^&tR V 3R lltRtV ;t# )
HttpServerc               $    V ^8  d   QhRRRRRR/# )r   hostr&   portintr   Noner   )r   s   "r   r   HttpServer.__annotate__'   s!     = =S = = =r   c                	   < \         SV `  W4       V P                  P                  \        P
                  ! R \        4      .4       R# )z/metricsN)super__init___app
add_routesr   getr*   )selfr.   r/   	__class__s   &&&r   r5   HttpServer.__init__'   s0    $		cggj':;<r   r   )__name__
__module____qualname____firstlineno__r5   __static_attributes____classcell__)r:   s   @r   r,   r,   &   s    = =r   r,   )
__future__r   r"   r   aiohttp.web_requestaiohttpr   prometheus_clientr   r   r   r    r	   r*   http_serverr,   r   r   r   <module>rH      s@    "  	    (=""-- =r   