summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorJon Marius Venstad <venstad@gmail.com>2019-09-18 14:41:30 +0200
committerJon Marius Venstad <venstad@gmail.com>2019-09-18 16:39:10 +0200
commitb7178d89985a0322adad1072417d0979fc10b054 (patch)
treec46b2ae7daa312461c89dde629f9e2390a03be96
parent78122526cb79a5affcf31f8240046f2251b796d3 (diff)
Write instances to the new instance path, as well as to the old
-rw-r--r--controller-server/src/main/java/com/yahoo/vespa/hosted/controller/persistence/CuratorDb.java7
1 files changed, 7 insertions, 0 deletions
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/persistence/CuratorDb.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/persistence/CuratorDb.java
index c0bddb5205a..52343fc527f 100644
--- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/persistence/CuratorDb.java
+++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/persistence/CuratorDb.java
@@ -74,6 +74,7 @@ public class CuratorDb {
private static final Path lockRoot = root.append("locks");
private static final Path tenantRoot = root.append("tenants");
private static final Path applicationRoot = root.append("applications");
+ private static final Path instanceRoot = root.append("instances");
private static final Path jobRoot = root.append("jobs");
private static final Path controllerRoot = root.append("controllers");
private static final Path routingPoliciesRoot = root.append("routingPolicies");
@@ -334,6 +335,7 @@ public class CuratorDb {
public void writeInstance(Instance instance) {
curator.set(applicationPath(instance.id()), asJson(instanceSerializer.toSlime(instance)));
+ curator.set(instancePath(instance.id()), asJson(instanceSerializer.toSlime(instance)));
}
public Optional<Instance> readInstance(ApplicationId application) {
@@ -362,6 +364,7 @@ public class CuratorDb {
public void removeInstance(ApplicationId id) {
curator.delete(applicationPath(id));
+ curator.delete(instancePath(id));
}
// -------------- Job Runs ------------------------------------------------
@@ -583,6 +586,10 @@ public class CuratorDb {
return applicationRoot.append(application.serializedForm());
}
+ private static Path instancePath(ApplicationId id) {
+ return instanceRoot.append(id.serializedForm());
+ }
+
private static Path runsPath(ApplicationId id, JobType type) {
return jobRoot.append(id.serializedForm()).append(type.jobName());
}