func executionManagerTags()

in common/persistence/wrappers/errorinjectors/utils.go [195:257]

• 63 lines of code
• 30 McCabe index (conditional complexity)

func executionManagerTags(op string) *tag.Tag {
	switch op {
	case "ExecutionManager.CreateWorkflowExecution":
		return &tag.StoreOperationCreateWorkflowExecution
	case "ExecutionManager.GetWorkflowExecution":
		return &tag.StoreOperationGetWorkflowExecution
	case "ExecutionManager.UpdateWorkflowExecution":
		return &tag.StoreOperationUpdateWorkflowExecution
	case "ExecutionManager.ResetWorkflowExecution":
		return &tag.StoreOperationResetWorkflowExecution
	case "ExecutionManager.DeleteWorkflowExecution":
		return &tag.StoreOperationDeleteWorkflowExecution
	case "ExecutionManager.GetCurrentExecution":
		return &tag.StoreOperationGetCurrentExecution
	case "ExecutionManager.ConflictResolveWorkflowExecution":
		return &tag.StoreOperationConflictResolveWorkflowExecution
	case "ExecutionManager.DeleteCurrentWorkflowExecution":
		return &tag.StoreOperationDeleteCurrentWorkflowExecution
	case "ExecutionManager.ListCurrentExecutions":
		return &tag.StoreOperationListCurrentExecution
	case "ExecutionManager.IsWorkflowExecutionExists":
		return &tag.StoreOperationIsWorkflowExecutionExists
	case "ExecutionManager.ListConcreteExecutions":
		return &tag.StoreOperationListConcreteExecution
	case "ExecutionManager.GetTransferTasks":
		return &tag.StoreOperationGetTransferTasks
	case "ExecutionManager.GetCrossClusterTasks":
		return &tag.StoreOperationGetCrossClusterTasks
	case "ExecutionManager.GetReplicationTasks":
		return &tag.StoreOperationGetReplicationTasks
	case "ExecutionManager.CompleteTransferTask":
		return &tag.StoreOperationCompleteTransferTask
	case "ExecutionManager.RangeCompleteTransferTask":
		return &tag.StoreOperationRangeCompleteTransferTask
	case "ExecutionManager.CompleteCrossClusterTask":
		return &tag.StoreOperationCompleteCrossClusterTask
	case "ExecutionManager.RangeCompleteCrossClusterTask":
		return &tag.StoreOperationRangeCompleteCrossClusterTask
	case "ExecutionManager.CompleteReplicationTask":
		return &tag.StoreOperationCompleteReplicationTask
	case "ExecutionManager.RangeCompleteReplicationTask":
		return &tag.StoreOperationRangeCompleteReplicationTask
	case "ExecutionManager.PutReplicationTaskToDLQ":
		return &tag.StoreOperationPutReplicationTaskToDLQ
	case "ExecutionManager.GetReplicationTasksFromDLQ":
		return &tag.StoreOperationGetReplicationTasksFromDLQ
	case "ExecutionManager.GetReplicationDLQSize":
		return &tag.StoreOperationGetReplicationDLQSize
	case "ExecutionManager.DeleteReplicationTaskFromDLQ":
		return &tag.StoreOperationDeleteReplicationTaskFromDLQ
	case "ExecutionManager.RangeDeleteReplicationTaskFromDLQ":
		return &tag.StoreOperationRangeDeleteReplicationTaskFromDLQ
	case "ExecutionManager.GetTimerIndexTasks":
		return &tag.StoreOperationGetTimerIndexTasks
	case "ExecutionManager.CompleteTimerTask":
		return &tag.StoreOperationCompleteTimerTask
	case "ExecutionManager.RangeCompleteTimerTask":
		return &tag.StoreOperationRangeCompleteTimerTask
	case "ExecutionManager.CreateFailoverMarkerTasks":
		return &tag.StoreOperationCreateFailoverMarkerTasks
	}
	return nil
}