diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2020-07-01 16:43:22 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-07-01 16:43:22 +0200 |
commit | 2704a5af8f7c78852e73bebdde9a46011cec8ad1 (patch) | |
tree | 3cc1d1396ccfc91a29a85c30d45279b9ea8368c7 /configserver | |
parent | 227ebbed0765606f1d03a9f16e0bca82950c94d7 (diff) | |
parent | 1ff6b4ff7485f019aade6f429d67f3f22efc46af (diff) |
Merge pull request #13771 from vespa-engine/balder/flag-for-feed-sequencer-type
Add flag for rolling out feed sequencer change.
Diffstat (limited to 'configserver')
-rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/deploy/ModelContextImpl.java | 5 |
1 files changed, 4 insertions, 1 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 74a9e72e255..b252ee3ef56 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 @@ -154,6 +154,7 @@ public class ModelContextImpl implements ModelContext { private final double threadPoolSizeFactor; private final double queueSizefactor; private final String jvmGCOPtions; + private final String feedSequencer; private final Optional<AthenzDomain> athenzDomain; private final Optional<ApplicationRoles> applicationRoles; private final int jdiscHealthCheckProxyClientTimeout; @@ -197,6 +198,8 @@ public class ModelContextImpl implements ModelContext { .with(FetchVector.Dimension.APPLICATION_ID, applicationId.serializedForm()).value(); jvmGCOPtions = Flags.JVM_GC_OPTIONS.bindTo(flagSource) .with(FetchVector.Dimension.APPLICATION_ID, applicationId.serializedForm()).value(); + feedSequencer = Flags.FEED_SEQUENCER_TYPE.bindTo(flagSource) + .with(FetchVector.Dimension.APPLICATION_ID, applicationId.serializedForm()).value(); this.athenzDomain = athenzDomain; this.applicationRoles = applicationRoles; jdiscHealthCheckProxyClientTimeout = Flags.JDISC_HEALTH_CHECK_PROXY_CLIENT_TIMEOUT.bindTo(flagSource) @@ -276,7 +279,7 @@ public class ModelContextImpl implements ModelContext { @Override public Duration jdiscHealthCheckProxyClientTimeout() { return Duration.ofMillis(jdiscHealthCheckProxyClientTimeout); } @Override public String jvmGCOptions() { return jvmGCOPtions; } - + @Override public String feedSequencerType() { return feedSequencer; } } } |