Versions in this module Expand all Collapse all v0 v0.0.1 Aug 24, 2026 Changes in this version + const MethodTaskCancel + const MethodTaskGet + const MethodTaskList + const ProcessStatusCancelled + const ProcessStatusFailed + const ProcessStatusSuccess + const ProcessStatusSystemError + const RunStatusDone + const RunStatusQueued + const RunStatusRunning + var ErrTaskNotActive = errors.New("task is not active") + func AcceptAsyncTask(ctx context.Context, methodName string, abilityParams interface{}) (interface{}, error) + func ExecuteNextQueuedTask(ctx context.Context) (bool, error) + func LoadAPIMethods() + func RequeueOrphanedTasks(ctx context.Context) error + func TaskCancel(ctx context.Context, input interface{}) (interface{}, error) + func TaskGet(ctx context.Context, input interface{}) (interface{}, error) + func TaskList(ctx context.Context, input interface{}) (interface{}, error) + func UpdateProgress(ctx context.Context, taskID string, progress float64, message string) error + type AsyncTaskInfo struct + TaskID string + UserID *string + func AsyncTaskInfoFromContext(ctx context.Context) (*AsyncTaskInfo, bool)
Go to main page