diff options
author | Geir Storli <geirst@verizonmedia.com> | 2021-10-22 12:27:50 +0000 |
---|---|---|
committer | Geir Storli <geirst@verizonmedia.com> | 2021-10-22 12:27:50 +0000 |
commit | 34eec1fe815a6382375f3c5fb4369fb939915ea1 (patch) | |
tree | 34f0119b239d6f138d13d58ab6e9459f4d940d17 /configserver | |
parent | 477354aea222aad8b23bb121ce6c4add8da1c462 (diff) |
Add feature flag for "async-apply-bucket-diff".
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 2752bda3c68..d8edcd747d8 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 @@ -198,6 +198,7 @@ public class ModelContextImpl implements ModelContext { private final boolean distributorEnhancedMaintenanceScheduling; private final int maxUnCommittedMemory; private final boolean forwardIssuesAsErrors; + private final boolean asyncApplyBucketDiff; public FeatureFlags(FlagSource source, ApplicationId appId) { this.defaultTermwiseLimit = flagValue(source, appId, Flags.DEFAULT_TERM_WISE_LIMIT); @@ -234,6 +235,7 @@ public class ModelContextImpl implements ModelContext { this.distributorEnhancedMaintenanceScheduling = flagValue(source, appId, Flags.DISTRIBUTOR_ENHANCED_MAINTENANCE_SCHEDULING); this.maxUnCommittedMemory = flagValue(source, appId, Flags.MAX_UNCOMMITTED_MEMORY);; this.forwardIssuesAsErrors = flagValue(source, appId, PermanentFlags.FORWARD_ISSUES_AS_ERRORS); + this.asyncApplyBucketDiff = flagValue(source, appId, Flags.ASYNC_APPLY_BUCKET_DIFF); } @Override public double defaultTermwiseLimit() { return defaultTermwiseLimit; } @@ -272,6 +274,7 @@ public class ModelContextImpl implements ModelContext { @Override public boolean distributorEnhancedMaintenanceScheduling() { return distributorEnhancedMaintenanceScheduling; } @Override public int maxUnCommittedMemory() { return maxUnCommittedMemory; } @Override public boolean forwardIssuesAsErrors() { return forwardIssuesAsErrors; } + @Override public boolean asyncApplyBucketDiff() { return asyncApplyBucketDiff; } private static <V> V flagValue(FlagSource source, ApplicationId appId, UnboundFlag<? extends V, ?, ?> flag) { return flag.bindTo(source) |