summaryrefslogtreecommitdiffstats
path: root/config-model/src/main/java/com/yahoo/config
diff options
context:
space:
mode:
authorTor Brede Vekterli <vekterli@yahooinc.com>2022-02-24 17:16:58 +0100
committerTor Brede Vekterli <vekterli@yahooinc.com>2022-02-24 17:16:58 +0100
commit8ee21f784095d2547cf4c4af49c9992f0c86f0f3 (patch)
tree7d912ddf2be3de44d0605c60628f50eda385f62f /config-model/src/main/java/com/yahoo/config
parent0f334e738a4def61a47b1c8251ed9583724b0ed2 (diff)
Add feature flag for controlling throttling of merge feed ops
Diffstat (limited to 'config-model/src/main/java/com/yahoo/config')
-rw-r--r--config-model/src/main/java/com/yahoo/config/model/deploy/TestProperties.java7
1 files changed, 7 insertions, 0 deletions
diff --git a/config-model/src/main/java/com/yahoo/config/model/deploy/TestProperties.java b/config-model/src/main/java/com/yahoo/config/model/deploy/TestProperties.java
index 41fdea27ee6..51f3455762c 100644
--- a/config-model/src/main/java/com/yahoo/config/model/deploy/TestProperties.java
+++ b/config-model/src/main/java/com/yahoo/config/model/deploy/TestProperties.java
@@ -74,6 +74,7 @@ public class TestProperties implements ModelContext.Properties, ModelContext.Fea
private double persistenceThrottlingWsBackoff = 0.95;
private int persistenceThrottlingWindowSize = -1;
private double persistenceThrottlingWsResizeRate = 3.0;
+ private boolean persistenceThrottlingOfMergeFeedOps = true;
private boolean inhibitDefaultMergesWhenGlobalMergesPending = false;
private boolean useV8GeoPositions = false;
private List<String> environmentVariables = List.of();
@@ -132,6 +133,7 @@ public class TestProperties implements ModelContext.Properties, ModelContext.Fea
@Override public double persistenceThrottlingWsBackoff() { return persistenceThrottlingWsBackoff; }
@Override public int persistenceThrottlingWindowSize() { return persistenceThrottlingWindowSize; }
@Override public double persistenceThrottlingWsResizeRate() { return persistenceThrottlingWsResizeRate; }
+ @Override public boolean persistenceThrottlingOfMergeFeedOps() { return persistenceThrottlingOfMergeFeedOps; }
@Override public boolean inhibitDefaultMergesWhenGlobalMergesPending() { return inhibitDefaultMergesWhenGlobalMergesPending; }
@Override public boolean useV8GeoPositions() { return useV8GeoPositions; }
@Override public List<String> environmentVariables() { return environmentVariables; }
@@ -348,6 +350,11 @@ public class TestProperties implements ModelContext.Properties, ModelContext.Fea
return this;
}
+ public TestProperties setPersistenceThrottlingOfMergeFeedOps(boolean throttleOps) {
+ this.persistenceThrottlingOfMergeFeedOps = throttleOps;
+ return this;
+ }
+
public TestProperties inhibitDefaultMergesWhenGlobalMergesPending(boolean value) {
this.inhibitDefaultMergesWhenGlobalMergesPending = value;
return this;