Versions in this module Expand all Collapse all v21 v21.11.1 Apr 26, 2022 Changes in this version type Task + func TaskFromContextOrVoid(ctx context.Context) (Task, fail.Error) v21.11.0 Feb 17, 2022 Changes in this version + const KeyForTaskInContext + var FailEarly = data.NewImmutableKeyValue("fail", "early") + var FailLately = data.NewImmutableKeyValue("fail", "lately") + var InheritParentIDOption = data.NewImmutableKeyValue(keywordInheritParentIDOption, true) + func AmendID(id string) data.ImmutableKeyValue + func NewTaskGroup(options ...data.ImmutableKeyValue) (*taskGroup, fail.Error) + func NewTaskGroupWithContext(ctx context.Context, options ...data.ImmutableKeyValue) (*taskGroup, fail.Error) + func NewTaskGroupWithParent(parentTask Task, options ...data.ImmutableKeyValue) (*taskGroup, fail.Error) + type Task interface + func NewTask() (Task, fail.Error) + func NewTaskWithContext(ctx context.Context, options ...data.ImmutableKeyValue) (Task, fail.Error) + func NewTaskWithParent(parentTask Task, options ...data.ImmutableKeyValue) (Task, fail.Error) + func NewUnbreakableTask() (Task, fail.Error) + func RootTask() (rt Task, ferr fail.Error) + func TaskFromContext(ctx context.Context) (Task, fail.Error) + func VoidTask() (Task, fail.Error) + type TaskAction func(t Task, parameters TaskParameters) (TaskResult, fail.Error) + type TaskCore interface + Abort func() fail.Error + AbortWithCause func(fail.Error) fail.Error + Abortable func() (bool, fail.Error) + Aborted func() bool + Context func() context.Context + DisarmAbortSignal func() func() + ID func() (string, fail.Error) + LastError func() (error, fail.Error) + Result func() (TaskResult, fail.Error) + Run func(fn TaskAction, params TaskParameters, options ...data.ImmutableKeyValue) (TaskResult, fail.Error) + SetID func(string) fail.Error + Signature func() string + Start func(fn TaskAction, params TaskParameters, options ...data.ImmutableKeyValue) (Task, fail.Error) + StartWithTimeout func(fn TaskAction, params TaskParameters, timeout time.Duration, ...) (Task, fail.Error) + Status func() (TaskStatus, fail.Error) + type TaskGroup interface + GroupStatus func() (map[TaskStatus][]string, fail.Error) + type TaskGroupGuard interface + Started func() (uint, fail.Error) + TryWaitGroup func() (bool, TaskGroupResult, fail.Error) + WaitGroup func() (TaskGroupResult, fail.Error) + WaitGroupFor func(time.Duration) (bool, TaskGroupResult, fail.Error) + type TaskGroupResult = map[string]TaskResult + type TaskGuard interface + TryWait func() (bool, TaskResult, fail.Error) + Wait func() (TaskResult, fail.Error) + WaitFor func(time.Duration) (bool, TaskResult, fail.Error) + type TaskParameters interface + type TaskResult interface + type TaskStatus int + const ABORTED + const DONE + const READY + const RUNNING + const TIMEOUT + const UNKNOWN Other modules containing this package github.com/CS-SI/SafeScale github.com/CS-SI/SafeScale/v22