src/telemetry_frontend/backend/tests/test_kafka_backend.py → src/telemetry/backend/tests/test_kafka_backend.py

@@ -17,9 +17,9 @@
 import logging
 from typing import Tuple
 from common.proto.context_pb2 import Empty
-from src.telemetry_frontend.tests.Messages import create_collector_request, create_collector_id
-from src.telemetry_frontend.backend.service.KafkaProducerService import KafkaProducerService
-from src.telemetry_frontend.backend.service.KafkaProducerServiceImpl import KafkaProducerServiceImpl
+from src.telemetry.frontend.tests.Messages import create_collector_request, create_collector_id
+from src.telemetry.backend.service.KafkaProducerService import KafkaProducerService
+from src.telemetry.backend.service.KafkaProducerServiceImpl import KafkaProducerServiceImpl
 
 LOGGER = logging.getLogger(__name__)
 

src/telemetry/frontend/__init__.py

+
+# Copyright 2022-2023 ETSI TeraFlowSDN - TFS OSG (https://tfs.etsi.org/)
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# 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.
+

src/telemetry_frontend/service/TelemetryFrontendService.py → src/telemetry/frontend/service/TelemetryFrontendService.py

@@ -17,7 +17,7 @@ from common.Settings import get_service_port_grpc
 from monitoring.service.NameMapping import NameMapping
 from common.tools.service.GenericGrpcService import GenericGrpcService
 from common.proto.telemetry_frontend_pb2_grpc import add_TelemetryFrontendServiceServicer_to_server
-from telemetry_frontend.service.TelemetryFrontendServiceServicerImpl import TelemetryFrontendServiceServicerImpl
+from telemetry.frontend.service.TelemetryFrontendServiceServicerImpl import TelemetryFrontendServiceServicerImpl
 
 
 class TelemetryFrontendService(GenericGrpcService):

src/telemetry_frontend/service/__main__.py → src/telemetry/frontend/service/__main__.py

@@ -12,6 +12,8 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
+import signal
+import sys
 import logging, threading
 from .TelemetryFrontendService import TelemetryFrontendService
 from monitoring.service.NameMapping import NameMapping

src/telemetry_frontend/tests/test_unitary.py → src/telemetry/frontend/tests/test_unitary.py

@@ -27,9 +27,9 @@ from common.tests.MockServicerImpl_Context import MockServicerImpl_Context
 from common.Settings import ( 
     get_service_port_grpc, get_env_var_name, ENVVAR_SUFIX_SERVICE_HOST, ENVVAR_SUFIX_SERVICE_PORT_GRPC)
 
-from telemetry_frontend.client.TelemetryFrontendClient import TelemetryFrontendClient
-from telemetry_frontend.service.TelemetryFrontendService import TelemetryFrontendService
-from telemetry_frontend.tests.Messages import ( create_collector_id, create_collector_request, 
+from telemetry.frontend.client.TelemetryFrontendClient import TelemetryFrontendClient
+from telemetry.frontend.service.TelemetryFrontendService import TelemetryFrontendService
+from telemetry.frontend.tests.Messages import ( create_collector_id, create_collector_request, 
     create_collector_filter, create_collector_request_a, create_collector_request_b)
 
 from device.client.DeviceClient import DeviceClient