9h2SSKr"SS\RS9rg)Nc\rSrSrSr\R S5r\R S5r\R S5r \R S5r \R S5r Sr g ) AbstractMetricsReporterza An abstract class to allow things to listen as new metrics are created so they can be reported. cg)z This is called when the reporter is first registered to initially register all existing metrics Arguments: metrics (list of KafkaMetric): All currently existing metrics N)selfmetricss fC:\Suresh\moveshuttle\MDcreated\moveengine\venv\Lib\site-packages\aiokafka/metrics/metrics_reporter.pyinitAbstractMetricsReporter.init cg)z[ This is called whenever a metric is updated or added Arguments: metric (KafkaMetric) Nrrmetrics r metric_change%AbstractMetricsReporter.metric_changer rcg)zR This is called whenever a metric is removed Arguments: metric (KafkaMetric) Nrrs r metric_removal&AbstractMetricsReporter.metric_removalr rcg)z` Configure this class with the given key-value pairs Arguments: configs (dict of {str, ?}) Nr)rconfigss r configure!AbstractMetricsReporter.configure&r rcg)z-Called when the metrics repository is closed.Nr)rs r closeAbstractMetricsReporter.close/r rrN) __name__ __module__ __qualname____firstlineno____doc__abcabstractmethodr rrrr__static_attributes__rrr rrs              <r(s -< -