Versions in this module Expand all Collapse all v0 v0.0.1 Nov 28, 2024 Changes in this version + var CANCELED = "canceled" + var CANCELING = "canceling" + var ERRORED = "errored" + var ErrTaskNotFound = errors.New("task not found") + var ErrTaskRunning = errors.New("task is running") + var PENDING = "pending" + var RUNNING = "running" + var SUCCEEDED = "succeeded" + type Callback func(task *Task[K]) + type Func func(task *Task[K]) error + type Manager struct + func NewTaskManager[K comparable](maxWorker int, updateID ...func(*K)) *Manager[K] + func (tm *Manager[K]) Cancel(tid K) error + func (tm *Manager[K]) ClearDone() + func (tm *Manager[K]) ClearSucceeded() + func (tm *Manager[K]) Get(tid K) (*Task[K], bool) + func (tm *Manager[K]) GetAll() []*Task[K] + func (tm *Manager[K]) GetByStates(states ...string) []*Task[K] + func (tm *Manager[K]) ListDone() []*Task[K] + func (tm *Manager[K]) ListUndone() []*Task[K] + func (tm *Manager[K]) MustGet(tid K) *Task[K] + func (tm *Manager[K]) RawTasks() *generic_sync.MapOf[K, *Task[K]] + func (tm *Manager[K]) Remove(tid K) error + func (tm *Manager[K]) RemoveAll() + func (tm *Manager[K]) RemoveByStates(states ...string) + func (tm *Manager[K]) Retry(tid K) error + func (tm *Manager[K]) Submit(task *Task[K]) K + type Task struct + Ctx context.Context + Error error + Func Func[K] + ID K + Name string + func WithCancelCtx[K comparable](task *Task[K]) *Task[K] + func (t *Task[K]) Cancel() + func (t *Task[K]) Done() bool + func (t *Task[K]) SetProgress(percentage float64) + func (t *Task[K]) SetStatus(status string) + func (t Task[K]) GetErrMsg() string + func (t Task[K]) GetProgress() float64 + func (t Task[K]) GetState() string + func (t Task[K]) GetStatus() string
Go to main page