Просмотр исходного кода

Allow backoff strategy reconfiguration

arkady-e1ppa 1 год назад
Родитель
Сommit
1d36e761da
2 измененных файлов с 9 добавлено и 1 удалено
  1. 6 0
      yt/yt/core/misc/backoff_strategy.cpp
  2. 3 1
      yt/yt/core/misc/backoff_strategy.h

+ 6 - 0
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

+ 3 - 1
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_;