diff options
author | Harald Musum <musum@yahooinc.com> | 2022-01-16 21:35:39 +0100 |
---|---|---|
committer | Harald Musum <musum@yahooinc.com> | 2022-01-16 21:35:39 +0100 |
commit | f3b0bc340c88b953a5f9f7985648e0a03a36ba5c (patch) | |
tree | f94abd1baafd7668a2b4dbe71f35393fac0eaed3 /configserver | |
parent | 79d57272a8228e9581d887ca26ecbaa7c7816c53 (diff) |
Add feature flag for checking config convergence before restart
Diffstat (limited to 'configserver')
-rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/ApplicationRepository.java | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/ApplicationRepository.java b/configserver/src/main/java/com/yahoo/vespa/config/server/ApplicationRepository.java index 80194337daa..c6c5b81019e 100644 --- a/configserver/src/main/java/com/yahoo/vespa/config/server/ApplicationRepository.java +++ b/configserver/src/main/java/com/yahoo/vespa/config/server/ApplicationRepository.java @@ -147,6 +147,7 @@ public class ApplicationRepository implements com.yahoo.config.provision.Deploye private final Metric metric; private final SecretStoreValidator secretStoreValidator; private final ClusterReindexingStatusClient clusterReindexingStatusClient; + private final FlagSource flagSource; @Inject public ApplicationRepository(TenantRepository tenantRepository, @@ -203,6 +204,7 @@ public class ApplicationRepository implements com.yahoo.config.provision.Deploye this.metric = Objects.requireNonNull(metric); this.secretStoreValidator = Objects.requireNonNull(secretStoreValidator); this.clusterReindexingStatusClient = clusterReindexingStatusClient; + this.flagSource = flagSource; } public static class Builder { @@ -1016,6 +1018,8 @@ public class ApplicationRepository implements com.yahoo.config.provision.Deploye return applicationId.orElse(null); } + public FlagSource flagSource() { return flagSource; } + private Session validateThatLocalSessionIsNotActive(Tenant tenant, long sessionId) { Session session = getLocalSession(tenant, sessionId); if (Session.Status.ACTIVATE.equals(session.getStatus())) { |