task

Documentation

Index

• type Manager
  • func GetTaskManager() *Manager
  • func NewManager() Manager
  • func (manager *Manager) GetStatus(id uuid.UUID) (status []models.Status, err error)
  • func (manager *Manager) IsDone(id uuid.UUID) (b bool, err error)
  • func (manager *Manager) IsStarted(id uuid.UUID) (b bool, err error)
  • func (manager *Manager) List() []uuid.UUID
  • func (manager *Manager) Remove(id uuid.UUID)
  • func (manager *Manager) RemoveTask(id uuid.UUID)
  • func (manager *Manager) Run(owner string, name string, f func(t *Task), startedFunc func(t *Task), ...) (uuid.UUID, error)
  • func (manager *Manager) Stop(id uuid.UUID) (bool, error)
• type Task
  • func (t *Task) AddSubTask(subTaskId uuid.UUID) (bool, error)
  • func (t *Task) Done(status models.TaskStatus)
  • func (t *Task) IsDone() bool
  • func (t *Task) Persist() (bool, error)
  • func (t *Task) Run()
  • func (t Task) String() string
  • func (t *Task) UpdateStatus(format string, args ...interface{})
  • func (t *Task) UpdateStatusList(status []models.Status, lastUpdated time.Time) (bool, error)
  • func (t *Task) UpdateTaskCompleted(b bool, status models.TaskStatus, lastUpdated time.Time) (bool, error)

Types

type Manager

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

var (
	TaskManager Manager
)

func GetTaskManager

func GetTaskManager() *Manager

func NewManager

func NewManager() Manager

func (*Manager) GetStatus

func (manager *Manager) GetStatus(id uuid.UUID) (status []models.Status, err error)

func (*Manager) IsDone

func (manager *Manager) IsDone(id uuid.UUID) (b bool, err error)

func (*Manager) IsStarted

func (manager *Manager) IsStarted(id uuid.UUID) (b bool, err error)

func (*Manager) List

func (manager *Manager) List() []uuid.UUID

func (*Manager) Remove

func (manager *Manager) Remove(id uuid.UUID)

func (*Manager) RemoveTask

func (manager *Manager) RemoveTask(id uuid.UUID)

func (*Manager) Run

func (manager *Manager) Run(owner string, name string, f func(t *Task), startedFunc func(t *Task), completedFunc func(t *Task), statusFunc func(t *Task, s *models.Status)) (uuid.UUID, error)

func (*Manager) Stop

func (manager *Manager) Stop(id uuid.UUID) (bool, error)

type Task

type Task struct {
	Mutex            *sync.Mutex
	ID               uuid.UUID
	Owner            string
	Name             string
	Tag              map[string]string
	Started          bool
	Completed        bool
	DoneCh           chan bool
	StatusList       []models.Status
	StopCh           chan bool
	Func             func(t *Task)
	StartedCbkFunc   func(t *Task)
	CompletedCbkFunc func(t *Task)
	StatusCbkFunc    func(t *Task, s *models.Status)
	LastUpdated      time.Time
}

func (*Task) AddSubTask

func (t *Task) AddSubTask(subTaskId uuid.UUID) (bool, error)

func (*Task) Done

func (t *Task) Done(status models.TaskStatus)

func (*Task) IsDone

func (t *Task) IsDone() bool

func (*Task) Persist

func (t *Task) Persist() (bool, error)

func (*Task) Run

func (t *Task) Run()

func (Task) String

func (t Task) String() string

func (*Task) UpdateStatus

func (t *Task) UpdateStatus(format string, args ...interface{})

func (*Task) UpdateStatusList

func (t *Task) UpdateStatusList(status []models.Status, lastUpdated time.Time) (bool, error)

func (*Task) UpdateTaskCompleted

func (t *Task) UpdateTaskCompleted(b bool, status models.TaskStatus, lastUpdated time.Time) (bool, error)