diff options
author | Jon Marius Venstad <venstad@gmail.com> | 2019-09-18 14:41:30 +0200 |
---|---|---|
committer | Jon Marius Venstad <venstad@gmail.com> | 2019-09-18 16:39:10 +0200 |
commit | b7178d89985a0322adad1072417d0979fc10b054 (patch) | |
tree | c46b2ae7daa312461c89dde629f9e2390a03be96 | |
parent | 78122526cb79a5affcf31f8240046f2251b796d3 (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.java | 7 |
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()); } |