diff options
| author | dgolear <[email protected]> | 2025-06-21 00:10:51 +0300 |
|---|---|---|
| committer | dgolear <[email protected]> | 2025-06-21 00:28:09 +0300 |
| commit | f973252cef2252054cfa38a3384c5f63c6c57ed6 (patch) | |
| tree | db2bcae8373ea189ef92d3771384e8206715c935 | |
| parent | b9da249148346f44e804b46026af2385537bc640 (diff) | |
YTORM-1384: Add overload controller to object service
commit_hash:d2821558020bab51a04d0c07ac3c06cec5c4911e
| -rw-r--r-- | yt/yt/core/rpc/overload_controller.cpp | 5 | ||||
| -rw-r--r-- | yt/yt/core/rpc/overload_controller.h | 1 |
2 files changed, 6 insertions, 0 deletions
diff --git a/yt/yt/core/rpc/overload_controller.cpp b/yt/yt/core/rpc/overload_controller.cpp index 87484a7b405..dc2dd8e2270 100644 --- a/yt/yt/core/rpc/overload_controller.cpp +++ b/yt/yt/core/rpc/overload_controller.cpp @@ -375,6 +375,11 @@ public: Periodic_->Start(); } + TFuture<void> Stop() override + { + return Periodic_->Stop(); + } + void TrackInvoker( TStringBuf name, const IInvokerPtr& invoker) override diff --git a/yt/yt/core/rpc/overload_controller.h b/yt/yt/core/rpc/overload_controller.h index 708ec833271..93ac4f57a05 100644 --- a/yt/yt/core/rpc/overload_controller.h +++ b/yt/yt/core/rpc/overload_controller.h @@ -40,6 +40,7 @@ public: DECLARE_INTERFACE_SIGNAL(void(), LoadAdjusted); virtual void Start() = 0; + virtual TFuture<void> Stop() = 0; virtual void Reconfigure(TOverloadControllerConfigPtr config) = 0; virtual void TrackInvoker( |