StatisticsService: updated HTML page (#8507)

Author: andrewstalin

ydb/core/statistics/service/service_impl.cpp

@@ -1246,16 +1246,76 @@ class TStatService : public TActorBootstrapped<TStatService> {
         TBase::PassAway();
     }
 
-    void Handle(NMon::TEvHttpInfo::TPtr& ev) {
-        auto& request = ev->Get()->Request;
+    void PrintStatServiceState(TStringStream& str) {
+        HTML(str) {
+            PRE() {
+                str << "---- StatisticsService ----" << Endl << Endl;
+                str << "StatisticsAggregatorId: " << StatisticsAggregatorId << Endl;
+                str << "SAPipeClientId: " << SAPipeClientId << Endl;
+
+                str << "InFlight: " << InFlight.size();
+                {
+                    ui32 simple{ 0 };
+                    ui32 countMin{ 0 };
+                    for (auto it = InFlight.begin(); it != InFlight.end(); ++it) {
+                        if (it->second.StatType == EStatType::SIMPLE) {
+                            ++simple;
+                        } else if (it->second.StatType == EStatType::COUNT_MIN_SKETCH) {
+                            ++countMin;
+                        }
+                    }
+                    str << "[SIMPLE: " << simple << ", COUNT_MIN_SKETCH: " << countMin << "]" << Endl;
+                }
+                str << "NextRequestId: " << NextRequestId << Endl;
 
-        if (!EnableColumnStatistics) {
-            Send(ev->Sender, new NMon::TEvHttpInfoRes("Column statistics is disabled"));
-            return;
+                str << "LoadQueriesInFlight: " << LoadQueriesInFlight.size() << Endl;
+                str << "NextLoadQueryCookie: " << NextLoadQueryCookie << Endl;
+
+                str << "NeedSchemeShards: " << NeedSchemeShards.size() << Endl;
+                str << "Statistics: " << Statistics.size() << Endl;
+
+                str << "ResolveSAStage: ";
+                if (ResolveSAStage == RSA_INITIAL) {
+                    str << "RSA_INITIAL";
+                } else if (ResolveSAStage == RSA_IN_FLIGHT) {
+                    str << "RSA_IN_FLIGHT";
+                }
+                else {
+                    str << "RSA_FINISHED";
+                }
+                str << Endl;
+
+                str << "AggregateKeepAlivePeriod: " << Settings.AggregateKeepAlivePeriod << Endl;
+                str << "AggregateKeepAliveTimeout: " << Settings.AggregateKeepAliveTimeout << Endl;
+                str << "AggregateKeepAliveAckTimeout: " << Settings.AggregateKeepAliveAckTimeout << Endl;
+                str << "StatisticsRequestTimeout: " << Settings.StatisticsRequestTimeout << Endl;
+                str << "MaxInFlightTabletRequests: " << Settings.MaxInFlightTabletRequests << Endl;
+                str << "FanOutFactor: " << Settings.FanOutFactor << Endl;
+
+                str << "---- AggregationStatistics ----" << Endl;
+                str << "Round: " << AggregationStatistics.Round << Endl;
+                str << "Cookie: " << AggregationStatistics.Cookie << Endl;
+                str << "PathId: " << AggregationStatistics.PathId.ToString() << Endl;
+                str << "LastAckHeartbeat: " << AggregationStatistics.LastAckHeartbeat << Endl;
+                str << "ParentNode: " << AggregationStatistics.ParentNode << Endl;
+                str << "PprocessedNodes: " << AggregationStatistics.PprocessedNodes << Endl;
+                str << "TotalStatisticsResponse: " << AggregationStatistics.TotalStatisticsResponse << Endl;
+                str << "Nodes: " << AggregationStatistics.Nodes.size() << Endl;
+                str << "CountMinSketches: " << AggregationStatistics.CountMinSketches.size() << Endl;
+            }
         }
+    }
+
+    void Handle(NMon::TEvHttpInfo::TPtr& ev) {
+        auto& request = ev->Get()->Request;
 
         auto method = request.GetMethod();
         if (method == HTTP_METHOD_POST) {
+            if (!EnableColumnStatistics) {
+                Send(ev->Sender, new NMon::TEvHttpInfoRes("Column statistics is disabled"));
+                return;
+            }
+
             auto& params = request.GetPostParams();
             auto itAction = params.find("action");
             if (itAction == params.end()) {
@@ -1276,6 +1336,18 @@ class TStatService : public TActorBootstrapped<TStatService> {
 
         } else if (method == HTTP_METHOD_GET) {
             auto& params = request.GetParams();
+            if (params.empty()) {
+                TStringStream str;
+                PrintStatServiceState(str);
+                Send(ev->Sender, new NMon::TEvHttpInfoRes(str.Str()));
+                return;
+            }
+
+            if (!EnableColumnStatistics) {
+                Send(ev->Sender, new NMon::TEvHttpInfoRes("Column statistics is disabled"));
+                return;
+            }
+
             auto itAction = params.find("action");
             if (itAction == params.end()) {
                 Send(ev->Sender, new NMon::TEvHttpInfoRes("'action' parameter is required"));