Ch@SSKrSSKrSSKJr SSKJr "SS5rg)N)QuotaViolationError) KafkaMetriccn\rSrSrSrSrSr\S5r\S5r SSjr S r SS jr SS jr S rS rg)Sensora 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. c<U(d [S5e[R"5UlXlX lU=(d /Ul/Ul/UlX@l US-Ul [R"5S-Ul UR[55 g)Nzname must be non-empty) ValueError threadingRLock_lock _registry_name_parents_metrics_stats_config#_inactive_sensor_expiration_time_mstime_last_record_time _check_forestset)selfregistrynameparentsconfig'inactive_sensor_expiration_time_secondss bC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\aiokafka/metrics/stats/sensor.py__init__Sensor.__init__s~56 6__& !  2    3d : 0"&t!3 35!cX;a[SURS35eURU5 URHnUR U5 M g)z? ? =) - 3 3 5   %%'7'<'T F NN * *6 2 MM  ( !6r"c0UR [XU=(d UR5nURR U5 UR R U5 URR U5 SSS5 g!,(df  g=f)a Register a metric with this sensor Arguments: metric_name (MetricName): The name of the metric stat (AbstractMeasurableStat): The statistic to keep config (MetricConfig): A special configuration for this metric. If None use the sensor default configuration. N)r rrrrArr?r)rr:r5rr<s rr$ Sensor.addts`ZZ F4JdllKF NN * *6 2 MM  ( KK  t $ ZZs A1B Bcf[R"5S-UR- UR:$)zF Return True if the Sensor is eligible for removal due to inactivity. r )rrrr)s r has_expiredSensor.has_expireds0 IIK$ !7!7 7  4 45 5r") rrrr rrrrr)g?Nr,)__name__ __module__ __qualname____firstlineno____doc__r rpropertyrr.r1r2rDr$rI__static_attributes__r"rrrsR"$*$$*. )*% 5r"r)r raiokafka.errorsraiokafka.metrics.kafka_metricrrrRr"rrUs /5B5B5r"