@@ -37,10 +37,46 @@ message TDqAsyncBufferStats {
37
37
uint64 QueuedRows = 15 ;
38
38
}
39
39
40
+ message TDqStatsAggr {
41
+ uint64 Min = 1 ;
42
+ uint64 Max = 2 ;
43
+ uint64 Sum = 3 ;
44
+ uint64 Cnt = 4 ;
45
+ repeated TDqHistoryItem History = 5 ;
46
+ }
47
+
48
+ message TDqExternalAggrStats {
49
+ TDqStatsAggr ExternalRows = 1 ;
50
+ TDqStatsAggr ExternalBytes = 2 ;
51
+ TDqStatsAggr StorageRows = 3 ;
52
+ TDqStatsAggr StorageBytes = 4 ;
53
+ TDqStatsAggr CpuTimeUs = 5 ;
54
+ TDqStatsAggr WaitInputTimeUs = 6 ;
55
+ TDqStatsAggr WaitOutputTimeUs = 7 ;
56
+ TDqStatsAggr FirstMessageMs = 8 ;
57
+ TDqStatsAggr LastMessageMs = 9 ;
58
+ uint32 PartitionCount = 10 ;
59
+ }
60
+
61
+ message TDqExternalStats {
62
+ uint64 ExternalRows = 1 ;
63
+ uint64 ExternalBytes = 2 ;
64
+ uint64 StorageRows = 3 ;
65
+ uint64 StorageBytes = 4 ;
66
+ uint64 CpuTimeUs = 5 ;
67
+ uint64 WaitInputTimeUs = 6 ;
68
+ uint64 WaitOutputTimeUs = 7 ;
69
+ uint64 FirstMessageMs = 8 ;
70
+ uint64 LastMessageMs = 9 ;
71
+ string PartitionId = 10 ;
72
+ }
73
+
40
74
message TDqAsyncInputBufferStats {
41
75
uint64 InputIndex = 1 ;
42
76
string IngressName = 9 ;
43
77
78
+ TDqExternalAggrStats External = 13 ;
79
+ repeated TDqExternalStats ExternalPartitions = 14 ;
44
80
TDqAsyncBufferStats Ingress = 10 ;
45
81
TDqAsyncBufferStats Push = 11 ;
46
82
TDqAsyncBufferStats Pop = 12 ;
@@ -282,14 +318,6 @@ message TDqHistoryItem {
282
318
uint64 Value = 2 ;
283
319
}
284
320
285
- message TDqStatsAggr {
286
- uint64 Min = 1 ;
287
- uint64 Max = 2 ;
288
- uint64 Sum = 3 ;
289
- uint64 Cnt = 4 ;
290
- repeated TDqHistoryItem History = 5 ;
291
- }
292
-
293
321
message TExtraStats {
294
322
map <string , TDqStatsAggr > Stats = 1 ;
295
323
}
@@ -322,6 +350,7 @@ message TDqAsyncStatsAggr {
322
350
}
323
351
324
352
message TDqAsyncBufferStatsAggr {
353
+ TDqExternalAggrStats External = 5 ;
325
354
TDqAsyncStatsAggr Ingress = 1 ; // for Ingress only
326
355
TDqAsyncStatsAggr Push = 2 ;
327
356
TDqAsyncStatsAggr Pop = 3 ;
0 commit comments