summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorHarald Musum <musum@yahooinc.com>2022-11-23 12:39:36 +0100
committerHarald Musum <musum@yahooinc.com>2022-11-23 12:39:36 +0100
commit30fa4dca80263323d6242d31247a76f66df2e97b (patch)
tree7bef829f7c9928a7cdfd2796a19d95a7c0b74c73
parent02dbfdece2c0bc6a1e2352c737da9c2ba7ae3d82 (diff)
Write quota to zk also when creating session from existing one
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/session/Session.java8
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionRepository.java1
2 files changed, 8 insertions, 1 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/session/Session.java b/configserver/src/main/java/com/yahoo/vespa/config/server/session/Session.java
index 62640668932..903323fcd58 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/session/Session.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/session/Session.java
@@ -6,6 +6,7 @@ import com.yahoo.config.FileReference;
import com.yahoo.config.application.api.ApplicationFile;
import com.yahoo.config.application.api.ApplicationMetaData;
import com.yahoo.config.application.api.ApplicationPackage;
+import com.yahoo.config.model.api.Quota;
import com.yahoo.config.model.api.TenantSecretStore;
import com.yahoo.config.provision.AllocatedHosts;
import com.yahoo.config.provision.ApplicationId;
@@ -19,7 +20,6 @@ import com.yahoo.transaction.Transaction;
import com.yahoo.vespa.config.server.NotFoundException;
import com.yahoo.vespa.config.server.application.ApplicationSet;
import com.yahoo.vespa.config.server.tenant.TenantRepository;
-
import java.security.cert.X509Certificate;
import java.time.Instant;
import java.util.List;
@@ -141,6 +141,10 @@ public abstract class Session implements Comparable<Session> {
sessionZooKeeperClient.writeAthenzDomain(athenzDomain);
}
+ public void setQuota(Optional<Quota> quota) {
+ sessionZooKeeperClient.writeQuota(quota);
+ }
+
public void setTenantSecretStores(List<TenantSecretStore> tenantSecretStores) {
sessionZooKeeperClient.writeTenantSecretStores(tenantSecretStores);
}
@@ -180,6 +184,8 @@ public abstract class Session implements Comparable<Session> {
public Optional<AthenzDomain> getAthenzDomain() { return sessionZooKeeperClient.readAthenzDomain(); }
+ public Optional<Quota> getQuota() { return sessionZooKeeperClient.readQuota(); }
+
public AllocatedHosts getAllocatedHosts() {
return sessionZooKeeperClient.getAllocatedHosts();
}
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionRepository.java b/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionRepository.java
index 0c7fc217e40..e9cd0fc5ec4 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionRepository.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/session/SessionRepository.java
@@ -284,6 +284,7 @@ public class SessionRepository {
session.setVespaVersion(existingSession.getVespaVersion());
session.setDockerImageRepository(existingSession.getDockerImageRepository());
session.setAthenzDomain(existingSession.getAthenzDomain());
+ session.setQuota(existingSession.getQuota());
session.setTenantSecretStores(existingSession.getTenantSecretStores());
session.setOperatorCertificates(existingSession.getOperatorCertificates());
session.setCloudAccount(existingSession.getCloudAccount());