diff options
author | Tor Brede Vekterli <vekterli@yahooinc.com> | 2022-02-24 17:16:58 +0100 |
---|---|---|
committer | Tor Brede Vekterli <vekterli@yahooinc.com> | 2022-02-24 17:16:58 +0100 |
commit | 8ee21f784095d2547cf4c4af49c9992f0c86f0f3 (patch) | |
tree | 7d912ddf2be3de44d0605c60628f50eda385f62f /config-model/src/main/java/com/yahoo/config | |
parent | 0f334e738a4def61a47b1c8251ed9583724b0ed2 (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.java | 7 |
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; |