add rate limiting settings to http (#10164)

Author: adameat

ydb/core/config/init/init_impl.h

@@ -287,6 +287,7 @@ struct TCommonAppOptions {
     ui32 MonitoringPort = 0;
     TString MonitoringAddress;
     ui32 MonitoringThreads = 10;
+    ui32 MonitoringMaxRequestsPerSecond = 0;
     TString MonitoringCertificateFile;
     TString RestartsCountFile = "";
     size_t CompileInflightLimit = 100000; // MiniKQLCompileService

ydb/core/driver_lib/run/config_parser.cpp

@@ -35,6 +35,7 @@ TRunCommandConfigParser::TRunOpts::TRunOpts()
     , MonitoringPort(0)
     , MonitoringAddress()
     , MonitoringThreads(10)
+    , MonitoringMaxRequestsPerSecond(0)
     , RestartsCountFile("")
     , StartTracingBusProxy(true)
     , CompileInflightLimit(100000)
@@ -365,6 +366,7 @@ void TRunCommandConfigParser::ApplyParsedOptions() {
     Config.AppConfig.MutableMonitoringConfig()->SetMonitoringPort(RunOpts.MonitoringPort);
     Config.AppConfig.MutableMonitoringConfig()->SetMonitoringAddress(RunOpts.MonitoringAddress);
     Config.AppConfig.MutableMonitoringConfig()->SetMonitoringThreads(RunOpts.MonitoringThreads);
+    Config.AppConfig.MutableMonitoringConfig()->SetMaxRequestsPerSecond(RunOpts.MonitoringMaxRequestsPerSecond);
     Config.AppConfig.MutableMonitoringConfig()->SetMonitoringCertificate(TUnbufferedFileInput(RunOpts.MonitoringCertificateFile).ReadAll());
     Config.AppConfig.MutableRestartsCountConfig()->SetRestartsCountFile(RunOpts.RestartsCountFile);
 }

ydb/core/driver_lib/run/config_parser.h

@@ -50,6 +50,7 @@ class TRunCommandConfigParser {
         TString MonitoringAddress;
         TString MonitoringCertificateFile;
         ui32 MonitoringThreads;
+        ui32 MonitoringMaxRequestsPerSecond;
         TString RestartsCountFile;
         bool StartTracingBusProxy;
         TString TracePath;

ydb/core/driver_lib/run/run.cpp

@@ -439,6 +439,7 @@ void TKikimrRunner::InitializeMonitoring(const TKikimrRunConfig& runConfig, bool
         monConfig.Threads = appConfig.GetMonitoringConfig().GetMonitoringThreads();
         monConfig.Address = appConfig.GetMonitoringConfig().GetMonitoringAddress();
         monConfig.Certificate = appConfig.GetMonitoringConfig().GetMonitoringCertificate();
+        monConfig.MaxRequestsPerSecond = appConfig.GetMonitoringConfig().GetMaxRequestsPerSecond();
         if (appConfig.GetMonitoringConfig().HasMonitoringCertificateFile()) {
             monConfig.Certificate = TUnbufferedFileInput(appConfig.GetMonitoringConfig().GetMonitoringCertificateFile()).ReadAll();
         }

ydb/core/mon/async_http_mon.cpp

@@ -826,6 +826,7 @@ void TAsyncHttpMon::Start(TActorSystem* actorSystem) {
         };
         addPort->SslCertificatePem = Config.Certificate;
         addPort->Secure = !Config.Certificate.empty();
+        addPort->MaxRequestsPerSecond = Config.MaxRequestsPerSecond;
         ActorSystem->Send(HttpProxyActorId, addPort.release());
         ActorSystem->Send(HttpProxyActorId, new NHttp::TEvHttpProxy::TEvRegisterHandler("/", HttpMonServiceActorId));
         ActorSystem->Send(HttpProxyActorId, new NHttp::TEvHttpProxy::TEvRegisterHandler("/node", NodeProxyServiceActorId));

ydb/core/mon/mon.h

@@ -41,6 +41,7 @@ class TMon {
         TVector<TString> AllowedSIDs;
         TString RedirectMainPageTo;
         TString Certificate;
+        ui32 MaxRequestsPerSecond = 0;
     };
 
     virtual ~TMon() = default;

ydb/core/protos/config.proto

@@ -535,6 +535,7 @@ message TMonitoringConfig {
     optional string MonitoringCertificate = 14;
     optional string MonitoringCertificateFile = 15;
     optional string MemAllocDumpPathPrefix = 16;
+    optional uint32 MaxRequestsPerSecond = 17 [default = 0];
 }
 
 message TRestartsCountConfig {