lighttaskscheduler

Nov 30, 2023

Changes in this version

+ type CallbackReceiver interface

+ GetCallbackChannel func(ctx context.Context) (taskChannel chan Task)

type Config

+ CallbackReceiver CallbackReceiver

+ DisableStatePoll bool

+ EnableFinshedTaskList bool

+ EnableStateCallback bool

+ MaxFailedAttempts int32

+ SchedulingPollInterval time.Duration

+ StatePollInterval time.Duration

type Task

+ FailedReason string

+ TaskAttemptsTime int32

+ TaskEnbTime time.Time

type TaskScheduler

+ Persistencer TaskdataPersistencer

+ func MakeScheduler(container TaskContainer, actuator TaskActuator, ...) (*TaskScheduler, error)

+ func (s *TaskScheduler) FinshedTasks() chan *Task

+ func (s *TaskScheduler) StopTask(ctx context.Context, ftask *Task) error

+ type TaskdataPersistencer interface

+ DataPersistence func(ctx context.Context, task *Task, data interface{}) (err error)

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

+ GetPersistenceData func(ctx context.Context, task *Task) (data interface{}, err error)

Apr 27, 2023

Changes in this version

+ type AsyncTaskStatus struct

+ FailedReason error

+ Progress interface{}

+ TaskStatus TaskStatus

+ type Config struct

+ ScanInterval time.Duration

+ TaskLimit int32

+ TaskTimeout time.Duration

+ type Task struct

+ TaskId string

+ TaskItem interface{}

+ TaskPriority int

+ TaskStartTime time.Time

+ TaskStatus TaskStatus

+ type TaskActuator interface

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

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

+ GetAsyncTaskStatus func(ctx context.Context, tasks []Task) (status []AsyncTaskStatus, err error)

+ GetOutput func(ctx context.Context, task *Task) (data interface{}, err error)

+ Init func(ctx context.Context, task *Task) (newTask *Task, err error)

+ Start func(ctx context.Context, task *Task) (newTask *Task, ignoreErr bool, err error)

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

+ type TaskContainer interface

+ AddTask func(ctx context.Context, task Task) (err error)

+ GetRunningTask func(ctx context.Context) (tasks []Task, err error)

+ GetRunningTaskCount func(ctx context.Context) (count int32, err error)

+ GetWaitingTask func(ctx context.Context, limit int32) (tasks []Task, err error)

+ ToDeleteStatus func(ctx context.Context, task *Task) (newTask *Task, err error)

+ ToExportStatus func(ctx context.Context, task *Task) (newTask *Task, err error)

+ ToFailedStatus func(ctx context.Context, task *Task, reason error) (newTask *Task, err error)

+ ToRunningStatus func(ctx context.Context, task *Task) (newTask *Task, err error)

+ ToStopStatus func(ctx context.Context, task *Task) (newTask *Task, err error)

+ ToSuccessStatus func(ctx context.Context, task *Task) (newTask *Task, err error)

+ UpdateRunningTaskStatus func(ctx context.Context, task *Task, status AsyncTaskStatus) error

+ type TaskScheduler struct

+ Actuator TaskActuator

+ Container TaskContainer

+ func MakeNewScheduler(ctx context.Context, container TaskContainer, actuator TaskActuator, ...) *TaskScheduler

+ func (s *TaskScheduler) AddTask(ctx context.Context, task Task) error

+ func (s *TaskScheduler) Close()

+ type TaskStatus int32

+ const TASK_STATUS_DELETE

+ const TASK_STATUS_EXPORTING

+ const TASK_STATUS_FAILED

+ const TASK_STATUS_INVALID

+ const TASK_STATUS_RUNNING

+ const TASK_STATUS_STOPED

+ const TASK_STATUS_SUCCESS

+ const TASK_STATUS_UNSTART

+ const TASK_STATUS_WAITING