taskwatcher

Documentation

Index

• type TaskWatcher
  • func NewTaskWatcher(redisConn *redis.Client, updateOrphanedTaskCron, taskPrefixKey string, ...) (taskWatcher TaskWatcher)
  • func (a *TaskWatcher) CloseUpdateOrphanedTask(uniqueKey string) (err error)
  • func (a *TaskWatcher) StartTaskWatcher(uniqueKey string) (stopFunc func(), err error)
  • func (a *TaskWatcher) StartUpdateOrphanedTask(uniqueKey string) (err error)

Types

type 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
}

func NewTaskWatcher

func NewTaskWatcher(
	redisConn *redis.Client,
	updateOrphanedTaskCron,
	taskPrefixKey string,
	tickerDuration,
	heartbeatDuration time.Duration,
	getRunningTasksFunc func() []string,
	updateTaskToFailFunc func(id string, redisErr error),
) (taskWatcher TaskWatcher)

func (*TaskWatcher) CloseUpdateOrphanedTask

func (a *TaskWatcher) CloseUpdateOrphanedTask(uniqueKey string) (err error)

func (*TaskWatcher) StartTaskWatcher

func (a *TaskWatcher) StartTaskWatcher(uniqueKey string) (stopFunc func(), err error)

func (*TaskWatcher) StartUpdateOrphanedTask

func (a *TaskWatcher) StartUpdateOrphanedTask(uniqueKey string) (err error)