Loading src/telemetry_frontend/service/TelemetryFrontendServiceServicerImpl.py +26 −1 Original line number Diff line number Diff line Loading @@ -11,3 +11,28 @@ # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. import logging from monitoring.service.NameMapping import NameMapping from common.proto.telemetry_frontend_pb2 import CollectorId, Collector from common.method_wrappers.Decorator import MetricsPool, safe_and_metered_rpc_method from common.proto.telemetry_frontend_pb2_grpc import TelemetryFrontendServiceServicer LOGGER = logging.getLogger(__name__) METRICS_POOL = MetricsPool('Monitoring', 'TelemetryFrontend') class TelemetryFrontendServiceServicerImpl(TelemetryFrontendServiceServicer): def __init__(self, name_mapping : NameMapping): LOGGER.info('Init TelemetryFrontendService') @safe_and_metered_rpc_method(METRICS_POOL, LOGGER) def StartCollector(self, request: Collector) -> CollectorId: response = CollectorId() collector_id = request.collector_id collector_kpi_id = request.kpi_id collector_duration = request.duration_s collector_interval = request.interval_s response.collector_id.uuid = request.collector_id.uuid return response No newline at end of file Loading
src/telemetry_frontend/service/TelemetryFrontendServiceServicerImpl.py +26 −1 Original line number Diff line number Diff line Loading @@ -11,3 +11,28 @@ # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. import logging from monitoring.service.NameMapping import NameMapping from common.proto.telemetry_frontend_pb2 import CollectorId, Collector from common.method_wrappers.Decorator import MetricsPool, safe_and_metered_rpc_method from common.proto.telemetry_frontend_pb2_grpc import TelemetryFrontendServiceServicer LOGGER = logging.getLogger(__name__) METRICS_POOL = MetricsPool('Monitoring', 'TelemetryFrontend') class TelemetryFrontendServiceServicerImpl(TelemetryFrontendServiceServicer): def __init__(self, name_mapping : NameMapping): LOGGER.info('Init TelemetryFrontendService') @safe_and_metered_rpc_method(METRICS_POOL, LOGGER) def StartCollector(self, request: Collector) -> CollectorId: response = CollectorId() collector_id = request.collector_id collector_kpi_id = request.kpi_id collector_duration = request.duration_s collector_interval = request.interval_s response.collector_id.uuid = request.collector_id.uuid return response No newline at end of file