IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-25 18:55:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

moving test files into log dir

Browse Source
This commit is contained in:
Jonathan Shook 2020-02-24 09:45:05 -06:00
parent 363c841f2d
commit 8d0008f28d
7 changed files with 22 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
nb-extensions/src/main/java/io/nosqlbench/extensions/histostatslogger/histostatslogger.md
View File

@ -6,7 +6,8 @@ a matching set of histogram or timer metrics, at some interval you specify.
### Example
~~~
histostatslogger.logHistoStats("test run 42", ".*", "histostats.csv", "0.5s");
histostatslogger.logHistoStats("test run 42", ".*", "logs/histostats
.csv", "0.5s");
~~~
The arguments to logHistoStats are:

9
nb/src/test/java/io/nosqlbench/script/AsyncScriptIntegrationTests.java
View File

@ -130,7 +130,8 @@ public class AsyncScriptIntegrationTests {
@Test
public void testExtensionCsvLogger() {
ScenarioResult scenarioResult = runScenario("extension_csvmetrics");
assertThat(scenarioResult.getIOLog()).contains("started new csvlogger: csvmetricstestdir");
assertThat(scenarioResult.getIOLog()).contains("started new " +
"csvlogger: logs/csvmetricstestdir");
}
@ -147,8 +148,10 @@ public class AsyncScriptIntegrationTests {
@Test
public void testExtensionHistoStatsLogger() throws IOException {
ScenarioResult scenarioResult = runScenario("extension_histostatslogger");
assertThat(scenarioResult.getIOLog()).contains("stdout started logging to histostats.csv");
List<String> strings = Files.readAllLines(Paths.get("histostats.csv"));
assertThat(scenarioResult.getIOLog()).contains("stdout started " +
"logging to logs/histostats.csv");
List<String> strings = Files.readAllLines(Paths.get(
"logs/histostats.csv"));
String logdata = strings.stream().collect(Collectors.joining("\n"));
assertThat(logdata).contains("min,p25,p50,p75,p90,p95,");
assertThat(logdata.split("Tag=testhistostatslogger.cycles.servicetime,").length).isGreaterThanOrEqualTo(3);

9
nb/src/test/java/io/nosqlbench/script/ScriptIntegrationTests.java
View File

@ -133,7 +133,8 @@ public class ScriptIntegrationTests {
@Test
public void testExtensionCsvLogger() {
ScenarioResult scenarioResult = runScenario("extension_csvmetrics");
assertThat(scenarioResult.getIOLog()).contains("started new csvlogger: csvmetricstestdir");
assertThat(scenarioResult.getIOLog()).contains("started new " +
"csvlogger: logs/csvmetricstestdir");
}
@ -150,8 +151,10 @@ public class ScriptIntegrationTests {
@Test
public void testExtensionHistoStatsLogger() throws IOException {
ScenarioResult scenarioResult = runScenario("extension_histostatslogger");
assertThat(scenarioResult.getIOLog()).contains("stdout started logging to histostats.csv");
List<String> strings = Files.readAllLines(Paths.get("histostats.csv"));
assertThat(scenarioResult.getIOLog()).contains("stdout started " +
"logging to logs/histostats.csv");
List<String> strings = Files.readAllLines(Paths.get(
"logs/histostats.csv"));
String logdata = strings.stream().collect(Collectors.joining("\n"));
assertThat(logdata).contains("min,p25,p50,p75,p90,p95,");
assertThat(logdata.split("Tag=testhistostatslogger.cycles.servicetime,").length).isGreaterThanOrEqualTo(3);

2
nb/src/test/resources/scripts/async/extension_csvmetrics.js
View File

@ -15,7 +15,7 @@
* /
*/
var csvlogger = csvmetrics.log("csvmetricstestdir");
var csvlogger = csvmetrics.log("logs/csvmetricstestdir");
activitydef = {
"alias" : "csvmetrics",

5
nb/src/test/resources/scripts/async/extension_histostatslogger.js
View File

@ -25,8 +25,9 @@ activitydef = {
"async" : "1000"
};
histostatslogger.logHistoStats("testing extention histostatslogger", ".*", "histostats.csv", "0.5s");
print("started logging to histostats.csv for all metrics at 1/2 second intervals.");
histostatslogger.logHistoStats("testing extention histostatslogger", ".*", "logs/histostats.csv", "0.5s");
print("started logging to logs/histostats.csv for all metrics at 1/2" +
" second intervals.");
scenario.start(activitydef);
scenario.waitMillis(2000);

2
nb/src/test/resources/scripts/sync/extension_csvmetrics.js
View File

@ -1,4 +1,4 @@
var csvlogger = csvmetrics.log("csvmetricstestdir");
var csvlogger = csvmetrics.log("logs/csvmetricstestdir");
activitydef = {
"alias" : "csvmetrics",

5
nb/src/test/resources/scripts/sync/extension_histostatslogger.js
View File

@ -7,8 +7,9 @@ activitydef = {
"targetrate" : "10000.0"
};
histostatslogger.logHistoStats("testing extention histostatslogger", ".*", "histostats.csv", "0.5s");
print("started logging to histostats.csv for all metrics at 1/2 second intervals.");
histostatslogger.logHistoStats("testing extention histostatslogger", ".*", "logs/histostats.csv", "0.5s");
print("started logging to logs/histostats.csv for all metrics at 1/2" +
" second intervals.");
scenario.start(activitydef);
scenario.waitMillis(2000);