tasks

Documentation

Index

• type Task
  • func (t *Task) Stop()
• type TaskManager
  • func NewTaskManager(log *logrus.Entry) *TaskManager
  • func (t *TaskManager) NewTask(f func(stop chan struct{})) error
  • func (t *TaskManager) NewTickerTask(duration time.Duration, before func(stop chan struct{}), ...) error

Types

type Task

type Task struct {
	Log *logrus.Entry
	// contains filtered or unexported fields
}

func (*Task) Stop

func (t *Task) Stop()

type TaskManager

type TaskManager struct {
	Log *logrus.Entry
	// contains filtered or unexported fields
}

func NewTaskManager

func NewTaskManager(log *logrus.Entry) *TaskManager

func (*TaskManager) NewTask

func (t *TaskManager) NewTask(f func(stop chan struct{})) error

func (*TaskManager) NewTickerTask

func (t *TaskManager) NewTickerTask(duration time.Duration, before func(stop chan struct{}), f func(stop, notifyStopped chan struct{})) error

NewTickerTask is a convenience function for making a new task that repeats some action once per e.g. second the before function gets called after the lock is obtained, but before the ticker starts. if you handle a message on the stop channel in f() you need to send a message on the notifyStopped channel because returning is not sufficient. Here, unlike in a regular task, simply returning means we're now going to wait till the next tick to run again.