diff options
author | arkady-e1ppa <[email protected]> | 2023-09-12 19:44:00 +0300 |
---|---|---|
committer | arkady-e1ppa <[email protected]> | 2023-09-12 20:37:38 +0300 |
commit | 1d36e761da527008b6d67c353f71ef524fc19b4b (patch) | |
tree | 3345b7a33595d76578f0f4f70586e5fae1a19b8d | |
parent | 60f706936ad7782fa57e021b0629fc79ca52a9a8 (diff) |
Allow backoff strategy reconfiguration
-rw-r--r-- | yt/yt/core/misc/backoff_strategy.cpp | 6 | ||||
-rw-r--r-- | yt/yt/core/misc/backoff_strategy.h | 4 |
2 files changed, 9 insertions, 1 deletions
diff --git a/yt/yt/core/misc/backoff_strategy.cpp b/yt/yt/core/misc/backoff_strategy.cpp index b53b7f9a9e9..76a1a80c94d 100644 --- a/yt/yt/core/misc/backoff_strategy.cpp +++ b/yt/yt/core/misc/backoff_strategy.cpp @@ -64,6 +64,12 @@ void TBackoffStrategy::ApplyJitter() BackoffWithJitter_ = isNegative ? Backoff_ - jitter : Backoff_ + jitter; } + +void TBackoffStrategy::UpdateOptions(const TExponentialBackoffOptions& newOptions) +{ + Options_ = newOptions; +} + //////////////////////////////////////////////////////////////////////////////// } // namespace NYT diff --git a/yt/yt/core/misc/backoff_strategy.h b/yt/yt/core/misc/backoff_strategy.h index 5896067e137..4da3aebd441 100644 --- a/yt/yt/core/misc/backoff_strategy.h +++ b/yt/yt/core/misc/backoff_strategy.h @@ -52,8 +52,10 @@ public: TDuration GetBackoff() const; + void UpdateOptions(const TExponentialBackoffOptions& newOptions); + private: - const TExponentialBackoffOptions Options_; + TExponentialBackoffOptions Options_; int RetryIndex_; TDuration Backoff_; |