Create kesuses for rate limiting in YQ

Fill config in kikimr runner

Create coordination nodes

Pass to config

Protos

3 files changed, 32 insertions, 19 deletions

diff --git a/library/cpp/actors/http/http.h b/library/cpp/actors/http/http.h
index 318000389c..295b8f97b5 100644
--- a/library/cpp/actors/http/http.h
+++ b/library/cpp/actors/http/http.h
@@ -54,6 +54,27 @@ struct TEqNoCase {
     }
 };
 
+struct TSensors {
+    TString Direction;
+    TString Host;
+    TString Url;
+    TString Status;
+    TDuration Time;
+
+    TSensors(
+            TStringBuf direction,
+            TStringBuf host,
+            TStringBuf url,
+            TStringBuf status,
+            TDuration time)
+        : Direction(direction)
+        , Host(host)
+        , Url(url)
+        , Status(status)
+        , Time(time)
+    {}
+};
+
 struct TUrlParameters {
     THashMap<TStringBuf, TStringBuf> Parameters;
 
@@ -840,6 +861,7 @@ public:
 // it's temporary accessible for cleanup
 //protected:
     THttpIncomingRequestPtr Request;
+    std::unique_ptr<TSensors> Sensors;
 };
 
 }
diff --git a/library/cpp/actors/http/http_proxy.cpp b/library/cpp/actors/http/http_proxy.cpp
index 394cb17bd3..7cf83d38d8 100644
--- a/library/cpp/actors/http/http_proxy.cpp
+++ b/library/cpp/actors/http/http_proxy.cpp
@@ -260,6 +260,10 @@ TEvHttpProxy::TEvReportSensors* BuildOutgoingRequestSensors(const THttpOutgoingR
 }
 
 TEvHttpProxy::TEvReportSensors* BuildIncomingRequestSensors(const THttpIncomingRequestPtr& request, const THttpOutgoingResponsePtr& response) {
+    const auto& sensors = response->Sensors;
+    if (sensors) {
+        return new TEvHttpProxy::TEvReportSensors(*sensors);
+    }
     return new TEvHttpProxy::TEvReportSensors(
             "in",
             request->Host,
diff --git a/library/cpp/actors/http/http_proxy.h b/library/cpp/actors/http/http_proxy.h
index b95954e561..0ed09119e4 100644
--- a/library/cpp/actors/http/http_proxy.h
+++ b/library/cpp/actors/http/http_proxy.h
@@ -20,7 +20,7 @@ struct TSocketDescriptor : NActors::TSharedDescriptor, THttpConfig {
     SocketType Socket;
 
     TSocketDescriptor() = default;
-    
+
     TSocketDescriptor(int af)
         : Socket(af)
     {
@@ -213,24 +213,11 @@ struct TEvHttpProxy {
         {}
     };
 
-    struct TEvReportSensors : NActors::TEventLocal<TEvReportSensors, EvReportSensors> {
-        TString Direction;
-        TString Host;
-        TString Url;
-        TString Status;
-        TDuration Time;
-
-        TEvReportSensors(
-                TStringBuf direction,
-                TStringBuf host,
-                TStringBuf url,
-                TStringBuf status,
-                TDuration time)
-            : Direction(direction)
-            , Host(host)
-            , Url(url)
-            , Status(status)
-            , Time(time)
+    struct TEvReportSensors : TSensors, NActors::TEventLocal<TEvReportSensors, EvReportSensors> {
+        using TSensors::TSensors;
+
+        TEvReportSensors(const TSensors& sensors)
+            : TSensors(sensors)
         {}
     };
 };