diff --git a/test/telegraf-agents/rspec.yml b/test/telegraf-agents/rspec.yml index 0aef98861c3299a6788b53ad4eb641c2cd4ae6b3..e2290d4342ae999e89af4ddc8506a7a7d1ee5f48 100644 --- a/test/telegraf-agents/rspec.yml +++ b/test/telegraf-agents/rspec.yml @@ -79,11 +79,11 @@ hosts: ipendpoint_id: "metadata_database_I1_apache1" influxdb_url: "http://192.168.50.10:8086" database_name: "CLMCMetrics" - - name: ipendpoint + - name: host cpus: 1 memory: 2048 disk: "10GB" - service_name: "ipendpoint" + service_name: "host" forward_ports: - guest: 80 host: 8085 diff --git a/test/telegraf-agents/test_telegraf_agents.py b/test/telegraf-agents/test_telegraf_agents.py index 6e710dffd18f40780f58538eb9c96c322db32813..e7602723b2ae818ef4423f17c1959982edf4aed2 100644 --- a/test/telegraf-agents/test_telegraf_agents.py +++ b/test/telegraf-agents/test_telegraf_agents.py @@ -9,7 +9,7 @@ from influxdb import InfluxDBClient ('nginx'), ('mongo'), ('ffmpeg'), - ('ipendpoint'), + ('host'), ]) def test_service_name(telegraf_agent_config, service_name): assert any(s['name'] == service_name for s in telegraf_agent_config['hosts']), "{0} not in list of hosts".format(service_name) @@ -23,7 +23,11 @@ def test_ping(telegraf_agent_config): @pytest.mark.parametrize("measurement, query, expected_result", [ ('nginx', 'SELECT mean("requests") AS "mean" FROM "CLMCMetrics"."autogen"."nginx"', 0), ('cpu', 'SELECT mean("usage_idle") AS "mean" FROM "CLMCMetrics"."autogen"."cpu"', 0), - ('mongodb', 'SELECT mean("net_in_bytes") AS "mean" FROM "CLMCMetrics"."autogen"."mongodb"', 0) + ('mongodb', 'SELECT mean("net_in_bytes") AS "mean" FROM "CLMCMetrics"."autogen"."mongodb"', 0), + ('net', 'SELECT mean("bytes_sent") AS "mean" FROM "CLMCMetrics"."autogen"."net"', 0), + ('disk', 'SELECT mean("free") AS "mean" FROM "CLMCMetrics"."autogen"."disk"', 0), + ('diskio', 'SELECT mean("write_bytes") AS "mean" FROM "CLMCMetrics"."autogen"."diskio"', 0), + ('mem', 'SELECT mean("free") AS "mean" FROM "CLMCMetrics"."autogen"."mem"', 0) ]) def test_all_inputs(influxdb, measurement, query, expected_result): """Tests measurements are received from an input plugin aggregated across all services @@ -37,16 +41,6 @@ def test_all_inputs(influxdb, measurement, query, expected_result): actual_result = points[0]['mean'] assert actual_result > expected_result, "actual result {0} is not > expected result {1} for query {2}".format(actual_result, str(expected_result), query) -@pytest.mark.parametrize("ipendpoint, measurements", [ - ('id1', [{'measurement': 'cpu', 'query': 'query', 'result': 'result'} , {'measurement': 'nginx', 'query': 'query', 'result': 'result'}, {'measurement': 'mongo', 'query': 'query', 'result': 'result'}]), - ('id2', [{'measurement': 'cpu', 'query': 'query', 'result': 'result'} , {'measurement': 'nginx', 'query': 'query', 'result': 'result'}]) - ]) -def test_multiple_inputs_on_a_service(influxdb, ipendpoint, measurements): - """This test checks that a service configured with multiple input plugins as separate telegraf config files generates measurements in the database - """ - # for each item in the measurement list run the query and test the result - assert 1 - @pytest.mark.parametrize("query, expected_result", [('filter query', 0), ('filter query', 0),