duidui_fiber/internal/api/scheduler_routes.go
2026-03-27 10:34:03 +08:00

24 lines
727 B
Go

package api
import (
"dd_fiber_api/internal/scheduler"
"github.com/gofiber/fiber/v2"
)
// SetupSchedulerRoutes 调度器接口
func SetupSchedulerRoutes(router fiber.Router, schedulerHandler *scheduler.Handler) {
if schedulerHandler == nil {
return
}
sched := router.Group("/scheduler")
// 任务管理
sched.Post("/tasks", schedulerHandler.AddTask).Name("添加任务")
sched.Delete("/tasks/:task_id", schedulerHandler.RemoveTask).Name("删除任务")
sched.Get("/tasks/:task_id/status", schedulerHandler.GetTaskStatus).Name("查询任务状态")
sched.Get("/tasks", schedulerHandler.ListTasks).Name("列出所有任务")
sched.Get("/tasks/count", schedulerHandler.GetTaskCount).Name("获取任务数量")
}