Skip to content

Commit 32d563c

Browse files
rmllrrmllr
authored
Merge pull request #5 from tstrempel/experiment
create junit test for system level measurements
2 parents c281885 + 837230b commit 32d563c

3 files changed

Lines changed: 95 additions & 0 deletions

File tree

‎src/test/java/org/jqassistant/contrib/plugin/kieker/test/MeasurementIT.java‎

Lines changed: 83 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,83 @@
1+
package org.jqassistant.contrib.plugin.kieker.test;
2+
3+
import com.buschmais.jqassistant.core.scanner.api.DefaultScope;
4+
import com.buschmais.jqassistant.plugin.common.test.AbstractPluginIT;
5+
import org.junit.jupiter.api.Test;
6+
7+
import java.io.File;
8+
9+
import static org.hamcrest.CoreMatchers.equalTo;
10+
import static org.hamcrest.MatcherAssert.assertThat;
11+
12+
public class MeasurementIT extends AbstractPluginIT {
13+
14+
@Test
15+
public void testCpuUtilizationMeasurement() {
16+
final String TEST_DIRECTORY_PATH = "src/test/resources/measurements";
17+
File directory = new File(TEST_DIRECTORY_PATH);
18+
store.beginTransaction();
19+
getScanner().scan(directory, TEST_DIRECTORY_PATH, DefaultScope.NONE);
20+
TestResult testResult = query("MATCH (r:Record)-[:CONTAINS]->(c:CpuUtilization)" +
21+
"RETURN c.timestamp AS Timestamp, c.cpuID AS CPU_ID, c.totalUtilization AS CPUUtilization");
22+
assertThat(testResult.getRows().size(), equalTo(1));
23+
assertThat(testResult.getColumn("Timestamp").get(0).toString(), equalTo("1593952723894319300"));
24+
assertThat(testResult.getColumn("CPU_ID").get(0).toString(), equalTo("0"));
25+
assertThat(testResult.getColumn("CPUUtilization").get(0).toString(), equalTo("0.124"));
26+
}
27+
28+
@Test
29+
public void testDiskUsageMeasurement() {
30+
final String TEST_DIRECTORY_PATH = "src/test/resources/measurements";
31+
File directory = new File(TEST_DIRECTORY_PATH);
32+
store.beginTransaction();
33+
getScanner().scan(directory, TEST_DIRECTORY_PATH, DefaultScope.NONE);
34+
TestResult testResult = query("MATCH (r:Record)-[:CONTAINS]->(d:DiskUsage)" +
35+
"RETURN d.timestamp AS Timestamp, d.deviceName AS Device, d.readBytesPerSecond AS RBps");
36+
assertThat(testResult.getRows().size(), equalTo(1));
37+
assertThat(testResult.getColumn("Timestamp").get(0).toString(), equalTo("1593952728396520200"));
38+
assertThat(testResult.getColumn("Device").get(0).toString(), equalTo("C:\\\\"));
39+
assertThat(testResult.getColumn("RBps").get(0).toString(), equalTo("16384.0"));
40+
}
41+
42+
@Test
43+
public void testLoadAverageMeasurement() {
44+
final String TEST_DIRECTORY_PATH = "src/test/resources/measurements";
45+
File directory = new File(TEST_DIRECTORY_PATH);
46+
store.beginTransaction();
47+
getScanner().scan(directory, TEST_DIRECTORY_PATH, DefaultScope.NONE);
48+
TestResult testResult = query("MATCH (r:Record)-[:CONTAINS]->(l:LoadAverage)" +
49+
"RETURN l.timestamp AS Timestamp, l.loadAverage1min AS Load");
50+
assertThat(testResult.getRows().size(), equalTo(1));
51+
assertThat(testResult.getColumn("Timestamp").get(0).toString(), equalTo("1593952728434977600"));
52+
assertThat(testResult.getColumn("Load").get(0).toString(), equalTo("0.05"));
53+
}
54+
55+
@Test
56+
public void testMemSwapUsageMeasurement() {
57+
final String TEST_DIRECTORY_PATH = "src/test/resources/measurements";
58+
File directory = new File(TEST_DIRECTORY_PATH);
59+
store.beginTransaction();
60+
getScanner().scan(directory, TEST_DIRECTORY_PATH, DefaultScope.NONE);
61+
TestResult testResult = query("MATCH (r:Record)-[:CONTAINS]->(m:MemSwapUsage)" +
62+
"RETURN m.timestamp AS Timestamp, m.memTotal AS TotalMemory, m.swapUsed AS UsedSwap");
63+
assertThat(testResult.getRows().size(), equalTo(1));
64+
assertThat(testResult.getColumn("Timestamp").get(0).toString(), equalTo("1593952723915737300"));
65+
assertThat(testResult.getColumn("TotalMemory").get(0).toString(), equalTo("17129926656"));
66+
assertThat(testResult.getColumn("UsedSwap").get(0).toString(), equalTo("15588294656"));
67+
}
68+
69+
@Test
70+
public void testNetworkUtilizationMeasurement() {
71+
final String TEST_DIRECTORY_PATH = "src/test/resources/measurements";
72+
File directory = new File(TEST_DIRECTORY_PATH);
73+
store.beginTransaction();
74+
getScanner().scan(directory, TEST_DIRECTORY_PATH, DefaultScope.NONE);
75+
TestResult testResult = query("MATCH (r:Record)-[:CONTAINS]->(n:NetworkUtilization)" +
76+
"RETURN n.timestamp AS Timestamp, n.interfaceName AS Interface, n.speed AS Speed");
77+
assertThat(testResult.getRows().size(), equalTo(1));
78+
assertThat(testResult.getColumn("Timestamp").get(0).toString(), equalTo("1593952728404677600"));
79+
assertThat(testResult.getColumn("Interface").get(0).toString(), equalTo("eth0"));
80+
assertThat(testResult.getColumn("Speed").get(0).toString(), equalTo("1.0E8"));
81+
}
82+
83+
}

‎src/test/resources/measurements/kieker-20200705-123841331-UTC-001.dat‎

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
$0;1593952721341677300;1.14;KIEKER-SINGLETON;DESKTOP-LBQHRH1;1;false;0;NANOSECONDS;0
2+
$1;1593952723894361400;1593952723894319300;DESKTOP-LBQHRH1;0;0.062;0.062;0.0;0.0;0.0;0.124;0.876
3+
$2;1593952723915769200;1593952723915737300;DESKTOP-LBQHRH1;17129926656;8821727232;8308199424;22767071232;15588294656;7178776576
4+
$3;1593952728398092100;1593952728396520200;DESKTOP-LBQHRH1;C:\\;0.0;16384.0;1.0;-1.0;2472576.0;35.5
5+
$4;1593952728406610200;1593952728404677600;DESKTOP-LBQHRH1;eth0;100000000;0.0;0.0;0.0;0.0;0.0;0.0;0.0;0.0;0.0;0.0;0.0;0.0;0.0
6+
$5;1593952728404977600;1593952728434977600;DESKTOP-LBQHRH1;0.05;0.04;0.01

‎src/test/resources/measurements/kieker.map‎

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
$0=kieker.common.record.misc.KiekerMetadataRecord
2+
$1=kieker.common.record.system.CPUUtilizationRecord
3+
$2=kieker.common.record.system.MemSwapUsageRecord
4+
$3=kieker.common.record.system.DiskUsageRecord
5+
$4=kieker.common.record.system.NetworkUtilizationRecord
6+
$5=kieker.common.record.system.LoadAverageRecord

0 commit comments

Comments
 (0)