taskwatcher

type TaskWatcher struct {
	Cron      *cron.Cron
	CronId    cron.EntryID
	RedisConn *redis.Client

	TaskPrefixKey          string // to seperate different task watcher
	UpdateOrphanedTaskCron string

	TickerDuration    time.Duration
	HeartbeatDuration time.Duration // heartbeat should longer than ticker to prevent redis transport speed too slow

	GetRunningTasksFunc  func() []string
	UpdateTaskToFailFunc func(id string, redisErr error)

	ErrorAfterStartTaskWatcher error
}