28 lines
757 B
Go
28 lines
757 B
Go
package crontask
|
|
|
|
import (
|
|
"ems.agt/src/framework/cron"
|
|
"ems.agt/src/framework/logger"
|
|
"ems.agt/src/modules/crontask/backupEtcFromNE"
|
|
"ems.agt/src/modules/crontask/delExpiredNeBackup"
|
|
"ems.agt/src/modules/crontask/deleteExpiredRecord"
|
|
|
|
"github.com/gin-gonic/gin"
|
|
)
|
|
|
|
// Setup 模块路由注册
|
|
func Setup(router *gin.Engine) {
|
|
logger.Infof("开始加载 ====> crontask 模块路由")
|
|
|
|
// 初始定时任务队列
|
|
InitCronQueue()
|
|
}
|
|
|
|
// InitCronQueue 初始定时任务队列
|
|
func InitCronQueue() {
|
|
// delete expired NE backup file
|
|
cron.CreateQueue("delExpiredNeBackup", delExpiredNeBackup.NewProcessor)
|
|
cron.CreateQueue("deleteExpiredRecord", deleteExpiredRecord.NewProcessor)
|
|
cron.CreateQueue("backupEtcFromNE", backupEtcFromNE.NewProcessor)
|
|
}
|