o `j@s:ddlZddlZddlmZddlmZGdddZdS)N)QuotaViolationError) KafkaMetricc@sjeZdZdZdZddZddZeddZed d Z dd dZ ddZ dddZ dddZ ddZd S)Sensora5 A sensor applies a continuous sequence of numerical values to a set of associated metrics. For example a sensor on message size would record a sequence of message sizes using the `record(double)` api and would maintain a set of metrics about request sizes such as the average or max. ) _lock _registry_name_parents_metrics_stats_config#_inactive_sensor_expiration_time_ms_last_record_timecCsf|stdt|_||_||_|pg|_g|_g|_||_ |d|_ t d|_ |tdS)Nzname must be non-empty) ValueError threadingRLockrrrrr r r r time monotonicr _check_forestset)selfregistrynameparentsconfig'inactive_sensor_expiration_time_secondsrX/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/metrics/stats/sensor.py__init__s  zSensor.__init__cCs<||vr td|jf|||jD]}||qdS)zs