diff --git a/src/telemetry_frontend/backend/tests/messagesBackend.py b/src/telemetry_frontend/backend/tests/messagesBackend.py index bfcebf0cc67bbdd5cdd8ef9a51ef878fa2cef9bf..ef12353837ece7093ef44e153c5e47b806223002 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