task

Jan 4, 2026

Changes in this version

type CancelRequest

+ func NewCancelRequest(taskId string) *CancelRequest

type STATUS

+ func (s STATUS) MarshalJSON() ([]byte, error)

type TaskSpec

+ func (t *TaskSpec) IsAsync() bool

Sep 27, 2025

Changes in this version

type QUEUE_EVENT_TYPE

+ const QUEUE_EVENT_TYPE_UPDATE

type RunParam

+ func (r *RunParam) String() string

type STATUS

+ const STATUS_UPDATING

type Service

+ UpdateTaskStatus func(context.Context, *UpdateTaskStatusRequest) (*Task, error)

type Task

+ func (t *Task) WaitComplete(ctx context.Context, scanInterval time.Duration, maxScanCount int) error

type TaskSpec

+ func (t *TaskSpec) GetLabel(key string) string

+ func (t *TaskSpec) SetLabelByMap(m map[string]string) *TaskSpec

type TaskStatus

+ Extras map[string]string

+ ReferenceId string

+ ReferenceURL string

+ StatusChanged bool

+ func (s *TaskStatus) ComputedIsChanged(status STATUS)

+ type UpdateTaskStatusRequest struct

+ func NewUpdateTaskStatusRequest(taskId string) *UpdateTaskStatusRequest

Sep 7, 2025

Changes in this version

+ func NewDebugEvent(taskId string, format string, a ...any) *event.EventSpec

+ func NewWarnEvent(taskId string, format string, a ...any) *event.EventSpec

Sep 7, 2025

Changes in this version

+ const PRIORITY

+ const RUN_PARAM_TYPE_JSON

+ func ListAsyncRunner() (ns []string)

+ func ListSyncRunner() (ns []string)

+ func RegistryAsyncRunner(name string, runner AsyncRunner)

+ func RegistrySyncRunner(name string, runner SyncRunner)

+ type AsyncRunner interface

+ Cancel func(ctx context.Context, taskID string) error

+ GetStatus func(ctx context.Context, taskID string) (*TaskStatus, error)

+ Start func(ctx context.Context, task *Task) error

+ func GetAsyncRunner(name string) AsyncRunner

+ type CancelRequest struct

+ type QUEUE_EVENT_TYPE string

+ const QUEUE_EVENT_TYPE_CANCEL

+ const QUEUE_EVENT_TYPE_RUN

type QueryTaskRequest

+ Label map[string]string

+ func (r *QueryTaskRequest) SetLabel(key, value string) *QueryTaskRequest

+ type QueueEvent struct

+ TaskId string

+ Type QUEUE_EVENT_TYPE

+ func NewQueueEvent() *QueueEvent

+ func (e *QueueEvent) Load(v []byte) error

+ func (e *QueueEvent) String() string

+ type RUN_PARAM_TYPE string

+ type RunParam struct

+ Type RUN_PARAM_TYPE

+ Value string

+ func NewJsonRunParam(jsonStr string) *RunParam

+ func (r *RunParam) Load(v any) error

type STATUS

+ const STATUS_CANCELING

+ const STATUS_PENDDING

+ const STATUS_QUEUED

+ const STATUS_SKIPPED

type Service

+ Cancel func(context.Context, *CancelRequest) (*Task, error)

+ CreateTask func(context.Context, *TaskSpec) (*Task, error)

+ type SyncRunner interface

+ Run func(ctx context.Context, task *Task) error

+ func GetSyncRunner(name string) SyncRunner

type Task

+ Events []*event.Event

+ func (t *Task) IsCompleted() bool

+ func (t *Task) IsRunning() bool

+ func (t *Task) SetMessage(msg string) *Task

type TaskSpec

+ Resource string

+ Runner string

+ TaskId string

+ func NewTaskSpec(runner string, param *RunParam) *TaskSpec

type TaskStatus

+ Detail string

+ func (s *TaskStatus) TableName() string

+ type UnimplementedAsyncRunner struct

+ func (r *UnimplementedAsyncRunner) Cancel(ctx context.Context, taskID string) error

+ func (r *UnimplementedAsyncRunner) GetStatus(ctx context.Context, taskID string) (*TaskStatus, error)

+ func (r *UnimplementedAsyncRunner) Start(context.Context, *Task)

+ type UnimplementedSyncRunner struct

+ func (r *UnimplementedSyncRunner) Start(context.Context, *Task)

Jul 12, 2025

Changes in this version

type QueryTaskRequest

+ func NewQueryTaskRequest() *QueryTaskRequest

type Task

+ func (t *Task) Cancel()

type TaskSpec

+ Description string

+ DryRun bool

+ Name string

+ func (t *TaskSpec) SetDescription(desc string) *TaskSpec

+ func (t *TaskSpec) SetName(name string) *TaskSpec

Jul 6, 2025

Changes in this version

+ const APP_NAME

+ const EVENT_LABLE_TASK_ID

+ var DEFAULT_TIMEOUT = time.Second * 30

+ var STATUS_COMPLETE = []STATUS

+ var STATUS_MAP = map[STATUS]string

+ func NewErrorEvent(msg string, taskId string) *types.Set[*event.EventSpec]

+ func NewInfoEvent(msg string, taskId string) *types.Set[*event.EventSpec]

+ func StatusCompleteString() []string

+ type CONTEXT_TASK_KEY struct

+ type DescribeTaskRequest struct

+ TaskId string

+ func NewDescribeTaskRequest(taskId string) *DescribeTaskRequest

+ type QueryTaskRequest struct

+ type STATUS int

+ const STATUS_CANCELED

+ const STATUS_FAILED

+ const STATUS_PENDING

+ const STATUS_RUNNING

+ const STATUS_SUCCESS

+ func (s STATUS) String() string

+ type Service interface

+ DescribeTask func(context.Context, *DescribeTaskRequest) (*Task, error)

+ QueryTask func(context.Context, *QueryTaskRequest) (*types.Set[*Task], error)

+ Run func(context.Context, *TaskSpec) *Task

+ func GetService() Service

+ type TYPE string

+ const TYPE_FUNCTION

+ type Task struct

+ CreatedAt time.Time

+ Id string

+ func GetTaskFromCtx(ctx context.Context) *Task

+ func NewTask(spec TaskSpec) *Task

+ func (t *Task) BuildTimeoutCtx() context.Context

+ func (t *Task) Failed(msg string) *Task

+ func (t *Task) Running() *Task

+ func (t *Task) String() string

+ func (t *Task) Success() *Task

+ func (t *Task) TableName() string

+ type TaskFunc func(ctx context.Context, req any) error

+ type TaskSpec struct

+ Async bool

+ Label map[string]string

+ Params any

+ Timeout string

+ Type TYPE

+ WebHooks []*webhook.WebHook

+ func NewFnTask(fn TaskFunc, params any) *TaskSpec

+ func (t *TaskSpec) AddWebHook(hs ...*webhook.WebHook) *TaskSpec

+ func (t *TaskSpec) Cancel()

+ func (t *TaskSpec) GetFn() TaskFunc

+ func (t *TaskSpec) SetAsync(v bool) *TaskSpec

+ func (t *TaskSpec) SetLabel(key, value string) *TaskSpec

+ type TaskStatus struct

+ EndAt *time.Time

+ Events []*event.Event

+ Message string

+ StartAt *time.Time

+ Status STATUS

+ UpdateAt *time.Time

+ func NewTaskStatus() *TaskStatus

+ func (s *TaskStatus) SetEndAt(t time.Time)

+ func (s *TaskStatus) SetStartAt(t time.Time)

+ func (s *TaskStatus) SetUpdateAt(t time.Time)