diff options
author | Tor Brede Vekterli <vekterli@yahooinc.com> | 2022-02-23 16:51:53 +0100 |
---|---|---|
committer | Tor Brede Vekterli <vekterli@yahooinc.com> | 2022-02-23 16:51:53 +0100 |
commit | c4cb61ae2b5b32be6d157a866d132f86e7087ea0 (patch) | |
tree | 0634f10406e5b9d1ef3f198e250ee50d96bcbf8f /config-model/src/main/java/com/yahoo/config | |
parent | d015e7a9ef5f6e528fa8bb74949d46c4e9b2dcbc (diff) |
Add more feature flags for tuning dynamic persistence throttling
Adds the following feature flags:
* `persistence-throttling-window-size` for setting min/max window size
to the same value, effectively creating a static throttle policy.
* `persistence-throttling-ws-resize-rate` for controlling the rate
at which the dynamic throttle policy resizes its window.
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 | 14 |
1 files changed, 14 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 9ae1a75b858..41fdea27ee6 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 @@ -72,6 +72,8 @@ public class TestProperties implements ModelContext.Properties, ModelContext.Fea private String mergeThrottlingPolicy = "STATIC"; private double persistenceThrottlingWsDecrementFactor = 1.2; private double persistenceThrottlingWsBackoff = 0.95; + private int persistenceThrottlingWindowSize = -1; + private double persistenceThrottlingWsResizeRate = 3.0; private boolean inhibitDefaultMergesWhenGlobalMergesPending = false; private boolean useV8GeoPositions = false; private List<String> environmentVariables = List.of(); @@ -128,6 +130,8 @@ public class TestProperties implements ModelContext.Properties, ModelContext.Fea @Override public String mergeThrottlingPolicy() { return mergeThrottlingPolicy; } @Override public double persistenceThrottlingWsDecrementFactor() { return persistenceThrottlingWsDecrementFactor; } @Override public double persistenceThrottlingWsBackoff() { return persistenceThrottlingWsBackoff; } + @Override public int persistenceThrottlingWindowSize() { return persistenceThrottlingWindowSize; } + @Override public double persistenceThrottlingWsResizeRate() { return persistenceThrottlingWsResizeRate; } @Override public boolean inhibitDefaultMergesWhenGlobalMergesPending() { return inhibitDefaultMergesWhenGlobalMergesPending; } @Override public boolean useV8GeoPositions() { return useV8GeoPositions; } @Override public List<String> environmentVariables() { return environmentVariables; } @@ -334,6 +338,16 @@ public class TestProperties implements ModelContext.Properties, ModelContext.Fea return this; } + public TestProperties setPersistenceThrottlingWindowSize(int windowSize) { + this.persistenceThrottlingWindowSize = windowSize; + return this; + } + + public TestProperties setPersistenceThrottlingWsResizeRate(double resizeRate) { + this.persistenceThrottlingWsResizeRate = resizeRate; + return this; + } + public TestProperties inhibitDefaultMergesWhenGlobalMergesPending(boolean value) { this.inhibitDefaultMergesWhenGlobalMergesPending = value; return this; |