diff --git a/src/telemetry_frontend/service/TelemetryFrontendServiceServicerImpl.py b/src/telemetry_frontend/service/TelemetryFrontendServiceServicerImpl.py index 7814107ddb1436efdbdcb5a6fd53e3674e478816..cb66b6b6af7c8fe435cb49ea7f914eb98018a260 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