231
snapshot *InternalWorkflowSnapshot,
232
historyStatistics *HistoryStatistics,
233
>
) *MutableStateStatistics {
size.go
234
>
if snapshot == nil {
235
return nil
236
}
237
238
>
executionInfoSize := sizeOfBlob(snapshot.ExecutionInfoBlob)
size.go
239
>
executionStateSize := sizeOfBlob(snapshot.ExecutionStateBlob)
240
>
241
>
totalActivityCount := snapshot.ExecutionInfo.ActivityCount
242
>
activityInfoCount := len(snapshot.ActivityInfos)
243
>
activityInfoSize := sizeOfInt64BlobMap(snapshot.ActivityInfos)
244
>
245
>
totalUserTimerCount := snapshot.ExecutionInfo.UserTimerCount
246
>
timerInfoCount := len(snapshot.TimerInfos)
247
>
timerInfoSize := sizeOfStringBlobMap(snapshot.TimerInfos)
248
>
249
>
totalChildExecutionCount := snapshot.ExecutionInfo.ChildExecutionCount
250
>
childExecutionInfoCount := len(snapshot.ChildExecutionInfos)
251
>
childExecutionInfoSize := sizeOfInt64BlobMap(snapshot.ChildExecutionInfos)
252
>
253
>
totalRequestCancelExternalCount := snapshot.ExecutionInfo.RequestCancelExternalCount
254
>
requestCancelInfoCount := len(snapshot.RequestCancelInfos)
255
>
requestCancelInfoSize := sizeOfInt64BlobMap(snapshot.RequestCancelInfos)
256
>
257
>
totalSignalExternalCount := snapshot.ExecutionInfo.SignalExternalCount
258
>
signalInfoCount := len(snapshot.SignalInfos)
259
>
signalInfoSize := sizeOfInt64BlobMap(snapshot.SignalInfos)
260
>
261
>
totalSignalCount := snapshot.ExecutionInfo.SignalCount
262
>
signalRequestIDCount := len(snapshot.SignalRequestedIDs)
263
>
signalRequestIDSize := sizeOfStringSet(snapshot.SignalRequestedIDs)
264
>
265
>
totalUpdateCount := snapshot.ExecutionInfo.UpdateCount
266
>
updateInfoCount := len(snapshot.ExecutionInfo.UpdateInfos)
267
>
268
>
bufferedEventsCount := 0
269
>
bufferedEventsSize := 0
270
>
271
>
chasmTotalSize := sizeOfChasmNodeMap(snapshot.ChasmNodes)
272
>
273
>
totalSize := executionInfoSize
274
>
totalSize += executionStateSize
275
>
totalSize += activityInfoSize
276
>
totalSize += timerInfoSize
277
>
totalSize += childExecutionInfoSize
278
>
totalSize += requestCancelInfoSize
279
>
totalSize += signalInfoSize
280
>
totalSize += signalRequestIDSize
281
>
totalSize += bufferedEventsSize
282
>
totalSize += chasmTotalSize
283
>
284
>
taskCountByCategory := taskCountsByCategory(&snapshot.Tasks)
285
>
286
>
return &MutableStateStatistics{
287
>
TotalSize: totalSize,
288
>
HistoryStatistics: historyStatistics,
289
>
290
>
ExecutionInfoSize: executionInfoSize,
291
>
ExecutionStateSize: executionStateSize,
292
>
293
>
ActivityInfoSize: activityInfoSize,
294
>
ActivityInfoCount: activityInfoCount,
295
>
TotalActivityCount: totalActivityCount,
296
>
297
>
TimerInfoSize: timerInfoSize,
298
>
TimerInfoCount: timerInfoCount,
299
>
TotalUserTimerCount: totalUserTimerCount,
300
>
301
>
ChildInfoSize: childExecutionInfoSize,
302
>
ChildInfoCount: childExecutionInfoCount,
303
>
TotalChildExecutionCount: totalChildExecutionCount,
304
>
305
>
RequestCancelInfoSize: requestCancelInfoSize,
306
>
RequestCancelInfoCount: requestCancelInfoCount,
307
>
TotalRequestCancelExternalCount: totalRequestCancelExternalCount,
308
>
309
>
SignalInfoSize: signalInfoSize,
310
>
SignalInfoCount: signalInfoCount,
311
>
TotalSignalExternalCount: totalSignalExternalCount,
312
>
313
>
SignalRequestIDSize: signalRequestIDSize,
314
>
SignalRequestIDCount: signalRequestIDCount,
315
>
TotalSignalCount: totalSignalCount,
316
>
317
>
BufferedEventsSize: bufferedEventsSize,
318
>
BufferedEventsCount: bufferedEventsCount,
319
>
320
>
TaskCountByCategory: taskCountByCategory,
321
>
322
>
TotalUpdateCount: totalUpdateCount,
323
>
UpdateInfoCount: updateInfoCount,
324
>
325
>
ChasmTotalSize: chasmTotalSize,
326
>
}
327
}