in service/history/task/task_util.go [80:151]
func GetTransferTaskMetricsScope(
taskType int,
isActive bool,
) int {
switch taskType {
case persistence.TransferTaskTypeActivityTask:
if isActive {
return metrics.TransferActiveTaskActivityScope
}
return metrics.TransferStandbyTaskActivityScope
case persistence.TransferTaskTypeDecisionTask:
if isActive {
return metrics.TransferActiveTaskDecisionScope
}
return metrics.TransferStandbyTaskDecisionScope
case persistence.TransferTaskTypeCloseExecution:
if isActive {
return metrics.TransferActiveTaskCloseExecutionScope
}
return metrics.TransferStandbyTaskCloseExecutionScope
case persistence.TransferTaskTypeCancelExecution:
if isActive {
return metrics.TransferActiveTaskCancelExecutionScope
}
return metrics.TransferStandbyTaskCancelExecutionScope
case persistence.TransferTaskTypeSignalExecution:
if isActive {
return metrics.TransferActiveTaskSignalExecutionScope
}
return metrics.TransferStandbyTaskSignalExecutionScope
case persistence.TransferTaskTypeStartChildExecution:
if isActive {
return metrics.TransferActiveTaskStartChildExecutionScope
}
return metrics.TransferStandbyTaskStartChildExecutionScope
case persistence.TransferTaskTypeRecordWorkflowStarted:
if isActive {
return metrics.TransferActiveTaskRecordWorkflowStartedScope
}
return metrics.TransferStandbyTaskRecordWorkflowStartedScope
case persistence.TransferTaskTypeResetWorkflow:
if isActive {
return metrics.TransferActiveTaskResetWorkflowScope
}
return metrics.TransferStandbyTaskResetWorkflowScope
case persistence.TransferTaskTypeUpsertWorkflowSearchAttributes:
if isActive {
return metrics.TransferActiveTaskUpsertWorkflowSearchAttributesScope
}
return metrics.TransferStandbyTaskUpsertWorkflowSearchAttributesScope
case persistence.TransferTaskTypeRecordWorkflowClosed:
if isActive {
return metrics.TransferActiveTaskRecordWorkflowClosedScope
}
return metrics.TransferStandbyTaskRecordWorkflowClosedScope
case persistence.TransferTaskTypeRecordChildExecutionCompleted:
if isActive {
return metrics.TransferActiveTaskRecordChildExecutionCompletedScope
}
return metrics.TransferStandbyTaskRecordChildExecutionCompletedScope
case persistence.TransferTaskTypeApplyParentClosePolicy:
if isActive {
return metrics.TransferActiveTaskApplyParentClosePolicyScope
}
return metrics.TransferStandbyTaskApplyParentClosePolicyScope
default:
if isActive {
return metrics.TransferActiveQueueProcessorScope
}
return metrics.TransferStandbyQueueProcessorScope
}
}