Documentation ¶
Index ¶
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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.