tm

Documentation

Index

• func Watch() error
• type TaskManager
  • func NewTaskManager(p persister.Persister, q chan model.Task) *TaskManager
  • func (t *TaskManager) Add(task model.Task) error

Functions

func Watch

func Watch() error

Types

type TaskManager

type TaskManager struct {
	// contains filtered or unexported fields
}

func NewTaskManager

func NewTaskManager(p persister.Persister, q chan model.Task) *TaskManager

func (*TaskManager) Add

func (t *TaskManager) Add(task model.Task) error

Add enqueued a task to execute