intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

1 files changed, 18 insertions, 0 deletions

diff --git a/library/cpp/actors/helpers/flow_controlled_queue.h b/library/cpp/actors/helpers/flow_controlled_queue.h
new file mode 100644
index 0000000000..d250405304
--- /dev/null
+++ b/library/cpp/actors/helpers/flow_controlled_queue.h
@@ -0,0 +1,18 @@
+#pragma once
+
+#include <library/cpp/actors/core/actor.h>
+
+namespace NActors {
+
+    struct TFlowControlledQueueConfig {
+        ui32 MinAllowedInFly = 20;
+        ui32 MaxAllowedInFly = 100;
+        ui32 TargetDynamicRate = 0;
+
+        TDuration MinTrackedLatency = TDuration::MilliSeconds(20);
+        ui32 LatencyFactor = 4;
+    };
+
+    IActor* CreateFlowControlledRequestQueue(TActorId targetId, ui32 activity = IActor::ACTORLIB_COMMON, const TFlowControlledQueueConfig &config = TFlowControlledQueueConfig());
+
+}