Loading src/telemetry_frontend/backend/tests/messagesBackend.py +10 −24 Original line number Diff line number Diff line Loading @@ -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 Loading
src/telemetry_frontend/backend/tests/messagesBackend.py +10 −24 Original line number Diff line number Diff line Loading @@ -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
