Add task category tag to history tasks metrics

Author: Shaddoll

common/metrics/tags.go

@@ -347,6 +347,10 @@ func NamespaceTag(namespace string) Tag {
 	return metricWithUnknown("namespace", namespace)
 }
 
+func TaskCategoryTag(category string) Tag {
+	return metricWithUnknown("task_category", category)
+}
+
 // ReasonTag returns a new reason tag
 func ReasonTag(reason string) Tag {
 	return metricWithUnknown("reason", reason)

common/persistence/data_manager_interfaces.go

@@ -178,6 +178,7 @@ const (
 type HistoryTaskCategory struct {
 	categoryType int
 	categoryID   int
+	categoryName string
 }
 
 func (c *HistoryTaskCategory) Type() int {
@@ -188,6 +189,10 @@ func (c *HistoryTaskCategory) ID() int {
 	return c.categoryID
 }
 
+func (c *HistoryTaskCategory) Name() string {
+	return c.categoryName
+}
+
 const (
 	HistoryTaskCategoryTypeImmediate = iota + 1
 	HistoryTaskCategoryTypeScheduled
@@ -203,14 +208,17 @@ var (
 	HistoryTaskCategoryTransfer = HistoryTaskCategory{
 		categoryType: HistoryTaskCategoryTypeImmediate,
 		categoryID:   HistoryTaskCategoryIDTransfer,
+		categoryName: "transfer",
 	}
 	HistoryTaskCategoryTimer = HistoryTaskCategory{
 		categoryType: HistoryTaskCategoryTypeScheduled,
 		categoryID:   HistoryTaskCategoryIDTimer,
+		categoryName: "timer",
 	}
 	HistoryTaskCategoryReplication = HistoryTaskCategory{
 		categoryType: HistoryTaskCategoryTypeImmediate,
 		categoryID:   HistoryTaskCategoryIDReplication,
+		categoryName: "replication",
 	}
 )
 

common/persistence/metered.go

@@ -438,3 +438,7 @@ func (r GetCurrentExecutionRequest) GetDomainName() string {
 func (r GetCurrentExecutionRequest) GetExtraLogTags() []tag.Tag {
 	return []tag.Tag{tag.WorkflowID(r.WorkflowID)}
 }
+
+func (r GetHistoryTasksRequest) MetricTags() []metrics.Tag {
+	return []metrics.Tag{metrics.TaskCategoryTag(r.TaskCategory.Name())}
+}