Versions in this module Expand all Collapse all v0 v0.0.2 Nov 20, 2024 Changes in this version type TaskManager_t + func (t *TaskManager_t) CloseTaskManager(waitMsg bool) + func (t *TaskManager_t) DeleteAllTask() error v0.0.1 Nov 19, 2024 Changes in this version + type StatusEvent_t struct + Func TaskFunc + Operation TaskOperation_t + Status interface{} + type TaskFunc func(ctx context.Context, eventChan chan<- StatusEvent_t) error + type TaskManagerMsg_t struct + Err error + Msg string + T time.Time + type TaskManager_t struct + func NewTaskManager() *TaskManager_t + func (t *TaskManager_t) AddTask(taskName string, taskFunc TaskFunc) + func (t *TaskManager_t) DeleteTask(taskName string) error + func (t *TaskManager_t) GetEventMsg() <-chan TaskManagerMsg_t + func (t *TaskManager_t) GetTaskFuncLockStatus(taskName string) bool + func (t *TaskManager_t) GetTaskFuncResult(taskName string) error + func (t *TaskManager_t) GetTaskLastUpdateTime(taskName string) (time.Time, error) + func (t *TaskManager_t) GetTaskNameList() ([]string, error) + func (t *TaskManager_t) GetTaskOperation(taskName string) (TaskOperation_t, error) + func (t *TaskManager_t) GetTaskStatus(taskName string) (interface{}, error) + func (t *TaskManager_t) GetTotalTaskCount() int + func (t *TaskManager_t) GetTotalTaskCountByStatus(status interface{}) (int, error) + func (t *TaskManager_t) IsTaskExist(taskName string) bool + func (t *TaskManager_t) RestartTask(taskName string) error + func (t *TaskManager_t) RunTask(taskName string) error + func (t *TaskManager_t) Service() + func (t *TaskManager_t) StopAllTask() + func (t *TaskManager_t) StopTask(taskName string) error + func (t *TaskManager_t) StopTaskManager(waitMsg bool) + type TaskOperation_t int + const OPERATION_DELETE + const OPERATION_NONE + const OPERATION_RESTART + const OPERATION_START + const OPERATION_STOP
Go to main page