diff options
author | Tor Brede Vekterli <vekterli@yahooinc.com> | 2021-10-14 14:52:50 +0200 |
---|---|---|
committer | Tor Brede Vekterli <vekterli@yahooinc.com> | 2021-10-14 14:54:56 +0200 |
commit | 4c09e1b31dcaff2bc0a73b83ba3bdaafa63d4bd5 (patch) | |
tree | 3e5d2cab2847f265e333c6a3a302c9a5c6823684 /configserver | |
parent | 299e8fea68d4a0f28c365bd3ff7866f18ca290dd (diff) |
Add feature flag for enhanced distributor maintenance scheduling
Diffstat (limited to 'configserver')
-rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/deploy/ModelContextImpl.java | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/deploy/ModelContextImpl.java b/configserver/src/main/java/com/yahoo/vespa/config/server/deploy/ModelContextImpl.java index b25bbf1a5bb..c994a25602a 100644 --- a/configserver/src/main/java/com/yahoo/vespa/config/server/deploy/ModelContextImpl.java +++ b/configserver/src/main/java/com/yahoo/vespa/config/server/deploy/ModelContextImpl.java @@ -194,6 +194,7 @@ public class ModelContextImpl implements ModelContext { private final int distributorMergeBusyWait; private final int docstoreCompressionLevel; private final double diskBloatFactor; + private final boolean distributorEnhancedMaintenanceScheduling; public FeatureFlags(FlagSource source, ApplicationId appId) { this.defaultTermwiseLimit = flagValue(source, appId, Flags.DEFAULT_TERM_WISE_LIMIT); @@ -226,6 +227,7 @@ public class ModelContextImpl implements ModelContext { this.distributorMergeBusyWait = flagValue(source, appId, Flags.DISTRIBUTOR_MERGE_BUSY_WAIT); this.docstoreCompressionLevel = flagValue(source, appId, Flags.DOCSTORE_COMPRESSION_LEVEL); this.diskBloatFactor = flagValue(source, appId, Flags.DISK_BLOAT_FACTOR); + this.distributorEnhancedMaintenanceScheduling = flagValue(source, appId, Flags.DISTRIBUTOR_ENHANCED_MAINTENANCE_SCHEDULING); } @Override public double defaultTermwiseLimit() { return defaultTermwiseLimit; } @@ -260,6 +262,7 @@ public class ModelContextImpl implements ModelContext { @Override public int distributorMergeBusyWait() { return distributorMergeBusyWait; } @Override public double diskBloatFactor() { return diskBloatFactor; } @Override public int docstoreCompressionLevel() { return docstoreCompressionLevel; } + @Override public boolean distributorEnhancedMaintenanceScheduling() { return distributorEnhancedMaintenanceScheduling; } private static <V> V flagValue(FlagSource source, ApplicationId appId, UnboundFlag<? extends V, ?, ?> flag) { return flag.bindTo(source) |