Skip to content
Snippets Groups Projects
Commit 69e25c60 authored by MJB's avatar MJB
Browse files

Updated telegraf-agents test to include host metrics and fixed but in ffmpeg agent configuration

parent f8de58c8
No related branches found
No related tags found
No related merge requests found
...@@ -79,11 +79,11 @@ hosts: ...@@ -79,11 +79,11 @@ hosts:
ipendpoint_id: "metadata_database_I1_apache1" ipendpoint_id: "metadata_database_I1_apache1"
influxdb_url: "http://192.168.50.10:8086" influxdb_url: "http://192.168.50.10:8086"
database_name: "CLMCMetrics" database_name: "CLMCMetrics"
- name: ipendpoint - name: host
cpus: 1 cpus: 1
memory: 2048 memory: 2048
disk: "10GB" disk: "10GB"
service_name: "ipendpoint" service_name: "host"
forward_ports: forward_ports:
- guest: 80 - guest: 80
host: 8085 host: 8085
......
...@@ -9,7 +9,7 @@ from influxdb import InfluxDBClient ...@@ -9,7 +9,7 @@ from influxdb import InfluxDBClient
('nginx'), ('nginx'),
('mongo'), ('mongo'),
('ffmpeg'), ('ffmpeg'),
('ipendpoint'), ('host'),
]) ])
def test_service_name(telegraf_agent_config, service_name): 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) 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): ...@@ -23,7 +23,11 @@ def test_ping(telegraf_agent_config):
@pytest.mark.parametrize("measurement, query, expected_result", [ @pytest.mark.parametrize("measurement, query, expected_result", [
('nginx', 'SELECT mean("requests") AS "mean" FROM "CLMCMetrics"."autogen"."nginx"', 0), ('nginx', 'SELECT mean("requests") AS "mean" FROM "CLMCMetrics"."autogen"."nginx"', 0),
('cpu', 'SELECT mean("usage_idle") AS "mean" FROM "CLMCMetrics"."autogen"."cpu"', 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): def test_all_inputs(influxdb, measurement, query, expected_result):
"""Tests measurements are received from an input plugin aggregated across all services """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): ...@@ -37,16 +41,6 @@ def test_all_inputs(influxdb, measurement, query, expected_result):
actual_result = points[0]['mean'] 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) 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", @pytest.mark.parametrize("query, expected_result",
[('filter query', 0), [('filter query', 0),
('filter query', 0), ('filter query', 0),
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment