summaryrefslogtreecommitdiffstats
path: root/node-repository
diff options
context:
space:
mode:
authorMartin Polden <mpolden@mpolden.no>2022-10-14 16:13:20 +0200
committerMartin Polden <mpolden@mpolden.no>2022-10-14 16:15:37 +0200
commit4c0ff5a5d1a89555097c418f964d4c93124029bd (patch)
treea28c7648ad4d92c344384faea276c07db9429233 /node-repository
parent903bb98de0de610e155d9cc318b52ef89126489e (diff)
Store test data in target
Diffstat (limited to 'node-repository')
-rw-r--r--node-repository/src/test/java/com/yahoo/vespa/hosted/provision/autoscale/QuestMetricsDbTest.java48
1 files changed, 21 insertions, 27 deletions
diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/autoscale/QuestMetricsDbTest.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/autoscale/QuestMetricsDbTest.java
index 9e3213fc977..90e67a9b0cc 100644
--- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/autoscale/QuestMetricsDbTest.java
+++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/autoscale/QuestMetricsDbTest.java
@@ -13,12 +13,13 @@ import java.io.File;
import java.time.Duration;
import java.time.Instant;
import java.util.ArrayList;
+import java.util.Arrays;
import java.util.Collection;
-import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.stream.Collectors;
+import java.util.stream.Stream;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse;
@@ -35,9 +36,7 @@ public class QuestMetricsDbTest {
@Test
public void testNodeMetricsReadWrite() {
- String dataDir = "data/QuestMetricsDbReadWrite";
- IOUtils.recursiveDeleteDir(new File(dataDir));
- IOUtils.createDirectory(dataDir + "/metrics");
+ String dataDir = createEmptyDataDir("QuestMetricsDbReadWrite", "metrics");
ManualClock clock = new ManualClock("2020-10-01T00:00:00");
QuestMetricsDb db = new QuestMetricsDb(dataDir, clock);
Instant startTime = clock.instant();
@@ -81,9 +80,7 @@ public class QuestMetricsDbTest {
@Test
public void testClusterMetricsReadWrite() {
- String dataDir = "data/QuestMetricsDbReadWrite";
- IOUtils.recursiveDeleteDir(new File(dataDir));
- IOUtils.createDirectory(dataDir + "/clusterMetrics");
+ String dataDir = createEmptyDataDir("QuestMetricsDbReadWrite", "clusterMetrics");
ManualClock clock = new ManualClock("2020-10-01T00:00:00");
QuestMetricsDb db = new QuestMetricsDb(dataDir, clock);
Instant startTime = clock.instant();
@@ -134,9 +131,7 @@ public class QuestMetricsDbTest {
@Test
public void testWriteOldData() {
- String dataDir = "data/QuestMetricsDbWriteOldData";
- IOUtils.recursiveDeleteDir(new File(dataDir));
- IOUtils.createDirectory(dataDir + "/metrics");
+ String dataDir = createEmptyDataDir("QuestMetricsDbWriteOldData", "metrics");
ManualClock clock = new ManualClock("2020-10-01T00:00:00");
QuestMetricsDb db = new QuestMetricsDb(dataDir, clock);
Instant startTime = clock.instant();
@@ -161,9 +156,7 @@ public class QuestMetricsDbTest {
@Test
public void testGc() {
- String dataDir = "data/QuestMetricsDbGc";
- IOUtils.recursiveDeleteDir(new File(dataDir));
- IOUtils.createDirectory(dataDir + "/metrics");
+ String dataDir = createEmptyDataDir("QuestMetricsDbGc", "metrics");
ManualClock clock = new ManualClock();
int days = 10; // The first metrics are this many days in the past
clock.retreat(Duration.ofDays(10));
@@ -189,7 +182,7 @@ public class QuestMetricsDbTest {
@Ignore
@Test
public void testReadingAndAppendingToExistingData() {
- String dataDir = "data/QuestMetricsDbExistingData";
+ String dataDir = dataDir("QuestMetricsDbExistingData");
if ( ! new File(dataDir).exists()) {
System.out.println("No existing data to check");
return;
@@ -219,9 +212,7 @@ public class QuestMetricsDbTest {
@Ignore
@Test
public void updateExistingData() {
- String dataDir = "data/QuestMetricsDbExistingData";
- IOUtils.recursiveDeleteDir(new File(dataDir));
- IOUtils.createDirectory(dataDir + "/metrics");
+ String dataDir = createEmptyDataDir("QuestMetricsDbExistingData", "metrics");
ManualClock clock = new ManualClock("2020-10-01T00:00:00");
QuestMetricsDb db = new QuestMetricsDb(dataDir, clock);
Instant startTime = clock.instant();
@@ -249,16 +240,6 @@ public class QuestMetricsDbTest {
return timeseries;
}
- private List<ClusterMetricSnapshot> clusterTimeseries(int count, Duration sampleRate, ManualClock clock,
- ClusterSpec.Id cluster) {
- List<ClusterMetricSnapshot> timeseries = new ArrayList<>();
- for (int i = 1; i <= count; i++) {
- timeseries.add(new ClusterMetricSnapshot(clock.instant(), 30.0, 0.0));
- clock.advance(sampleRate);
- }
- return timeseries;
- }
-
private Collection<Pair<String, NodeMetricSnapshot>> timeseriesAt(int countPerHost, Instant at, String ... hosts) {
Collection<Pair<String, NodeMetricSnapshot>> timeseries = new ArrayList<>();
for (int i = 1; i <= countPerHost; i++) {
@@ -272,4 +253,17 @@ public class QuestMetricsDbTest {
return timeseries;
}
+ private static String dataDir(String name) {
+ return "target/questdb/" + name;
+ }
+
+ private static String createEmptyDataDir(String name, String... subPath) {
+ String dataDir = dataDir(name);
+ IOUtils.recursiveDeleteDir(new File(dataDir));
+ String path = Stream.concat(Stream.of(dataDir), Arrays.stream(subPath))
+ .collect(Collectors.joining("/"));
+ IOUtils.createDirectory(path);
+ return dataDir;
+ }
+
}