Skip to content

Commit 6069a75

Browse files
yycpttwxing1292
yycptt
authored and
wxing1292
committed
Track and emit metrics for entities in a single workflow (#4065)
1 parent 1939eca commit 6069a75

File tree

12 files changed

+916
-322
lines changed

12 files changed

+916
-322
lines changed

‎api/checksum/v1/message.pb.go‎

Lines changed: 263 additions & 48 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎api/persistence/v1/executions.pb.go‎

Lines changed: 439 additions & 224 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎common/metrics/metric_defs.go‎

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1413,14 +1413,22 @@ var (
14131413
ChildInfoSize = NewBytesHistogramDef("child_info_size")
14141414
RequestCancelInfoSize = NewBytesHistogramDef("request_cancel_info_size")
14151415
SignalInfoSize = NewBytesHistogramDef("signal_info_size")
1416+
SignalRequestIDSize = NewBytesHistogramDef("signal_request_id_size")
14161417
BufferedEventsSize = NewBytesHistogramDef("buffered_events_size")
14171418
ActivityInfoCount = NewDimensionlessHistogramDef("activity_info_count")
14181419
TimerInfoCount = NewDimensionlessHistogramDef("timer_info_count")
14191420
ChildInfoCount = NewDimensionlessHistogramDef("child_info_count")
14201421
SignalInfoCount = NewDimensionlessHistogramDef("signal_info_count")
14211422
RequestCancelInfoCount = NewDimensionlessHistogramDef("request_cancel_info_count")
1423+
SignalRequestIDCount = NewDimensionlessHistogramDef("signal_request_id_count")
14221424
BufferedEventsCount = NewDimensionlessHistogramDef("buffered_events_count")
14231425
TaskCount = NewDimensionlessHistogramDef("task_count")
1426+
TotalActivityCount = NewDimensionlessHistogramDef("total_activity_count")
1427+
TotalUserTimerCount = NewDimensionlessHistogramDef("total_user_timer_count")
1428+
TotalChildExecutionCount = NewDimensionlessHistogramDef("total_child_execution_count")
1429+
TotalRequestCancelExternalCount = NewDimensionlessHistogramDef("total_request_cancel_external_count")
1430+
TotalSignalExternalCount = NewDimensionlessHistogramDef("total_signal_external_count")
1431+
TotalSignalCount = NewDimensionlessHistogramDef("total_signal_count")
14241432
WorkflowRetryBackoffTimerCount = NewCounterDef("workflow_retry_backoff_timer")
14251433
WorkflowCronBackoffTimerCount = NewCounterDef("workflow_cron_backoff_timer")
14261434
WorkflowCleanupDeleteCount = NewCounterDef("workflow_cleanup_delete")

‎common/persistence/dataInterfaces.go‎

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -680,6 +680,14 @@ type (
680680
SignalRequestIDCount int
681681
BufferedEventsCount int
682682
TaskCountByCategory map[string]int
683+
684+
// Total item count for various information captured within mutable state
685+
TotalActivityCount int64
686+
TotalUserTimerCount int64
687+
TotalChildExecutionCount int64
688+
TotalRequestCancelExternalCount int64
689+
TotalSignalExternalCount int64
690+
TotalSignalCount int64
683691
}
684692

685693
HistoryStatistics struct {

‎common/persistence/execution_manager.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -359,7 +359,7 @@ func (m *executionManagerImpl) GetWorkflowExecution(
359359
newResponse := &GetWorkflowExecutionResponse{
360360
State: state,
361361
DBRecordVersion: response.DBRecordVersion,
362-
MutableStateStats: *statusOfInternalWorkflow(response.State, nil),
362+
MutableStateStats: *statusOfInternalWorkflow(response.State, state, nil),
363363
}
364364
return newResponse, nil
365365
}

‎common/persistence/size.go‎

Lines changed: 89 additions & 49 deletions
Original file line numberDiff line numberDiff line change
@@ -24,39 +24,49 @@
2424

2525
package persistence
2626

27-
import "go.temporal.io/server/service/history/tasks"
27+
import (
28+
persistencespb "go.temporal.io/server/api/persistence/v1"
29+
"go.temporal.io/server/service/history/tasks"
30+
)
2831

2932
func statusOfInternalWorkflow(
30-
state *InternalWorkflowMutableState,
33+
internalState *InternalWorkflowMutableState,
34+
state *persistencespb.WorkflowMutableState,
3135
historyStatistics *HistoryStatistics,
3236
) *MutableStateStatistics {
33-
if state == nil {
37+
if internalState == nil {
3438
return nil
3539
}
3640

37-
executionInfoSize := sizeOfBlob(state.ExecutionInfo)
38-
executionStateSize := sizeOfBlob(state.ExecutionState)
41+
executionInfoSize := sizeOfBlob(internalState.ExecutionInfo)
42+
executionStateSize := sizeOfBlob(internalState.ExecutionState)
3943

40-
activityInfoCount := len(state.ActivityInfos)
41-
activityInfoSize := sizeOfInt64BlobMap(state.ActivityInfos)
44+
totalActivityCount := state.ExecutionInfo.ActivityCount
45+
activityInfoCount := len(internalState.ActivityInfos)
46+
activityInfoSize := sizeOfInt64BlobMap(internalState.ActivityInfos)
4247

43-
timerInfoCount := len(state.TimerInfos)
44-
timerInfoSize := sizeOfStringBlobMap(state.TimerInfos)
48+
totalUserTimerCount := state.ExecutionInfo.UserTimerCount
49+
timerInfoCount := len(internalState.TimerInfos)
50+
timerInfoSize := sizeOfStringBlobMap(internalState.TimerInfos)
4551

46-
childExecutionInfoCount := len(state.ChildExecutionInfos)
47-
childExecutionInfoSize := sizeOfInt64BlobMap(state.ChildExecutionInfos)
52+
totalChildExecutionCount := state.ExecutionInfo.ChildExecutionCount
53+
childExecutionInfoCount := len(internalState.ChildExecutionInfos)
54+
childExecutionInfoSize := sizeOfInt64BlobMap(internalState.ChildExecutionInfos)
4855

49-
requestCancelInfoCount := len(state.RequestCancelInfos)
50-
requestCancelInfoSize := sizeOfInt64BlobMap(state.RequestCancelInfos)
56+
totalRequestCancelExternalCount := state.ExecutionInfo.RequestCancelExternalCount
57+
requestCancelInfoCount := len(internalState.RequestCancelInfos)
58+
requestCancelInfoSize := sizeOfInt64BlobMap(internalState.RequestCancelInfos)
5159

52-
signalInfoCount := len(state.SignalInfos)
53-
signalInfoSize := sizeOfInt64BlobMap(state.SignalInfos)
60+
totalSignalExternalCount := state.ExecutionInfo.SignalExternalCount
61+
signalInfoCount := len(internalState.SignalInfos)
62+
signalInfoSize := sizeOfInt64BlobMap(internalState.SignalInfos)
5463

55-
signalRequestIDCount := len(state.SignalRequestedIDs)
56-
signalRequestIDSize := sizeOfStringSlice(state.SignalRequestedIDs)
64+
totalSignalCount := state.ExecutionInfo.SignalCount
65+
signalRequestIDCount := len(internalState.SignalRequestedIDs)
66+
signalRequestIDSize := sizeOfStringSlice(internalState.SignalRequestedIDs)
5767

58-
bufferedEventsCount := len(state.BufferedEvents)
59-
bufferedEventsSize := sizeOfBlobSlice(state.BufferedEvents)
68+
bufferedEventsCount := len(internalState.BufferedEvents)
69+
bufferedEventsSize := sizeOfBlobSlice(internalState.BufferedEvents)
6070

6171
totalSize := executionInfoSize
6272
totalSize += executionStateSize
@@ -75,23 +85,29 @@ func statusOfInternalWorkflow(
7585
ExecutionInfoSize: executionInfoSize,
7686
ExecutionStateSize: executionStateSize,
7787

78-
ActivityInfoSize: activityInfoSize,
79-
ActivityInfoCount: activityInfoCount,
88+
ActivityInfoSize: activityInfoSize,
89+
ActivityInfoCount: activityInfoCount,
90+
TotalActivityCount: totalActivityCount,
8091

81-
TimerInfoSize: timerInfoSize,
82-
TimerInfoCount: timerInfoCount,
92+
TimerInfoSize: timerInfoSize,
93+
TimerInfoCount: timerInfoCount,
94+
TotalUserTimerCount: totalUserTimerCount,
8395

84-
ChildInfoSize: childExecutionInfoSize,
85-
ChildInfoCount: childExecutionInfoCount,
96+
ChildInfoSize: childExecutionInfoSize,
97+
ChildInfoCount: childExecutionInfoCount,
98+
TotalChildExecutionCount: totalChildExecutionCount,
8699

87-
RequestCancelInfoSize: requestCancelInfoSize,
88-
RequestCancelInfoCount: requestCancelInfoCount,
100+
RequestCancelInfoSize: requestCancelInfoSize,
101+
RequestCancelInfoCount: requestCancelInfoCount,
102+
TotalRequestCancelExternalCount: totalRequestCancelExternalCount,
89103

90-
SignalInfoSize: signalInfoSize,
91-
SignalInfoCount: signalInfoCount,
104+
SignalInfoSize: signalInfoSize,
105+
SignalInfoCount: signalInfoCount,
106+
TotalSignalExternalCount: totalSignalExternalCount,
92107

93108
SignalRequestIDSize: signalRequestIDSize,
94109
SignalRequestIDCount: signalRequestIDCount,
110+
TotalSignalCount: totalSignalCount,
95111

96112
BufferedEventsSize: bufferedEventsSize,
97113
BufferedEventsCount: bufferedEventsCount,
@@ -109,31 +125,37 @@ func statusOfInternalWorkflowMutation(
109125
executionInfoSize := sizeOfBlob(mutation.ExecutionInfoBlob)
110126
executionStateSize := sizeOfBlob(mutation.ExecutionStateBlob)
111127

128+
totalActivityCount := mutation.ExecutionInfo.ActivityCount
112129
activityInfoCount := len(mutation.UpsertActivityInfos)
113130
activityInfoCount += len(mutation.DeleteActivityInfos)
114131
activityInfoSize := sizeOfInt64BlobMap(mutation.UpsertActivityInfos)
115132
activityInfoSize += sizeOfInt64Set(mutation.DeleteActivityInfos)
116133

134+
totalUserTimerCount := mutation.ExecutionInfo.UserTimerCount
117135
timerInfoCount := len(mutation.UpsertTimerInfos)
118136
timerInfoCount += len(mutation.DeleteTimerInfos)
119137
timerInfoSize := sizeOfStringBlobMap(mutation.UpsertTimerInfos)
120138
timerInfoSize += sizeOfStringSet(mutation.DeleteTimerInfos)
121139

140+
totalChildExecutionCount := mutation.ExecutionInfo.ChildExecutionCount
122141
childExecutionInfoCount := len(mutation.UpsertChildExecutionInfos)
123142
childExecutionInfoCount += len(mutation.DeleteChildExecutionInfos)
124143
childExecutionInfoSize := sizeOfInt64BlobMap(mutation.UpsertChildExecutionInfos)
125144
childExecutionInfoSize += sizeOfInt64Set(mutation.DeleteChildExecutionInfos)
126145

146+
totalRequestCancelExternalCount := mutation.ExecutionInfo.RequestCancelExternalCount
127147
requestCancelInfoCount := len(mutation.UpsertRequestCancelInfos)
128148
requestCancelInfoCount += len(mutation.DeleteRequestCancelInfos)
129149
requestCancelInfoSize := sizeOfInt64BlobMap(mutation.UpsertRequestCancelInfos)
130150
requestCancelInfoSize += sizeOfInt64Set(mutation.DeleteRequestCancelInfos)
131151

152+
totalSignalExternalCount := mutation.ExecutionInfo.SignalExternalCount
132153
signalInfoCount := len(mutation.UpsertSignalInfos)
133154
signalInfoCount += len(mutation.DeleteSignalInfos)
134155
signalInfoSize := sizeOfInt64BlobMap(mutation.UpsertSignalInfos)
135156
signalInfoSize += sizeOfInt64Set(mutation.DeleteSignalInfos)
136157

158+
totalSignalCount := mutation.ExecutionInfo.SignalCount
137159
signalRequestIDCount := len(mutation.UpsertSignalRequestedIDs)
138160
signalRequestIDCount += len(mutation.DeleteSignalRequestedIDs)
139161
signalRequestIDSize := sizeOfStringSet(mutation.UpsertSignalRequestedIDs)
@@ -167,23 +189,29 @@ func statusOfInternalWorkflowMutation(
167189
ExecutionInfoSize: executionInfoSize,
168190
ExecutionStateSize: executionStateSize,
169191

170-
ActivityInfoSize: activityInfoSize,
171-
ActivityInfoCount: activityInfoCount,
192+
ActivityInfoSize: activityInfoSize,
193+
ActivityInfoCount: activityInfoCount,
194+
TotalActivityCount: totalActivityCount,
172195

173-
TimerInfoSize: timerInfoSize,
174-
TimerInfoCount: timerInfoCount,
196+
TimerInfoSize: timerInfoSize,
197+
TimerInfoCount: timerInfoCount,
198+
TotalUserTimerCount: totalUserTimerCount,
175199

176-
ChildInfoSize: childExecutionInfoSize,
177-
ChildInfoCount: childExecutionInfoCount,
200+
ChildInfoSize: childExecutionInfoSize,
201+
ChildInfoCount: childExecutionInfoCount,
202+
TotalChildExecutionCount: totalChildExecutionCount,
178203

179-
RequestCancelInfoSize: requestCancelInfoSize,
180-
RequestCancelInfoCount: requestCancelInfoCount,
204+
RequestCancelInfoSize: requestCancelInfoSize,
205+
RequestCancelInfoCount: requestCancelInfoCount,
206+
TotalRequestCancelExternalCount: totalRequestCancelExternalCount,
181207

182-
SignalInfoSize: signalInfoSize,
183-
SignalInfoCount: signalInfoCount,
208+
SignalInfoSize: signalInfoSize,
209+
SignalInfoCount: signalInfoCount,
210+
TotalSignalExternalCount: totalSignalExternalCount,
184211

185212
SignalRequestIDSize: signalRequestIDSize,
186213
SignalRequestIDCount: signalRequestIDCount,
214+
TotalSignalCount: totalSignalCount,
187215

188216
BufferedEventsSize: bufferedEventsSize,
189217
BufferedEventsCount: bufferedEventsCount,
@@ -211,21 +239,27 @@ func statusOfInternalWorkflowSnapshot(
211239
executionInfoSize := sizeOfBlob(snapshot.ExecutionInfoBlob)
212240
executionStateSize := sizeOfBlob(snapshot.ExecutionStateBlob)
213241

242+
totalActivityCount := snapshot.ExecutionInfo.ActivityCount
214243
activityInfoCount := len(snapshot.ActivityInfos)
215244
activityInfoSize := sizeOfInt64BlobMap(snapshot.ActivityInfos)
216245

246+
totalUserTimerCount := snapshot.ExecutionInfo.UserTimerCount
217247
timerInfoCount := len(snapshot.TimerInfos)
218248
timerInfoSize := sizeOfStringBlobMap(snapshot.TimerInfos)
219249

250+
totalChildExecutionCount := snapshot.ExecutionInfo.ChildExecutionCount
220251
childExecutionInfoCount := len(snapshot.ChildExecutionInfos)
221252
childExecutionInfoSize := sizeOfInt64BlobMap(snapshot.ChildExecutionInfos)
222253

254+
totalRequestCancelExternalCount := snapshot.ExecutionInfo.RequestCancelExternalCount
223255
requestCancelInfoCount := len(snapshot.RequestCancelInfos)
224256
requestCancelInfoSize := sizeOfInt64BlobMap(snapshot.RequestCancelInfos)
225257

258+
totalSignalExternalCount := snapshot.ExecutionInfo.SignalExternalCount
226259
signalInfoCount := len(snapshot.SignalInfos)
227260
signalInfoSize := sizeOfInt64BlobMap(snapshot.SignalInfos)
228261

262+
totalSignalCount := snapshot.ExecutionInfo.SignalCount
229263
signalRequestIDCount := len(snapshot.SignalRequestedIDs)
230264
signalRequestIDSize := sizeOfStringSet(snapshot.SignalRequestedIDs)
231265

@@ -251,23 +285,29 @@ func statusOfInternalWorkflowSnapshot(
251285
ExecutionInfoSize: executionInfoSize,
252286
ExecutionStateSize: executionStateSize,
253287

254-
ActivityInfoSize: activityInfoSize,
255-
ActivityInfoCount: activityInfoCount,
288+
ActivityInfoSize: activityInfoSize,
289+
ActivityInfoCount: activityInfoCount,
290+
TotalActivityCount: totalActivityCount,
256291

257-
TimerInfoSize: timerInfoSize,
258-
TimerInfoCount: timerInfoCount,
292+
TimerInfoSize: timerInfoSize,
293+
TimerInfoCount: timerInfoCount,
294+
TotalUserTimerCount: totalUserTimerCount,
259295

260-
ChildInfoSize: childExecutionInfoSize,
261-
ChildInfoCount: childExecutionInfoCount,
296+
ChildInfoSize: childExecutionInfoSize,
297+
ChildInfoCount: childExecutionInfoCount,
298+
TotalChildExecutionCount: totalChildExecutionCount,
262299

263-
RequestCancelInfoSize: requestCancelInfoSize,
264-
RequestCancelInfoCount: requestCancelInfoCount,
300+
RequestCancelInfoSize: requestCancelInfoSize,
301+
RequestCancelInfoCount: requestCancelInfoCount,
302+
TotalRequestCancelExternalCount: totalRequestCancelExternalCount,
265303

266-
SignalInfoSize: signalInfoSize,
267-
SignalInfoCount: signalInfoCount,
304+
SignalInfoSize: signalInfoSize,
305+
SignalInfoCount: signalInfoCount,
306+
TotalSignalExternalCount: totalSignalExternalCount,
268307

269308
SignalRequestIDSize: signalRequestIDSize,
270309
SignalRequestIDCount: signalRequestIDCount,
310+
TotalSignalCount: totalSignalCount,
271311

272312
BufferedEventsSize: bufferedEventsSize,
273313
BufferedEventsCount: bufferedEventsCount,

‎proto/internal/temporal/server/api/checksum/v1/message.proto‎

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,13 @@ message MutableStateChecksumPayload {
3939
int64 last_first_event_id = 6;
4040
int64 next_event_id = 7;
4141
int64 last_processed_event_id = 8;
42+
4243
int64 signal_count = 9;
44+
int64 activity_count = 21;
45+
int64 child_execution_count = 22;
46+
int64 user_timer_count = 23;
47+
int64 request_cancel_external_count = 24;
48+
int64 signal_external_count = 25;
4349

4450
int32 workflow_task_attempt = 10;
4551
int64 workflow_task_version = 11;
@@ -54,4 +60,5 @@ message MutableStateChecksumPayload {
5460

5561
string sticky_task_queue_name = 19;
5662
temporal.server.api.history.v1.VersionHistories version_histories = 20;
63+
5764
}

‎proto/internal/temporal/server/api/persistence/v1/executions.proto‎

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -121,6 +121,11 @@ message WorkflowExecutionInfo {
121121
reserved 44;
122122
reserved 45;
123123
int64 signal_count = 46;
124+
int64 activity_count = 71;
125+
int64 child_execution_count = 72;
126+
int64 user_timer_count = 73;
127+
int64 request_cancel_external_count = 74;
128+
int64 signal_external_count = 75;
124129
reserved 47;
125130
reserved 48;
126131
reserved 49;

‎service/history/workflow/checksum.go‎

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -67,6 +67,11 @@ func newMutableStateChecksumPayload(ms MutableState) *checksumspb.MutableStateCh
6767
LastFirstEventId: executionInfo.LastFirstEventId,
6868
NextEventId: ms.GetNextEventID(),
6969
LastProcessedEventId: executionInfo.LastWorkflowTaskStartedEventId,
70+
ActivityCount: executionInfo.ActivityCount,
71+
ChildExecutionCount: executionInfo.ChildExecutionCount,
72+
UserTimerCount: executionInfo.UserTimerCount,
73+
RequestCancelExternalCount: executionInfo.RequestCancelExternalCount,
74+
SignalExternalCount: executionInfo.SignalExternalCount,
7075
SignalCount: executionInfo.SignalCount,
7176
WorkflowTaskAttempt: executionInfo.WorkflowTaskAttempt,
7277
WorkflowTaskScheduledEventId: executionInfo.WorkflowTaskScheduledEventId,

‎service/history/workflow/metrics.go‎

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -57,14 +57,22 @@ func emitMutableStateStatus(
5757
metricsHandler.Histogram(metrics.ExecutionStateSize.GetMetricName(), metrics.ExecutionStateSize.GetMetricUnit()).Record(int64(stats.ExecutionStateSize))
5858
metricsHandler.Histogram(metrics.ActivityInfoSize.GetMetricName(), metrics.ActivityInfoSize.GetMetricUnit()).Record(int64(stats.ActivityInfoSize))
5959
metricsHandler.Histogram(metrics.ActivityInfoCount.GetMetricName(), metrics.ActivityInfoCount.GetMetricUnit()).Record(int64(stats.ActivityInfoCount))
60+
metricsHandler.Histogram(metrics.TotalActivityCount.GetMetricName(), metrics.TotalActivityCount.GetMetricUnit()).Record(stats.TotalActivityCount)
6061
metricsHandler.Histogram(metrics.TimerInfoSize.GetMetricName(), metrics.TimerInfoSize.GetMetricUnit()).Record(int64(stats.TimerInfoSize))
6162
metricsHandler.Histogram(metrics.TimerInfoCount.GetMetricName(), metrics.TimerInfoCount.GetMetricUnit()).Record(int64(stats.TimerInfoCount))
63+
metricsHandler.Histogram(metrics.TotalUserTimerCount.GetMetricName(), metrics.TotalUserTimerCount.GetMetricUnit()).Record(stats.TotalUserTimerCount)
6264
metricsHandler.Histogram(metrics.ChildInfoSize.GetMetricName(), metrics.ChildInfoSize.GetMetricUnit()).Record(int64(stats.ChildInfoSize))
6365
metricsHandler.Histogram(metrics.ChildInfoCount.GetMetricName(), metrics.ChildInfoCount.GetMetricUnit()).Record(int64(stats.ChildInfoCount))
66+
metricsHandler.Histogram(metrics.TotalChildExecutionCount.GetMetricName(), metrics.TotalChildExecutionCount.GetMetricUnit()).Record(stats.TotalChildExecutionCount)
6467
metricsHandler.Histogram(metrics.RequestCancelInfoSize.GetMetricName(), metrics.RequestCancelInfoSize.GetMetricUnit()).Record(int64(stats.RequestCancelInfoSize))
6568
metricsHandler.Histogram(metrics.RequestCancelInfoCount.GetMetricName(), metrics.RequestCancelInfoCount.GetMetricUnit()).Record(int64(stats.RequestCancelInfoCount))
69+
metricsHandler.Histogram(metrics.TotalRequestCancelExternalCount.GetMetricName(), metrics.TotalRequestCancelExternalCount.GetMetricUnit()).Record(stats.TotalRequestCancelExternalCount)
6670
metricsHandler.Histogram(metrics.SignalInfoSize.GetMetricName(), metrics.SignalInfoSize.GetMetricUnit()).Record(int64(stats.SignalInfoSize))
6771
metricsHandler.Histogram(metrics.SignalInfoCount.GetMetricName(), metrics.SignalInfoCount.GetMetricUnit()).Record(int64(stats.SignalInfoCount))
72+
metricsHandler.Histogram(metrics.TotalSignalExternalCount.GetMetricName(), metrics.TotalSignalExternalCount.GetMetricUnit()).Record(stats.TotalSignalExternalCount)
73+
metricsHandler.Histogram(metrics.SignalRequestIDSize.GetMetricName(), metrics.SignalRequestIDSize.GetMetricUnit()).Record(int64(stats.SignalRequestIDSize))
74+
metricsHandler.Histogram(metrics.SignalRequestIDCount.GetMetricName(), metrics.SignalRequestIDCount.GetMetricUnit()).Record(int64(stats.SignalRequestIDCount))
75+
metricsHandler.Histogram(metrics.TotalSignalCount.GetMetricName(), metrics.TotalSignalCount.GetMetricUnit()).Record(stats.TotalSignalCount)
6876
metricsHandler.Histogram(metrics.BufferedEventsSize.GetMetricName(), metrics.BufferedEventsSize.GetMetricUnit()).Record(int64(stats.BufferedEventsSize))
6977
metricsHandler.Histogram(metrics.BufferedEventsCount.GetMetricName(), metrics.BufferedEventsCount.GetMetricUnit()).Record(int64(stats.BufferedEventsCount))
7078

0 commit comments

Comments
 (0)