
    &`i.                     |   d dl mZ d dlmZ  e            Ze dZe                    ed           e dZe                    ed           e dZe                    ed           e d	Z	e
                    e	d
g d           e dZe                    ed           e dZe                    ed           dS )    )OpenTelemetryMetricRecorder)AGGREGATOR_AGENT_METRIC_PREFIX_published_eventszATotal number of events successfully published to the destination._filtered_eventszITotal number of events filtered out before publishing to the destination._publish_failuresz<Total number of events that failed to publish after retries._publish_latency_secondsz%Duration of publish calls in seconds.)gMbP?g{Gzt?g{Gz?g?g?g?g      ?g      ?         (_consecutive_failures_since_last_successzENumber of consecutive failed publish attempts since the last success. _time_since_last_success_secondsz=Seconds since the last successful publish to the destination.N)5ray._private.telemetry.open_telemetry_metric_recorderr   *ray.dashboard.modules.aggregator.constantsr   metric_recorderpublished_counter_nameregister_counter_metricfiltered_counter_namefailed_counter_namepublish_latency_hist_nameregister_histogram_metricconsecutive_failures_gauge_nameregister_gauge_metric"time_since_last_success_gauge_name     /home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/dashboard/modules/aggregator/publisher/metrics.py<module>r      s            
 .-// ;MMM   ' 'G  
 :KKK   ' 'O  
 8JJJ   ' 'B    >WWW   ) )+>>>   &OOO    % %#K   &GGG #  % %&C    r   