tasks

Aug 23, 2023

Changes in this version

type TaskItem

+ func (t *TaskItem) CancelWatch()

Feb 22, 2023

Changes in this version

+ type TaskEvent struct

+ Meta map[string]interface{}

+ Name string

+ State TaskState

+ func NewTaskEvent(item *TaskItem, state TaskState) *TaskEvent

+ func (e *TaskEvent) String() string

type TaskItem

+ func (t *TaskItem) UpdateMeta(meta map[string]interface{})

type TaskManager

+ func NewTaskManager() *TaskManager

+ type TaskState int

+ const TaskStateAdded

+ const TaskStateFailed

+ const TaskStateFinished

+ const TaskStateIdle

+ const TaskStateRemoved

+ const TaskStateRunning

+ const TaskStateStopped

+ const TaskStateWatching

+ func (s TaskState) String() string

Feb 17, 2023

Changes in this version

+ var ErrTaskNotFound = errors.New("task not found")

+ type TaskFunc func(ctx context.Context) error

+ type TaskItem struct

+ func NewTaskItem(name string, tf TaskFunc) *TaskItem

+ func (t *TaskItem) Cancel()

+ func (t *TaskItem) Run(ctx context.Context) error

+ func (t *TaskItem) Watch(ctx context.Context, dependencies ...string)

+ type TaskManager struct

+ func New() *TaskManager

+ func (tm *TaskManager) AddTask(task *TaskItem)

+ func (tm *TaskManager) Cancel(name string) error

+ func (tm *TaskManager) CancelAll()

+ func (tm *TaskManager) Get(name string) *TaskItem

+ func (tm *TaskManager) Has(name string) bool

+ func (tm *TaskManager) Names() []string

+ func (tm *TaskManager) Register(name string, tf TaskFunc) *TaskItem

+ func (tm *TaskManager) RmTask(name string) error

+ func (tm *TaskManager) Run(ctx context.Context, name string) error

+ func (tm *TaskManager) Watch(ctx context.Context, name string, dependencies ...string) error