scheduler

var (
	HandlerRegistrationName = "scheduler"

	ErrMetricManagerNotSet = errors.New("MetricManager is not set.")
	ErrSchedulerNotStarted = errors.New("Scheduler is not started.")
	ErrTaskAlreadyRunning  = errors.New("Task is already running.")
	ErrTaskAlreadyStopped  = errors.New("Task is already stopped.")
)

var (
	ErrTaskNotFound            = errors.New("Task not found")
	ErrTaskNotStopped          = errors.New("Task must be stopped")
	ErrTaskHasAlreadyBeenAdded = errors.New("Task has already been added")
	ErrTaskDisabledOnFailures  = errors.New("Task disabled due to consecutive failures")
	ErrTaskNotDisabled         = errors.New("Task must be disabled")
)

var (
	WorkflowStateLookup = map[WorkflowState]string{
		WorkflowStopped: "Stopped",
		WorkflowStarted: "Started",
	}

	ErrNullCollectNode        = errors.New("Missing collection node in workflow map")
	ErrNoMetricsInCollectNode = errors.New("Collection node has not metrics defined to collect")
)