aboutsummaryrefslogtreecommitdiffstats
path: root/controller-server/src/test/java/com/yahoo
diff options
context:
space:
mode:
authorjonmv <venstad@gmail.com>2022-04-10 12:03:39 +0200
committerjonmv <venstad@gmail.com>2022-04-11 13:42:25 +0200
commite64eb299b12e79c9d9cbc2c8129f8225291daf90 (patch)
treec3d83b1940e94be33abf3df81dc5e7cb19f53212 /controller-server/src/test/java/com/yahoo
parent30f1c233e6fd26c89f3b4f194478b66cbf1152cb (diff)
Simplify ApplicationStore
Diffstat (limited to 'controller-server/src/test/java/com/yahoo')
-rw-r--r--controller-server/src/test/java/com/yahoo/vespa/hosted/controller/integration/ApplicationStoreMock.java28
1 files changed, 7 insertions, 21 deletions
diff --git a/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/integration/ApplicationStoreMock.java b/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/integration/ApplicationStoreMock.java
index bedae15824f..3dbe307fa5a 100644
--- a/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/integration/ApplicationStoreMock.java
+++ b/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/integration/ApplicationStoreMock.java
@@ -77,21 +77,23 @@ public class ApplicationStoreMock implements ApplicationStore {
}
@Override
- public void put(TenantName tenant, ApplicationName application, ApplicationVersion applicationVersion, byte[] applicationPackage, byte[] diff) {
- store.computeIfAbsent(appId(tenant, application), __ -> new ConcurrentHashMap<>()).put(applicationVersion, applicationPackage);
+ public void put(TenantName tenant, ApplicationName application, ApplicationVersion applicationVersion, byte[] bytes, byte[] tests, byte[] diff) {
+ store.computeIfAbsent(appId(tenant, application), __ -> new ConcurrentHashMap<>()).put(applicationVersion, bytes);
+ store.computeIfAbsent(testerId(tenant, application), key -> new ConcurrentHashMap<>()) .put(applicationVersion, tests);
applicationVersion.buildNumber().ifPresent(buildNumber ->
diffs.computeIfAbsent(appId(tenant, application), __ -> new ConcurrentHashMap<>()).put(buildNumber, diff));
}
@Override
- public boolean prune(TenantName tenant, ApplicationName application, ApplicationVersion oldestToRetain) {
- return store.containsKey(appId(tenant, application))
- && store.get(appId(tenant, application)).keySet().removeIf(version -> version.compareTo(oldestToRetain) < 0);
+ public void prune(TenantName tenant, ApplicationName application, ApplicationVersion oldestToRetain) {
+ store.getOrDefault(appId(tenant, application), Map.of()).keySet().removeIf(version -> version.compareTo(oldestToRetain) < 0);
+ store.getOrDefault(testerId(tenant, application), Map.of()).keySet().removeIf(version -> version.compareTo(oldestToRetain) < 0);
}
@Override
public void removeAll(TenantName tenant, ApplicationName application) {
store.remove(appId(tenant, application));
+ store.remove(testerId(tenant, application));
}
@Override
@@ -99,22 +101,6 @@ public class ApplicationStoreMock implements ApplicationStore {
return requireNonNull(store.get(testerId(tenant, application)).get(applicationVersion));
}
- @Override
- public void putTester(TenantName tenant, ApplicationName application, ApplicationVersion applicationVersion, byte[] testerPackage) {
- store.computeIfAbsent(testerId(tenant, application), key -> new ConcurrentHashMap<>())
- .put(applicationVersion, testerPackage);
- }
-
- @Override
- public boolean pruneTesters(TenantName tenant, ApplicationName application, ApplicationVersion oldestToRetain) {
- return store.containsKey(testerId(tenant, application))
- && store.get(testerId(tenant, application)).keySet().removeIf(version -> version.compareTo(oldestToRetain) < 0);
- }
-
- @Override
- public void removeAllTesters(TenantName tenant, ApplicationName application) {
- store.remove(testerId(tenant, application));
- }
@Override
public Optional<byte[]> getDevDiff(DeploymentId deploymentId, long buildNumber) {