forked from temporalio/temporal
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathmetric_defs.go
More file actions
1563 lines (1511 loc) · 106 KB
/
Copy pathmetric_defs.go
File metadata and controls
1563 lines (1511 loc) · 106 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
919
920
921
922
923
924
925
926
927
928
929
930
931
932
933
934
935
936
937
938
939
940
941
942
943
944
945
946
947
948
949
950
951
952
953
954
955
956
957
958
959
960
961
962
963
964
965
966
967
968
969
970
971
972
973
974
975
976
977
978
979
980
981
982
983
984
985
986
987
988
989
990
991
992
993
994
995
996
997
998
999
1000
package metrics
// Common tags for all services
const (
OperationTagName = "operation"
ServiceRoleTagName = "service_role"
CacheTypeTagName = "cache_type"
FailureTagName = "failure"
FailureSourceTagName = "failure_source"
TaskCategoryTagName = "task_category"
TaskTypeTagName = "task_type"
TaskPriorityTagName = "task_priority"
QueueReaderIDTagName = "queue_reader_id"
QueueActionTagName = "queue_action"
QueueTypeTagName = "queue_type"
visibilityPluginNameTagName = "visibility_plugin_name"
visibilityIndexNameTagName = "visibility_index_name"
ErrorTypeTagName = "error_type"
httpStatusTagName = "http_status"
nexusMethodTagName = "method"
nexusEndpointTagName = "nexus_endpoint"
nexusServiceTagName = "nexus_service"
nexusOperationTagName = "nexus_operation"
outcomeTagName = "outcome"
versionedTagName = "versioned"
resourceExhaustedTag = "resource_exhausted_cause"
resourceExhaustedScopeTag = "resource_exhausted_scope"
PartitionTagName = "partition"
PriorityTagName = "priority"
PersistenceDBKindTagName = "db_kind"
WorkerPluginNameTagName = "worker_plugin_name"
WorkerStorageDriverTypeTagName = "worker_storage_driver_type"
headerCallsiteTagName = "header_callsite"
ArchetypeTagName = "archetype"
ChasmTaskTypeTagName = "chasm_task_type"
timeoutTypeTagName = "timeout_type"
)
// This package should hold all the metrics and tags for temporal
const (
HistoryRoleTagValue = "history"
MatchingRoleTagValue = "matching"
FrontendRoleTagValue = "frontend"
AdminRoleTagValue = "admin"
DCRedirectionRoleTagValue = "dc_redirection"
BlobstoreRoleTagValue = "blobstore"
MutableStateCacheTypeTagValue = "mutablestate"
EventsCacheTypeTagValue = "events"
VersionMembershipCacheTypeTagValue = "version_membership"
ReactivationSignalDedupCacheTypeTagValue = "reactivation_signal_dedup"
RoutingInfoCacheTypeTagValue = "routing_info"
NexusEndpointRegistryReadThroughCacheTypeTagValue = "nexus_endpoint_registry_readthrough"
ReplicationProgressCacheTypeTagValue = "replication_progress"
InvalidHistoryURITagValue = "invalid_history_uri"
InvalidVisibilityURITagValue = "invalid_visibility_uri"
ActiveNamespaceStateTagValue = "active"
PassiveNamespaceStateTagValue = "passive"
UnknownNamespaceStateTagValue = "unknown"
)
// Admin Client Operations
const (
// AdminClientStreamWorkflowReplicationMessagesScope tracks RPC calls to admin service
AdminClientStreamWorkflowReplicationMessagesScope = "AdminClientStreamWorkflowReplicationMessages"
)
// History Client Operations
const (
// HistoryClientStreamWorkflowReplicationMessagesScope tracks RPC calls to history service
HistoryClientStreamWorkflowReplicationMessagesScope = "HistoryClientStreamWorkflowReplicationMessages"
)
// Matching Client Operations
const (
MatchingClientPollWorkflowTaskQueueScope = "MatchingClientPollWorkflowTaskQueue"
MatchingClientPollActivityTaskQueueScope = "MatchingClientPollActivityTaskQueue"
MatchingClientPollNexusTaskQueueScope = "MatchingClientPollNexusTaskQueue"
MatchingClientAddActivityTaskScope = "MatchingClientAddActivityTask"
MatchingClientAddWorkflowTaskScope = "MatchingClientAddWorkflowTask"
MatchingClientQueryWorkflowScope = "MatchingClientQueryWorkflow"
MatchingClientDispatchNexusTaskScope = "MatchingDispatchNexusTask"
)
// Worker
const (
// TaskQueueScavengerScope is scope used by all metrics emitted by worker.taskqueue.Scavenger module
TaskQueueScavengerScope = "TaskQueueScavenger"
// ExecutionsScavengerScope is scope used by all metrics emitted by worker.executions.Scavenger module
ExecutionsScavengerScope = "ExecutionsScavenger"
)
const (
// PersistenceAppendHistoryNodesScope tracks AppendHistoryNodes calls made by service to persistence layer
PersistenceAppendHistoryNodesScope = "AppendHistoryNodes"
// PersistenceAppendRawHistoryNodesScope tracks AppendRawHistoryNodes calls made by service to persistence layer
PersistenceAppendRawHistoryNodesScope = "AppendRawHistoryNodes"
// PersistenceReadHistoryBranchScope tracks ReadHistoryBranch calls made by service to persistence layer
PersistenceReadHistoryBranchScope = "ReadHistoryBranch"
// PersistenceReadHistoryBranchReverseScope tracks ReadHistoryBranchReverse calls made by service to persistence layer
PersistenceReadHistoryBranchReverseScope = "ReadHistoryBranchReverse"
// PersistenceReadRawHistoryBranchScope tracks ReadRawHistoryBranch calls made by service to persistence layer
PersistenceReadRawHistoryBranchScope = "ReadRawHistoryBranch"
// PersistenceForkHistoryBranchScope tracks ForkHistoryBranch calls made by service to persistence layer
PersistenceForkHistoryBranchScope = "ForkHistoryBranch"
// PersistenceDeleteHistoryBranchScope tracks DeleteHistoryBranch calls made by service to persistence layer
PersistenceDeleteHistoryBranchScope = "DeleteHistoryBranch"
// PersistenceTrimHistoryBranchScope tracks TrimHistoryBranch calls made by service to persistence layer
PersistenceTrimHistoryBranchScope = "TrimHistoryBranch"
// PersistenceGetAllHistoryTreeBranchesScope tracks GetAllHistoryTreeBranches calls made by service to persistence layer
PersistenceGetAllHistoryTreeBranchesScope = "GetAllHistoryTreeBranches"
// PersistenceNamespaceReplicationQueueScope is the metrics scope for namespace replication queue
PersistenceNamespaceReplicationQueueScope = "NamespaceReplicationQueue"
// PersistenceEnqueueMessageScope tracks Enqueue calls made by service to persistence layer
PersistenceEnqueueMessageScope = "EnqueueMessage"
// PersistenceEnqueueMessageToDLQScope tracks Enqueue DLQ calls made by service to persistence layer
PersistenceEnqueueMessageToDLQScope = "EnqueueMessageToDLQ"
// PersistenceReadQueueMessagesScope tracks ReadMessages calls made by service to persistence layer
PersistenceReadQueueMessagesScope = "ReadQueueMessages"
// PersistenceReadMessagesFromDLQScope tracks ReadMessagesFromDLQ calls made by service to persistence layer
PersistenceReadMessagesFromDLQScope = "ReadMessagesFromDLQ"
// PersistenceDeleteMessagesBeforeScope tracks DeleteMessagesBefore calls made by service to persistence layer
PersistenceDeleteMessagesBeforeScope = "DeleteMessagesBefore"
// PersistenceDeleteMessageFromDLQScope tracks DeleteMessageFromDLQ calls made by service to persistence layer
PersistenceDeleteMessageFromDLQScope = "DeleteMessageFromDLQ"
// PersistenceRangeDeleteMessagesFromDLQScope tracks RangeDeleteMessagesFromDLQ calls made by service to persistence layer
PersistenceRangeDeleteMessagesFromDLQScope = "RangeDeleteMessagesFromDLQ"
// PersistenceUpdateAckLevelScope tracks UpdateAckLevel calls made by service to persistence layer
PersistenceUpdateAckLevelScope = "UpdateAckLevel"
// PersistenceGetAckLevelScope tracks GetAckLevel calls made by service to persistence layer
PersistenceGetAckLevelScope = "GetAckLevel"
// PersistenceUpdateDLQAckLevelScope tracks UpdateDLQAckLevel calls made by service to persistence layer
PersistenceUpdateDLQAckLevelScope = "UpdateDLQAckLevel"
// PersistenceGetDLQAckLevelScope tracks GetDLQAckLevel calls made by service to persistence layer
PersistenceGetDLQAckLevelScope = "GetDLQAckLevel"
// PersistenceListClusterMetadataScope tracks ListClusterMetadata calls made by service to persistence layer
PersistenceListClusterMetadataScope = "ListClusterMetadata"
// PersistenceGetClusterMetadataScope tracks GetClusterMetadata calls made by service to persistence layer
PersistenceGetClusterMetadataScope = "GetClusterMetadata"
// PersistenceGetCurrentClusterMetadataScope tracks GetCurrentClusterMetadata calls made by service to persistence layer
PersistenceGetCurrentClusterMetadataScope = "GetCurrentClusterMetadata"
// PersistenceSaveClusterMetadataScope tracks SaveClusterMetadata calls made by service to persistence layer
PersistenceSaveClusterMetadataScope = "SaveClusterMetadata"
// PersistenceDeleteClusterMetadataScope tracks DeleteClusterMetadata calls made by service to persistence layer
PersistenceDeleteClusterMetadataScope = "DeleteClusterMetadata"
// PersistenceUpsertClusterMembershipScope tracks UpsertClusterMembership calls made by service to persistence layer
PersistenceUpsertClusterMembershipScope = "UpsertClusterMembership"
// PersistencePruneClusterMembershipScope tracks PruneClusterMembership calls made by service to persistence layer
PersistencePruneClusterMembershipScope = "PruneClusterMembership"
// PersistenceGetClusterMembersScope tracks GetClusterMembers calls made by service to persistence layer
PersistenceGetClusterMembersScope = "GetClusterMembers"
// PersistenceGetOrCreateShardScope tracks GetOrCreateShard calls made by service to persistence layer
PersistenceGetOrCreateShardScope = "GetOrCreateShard"
// PersistenceUpdateShardScope tracks UpdateShard calls made by service to persistence layer
PersistenceUpdateShardScope = "UpdateShard"
// PersistenceAssertShardOwnershipScope tracks UpdateShard calls made by service to persistence layer
PersistenceAssertShardOwnershipScope = "AssertShardOwnership"
// PersistenceCreateWorkflowExecutionScope tracks CreateWorkflowExecution calls made by service to persistence layer
PersistenceCreateWorkflowExecutionScope = "CreateWorkflowExecution"
// PersistenceGetWorkflowExecutionScope tracks GetWorkflowExecution calls made by service to persistence layer
PersistenceGetWorkflowExecutionScope = "GetWorkflowExecution"
// PersistenceSetWorkflowExecutionScope tracks SetWorkflowExecution calls made by service to persistence layer
PersistenceSetWorkflowExecutionScope = "SetWorkflowExecution"
// PersistenceUpdateWorkflowExecutionScope tracks UpdateWorkflowExecution calls made by service to persistence layer
PersistenceUpdateWorkflowExecutionScope = "UpdateWorkflowExecution"
// PersistenceConflictResolveWorkflowExecutionScope tracks ConflictResolveWorkflowExecution calls made by service to persistence layer
PersistenceConflictResolveWorkflowExecutionScope = "ConflictResolveWorkflowExecution"
// PersistenceDeleteWorkflowExecutionScope tracks DeleteWorkflowExecution calls made by service to persistence layer
PersistenceDeleteWorkflowExecutionScope = "DeleteWorkflowExecution"
// PersistenceDeleteCurrentWorkflowExecutionScope tracks DeleteCurrentWorkflowExecution calls made by service to persistence layer
PersistenceDeleteCurrentWorkflowExecutionScope = "DeleteCurrentWorkflowExecution"
// PersistenceGetCurrentExecutionScope tracks GetCurrentExecution calls made by service to persistence layer
PersistenceGetCurrentExecutionScope = "GetCurrentExecution"
// PersistenceListConcreteExecutionsScope tracks ListConcreteExecutions calls made by service to persistence layer
PersistenceListConcreteExecutionsScope = "ListConcreteExecutions"
// PersistenceAddTasksScope tracks AddTasks calls made by service to persistence layer
PersistenceAddTasksScope = "AddTasks"
// PersistenceGetTransferTasksScope tracks GetTransferTasks calls made by service to persistence layer
PersistenceGetTransferTasksScope = "GetTransferTasks"
// PersistenceCompleteTransferTaskScope tracks CompleteTransferTasks calls made by service to persistence layer
PersistenceCompleteTransferTaskScope = "CompleteTransferTask"
// PersistenceRangeCompleteTransferTasksScope tracks CompleteTransferTasks calls made by service to persistence layer
PersistenceRangeCompleteTransferTasksScope = "RangeCompleteTransferTasks"
// PersistenceGetVisibilityTasksScope tracks GetVisibilityTasks calls made by service to persistence layer
PersistenceGetVisibilityTasksScope = "GetVisibilityTasks"
// PersistenceCompleteVisibilityTaskScope tracks CompleteVisibilityTasks calls made by service to persistence layer
PersistenceCompleteVisibilityTaskScope = "CompleteVisibilityTask"
// PersistenceRangeCompleteVisibilityTasksScope tracks CompleteVisibilityTasks calls made by service to persistence layer
PersistenceRangeCompleteVisibilityTasksScope = "RangeCompleteVisibilityTasks"
// PersistenceGetReplicationTaskScope tracks GetReplicationTask calls made by service to persistence layer
PersistenceGetArchivalTasksScope = "GetArchivalTasks"
// PersistenceGetOutboundTasksScope tracks GetOutboundTasks calls made by service to persistence layer
PersistenceGetOutboundTasksScope = "GetOutboundTasks"
// PersistenceCompleteOutboundTasksScope tracks CompleteOutboundTasks calls made by service to persistence layer
PersistenceCompleteOutboundTasksScope = "CompleteOutboundTasks"
// PersistenceRangeCompleteOutboundTasksScope tracks RangeCompleteOutboundTasks calls made by service to persistence layer
PersistenceRangeCompleteOutboundTasksScope = "RangeCompleteOutboundTasks"
// PersistenceCompleteArchivalTaskScope tracks CompleteArchivalTasks calls made by service to persistence layer
PersistenceCompleteArchivalTaskScope = "CompleteArchivalTask"
// PersistenceRangeCompleteArchivalTasksScope tracks CompleteArchivalTasks calls made by service to persistence layer
PersistenceRangeCompleteArchivalTasksScope = "RangeCompleteArchivalTasks"
// PersistenceGetReplicationTasksScope tracks GetReplicationTasks calls made by service to persistence layer
PersistenceGetReplicationTasksScope = "GetReplicationTasks"
// PersistenceCompleteReplicationTaskScope tracks CompleteReplicationTasks calls made by service to persistence layer
PersistenceCompleteReplicationTaskScope = "CompleteReplicationTask"
// PersistenceRangeCompleteReplicationTasksScope tracks RangeCompleteReplicationTasks calls made by service to persistence layer
PersistenceRangeCompleteReplicationTasksScope = "RangeCompleteReplicationTasks"
// PersistencePutReplicationTaskToDLQScope tracks PersistencePutReplicationTaskToDLQScope calls made by service to persistence layer
PersistencePutReplicationTaskToDLQScope = "PutReplicationTaskToDLQ"
// PersistenceGetReplicationTasksFromDLQScope tracks PersistenceGetReplicationTasksFromDLQScope calls made by service to persistence layer
PersistenceGetReplicationTasksFromDLQScope = "GetReplicationTasksFromDLQ"
// PersistenceDeleteReplicationTaskFromDLQScope tracks PersistenceDeleteReplicationTaskFromDLQScope calls made by service to persistence layer
PersistenceDeleteReplicationTaskFromDLQScope = "DeleteReplicationTaskFromDLQ"
// PersistenceRangeDeleteReplicationTaskFromDLQScope tracks PersistenceRangeDeleteReplicationTaskFromDLQScope calls made by service to persistence layer
PersistenceRangeDeleteReplicationTaskFromDLQScope = "RangeDeleteReplicationTaskFromDLQ"
// PersistenceGetTimerTasksScope tracks GetTimerTasks calls made by service to persistence layer
PersistenceGetTimerTasksScope = "GetTimerTasks"
// PersistenceCompleteTimerTaskScope tracks CompleteTimerTasks calls made by service to persistence layer
PersistenceCompleteTimerTaskScope = "CompleteTimerTask"
// PersistenceRangeCompleteTimerTasksScope tracks CompleteTimerTasks calls made by service to persistence layer
PersistenceRangeCompleteTimerTasksScope = "RangeCompleteTimerTasks"
// PersistenceCreateTasksScope tracks CreateTasks calls made by service to persistence layer
PersistenceCreateTasksScope = "CreateTasks"
// PersistenceGetTasksScope tracks GetTasks calls made by service to persistence layer
PersistenceGetTasksScope = "GetTasks"
// PersistenceCompleteTaskScope tracks CompleteTask calls made by service to persistence layer
PersistenceCompleteTaskScope = "CompleteTask"
// PersistenceCompleteTasksLessThanScope is the metric scope for persistence.TaskManager.PersistenceCompleteTasksLessThan API
PersistenceCompleteTasksLessThanScope = "CompleteTasksLessThan"
// PersistenceCreateTaskQueueScope tracks PersistenceCreateTaskQueueScope calls made by service to persistence layer
PersistenceCreateTaskQueueScope = "CreateTaskQueue"
// PersistenceUpdateTaskQueueScope tracks PersistenceUpdateTaskQueueScope calls made by service to persistence layer
PersistenceUpdateTaskQueueScope = "UpdateTaskQueue"
// PersistenceGetTaskQueueScope tracks PersistenceGetTaskQueueScope calls made by service to persistence layer
PersistenceGetTaskQueueScope = "GetTaskQueue"
// PersistenceListTaskQueueScope is the metric scope for persistence.TaskManager.ListTaskQueue API
PersistenceListTaskQueueScope = "ListTaskQueue"
// PersistenceDeleteTaskQueueScope is the metric scope for persistence.TaskManager.DeleteTaskQueue API
PersistenceDeleteTaskQueueScope = "DeleteTaskQueue"
// PersistenceGetTaskQueueUserDataScope is the metric scope for persistence.TaskManager.GetTaskQueueUserData API
PersistenceGetTaskQueueUserDataScope = "GetTaskQueueUserData"
// PersistenceUpdateTaskQueueUserDataScope is the metric scope for persistence.TaskManager.UpdateTaskQueueUserData API
PersistenceUpdateTaskQueueUserDataScope = "UpdateTaskQueueUserData"
// PersistenceListTaskQueueUserDataEntriesScope is the metric scope for persistence.TaskManager.ListTaskQueueUserDataEntries API
PersistenceListTaskQueueUserDataEntriesScope = "ListTaskQueueUserDataEntries"
// PersistenceGetTaskQueuesByBuildIdScope is the metric scope for persistence.TaskManager.GetTaskQueuesByBuildId API
PersistenceGetTaskQueuesByBuildIdScope = "GetTaskQueuesByBuildId"
// PersistenceCountTaskQueuesByBuildIdScope is the metric scope for persistence.TaskManager.CountTaskQueuesByBuildId API
PersistenceCountTaskQueuesByBuildIdScope = "CountTaskQueuesByBuildId"
// PersistenceInitializeSystemNamespaceScope tracks InitializeSystemNamespaceScope calls made by service to persistence layer
PersistenceInitializeSystemNamespaceScope = "InitializeSystemNamespace"
// PersistenceCreateNamespaceScope tracks CreateNamespace calls made by service to persistence layer
PersistenceCreateNamespaceScope = "CreateNamespace"
// PersistenceGetNamespaceScope tracks GetNamespace calls made by service to persistence layer
PersistenceGetNamespaceScope = "GetNamespace"
// PersistenceUpdateNamespaceScope tracks UpdateNamespace calls made by service to persistence layer
PersistenceUpdateNamespaceScope = "UpdateNamespace"
// PersistenceDeleteNamespaceScope tracks DeleteNamespace calls made by service to persistence layer
PersistenceDeleteNamespaceScope = "DeleteNamespace"
// PersistenceRenameNamespaceScope tracks RenameNamespace calls made by service to persistence layer
PersistenceRenameNamespaceScope = "RenameNamespace"
// PersistenceDeleteNamespaceByNameScope tracks DeleteNamespaceByName calls made by service to persistence layer
PersistenceDeleteNamespaceByNameScope = "DeleteNamespaceByName"
// PersistenceListNamespacesScope tracks ListNamespaces calls made by service to persistence layer
PersistenceListNamespacesScope = "ListNamespaces"
// PersistenceGetMetadataScope tracks GetMetadata calls made by service to persistence layer
PersistenceGetMetadataScope = "GetMetadata"
// PersistenceWatchNamespacesScope tracks WatchNamespaces calls made by service to persistence layer
PersistenceWatchNamespacesScope = "WatchNamespaces"
// PersistenceGetNexusEndpointScope tracks GetNexusEndpoint calls made by service to persistence layer
PersistenceGetNexusEndpointScope = "GetNexusEndpoint"
// PersistenceListNexusEndpointsScope tracks ListNexusEndpoint calls made by service to persistence layer
PersistenceListNexusEndpointsScope = "ListNexusEndpoints"
// PersistenceCreateOrUpdateNexusEndpointScope tracks CreateOrUpdateNexusEndpoint calls made by service to persistence layer
PersistenceCreateOrUpdateNexusEndpointScope = "CreateOrUpdateNexusEndpoint"
// PersistenceDeleteNexusEndpointScope tracks DeleteNexusEndpoint calls made by service to persistence layer
PersistenceDeleteNexusEndpointScope = "DeleteNexusEndpoint"
// VisibilityPersistenceRecordWorkflowExecutionStartedScope tracks RecordWorkflowExecutionStarted calls made by service to visibility persistence layer
VisibilityPersistenceRecordWorkflowExecutionStartedScope = "RecordWorkflowExecutionStarted"
// VisibilityPersistenceRecordWorkflowExecutionClosedScope tracks RecordWorkflowExecutionClosed calls made by service to visibility persistence layer
VisibilityPersistenceRecordWorkflowExecutionClosedScope = "RecordWorkflowExecutionClosed"
// VisibilityPersistenceUpsertWorkflowExecutionScope tracks UpsertWorkflowExecution calls made by service to persistence visibility layer
VisibilityPersistenceUpsertWorkflowExecutionScope = "UpsertWorkflowExecution"
// VisibilityPersistenceDeleteWorkflowExecutionScope tracks DeleteWorkflowExecutions calls made by service to visibility persistence layer
VisibilityPersistenceDeleteWorkflowExecutionScope = "DeleteWorkflowExecution"
// VisibilityPersistenceListWorkflowExecutionsScope tracks ListWorkflowExecutions calls made by service to visibility persistence layer
VisibilityPersistenceListWorkflowExecutionsScope = "ListWorkflowExecutions"
// VisibilityPersistenceListChasmExecutionsScope tracks ListChasmExecutions calls made by service to visibility persistence layer
VisibilityPersistenceListChasmExecutionsScope = "ListChasmExecutions"
// VisibilityPersistenceScanWorkflowExecutionsScope tracks ScanWorkflowExecutions calls made by service to visibility persistence layer
VisibilityPersistenceScanWorkflowExecutionsScope = "ScanWorkflowExecutions"
// VisibilityPersistenceCountWorkflowExecutionsScope tracks CountWorkflowExecutions calls made by service to visibility persistence layer
VisibilityPersistenceCountWorkflowExecutionsScope = "CountWorkflowExecutions"
// VisibilityPersistenceCountChasmExecutionsScope tracks CountChasmExecutions calls made by service to visibility persistence layer
VisibilityPersistenceCountChasmExecutionsScope = "CountChasmExecutions"
// VisibilityPersistenceGetWorkflowExecutionScope tracks GetWorkflowExecution calls made by service to visibility persistence layer
VisibilityPersistenceGetWorkflowExecutionScope = "GetWorkflowExecution"
// VisibilityPersistenceAddSearchAttributesScope tracks AddSearchAttributes calls made by service to visibility persistence layer
VisibilityPersistenceAddSearchAttributesScope = "AddSearchAttributes"
)
// Common
const (
ServerTlsScope = "ServerTls"
// AuthorizationScope is the scope used by all metric emitted by authorization code
AuthorizationScope = "Authorization"
// NamespaceCacheScope tracks namespace cache callbacks
NamespaceCacheScope = "NamespaceCache"
)
// Frontend Scope
const (
// AdminGetWorkflowExecutionRawHistoryV2Scope is the metric scope for admin.GetWorkflowExecutionRawHistoryScope
AdminGetWorkflowExecutionRawHistoryV2Scope = "AdminGetWorkflowExecutionRawHistoryV2"
// AdminGetWorkflowExecutionRawHistoryScope is the metric scope for admin.GetWorkflowExecutionRawHistoryScope
AdminGetWorkflowExecutionRawHistoryScope = "AdminGetWorkflowExecutionRawHistory"
// OperatorAddSearchAttributesScope is the metric scope for operator.AddSearchAttributes
OperatorAddSearchAttributesScope = "OperatorAddSearchAttributes"
// OperatorDeleteNamespaceScope is the metric scope for operator.OperatorDeleteNamespace
OperatorDeleteNamespaceScope = "OperatorDeleteNamespace"
// FrontendGetWorkflowExecutionHistoryScope is the metric scope for non-long-poll frontend.GetWorkflowExecutionHistory
FrontendGetWorkflowExecutionHistoryScope = "GetWorkflowExecutionHistory"
// FrontendPollWorkflowExecutionHistoryScope is the metric scope for long poll case of frontend.GetWorkflowExecutionHistory
FrontendPollWorkflowExecutionHistoryScope = "PollWorkflowExecutionHistory"
// VersionCheckScope is scope used by version checker
VersionCheckScope = "VersionCheck"
)
// History Scope
const (
// HistoryStartWorkflowExecutionScope tracks StartWorkflowExecution API calls received by service
HistoryStartWorkflowExecutionScope = "StartWorkflowExecution"
// HistoryRecordActivityTaskHeartbeatScope tracks RecordActivityTaskHeartbeat API calls received by service
HistoryRecordActivityTaskHeartbeatScope = "RecordActivityTaskHeartbeat"
// HistoryRespondWorkflowTaskCompletedScope tracks RespondWorkflowTaskCompleted API calls received by service
HistoryRespondWorkflowTaskCompletedScope = "RespondWorkflowTaskCompleted"
HistoryRespondWorkflowTaskFailedScope = "RespondWorkflowTaskFailed"
// HistoryRespondActivityTaskCompletedScope tracks RespondActivityTaskCompleted API calls received by service
HistoryRespondActivityTaskCompletedScope = "RespondActivityTaskCompleted"
// HistoryRespondActivityTaskFailedScope tracks RespondActivityTaskFailed API calls received by service
HistoryRespondActivityTaskFailedScope = "RespondActivityTaskFailed"
// HistoryRespondActivityTaskCanceledScope tracks RespondActivityTaskCanceled API calls received by service
HistoryRespondActivityTaskCanceledScope = "RespondActivityTaskCanceled"
// ActivityTerminatedScope tracks TerminateActivityExecution API calls received by service
ActivityTerminatedScope = "ActivityTerminated"
// HistoryGetWorkflowExecutionHistoryScope is the metric scope for non-long-poll frontend.GetWorkflowExecutionHistory
HistoryGetWorkflowExecutionHistoryScope = "GetWorkflowExecutionHistory"
// HistoryPollWorkflowExecutionHistoryScope is the metric scope for long poll case of frontend.GetWorkflowExecutionHistory
HistoryPollWorkflowExecutionHistoryScope = "PollWorkflowExecutionHistory"
// HistoryGetWorkflowExecutionRawHistoryScope tracks GetWorkflowExecutionRawHistoryV2Scope API calls received by service
HistoryGetWorkflowExecutionRawHistoryScope = "GetWorkflowExecutionRawHistory"
// HistoryGetWorkflowExecutionRawHistoryV2Scope tracks GetWorkflowExecutionRawHistoryV2Scope API calls received by service
HistoryGetWorkflowExecutionRawHistoryV2Scope = "GetWorkflowExecutionRawHistoryV2"
// HistoryGetHistoryScope tracks GetHistoryScope API calls received by service
HistoryGetHistoryScope = "GetHistory"
// HistoryGetRawHistoryScope tracks GetRawHistoryScope API calls received by service
HistoryGetRawHistoryScope = "GetRawHistory"
// HistoryGetHistoryReverseScope tracks GetHistoryReverseScope API calls received by service
HistoryGetHistoryReverseScope = "GetHistoryReverse"
// HistoryRecordWorkflowTaskStartedScope tracks RecordWorkflowTaskStarted API calls received by service
HistoryRecordWorkflowTaskStartedScope = "RecordWorkflowTaskStarted"
// HistoryRecordActivityTaskStartedScope tracks RecordActivityTaskStarted API calls received by service
HistoryRecordActivityTaskStartedScope = "RecordActivityTaskStarted"
// HistorySignalWithStartWorkflowExecutionScope tracks SignalWithStartWorkflowExecution API calls received by service
HistorySignalWithStartWorkflowExecutionScope = "SignalWithStartWorkflowExecution"
// HistoryCompleteNexusOperationScope tracks CompleteNexusOperation API calls received by service
HistoryCompleteNexusOperationScope = "CompleteNexusOperation"
// HistoryCompleteNexusOperationChasmScope tracks CompleteNexusOperationChasm API calls received by service
HistoryCompleteNexusOperationChasmScope = "CompleteNexusOperationChasm"
// HistorySyncShardStatusScope tracks HistorySyncShardStatus API calls received by service
HistorySyncShardStatusScope = "SyncShardStatus"
// HistoryShardControllerScope is the scope used by shard controller
HistoryShardControllerScope = "ShardController"
// HistoryReapplyEventsScope is the scope used by event reapplication
HistoryReapplyEventsScope = "ReapplyEvents"
// HistoryQueryWorkflowScope tracks QueryWorkflow API calls received by service
HistoryQueryWorkflowScope = "QueryWorkflow"
HistoryResetWorkflowScope = "HistoryResetWorkflow"
// HistoryProcessDeleteHistoryEventScope tracks ProcessDeleteHistoryEvent processing calls
HistoryProcessDeleteHistoryEventScope = "ProcessDeleteHistoryEvent"
// HistoryDeleteWorkflowExecutionScope tracks DeleteWorkflowExecutions API calls
HistoryDeleteWorkflowExecutionScope = "DeleteWorkflowExecution"
// HistoryCacheGetOrCreateScope is the scope used by history cache
HistoryCacheGetOrCreateScope = "HistoryCacheGetOrCreate"
// HistoryCacheGetOrCreateCurrentScope is the scope used by history cache
HistoryCacheGetOrCreateCurrentScope = "HistoryCacheGetOrCreateCurrent"
// TransferActiveTaskCloseExecutionScope is the scope used for close execution task processing by transfer queue processor
TransferActiveTaskCloseExecutionScope = "TransferActiveTaskCloseExecution"
// TimerActiveTaskActivityTimeoutScope is the scope used by metric emitted by timer queue processor for processing activity timeouts
TimerActiveTaskActivityTimeoutScope = "TimerActiveTaskActivityTimeout"
// TimerActiveTaskWorkflowTaskTimeoutScope is the scope used by metric emitted by timer queue processor for processing workflow task timeouts
TimerActiveTaskWorkflowTaskTimeoutScope = "TimerActiveTaskWorkflowTaskTimeout"
// TimerActiveTaskWorkflowBackoffTimerScope is the scope used by metric emitted by timer queue processor for processing retry task.
TimerActiveTaskWorkflowBackoffTimerScope = "TimerActiveTaskWorkflowBackoffTimer"
// ReplicatorQueueProcessorScope is the scope used by all metric emitted by replicator queue processor
ReplicatorQueueProcessorScope = "ReplicatorQueueProcessor"
// ReplicateHistoryEventsScope is the scope used by historyReplicator API for applying events
ReplicateHistoryEventsScope = "ReplicateHistoryEvents"
// HistoryRereplicationByTransferTaskScope tracks history replication calls made by transfer task
HistoryRereplicationByTransferTaskScope = "HistoryRereplicationByTransferTask"
// HistoryRereplicationByTimerTaskScope tracks history replication calls made by timer task
HistoryRereplicationByTimerTaskScope = "HistoryRereplicationByTimerTask"
// HistoryRereplicationByHistoryReplicationScope tracks history replication calls made by history replication
HistoryRereplicationByHistoryReplicationScope = "HistoryRereplicationByHistoryReplication"
// HistoryRereplicationByActivityReplicationScope tracks history replication calls made by activity replication
HistoryRereplicationByActivityReplicationScope = "HistoryRereplicationByActivityReplication"
// ShardInfoScope is the scope used when updating shard info
ShardInfoScope = "ShardInfo"
// WorkflowContextScope is the scope used by WorkflowContext component
WorkflowContextScope = "WorkflowContext"
// ExecutionStatsScope is the scope used for emiting workflow execution related stats
ExecutionStatsScope = "ExecutionStats"
// SessionStatsScope is the scope used for emiting session update related stats
SessionStatsScope = "SessionStats"
// WorkflowCompletionStatsScope tracks workflow completion updates
WorkflowCompletionStatsScope = "CompletionStats"
// ReplicationTaskFetcherScope is scope used by all metrics emitted by ReplicationTaskFetcher
ReplicationTaskFetcherScope = "ReplicationTaskFetcher"
// ReplicationTaskTrackerScope is scope used by all metrics emitted by ExecutableTaskTracker
ReplicationTaskTrackerScope = "ReplicationTaskTracker"
// ReplicationTaskCleanupScope is scope used by all metrics emitted by ReplicationTaskProcessor cleanup
ReplicationTaskCleanupScope = "ReplicationTaskCleanup"
// ReplicationDLQStatsScope is scope used by all metrics emitted related to replication DLQ
ReplicationDLQStatsScope = "ReplicationDLQStats"
// EventsCacheGetEventScope is the scope used by events cache
EventsCacheGetEventScope = "EventsCacheGetEvent"
// EventsCachePutEventScope is the scope used by events cache
EventsCachePutEventScope = "EventsCachePutEvent"
// EventsCacheDeleteEventScope is the scope used by events cache
EventsCacheDeleteEventScope = "EventsCacheDeleteEvent"
// EventsCacheGetFromStoreScope is the scope used by events cache
EventsCacheGetFromStoreScope = "EventsCacheGetFromStore"
// HistoryEventNotificationScope is the scope used by shard history event notification
HistoryEventNotificationScope = "HistoryEventNotification"
// ArchiverClientScope is scope used by all metrics emitted by archiver.Client
ArchiverClientScope = "ArchiverClient"
// DeadlockDetectorScope is a scope for deadlock detector
DeadlockDetectorScope = "DeadlockDetector"
// OperationTimerQueueProcessorScope is a scope for timer queue base processor
OperationTimerQueueProcessorScope = "TimerQueueProcessor"
// OperationTransferQueueProcessorScope is a scope for transfer queue base processor
OperationTransferQueueProcessorScope = "TransferQueueProcessor"
// OperationVisibilityQueueProcessorScope is a scope for visibility queue processor
OperationVisibilityQueueProcessorScope = "VisibilityQueueProcessor"
// OperationArchivalQueueProcessorScope is a scope for archival queue processor
OperationArchivalQueueProcessorScope = "ArchivalQueueProcessor"
// OperationMemoryScheduledQueueProcessorScope is a scope for memory scheduled queue processor.
OperationMemoryScheduledQueueProcessorScope = "MemoryScheduledQueueProcessor"
// OperationOutboundQueueProcessorScope is a scope for the outbound queue processor.
OperationOutboundQueueProcessorScope = "OutboundQueueProcessor"
// VersionMembershipCacheGetScope is the scope used by version membership cache
VersionMembershipCacheGetScope = "VersionMembershipCacheGet"
// VersionMembershipCachePutScope is the scope used by version membership cache
VersionMembershipCachePutScope = "VersionMembershipCachePut"
// ReactivationSignalDedupScope is the scope used by the per-pod reactivation-signal
// dedup cache on the worker-deployment client.
ReactivationSignalDedupScope = "ReactivationSignalDedup"
// RoutingInfoCacheGetScope is the scope used by routing info cache
RoutingInfoCacheGetScope = "RoutingInfoCacheGet"
// RoutingInfoCachePutScope is the scope used by routing info cache
RoutingInfoCachePutScope = "RoutingInfoCachePut"
)
// Matching Scope
const (
// MatchingPollWorkflowTaskQueueScope tracks PollWorkflowTaskQueue API calls received by service
MatchingPollWorkflowTaskQueueScope = "PollWorkflowTaskQueue"
// MatchingPollActivityTaskQueueScope tracks PollActivityTaskQueue API calls received by service
MatchingPollActivityTaskQueueScope = "PollActivityTaskQueue"
// MatchingPollNexusTaskQueueScope tracks PollNexusTaskQueue API calls received by service
MatchingPollNexusTaskQueueScope = "PollNexusTaskQueue"
// MatchingAddActivityTaskScope tracks AddActivityTask API calls received by service
MatchingAddActivityTaskScope = "AddActivityTask"
// MatchingAddWorkflowTaskScope tracks AddWorkflowTask API calls received by service
MatchingAddWorkflowTaskScope = "AddWorkflowTask"
// MatchingTaskQueueMgrScope is the metrics scope for matching.TaskQueueManager component
MatchingTaskQueueMgrScope = "TaskQueueMgr"
// MatchingTaskQueuePartitionManagerScope is the metrics scope for matching.TaskQueuePartitionManager component
MatchingTaskQueuePartitionManagerScope = "TaskQueuePartitionManager"
// MatchingEngineScope is the metrics scope for matchingEngine component
MatchingEngineScope = "MatchingEngine"
// MatchingQueryWorkflowScope tracks AddWorkflowTask API calls received by service
MatchingQueryWorkflowScope = "QueryWorkflow"
// MatchingRespondQueryTaskCompletedScope tracks RespondQueryTaskCompleted API calls received by service
MatchingRespondQueryTaskCompletedScope = "RespondQueryTaskCompleted"
// MatchingRespondNexusTaskCompletedScope tracks RespondNexusTaskCompleted API calls received by service
MatchingRespondNexusTaskCompletedScope = "RespondNexusTaskCompleted"
// MatchingRespondNexusTaskFailedScope tracks RespondNexusTaskFailed API calls received by service
MatchingRespondNexusTaskFailedScope = "RespondNexusTaskFailed"
)
// Worker Scope
const (
// HistoryArchiverScope is used by history archivers
HistoryArchiverScope = "HistoryArchiver"
// VisibilityArchiverScope is used by visibility archivers
VisibilityArchiverScope = "VisibilityArchiver"
// HistoryScavengerScope is scope used by all metrics emitted by worker.history.Scavenger module
HistoryScavengerScope = "HistoryScavenger"
// ArchiverDeleteHistoryActivityScope is scope used by all metrics emitted by archiver.DeleteHistoryActivity
ArchiverDeleteHistoryActivityScope = "ArchiverDeleteHistoryActivity"
// ArchiverUploadHistoryActivityScope is scope used by all metrics emitted by archiver.UploadHistoryActivity
ArchiverUploadHistoryActivityScope = "ArchiverUploadHistoryActivity"
// ArchiverArchiveVisibilityActivityScope is scope used by all metrics emitted by archiver.ArchiveVisibilityActivity
ArchiverArchiveVisibilityActivityScope = "ArchiverArchiveVisibilityActivity"
// ArchiverScope is scope used by all metrics emitted by archiver.Archiver
ArchiverScope = "Archiver"
// ArchiverPumpScope is scope used by all metrics emitted by archiver.Pump
ArchiverPumpScope = "ArchiverPump"
// ArchiverArchivalWorkflowScope is scope used by all metrics emitted by archiver.ArchivalWorkflow
ArchiverArchivalWorkflowScope = "ArchiverArchivalWorkflow"
// AddSearchAttributesWorkflowScope is scope used by all metrics emitted by worker.AddSearchAttributesWorkflowScope module
AddSearchAttributesWorkflowScope = "AddSearchAttributesWorkflow"
// BatcherScope is scope used by all metrics emitted by worker.Batcher module
BatcherScope = "Batcher"
// ElasticsearchBulkProcessor is scope used by all metric emitted by Elasticsearch bulk processor
ElasticsearchBulkProcessor = "ElasticsearchBulkProcessor"
// ElasticsearchVisibility is scope used by all Elasticsearch visibility metrics
ElasticsearchVisibility = "ElasticsearchVisibility"
// MigrationWorkflowScope is scope used by metrics emitted by migration related workflows
MigrationWorkflowScope = "MigrationWorkflow"
// ReplicatorScope is the scope used by all metric emitted by replicator
ReplicatorScope = "Replicator"
// NamespaceReplicationTaskScope is the scope used by namespace task replication processing
NamespaceReplicationTaskScope = "NamespaceReplicationTask"
// HistoryReplicationTaskScope is the scope used by history task replication processing
HistoryReplicationTaskScope = "HistoryReplicationTask"
// HistoryMetadataReplicationTaskScope is the scope used by history metadata task replication processing
HistoryMetadataReplicationTaskScope = "HistoryMetadataReplicationTask"
// SyncShardTaskScope is the scope used by sync shrad information processing
SyncShardTaskScope = "SyncShardTask"
// SyncActivityTaskScope is the scope used by sync activity
SyncActivityTaskScope = "SyncActivityTask"
// SyncWorkflowStateTaskScope is the scope used by closed workflow task replication processing
SyncWorkflowStateTaskScope = "SyncWorkflowStateTask"
// SyncHSMTaskScope is the scope used by sync HSM replication task
SyncHSMTaskScope = "SyncHSMTask"
// BackfillHistoryEventsTaskScope is the scope used by backfill history events replication processing
BackfillHistoryEventsTaskScope = "BackfillHistoryEventsTask"
// VerifyVersionedTransitionTaskScope is the scope used by verify versioned transition task processing
VerifyVersionedTransitionTaskScope = "VerifyVersionedTransitionTask"
// SyncVersionedTransitionTaskScope is the scope used by sync versioned transition task processing
SyncVersionedTransitionTaskScope = "SyncVersionedTransitionTask"
// SyncWatermarkScope is the scope used by closed workflow task replication processing
SyncWatermarkScope = "SyncWatermark"
// NoopTaskScope is the scope used by noop task
NoopTaskScope = "NoopTask"
// UnknownTaskScope is the scope used by unknown task
UnknownTaskScope = "UnknownTask"
// ParentClosePolicyProcessorScope is scope used by all metrics emitted by worker.ParentClosePolicyProcessor
ParentClosePolicyProcessorScope = "ParentClosePolicyProcessor"
// DeleteExecutionReplicationTaskScope is the scope used by delete execution replication task processing
DeleteExecutionReplicationTaskScope = "DeleteExecutionReplicationTask"
)
// History task type
const (
TaskTypeTransferActiveTaskActivity = "TransferActiveTaskActivity"
TaskTypeTransferActiveTaskWorkflowTask = "TransferActiveTaskWorkflowTask"
TaskTypeTransferActiveTaskCloseExecution = "TransferActiveTaskCloseExecution"
TaskTypeTransferActiveTaskCancelExecution = "TransferActiveTaskCancelExecution"
TaskTypeTransferActiveTaskSignalExecution = "TransferActiveTaskSignalExecution"
TaskTypeTransferActiveTaskStartChildExecution = "TransferActiveTaskStartChildExecution"
TaskTypeTransferActiveTaskResetWorkflow = "TransferActiveTaskResetWorkflow"
TaskTypeTransferActiveTaskDeleteExecution = "TransferActiveTaskDeleteExecution"
TaskTypeTransferStandbyTaskActivity = "TransferStandbyTaskActivity"
TaskTypeTransferStandbyTaskWorkflowTask = "TransferStandbyTaskWorkflowTask"
TaskTypeTransferStandbyTaskCloseExecution = "TransferStandbyTaskCloseExecution"
TaskTypeTransferStandbyTaskCancelExecution = "TransferStandbyTaskCancelExecution"
TaskTypeTransferStandbyTaskSignalExecution = "TransferStandbyTaskSignalExecution"
TaskTypeTransferStandbyTaskStartChildExecution = "TransferStandbyTaskStartChildExecution"
TaskTypeTransferStandbyTaskResetWorkflow = "TransferStandbyTaskResetWorkflow"
TaskTypeTransferStandbyTaskDeleteExecution = "TransferStandbyTaskDeleteExecution"
TaskTypeVisibilityTaskStartExecution = "VisibilityTaskStartExecution"
TaskTypeVisibilityTaskUpsertExecution = "VisibilityTaskUpsertExecution"
TaskTypeVisibilityTaskCloseExecution = "VisibilityTaskCloseExecution"
TaskTypeVisibilityTaskDeleteExecution = "VisibilityTaskDeleteExecution"
TaskTypeVisibilityTaskUpsertChasmExecution = "VisibilityTaskUpsertChasmExecution"
TaskTypeArchivalTaskArchiveExecution = "ArchivalTaskArchiveExecution"
TaskTypeTimerActiveTaskActivityTimeout = "TimerActiveTaskActivityTimeout"
TaskTypeTimerActiveTaskWorkflowTaskTimeout = "TimerActiveTaskWorkflowTaskTimeout"
TaskTypeTimerActiveTaskUserTimer = "TimerActiveTaskUserTimer"
TaskTypeTimerActiveTaskWorkflowRunTimeout = "TimerActiveTaskWorkflowRunTimeout"
TaskTypeTimerActiveTaskWorkflowExecutionTimeout = "TimerActiveTaskWorkflowExecutionTimeout"
TaskTypeTimerActiveTaskActivityRetryTimer = "TimerActiveTaskActivityRetryTimer"
TaskTypeTimerActiveTaskWorkflowBackoffTimer = "TimerActiveTaskWorkflowBackoffTimer"
TaskTypeTimerActiveTaskDeleteHistoryEvent = "TimerActiveTaskDeleteHistoryEvent"
TaskTypeTimerActiveTaskSpeculativeWorkflowTaskTimeout = "TimerActiveTaskSpeculativeWorkflowTaskTimeout"
TaskTypeTimerActiveTaskChasmPureTask = "TimerActiveTaskChasmPureTask"
TaskTypeTimerActiveTaskTimeSkippingTimer = "TimerActiveTaskTimeSkippingTimer"
TaskTypeTimerStandbyTaskActivityTimeout = "TimerStandbyTaskActivityTimeout"
TaskTypeTimerStandbyTaskWorkflowTaskTimeout = "TimerStandbyTaskWorkflowTaskTimeout"
TaskTypeTimerStandbyTaskUserTimer = "TimerStandbyTaskUserTimer"
TaskTypeTimerStandbyTaskWorkflowRunTimeout = "TimerStandbyTaskWorkflowRunTimeout"
TaskTypeTimerStandbyTaskWorkflowExecutionTimeout = "TimerStandbyTaskWorkflowExecutionTimeout"
TaskTypeTimerStandbyTaskActivityRetryTimer = "TimerStandbyTaskActivityRetryTimer"
TaskTypeTimerStandbyTaskWorkflowBackoffTimer = "TimerStandbyTaskWorkflowBackoffTimer"
TaskTypeTimerStandbyTaskDeleteHistoryEvent = "TimerStandbyTaskDeleteHistoryEvent"
TaskTypeTimerStandbyTaskChasmPureTask = "TimerStandbyTaskChasmPureTask"
TaskTypeTimerStandbyTaskTimeSkippingTimer = "TimerStandbyTaskTimeSkippingTimer"
)
// Schedule action types
const (
ScheduleActionTypeTag = "schedule_action"
ScheduleActionStartWorkflow = "start_workflow"
ScheduleBackendTag = "scheduler_backend"
ScheduleBackendChasm = "chasm"
ScheduleBackendLegacy = "legacy"
ScheduleBackendWorkflow = "workflow"
ScheduleOverlapPolicyTag = "schedule_overlap_policy"
ScheduleMissedReasonTag = "reason"
ScheduleMissedReasonNotBuffered = "not_buffered"
ScheduleMissedReasonBufferExpired = "buffer_expired"
ScheduleActionRunningTag = "action_running"
ScheduleMigrationDirectionTag = "schedule_migration_direction"
ScheduleMigrationDirectionToChasm = "to_chasm"
ScheduleMigrationDirectionToWorkflow = "to_workflow"
)
var (
ServiceRequests = NewCounterDef(
"service_requests",
WithDescription("The number of RPC requests received by the service."),
)
ServicePendingRequests = NewGaugeDef("service_pending_requests")
ServiceFailures = NewCounterDef(
"service_errors",
WithDescription("The number of unexpected service request errors."),
)
ServicePanic = NewCounterDef("service_panics")
ServiceErrorWithType = NewCounterDef(
"service_error_with_type",
WithDescription("The number of all service request errors by error type."),
)
ServiceConnAccepted = NewCounterDef(
"service_grpc_conn_accepted",
WithDescription("Number of gRPC's TCP connections accepted by the service."),
)
ServiceConnClosed = NewCounterDef(
"service_grpc_conn_closed",
WithDescription("Number of gRPC's TCP connections closed on the service."),
)
ServiceConnActive = NewGaugeDef(
"service_grpc_conn_active",
WithDescription("Current number of gRPC's active TCP connections."),
)
ServiceDialLatency = NewTimerDef("service_dial_latency", WithDescription("The latency of establishing a new TCP connection."))
ServiceDialSuccessCount = NewCounterDef("service_dial_success", WithDescription("Number of TCP dial attempts that successfully established a connection."))
ServiceDialErrorCount = NewCounterDef("service_dial_error", WithDescription("Number of TCP dial attempts that failed to establish a connection."))
DynamicConfigUpdateFailure = NewGaugeDef("dynamic_config_update_failure")
ServiceLatency = NewTimerDef("service_latency")
ServiceLatencyNoUserLatency = NewTimerDef("service_latency_nouserlatency")
ServiceLatencyUserLatency = NewTimerDef("service_latency_userlatency")
ServiceErrInvalidArgumentCounter = NewCounterDef("service_errors_invalid_argument")
ServiceErrNamespaceNotActiveCounter = NewCounterDef("service_errors_namespace_not_active")
ServiceErrResourceExhaustedCounter = NewCounterDef("service_errors_resource_exhausted")
ServiceErrNotFoundCounter = NewCounterDef("service_errors_entity_not_found")
ServiceErrExecutionAlreadyStartedCounter = NewCounterDef("service_errors_execution_already_started")
ServiceErrContextTimeoutCounter = NewCounterDef("service_errors_context_timeout")
ServiceErrRetryTaskCounter = NewCounterDef("service_errors_retry_task")
ServiceErrIncompleteHistoryCounter = NewCounterDef("service_errors_incomplete_history")
ServiceErrNonDeterministicCounter = NewCounterDef("service_errors_nondeterministic")
ServiceErrUnauthorizedCounter = NewCounterDef("service_errors_unauthorized")
ServiceErrAuthorizeFailedCounter = NewCounterDef("service_errors_authorize_failed")
ActionCounter = NewCounterDef("action")
OperationCounter = NewCounterDef("operation")
TlsCertsExpired = NewGaugeDef("certificates_expired")
TlsCertsExpiring = NewGaugeDef("certificates_expiring")
ServiceAuthorizationLatency = NewTimerDef("service_authorization_latency")
NamespaceRateLimitWaitLatency = NewTimerDef("namespace_rate_limit_poll_wait_latency")
EventBlobSize = NewBytesHistogramDef("event_blob_size")
BlobSizeError = NewCounterDef(
"blob_size_error",
WithDescription("The number of requests that failed due to blob size exceeding limits configured with BlobSizeLimitError and MemoSizeLimitError."),
)
HeaderSize = NewBytesHistogramDef("header_size", WithDescription("The size of the header in bytes passed to the server by the client. This metric is experimental and can be removed in the future."))
LockRequests = NewCounterDef("lock_requests")
LockLatency = NewTimerDef("lock_latency")
SemaphoreRequests = NewCounterDef("semaphore_requests")
SemaphoreFailures = NewCounterDef("semaphore_failures")
SemaphoreLatency = NewTimerDef("semaphore_latency")
ClientRequests = NewCounterDef(
"client_requests",
WithDescription("The number of requests sent by the client to an individual service, keyed by `service_role` and `operation`."),
)
ClientFailures = NewCounterDef("client_errors")
ClientLatency = NewTimerDef("client_latency")
ClientRedirectionRequests = NewCounterDef("client_redirection_requests")
ClientRedirectionFailures = NewCounterDef("client_redirection_errors")
ClientRedirectionLatency = NewTimerDef("client_redirection_latency")
StateTransitionCount = NewDimensionlessHistogramDef("state_transition_count")
HistorySize = NewBytesHistogramDef("history_size")
HistoryCount = NewDimensionlessHistogramDef("history_count")
TasksCompletedPerShardInfoUpdate = NewDimensionlessHistogramDef("tasks_per_shardinfo_update")
TimeBetweenShardInfoUpdates = NewTimerDef("time_between_shardinfo_update")
SearchAttributesSize = NewBytesHistogramDef("search_attributes_size")
MemoSize = NewBytesHistogramDef("memo_size")
TooManyPendingChildWorkflows = NewCounterDef(
"wf_too_many_pending_child_workflows",
WithDescription("The number of Workflow Tasks failed because they would cause the limit on the number of pending child workflows to be exceeded. See https://t.mp/limits for more information."),
)
TooManyPendingActivities = NewCounterDef(
"wf_too_many_pending_activities",
WithDescription("The number of Workflow Tasks failed because they would cause the limit on the number of pending activities to be exceeded. See https://t.mp/limits for more information."),
)
TooManyPendingCancelRequests = NewCounterDef(
"wf_too_many_pending_cancel_requests",
WithDescription("The number of Workflow Tasks failed because they would cause the limit on the number of pending cancel requests to be exceeded. See https://t.mp/limits for more information."),
)
TooManyPendingSignalsToExternalWorkflows = NewCounterDef(
"wf_too_many_pending_external_workflow_signals",
WithDescription("The number of Workflow Tasks failed because they would cause the limit on the number of pending signals to external workflows to be exceeded. See https://t.mp/limits for more information."),
)
TotalNamespaces = NewGaugeDef("total_namespaces")
// Frontend
AddSearchAttributesWorkflowSuccessCount = NewCounterDef("add_search_attributes_workflow_success")
AddSearchAttributesWorkflowFailuresCount = NewCounterDef("add_search_attributes_workflow_failure")
VersionCheckSuccessCount = NewCounterDef("version_check_success")
VersionCheckFailedCount = NewCounterDef("version_check_failed")
VersionCheckRequestFailedCount = NewCounterDef("version_check_request_failed")
VersionCheckLatency = NewTimerDef("version_check_latency")
HTTPServiceRequests = NewCounterDef(
"http_service_requests",
WithDescription("The number of HTTP requests received by the service."),
)
NexusRequests = NewCounterDef(
"nexus_requests",
WithDescription("The number of Nexus requests received by the service."),
)
NexusRequestPreProcessErrors = NewCounterDef(
"nexus_request_preprocess_errors",
WithDescription("The number of Nexus requests for which pre-processing failed."),
)
NexusRequestErrors = NewCounterDef(
"nexus_request_errors",
WithDescription("The number of Nexus requests that resulted in errors."),
)
NexusLatency = NewTimerDef(
"nexus_latency",
WithDescription("Latency of Nexus requests."),
)
NexusCompletionRequests = NewCounterDef(
"nexus_completion_requests",
WithDescription("The number of Nexus completion (callback) requests received by the service."),
)
NexusCompletionLatencyHistogram = NewTimerDef(
"nexus_completion_latency",
WithDescription("Latency histogram of Nexus completion (callback) requests."),
)
NexusCompletionRequestPreProcessErrors = NewCounterDef(
"nexus_completion_request_preprocess_errors",
WithDescription("The number of Nexus completion requests for which pre-processing failed."),
)
WorkerCommandsSent = NewCounterDef(
"worker_commands_sent",
WithDescription("The number of worker command dispatches, tagged by outcome (e.g. success, no_poller, rpc_error)."),
)
HostRPSLimit = NewGaugeDef("host_rps_limit")
NamespaceHostRPSLimit = NewGaugeDef("namespace_host_rps_limit")
HandoverWaitLatency = NewTimerDef("handover_wait_latency")
VisibilityListWorkflowsQueryLength = NewDimensionlessHistogramDef("visibility_list_workflows_query_length")
// History
CacheRequests = NewCounterDef("cache_requests")
CacheFailures = NewCounterDef("cache_errors")
CacheLatency = NewTimerDef("cache_latency")
CacheMissCounter = NewCounterDef("cache_miss")
CacheSize = NewGaugeDef("cache_size")
CacheUsage = NewGaugeDef("cache_usage")
CachePinnedUsage = NewGaugeDef("cache_pinned_usage")
CacheTtl = NewTimerDef("cache_ttl")
CacheEntryAgeOnGet = NewTimerDef("cache_entry_age_on_get")
CacheEntryAgeOnEviction = NewTimerDef("cache_entry_age_on_eviction")
HistoryEventNotificationQueueingLatency = NewTimerDef("history_event_notification_queueing_latency")
HistoryEventNotificationFanoutLatency = NewTimerDef("history_event_notification_fanout_latency")
HistoryEventNotificationInFlightMessageGauge = NewGaugeDef("history_event_notification_inflight_message_gauge")
HistoryEventNotificationFailDeliveryCount = NewCounterDef("history_event_notification_fail_delivery_count")
HistoryHostHealthGauge = NewGaugeDef("host_health")
// ArchivalTaskInvalidURI is emitted by the archival queue task executor when the history or visibility URI for an
// archival task is not a valid URI.
// We may emit this metric several times for a single task if the task is retried.
ArchivalTaskInvalidURI = NewCounterDef("archival_task_invalid_uri")
ArchiverArchiveLatency = NewTimerDef("archiver_archive_latency")
ArchiverArchiveTargetLatency = NewTimerDef("archiver_archive_target_latency")
ShardContextClosedCounter = NewCounterDef("shard_closed_count")
ShardContextCreatedCounter = NewCounterDef("sharditem_created_count")
ShardContextRemovedCounter = NewCounterDef("sharditem_removed_count")
ShardContextAcquisitionLatency = NewTimerDef("sharditem_acquisition_latency")
ShardInfoImmediateQueueLagHistogram = NewDimensionlessHistogramDef(
"shardinfo_immediate_queue_lag",
WithDescription("A histogram across history shards for the difference between the smallest taskID of pending history tasks and the last generated history task ID."),
)
ShardInfoScheduledQueueLagTimer = NewTimerDef(
"shardinfo_scheduled_queue_lag",
WithDescription("A histogram across history shards for the difference between the earliest scheduled time of pending history tasks and current time."),
)
SyncShardFromRemoteCounter = NewCounterDef("syncshard_remote_count")
SyncShardFromRemoteFailure = NewCounterDef("syncshard_remote_failed")
FinalizerRuns = NewCounterDef(
"finalizer_runs",
WithDescription("The number of finalizer runs."),
)
FinalizerRunTimeouts = NewCounterDef(
"finalizer_run_timeouts",
WithDescription("The number of finalizer run timeouts."),
)
FinalizerItemsCompleted = NewCounterDef(
"finalizer_items_completed",
WithDescription("The number of finalizer items that were completed successfully."),
)
FinalizerItemsUnfinished = NewCounterDef(
"finalizer_items_unfinished",
WithDescription("The number of finalizer items that were aborted before completion."),
)
FinalizerLatency = NewTimerDef("finalizer_latency")
TaskRequests = NewCounterDef(
"task_requests",
WithDescription("The number of history tasks processed."),
)
TaskLoadLatency = NewTimerDef(
"task_latency_load",
WithDescription("Latency from history task generation to loading into memory (persistence schedule to start latency)."),
)
TaskScheduleLatency = NewTimerDef(
"task_latency_schedule",
WithDescription("Latency from history task loading to start processing (in-memory schedule to start latency)."),
)
TaskProcessingLatency = NewTimerDef(
"task_latency_processing",
WithDescription("Latency for processing a history task one time."),
)
// TaskPersistenceLatency is used only as a context key for accumulating persistence duration (ContextCounterAdd/Get); not emitted as a metric.
TaskPersistenceLatency = NewTimerDef(
"task_persistence_latency",
WithDescription("Context key for persistence duration; not emitted."),
)
TaskProcessingNoPersistenceLatency = NewTimerDef(
"task_processing_no_persistence_latency",
WithDescription("Latency for processing a history task one time excluding persistence."),
)
TaskLatency = NewTimerDef(
"task_latency",
WithDescription("Latency for procsssing and completing a history task. This latency is across all attempts but excludes any latencies related to workflow lock or user qutoa limit."),
)
TaskQueueLatency = NewTimerDef(
"task_latency_queue",
WithDescription("End-to-end latency for processing and completing a history task, from task generation to completion."),
)
TaskAttempt = NewDimensionlessHistogramDef(
"task_attempt",
WithDescription("The number of attempts took to complete a history task."),
)
TaskFailures = NewCounterDef(
"task_errors",
WithDescription("The number of unexpected history task processing errors."),
)
TaskTerminalFailures = NewCounterDef(
"task_terminal_failures",
WithDescription("The number of times a history task failed with a terminal failure, causing it to be sent to the DLQ."),
)
TaskDLQFailures = NewCounterDef(
"task_dlq_failures",
WithDescription("The number of times we failed to send a history task to the DLQ."),
)
TaskDLQSendLatency = NewTimerDef(
"task_dlq_latency",
WithDescription("The amount of time it took to successfully send a task to the DLQ. This only records the"+
" latency of the final attempt to send the task to the DLQ, not the cumulative latency of all attempts."),
)
TaskDiscarded = NewCounterDef("task_errors_discarded")
TaskSkipped = NewCounterDef("task_skipped")
TaskVersionMisMatch = NewCounterDef("task_errors_version_mismatch")
TasksDependencyTaskNotCompleted = NewCounterDef("task_dependency_task_not_completed")
TaskStandbyRetryCounter = NewCounterDef("task_errors_standby_retry_counter")
TaskWorkflowBusyCounter = NewCounterDef(
"task_errors_workflow_busy",
WithDescription("The number of history task processing errors caused by failing to acquire workflow lock within the configured timeout (history.cacheNonUserContextLockTimeout)."),
)
TaskNotActiveCounter = NewCounterDef("task_errors_not_active_counter")
TaskNamespaceHandoverCounter = NewCounterDef("task_errors_namespace_handover")
TaskInternalErrorCounter = NewCounterDef("task_errors_internal")
TaskThrottledCounter = NewCounterDef(
"task_errors_throttled",
WithDescription("The number of history task processing errors caused by resource exhausted errors, excluding workflow busy case."),
)
TaskCorruptionCounter = NewCounterDef("task_errors_corruption")
ChasmPureTaskRequests = NewCounterDef(
"chasm_pure_task_requests",
WithDescription("The number of CHASM pure tasks executed."),
)
ChasmPureTaskErrors = NewCounterDef(
"chasm_pure_task_errors",
WithDescription("The number of errors during CHASM pure task execution."),
)
ChasmIncomingSignalWritten = NewCounterDef(
"chasm_incoming_signal_written",
WithDescription("The number of signal backlinks written to the CHASM IncomingSignals map."),
)
ChasmIncomingSignalDuplicate = NewCounterDef(
"chasm_incoming_signal_duplicate",
WithDescription("The number of duplicate signal request IDs detected when writing to the CHASM IncomingSignals map. Non-zero values indicate unexpected signal redelivery."),
)
TaskScheduleToStartLatency = NewTimerDef("task_schedule_to_start_latency")
TaskBatchCompleteCounter = NewCounterDef("task_batch_complete_counter")
TaskReschedulerPendingTasks = NewDimensionlessHistogramDef("task_rescheduler_pending_tasks")
PendingTasksCounter = NewDimensionlessHistogramDef(
"pending_tasks",
WithDescription("A histogram across history shards for the number of in-memory pending history tasks."),
)
TaskSchedulerThrottled = NewCounterDef("task_scheduler_throttled")
QueueScheduleLatency = NewTimerDef("queue_latency_schedule") // latency for scheduling 100 tasks in one task channel
QueueReaderCountHistogram = NewDimensionlessHistogramDef("queue_reader_count")
QueueSliceCountHistogram = NewDimensionlessHistogramDef("queue_slice_count")
QueueActionCounter = NewCounterDef("queue_actions")
ActivityE2ELatency = NewTimerDef(
"activity_end_to_end_latency",
WithDescription("DEPRECATED: Will be removed in one of the next releases. Duration of an activity attempt. Use activity_start_to_close_latency instead."),
)
ActivityStartToCloseLatency = NewTimerDef(
"activity_start_to_close_latency",
WithDescription("Duration of a single activity attempt. Doesn't include retries or backoffs."),
)
ActivityScheduleToCloseLatency = NewTimerDef(
"activity_schedule_to_close_latency",
WithDescription("Duration of activity execution from scheduled time to terminal state. Includes retries and backoffs."),
)
ActivitySuccess = NewCounterDef("activity_success", WithDescription("Number of activities that succeeded (doesn't include retries)."))
ActivityFail = NewCounterDef("activity_fail", WithDescription("Number of activities that failed and won't be retried anymore."))
ActivityTaskFail = NewCounterDef("activity_task_fail", WithDescription("Number of activity task failures (includes retries)."))
ActivityCancel = NewCounterDef("activity_cancel", WithDescription("Number of activities that are cancelled."))
ActivityTerminate = NewCounterDef("activity_terminate", WithDescription("Number of activities that are terminated."))
ActivityTaskTimeout = NewCounterDef("activity_task_timeout", WithDescription("Number of activity task timeouts (including retries)."))
ActivityTimeout = NewCounterDef("activity_timeout", WithDescription("Number of terminal activity timeouts."))
ActivityPayloadSize = NewCounterDef("activity_payload_size", WithDescription("Size of activity payloads in bytes."))
AckLevelUpdateCounter = NewCounterDef("ack_level_update")
AckLevelUpdateFailedCounter = NewCounterDef("ack_level_update_failed")
CommandCounter = NewCounterDef("command")
MessageTypeRequestWorkflowExecutionUpdateCounter = NewCounterDef("request_workflow_update_message")
MessageTypeAcceptWorkflowExecutionUpdateCounter = NewCounterDef("accept_workflow_update_message")
MessageTypeRespondWorkflowExecutionUpdateCounter = NewCounterDef("respond_workflow_update_message")
MessageTypeRejectWorkflowExecutionUpdateCounter = NewCounterDef("reject_workflow_update_message")
WorkflowExecutionUpdateRegistrySize = NewBytesHistogramDef("workflow_update_registry_size")
WorkflowExecutionUpdateRegistrySizeLimited = NewCounterDef("workflow_update_registry_size_limited")
WorkflowExecutionUpdateRequestRateLimited = NewCounterDef("workflow_update_request_rate_limited")
BusinessIDReuseRateLimited = NewCounterDef("business_id_reuse_rate_limited")
WorkflowExecutionUpdateTooMany = NewCounterDef("workflow_update_request_too_many")
WorkflowExecutionUpdateAborted = NewCounterDef("workflow_update_aborted")
WorkflowExecutionUpdateSentToWorker = NewCounterDef("workflow_update_sent_to_worker")
WorkflowExecutionUpdateSentToWorkerAgain = NewCounterDef("workflow_update_sent_to_worker_again")
WorkflowExecutionUpdateWaitStageAccepted = NewCounterDef("workflow_update_wait_stage_accepted")
WorkflowExecutionUpdateWaitStageCompleted = NewCounterDef("workflow_update_wait_stage_completed")
WorkflowExecutionUpdateClientTimeout = NewCounterDef("workflow_update_client_timeout")
WorkflowExecutionUpdateServerTimeout = NewCounterDef("workflow_update_server_timeout")
SpeculativeWorkflowTaskCommits = NewCounterDef("speculative_workflow_task_commits")
SpeculativeWorkflowTaskRollbacks = NewCounterDef("speculative_workflow_task_rollbacks")
ActivityEagerExecutionCounter = NewCounterDef("activity_eager_execution")
// WorkflowEagerExecutionCounter is emitted any time eager workflow start is requested.
WorkflowEagerExecutionCounter = NewCounterDef("workflow_eager_execution")
// WorkflowEagerExecutionDeniedCounter is emitted any time eager workflow start is requested and the serer fell back
// to standard dispatch.
// Timeouts and failures are not counted in this metric.
// This metric has a "reason" tag attached to it to understand why eager start was denied.
WorkflowEagerExecutionDeniedCounter = NewCounterDef("workflow_eager_execution_denied")
StartWorkflowRequestDeduped = NewCounterDef("start_workflow_request_deduped")
EmptyCompletionCommandsCounter = NewCounterDef("empty_completion_commands")
MultipleCompletionCommandsCounter = NewCounterDef("multiple_completion_commands")
FailedWorkflowTasksCounter = NewCounterDef("failed_workflow_tasks")
WorkflowTaskAttempt = NewDimensionlessHistogramDef("workflow_task_attempt")
StaleMutableStateCounter = NewCounterDef("stale_mutable_state")
AutoResetPointsLimitExceededCounter = NewCounterDef("auto_reset_points_exceed_limit")
AutoResetPointCorruptionCounter = NewCounterDef("auto_reset_point_corruption")
BatchableTaskBatchCount = NewGaugeDef("batchable_task_batch_count")
ConcurrencyUpdateFailureCounter = NewCounterDef("concurrency_update_failure")
ServiceErrShardOwnershipLostCounter = NewCounterDef("service_errors_shard_ownership_lost")
HeartbeatTimeoutCounter = NewCounterDef("heartbeat_timeout")
ScheduleToStartTimeoutCounter = NewCounterDef("schedule_to_start_timeout")
StartToCloseTimeoutCounter = NewCounterDef("start_to_close_timeout")
ScheduleToCloseTimeoutCounter = NewCounterDef("schedule_to_close_timeout")
NewTimerNotifyCounter = NewCounterDef("new_timer_notifications")
StateMachineTimerProcessingFailuresCounter = NewCounterDef("state_machine_timer_processing_failures")
StateMachineTimerSkipsCounter = NewCounterDef("state_machine_timer_skips")
AcquireShardsCounter = NewCounterDef("acquire_shards_count")
AcquireShardsLatency = NewTimerDef("acquire_shards_latency")
MembershipChangedCounter = NewCounterDef("membership_changed_count")
NumShardsGauge = NewGaugeDef("numshards_gauge")
GetEngineForShardErrorCounter = NewCounterDef("get_engine_for_shard_errors")