summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorarkady-e1ppa <[email protected]>2023-09-12 19:44:00 +0300
committerarkady-e1ppa <[email protected]>2023-09-12 20:37:38 +0300
commit1d36e761da527008b6d67c353f71ef524fc19b4b (patch)
tree3345b7a33595d76578f0f4f70586e5fae1a19b8d
parent60f706936ad7782fa57e021b0629fc79ca52a9a8 (diff)
Allow backoff strategy reconfiguration
-rw-r--r--yt/yt/core/misc/backoff_strategy.cpp6
-rw-r--r--yt/yt/core/misc/backoff_strategy.h4
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_;