Loading src/telemetry_frontend/service/TelemetryFrontendServiceServicerImpl.py +14 −1 Original line number Diff line number Diff line Loading @@ -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 Loading @@ -38,3 +39,15 @@ class TelemetryFrontendServiceServicerImpl(TelemetryFrontendServiceServicer): 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 Loading
src/telemetry_frontend/service/TelemetryFrontendServiceServicerImpl.py +14 −1 Original line number Diff line number Diff line Loading @@ -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 Loading @@ -38,3 +39,15 @@ class TelemetryFrontendServiceServicerImpl(TelemetryFrontendServiceServicer): 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