From 4343146c456ecd906c0ab51154e5361fb4852a57 Mon Sep 17 00:00:00 2001
From: Waleed Akbar <wakbar@cttc.es>
Date: Fri, 26 Apr 2024 16:16:43 +0000
Subject: [PATCH] "StopCollector" and "SelectCollector" methods are added
---
.../TelemetryFrontendServiceServicerImpl.py | 15 ++++++++++++++-
1 file changed, 14 insertions(+), 1 deletion(-)
diff --git a/src/telemetry_frontend/service/TelemetryFrontendServiceServicerImpl.py b/src/telemetry_frontend/service/TelemetryFrontendServiceServicerImpl.py
index 7814107dd..cb66b6b6a 100644
--- a/src/telemetry_frontend/service/TelemetryFrontendServiceServicerImpl.py
+++ b/src/telemetry_frontend/service/TelemetryFrontendServiceServicerImpl.py
@@ -14,8 +14,9 @@
import grpc
import logging
+from common.proto.context_pb2 import Empty
from monitoring.service.NameMapping import NameMapping
-from common.proto.telemetry_frontend_pb2 import CollectorId, Collector
+from common.proto.telemetry_frontend_pb2 import CollectorId, Collector, CollectorFilter, CollectorList
from common.method_wrappers.Decorator import MetricsPool, safe_and_metered_rpc_method
from common.proto.telemetry_frontend_pb2_grpc import TelemetryFrontendServiceServicer
@@ -37,4 +38,16 @@ class TelemetryFrontendServiceServicerImpl(TelemetryFrontendServiceServicer):
# collector_interval = request.interval_s
response.collector_id.uuid = _collector_id.collector_id.uuid
+ return response
+
+ @safe_and_metered_rpc_method(METRICS_POOL, LOGGER)
+ def StopCollector(self, request : CollectorId, grpc_context: grpc.ServicerContext # type: ignore
+ ) -> Empty: # type: ignore
+
+ return Empty()
+
+ def SelectCollectors(self, request : CollectorFilter, contextgrpc_context: grpc.ServicerContext # type: ignore
+ ) -> CollectorList: # type: ignore
+ response = CollectorList()
+
return response
\ No newline at end of file
--
GitLab