pcm-openstack/internal/pkg/cron/cron.go

20 lines
455 B
Go

package cron
import "gitlink.org.cn/JointCloud/pcm-openstack/internal/svc"
func AddCronGroup(svc *svc.ServiceContext) {
// 同步任务信息到core端
svc.Cron.AddFunc("*/5 * * * * ?", func() {
SyncTask(svc)
})
// 推送p端心跳
svc.Cron.AddFunc("*/5 * * * * ?", func() {
ReportHeartbeat(svc.Config.Participant.Address, svc.ParticipantRpc)
})
// 推送节点动态信息
svc.Cron.AddFunc("*/59 * * * * ?", func() {
})
}