task

package
v0.0.0-...-d1c0bb1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 29, 2016 License: Apache-2.0 Imports: 10 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL