in src/worker/publisher/metrics_publisher.py [0:0]
def __init__(self, metrics_ports=None, metrics_auth=None, metrics_namespace=None):
self.metrics_ports = metrics_ports
self.metrics_auth = metrics_auth
self.metrics_namespace = metrics_namespace
self.node_name = socket.gethostname()
self.vm_id = get_vm_id()
self.scaleset_name = get_scaleset_name()
if publisher_agent == 'geneva':
self.meter = get_geneva_exporter_meter(self.metrics_auth, self.metrics_namespace)
elif publisher_agent == 'azure_monitor':
self.meter = get_azure_monitor_exporter_meter(self.metrics_auth, self.metrics_namespace)
else:
print("##[ERROR]Invalid publisher agent")
self.metricNametoCounter = dict()
self.metricNametoHistogram = dict()
self.metricKeytoPreviousValue = dict()