o `šjÆã@s$ddlmZmZGdd„deƒZdS)é)ÚABCÚabstractmethodc@sLeZdZdZedd„ƒZedd„ƒZedd„ƒZedd „ƒZed d „ƒZ d S) ÚAbstractMetricsReporterzm An abstract class to allow things to listen as new metrics are created so they can be reported. cCódS)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©)ÚselfÚmetricsrrú\/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/metrics/metrics_reporter.pyÚinit s zAbstractMetricsReporter.initcCr)z{ This is called whenever a metric is updated or added Arguments: metric (KafkaMetric) Nr©rÚmetricrrr Ú metric_changeóz%AbstractMetricsReporter.metric_changecCr)zr This is called whenever a metric is removed Arguments: metric (KafkaMetric) Nrr rrr Úmetric_removalrz&AbstractMetricsReporter.metric_removalcCr)z€ Configure this class with the given key-value pairs Arguments: configs (dict of {str, ?}) Nr)rÚconfigsrrr Ú configure(rz!AbstractMetricsReporter.configurecCr)z-Called when the metrics repository is closed.Nr)rrrr Úclose2szAbstractMetricsReporter.closeN) Ú__name__Ú __module__Ú __qualname__Ú__doc__rr r rrrrrrr rs     rN)Úabcrrrrrrr Ús