From a7e1ddfbc2ee39936c83f2d6a2105ebfd97473bd Mon Sep 17 00:00:00 2001
From: Waleed Akbar <wakbar@cttc.es>
Date: Wed, 8 May 2024 13:29:03 +0000
Subject: [PATCH] Remove "create_kafka_config" message type
---
.../backend/tests/messagesBackend.py | 34 ++++++-------------
1 file changed, 10 insertions(+), 24 deletions(-)
diff --git a/src/telemetry_frontend/backend/tests/messagesBackend.py b/src/telemetry_frontend/backend/tests/messagesBackend.py
index bfcebf0cc..ef1235383 100644
--- a/src/telemetry_frontend/backend/tests/messagesBackend.py
+++ b/src/telemetry_frontend/backend/tests/messagesBackend.py
@@ -13,34 +13,20 @@
# limitations under the License.
-def create_kafka_config():
- """
- No input parameter is requested
- Returns the dict object with Kafka configs
- """
- _kafka_configs = dict()
- _kafka_configs['bootstrap_servers'] = '127.0.0.1:9092'
- _kafka_configs['exporter_endpoint'] = 'http://10.152.183.231:9100/metrics'
- _kafka_configs['kafka_topic'] = 'metric-data'
- _kafka_configs['run_duration'] = 20
- _kafka_configs['fetch_interval'] = 4
-
- return _kafka_configs
-
-def create_kafka_config_a(bootstrap_server, exporter_endpoint, kafka_topic, run_duration, fetch_interval):
+def create_kafka_config_a(bootstrap_server: str, exporter_endpoint: str, kafka_topic: str,
+ run_duration: int, fetch_interval: int):
"""
Provide ...
Bootstrap_server IP address as String.
Exporter endpoint with port <http://ip:port(metrics)> address as String.
Kafka topic name as String.
- Total duration of the test as Float.
- Fetch_interval as Float.
+ Total duration of the test as Int.
+ Fetch_interval as Int.
"""
- _kafka_configs = dict()
- _kafka_configs['bootstrap_servers'] = bootstrap_server
- _kafka_configs['exporter_endpoint'] = exporter_endpoint
- _kafka_configs['kafka_topic'] = kafka_topic
- _kafka_configs['run_duration'] = run_duration
- _kafka_configs['fetch_interval'] = fetch_interval
+ _bootstrap_servers = bootstrap_server
+ _exporter_endpoint = exporter_endpoint
+ _kafka_topic = kafka_topic
+ _run_duration = run_duration
+ _fetch_interval = fetch_interval
- return _kafka_configs
\ No newline at end of file
+ return _bootstrap_servers, _exporter_endpoint, _kafka_topic, _run_duration, _fetch_interval
--
GitLab