task

Documentation

Index

• type FileScheduleManager
  • func GetFileScheduleManager() *FileScheduleManager
  • func InitFileScheduleManager() *FileScheduleManager
  • func (m *FileScheduleManager) ClearServiceAndTaskAll() error
  • func (m *FileScheduleManager) CreateAndStartSchedule(schedule models.Schedule) error
  • func (m *FileScheduleManager) CreateSchedule(schedule models.Schedule) error
  • func (m *FileScheduleManager) CreateTask(task models.DataTask) error
  • func (m *FileScheduleManager) DeleteAndRestartScheduler(scheduleID string) error
  • func (m *FileScheduleManager) DeleteSchedule(id string) error
  • func (m *FileScheduleManager) DeleteTask(taskID string) error
  • func (m *FileScheduleManager) DeleteTasksByType(taskType models.TaskType, taskID string) error
  • func (m *FileScheduleManager) GetSchedule(id string) (models.Schedule, error)
  • func (m *FileScheduleManager) GetScheduleList() ([]models.Schedule, error)
  • func (m *FileScheduleManager) GetTask(taskID string) (models.BasicDataTask, error)
  • func (m *FileScheduleManager) GetTaskList() ([]models.BasicDataTask, error)
  • func (m *FileScheduleManager) GetTasksByType(taskType models.TaskType, taskID string) (models.BasicDataTask, error)
  • func (m *FileScheduleManager) GetTasksByTypeList(taskType models.TaskType) ([]models.BasicDataTask, error)
  • func (m *FileScheduleManager) RunTaskOnce(task models.DataTask) bool
  • func (m *FileScheduleManager) RunTasks(tasks []models.BasicDataTask)
  • func (m *FileScheduleManager) StartSchedulers()
  • func (m *FileScheduleManager) StopSchedulers()
  • func (m *FileScheduleManager) UpdateAndRestartSchedule(scheduleID string, updatedSchedule models.Schedule) error
  • func (m *FileScheduleManager) UpdateSchedule(id string, updatedSchedule models.Schedule) error
  • func (m *FileScheduleManager) UpdateTask(taskID string, updatedTask models.BasicDataTask) error
  • func (m *FileScheduleManager) UpdateTasksByType(taskType models.TaskType, taskID string, updatedTask models.BasicDataTask) error

Types

type FileScheduleManager

type FileScheduleManager struct {
	// contains filtered or unexported fields
}

FileScheduleManager manages task schedules, flows, and tasks.

func GetFileScheduleManager

func GetFileScheduleManager() *FileScheduleManager

GetFileScheduleManager provides access to the singleton instance.

func InitFileScheduleManager

func InitFileScheduleManager() *FileScheduleManager

InitFileScheduleManager initializes the singleton instance of FileScheduleManager.

func (*FileScheduleManager) ClearServiceAndTaskAll

func (m *FileScheduleManager) ClearServiceAndTaskAll() error

ClearServiceAndTaskAll loads all tasks, changes their TaskType to 'delete', executes the delete tasks to remove services, and then removes the tasks and schedules.

func (*FileScheduleManager) CreateAndStartSchedule

func (m *FileScheduleManager) CreateAndStartSchedule(schedule models.Schedule) error

CreateAndStartSchedule creates a new schedule and registers it without stopping any schedulers.

func (*FileScheduleManager) CreateSchedule

func (m *FileScheduleManager) CreateSchedule(schedule models.Schedule) error

CreateSchedule creates a new schedule, saves it to the file, and registers it with the scheduler. It handles multiple time zones by assigning schedules to their respective schedulers. If a schedule with the same ScheduleID already exists, it rejects the registration.

func (*FileScheduleManager) CreateTask

func (m *FileScheduleManager) CreateTask(task models.DataTask) error

func (*FileScheduleManager) DeleteAndRestartScheduler

func (m *FileScheduleManager) DeleteAndRestartScheduler(scheduleID string) error

DeleteAndRestartScheduler deletes a schedule without stopping any schedulers.

func (*FileScheduleManager) DeleteSchedule

func (m *FileScheduleManager) DeleteSchedule(id string) error

DeleteSchedule deletes a schedule by ScheduleID or OperationID.

func (*FileScheduleManager) DeleteTask

func (m *FileScheduleManager) DeleteTask(taskID string) error

DeleteTask deletes a task by its TaskID.

func (*FileScheduleManager) DeleteTasksByType

func (m *FileScheduleManager) DeleteTasksByType(taskType models.TaskType, taskID string) error

DeleteTasksByType deletes a task specified by TaskType and TaskID.

func (*FileScheduleManager) GetSchedule

func (m *FileScheduleManager) GetSchedule(id string) (models.Schedule, error)

GetSchedule retrieves a schedule by its ID or OperationID.

func (*FileScheduleManager) GetScheduleList

func (m *FileScheduleManager) GetScheduleList() ([]models.Schedule, error)

GetScheduleList retrieves a list of all schedules.

func (*FileScheduleManager) GetTask

func (m *FileScheduleManager) GetTask(taskID string) (models.BasicDataTask, error)

GetTask retrieves a task by its TaskID.

func (*FileScheduleManager) GetTaskList

func (m *FileScheduleManager) GetTaskList() ([]models.BasicDataTask, error)

GetTaskList retrieves a list of all tasks.

func (*FileScheduleManager) GetTasksByType

func (m *FileScheduleManager) GetTasksByType(taskType models.TaskType, taskID string) (models.BasicDataTask, error)

GetTasksByType retrieves a task filtered by TaskType and TaskID.

func (*FileScheduleManager) GetTasksByTypeList

func (m *FileScheduleManager) GetTasksByTypeList(taskType models.TaskType) ([]models.BasicDataTask, error)

GetTasksByTypeList retrieves tasks filtered by TaskType.

func (*FileScheduleManager) RunTaskOnce

func (m *FileScheduleManager) RunTaskOnce(task models.DataTask) bool

func (*FileScheduleManager) RunTasks

func (m *FileScheduleManager) RunTasks(tasks []models.BasicDataTask)

RunTasks executes the tasks associated with a schedule.

func (*FileScheduleManager) StartSchedulers

func (m *FileScheduleManager) StartSchedulers()

StartSchedulers starts all schedulers asynchronously.

func (*FileScheduleManager) StopSchedulers

func (m *FileScheduleManager) StopSchedulers()

StopSchedulers stops all schedulers.

func (*FileScheduleManager) UpdateAndRestartSchedule

func (m *FileScheduleManager) UpdateAndRestartSchedule(scheduleID string, updatedSchedule models.Schedule) error

UpdateAndRestartSchedule updates an existing schedule without stopping any schedulers.

func (*FileScheduleManager) UpdateSchedule

func (m *FileScheduleManager) UpdateSchedule(id string, updatedSchedule models.Schedule) error

UpdateSchedule updates an existing schedule by ScheduleID or OperationID. It handles time zone changes by moving the schedule to the appropriate scheduler.

func (*FileScheduleManager) UpdateTask

func (m *FileScheduleManager) UpdateTask(taskID string, updatedTask models.BasicDataTask) error

UpdateTask updates an existing task by TaskID.

func (*FileScheduleManager) UpdateTasksByType

func (m *FileScheduleManager) UpdateTasksByType(taskType models.TaskType, taskID string, updatedTask models.BasicDataTask) error

UpdateTasksByType updates a task specified by TaskType and TaskID.