taskmanager

Documentation

Index

• type TaskManager
  • func New(logger logger.Logger) *TaskManager
  • func (tm *TaskManager) AddTask(schedule string, task func()) (cron.EntryID, error)
  • func (tm *TaskManager) ListTasks() []cron.Entry
  • func (tm *TaskManager) RemoveTask(id cron.EntryID)
  • func (tm *TaskManager) RunJob(id cron.EntryID) error
  • func (tm *TaskManager) Start()
  • func (tm *TaskManager) Stop()

Types

type TaskManager

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

func New

func New(logger logger.Logger) *TaskManager

func (*TaskManager) AddTask

func (tm *TaskManager) AddTask(schedule string, task func()) (cron.EntryID, error)

func (*TaskManager) ListTasks

func (tm *TaskManager) ListTasks() []cron.Entry

func (*TaskManager) RemoveTask

func (tm *TaskManager) RemoveTask(id cron.EntryID)

func (*TaskManager) RunJob

func (tm *TaskManager) RunJob(id cron.EntryID) error

func (*TaskManager) Start

func (tm *TaskManager) Start()

func (*TaskManager) Stop

func (tm *TaskManager) Stop()