From 08aa05346c152c6008cd1ef90f87937152030579 Mon Sep 17 00:00:00 2001 From: Isala Piyarisi Date: Fri, 18 Feb 2022 21:18:33 +0530 Subject: [PATCH] feat(gazer): Tracked request exchanges between services --- gazer/gazer.py | 12 ++++-------- 1 file changed, 4 insertions(+), 8 deletions(-) diff --git a/gazer/gazer.py b/gazer/gazer.py index cc24f02..33c63c4 100644 --- a/gazer/gazer.py +++ b/gazer/gazer.py @@ -20,6 +20,7 @@ backlog = Gauge("backlog", "Request backlog", ["namespace", "serviceName", "podName", "level"]) cpu = Gauge("cpu_seconds", "CPU usage", ["namespace", "serviceName", "podName"]) memory = Gauge("memory_usage_bytes", "Memory usage", ["namespace", "serviceName", "podName"]) +request_exchanges = Counter("request_exchanges", "Request exchanges between services", ["origin", "destination"]) class Gazer: @@ -76,6 +77,7 @@ def ipv4_request_event(self, cpu, data, size): if not rpod['isService']: return request_received.labels(rpod['namespace'], rpod['serviceName'], rpod['name']).inc() + request_exchanges.labels(pod['serviceName'], rpod['serviceName']).inc() ms.labels(pod['namespace'], pod['serviceName'], pod['name']).observe(event['MS'] / 1000000) tx_kb.labels(pod['namespace'], pod['serviceName'], pod['name']).observe(event['TX_KB']) @@ -123,7 +125,8 @@ def poll_syn_backlog(self): if saddr in config_watcher.config: pod = config_watcher.config[saddr] - backlog.labels(pod['namespace'], pod['serviceName'], pod['name'], row[0].slot).set(row[1].value) + backlog.labels(pod['namespace'], pod['serviceName'], pod['name'], int(row[0].slot)).set( + int(row[1].value)) if self.console_mode: self.syn_df = self.syn_df.append({ @@ -181,10 +184,3 @@ def poll_data_in_bg(self): poll_syn_backlog.join() poll_requests.join() poll_kube_api.join() - -def extract_number(text): - res = [int(i) for i in text.split() if i.isdigit()] - if len(res) == 1: - return int(res) - else: - return 0