108 lines
3.8 KiB
Go
108 lines
3.8 KiB
Go
package scheduler
|
|
|
|
//
|
|
//import (
|
|
// "alfred/cmd/core/app/service"
|
|
// "alfred/config"
|
|
// "alfred/internal/clients"
|
|
// "alfred/internal/infra"
|
|
// "alfred/internal/shedlock"
|
|
// "alfred/pkg/log"
|
|
// "alfred/repositoryAccessLayer"
|
|
// "alfred/utils"
|
|
// "go.uber.org/zap"
|
|
//)
|
|
//
|
|
//func ScheduleCronForDeviceMetricsToSlack(repositories *repositoryAccessLayer.RepositoryAccessLayer, httpClient *clients.HttpClient) {
|
|
// DeviceMetricsService := service.NewDeviceMetrics(repositories, httpClient)
|
|
//
|
|
// go func() {
|
|
// schedule := config.GetCoreConfig().DeviceMonitoringConfig.DeviceMetricsUpdateCronScheduleMap[utils.NAVI_USER_APP]
|
|
// cronTime := utils.GetCronTime(schedule)
|
|
// _, err := infra.ScheduleJob(schedule, func() {
|
|
//
|
|
// err := shedlock.Lock(utils.UPDATE_DEVICE_METRICS_CRON, config.GetCoreConfig().ShedlockConfig.DeviceMetricsCronLockedUntil, repositories)
|
|
// if err != nil {
|
|
// log.Error("Cron Already Locked for Updating Device Metrics", zap.Error(err))
|
|
// return
|
|
// }
|
|
//
|
|
// log.Info("Cron Initiated for Updating Device Metrics For Navi App")
|
|
//
|
|
// DeviceMetricsService.UpdateDeviceMetrics(utils.NAVI_USER_APP, cronTime)
|
|
//
|
|
// })
|
|
// if err != nil {
|
|
// log.Error("Cron Failed For Device Metrics For Navi App:", zap.Error(err))
|
|
// return
|
|
// }
|
|
// log.Info("Cron Success for Device Metrics For Navi App")
|
|
// }()
|
|
//
|
|
// go func() {
|
|
// schedule := config.GetCoreConfig().DeviceMonitoringConfig.DeviceMetricsUpdateCronScheduleMap[utils.COSMOS]
|
|
// cronTime := utils.GetCronTime(schedule)
|
|
// _, err := infra.ScheduleJob(schedule, func() {
|
|
//
|
|
// err := shedlock.Lock(utils.UPDATE_DEVICE_METRICS_CRON_COSMOS, config.GetCoreConfig().ShedlockConfig.DeviceMetricsCronLockedUntil, repositories)
|
|
// if err != nil {
|
|
// log.Error("Cron Already Locked for Updating Device Metrics Cosmos", zap.Error(err))
|
|
// return
|
|
// }
|
|
//
|
|
// log.Info("Cron Initiated for Updating Device Metrics For Cosmos")
|
|
//
|
|
// DeviceMetricsService.UpdateDeviceMetrics(utils.COSMOS, cronTime)
|
|
// })
|
|
// if err != nil {
|
|
// log.Error("Cron Failed For Updating Device Metrics For Cosmos:", zap.Error(err))
|
|
// return
|
|
// }
|
|
// log.Info("Cron Success for Updating Device Metrics For Cosmos")
|
|
// }()
|
|
//
|
|
// go func() {
|
|
// schedule := config.GetCoreConfig().DeviceMonitoringConfig.DeviceMonitoringCronScheduleMap[utils.NAVI_USER_APP]
|
|
// cronTime := utils.GetCronTime(schedule)
|
|
// _, err := infra.ScheduleJob(schedule, func() {
|
|
//
|
|
// err := shedlock.Lock(utils.DEVICE_METRICS_ALERT_CRON, config.GetCoreConfig().ShedlockConfig.DeviceMetricsCronLockedUntil, repositories)
|
|
// if err != nil {
|
|
// log.Error("Cron Already Locked for Device Metrics", zap.Error(err))
|
|
// return
|
|
// }
|
|
//
|
|
// log.Info("Cron Initiated for Device Metrics For Navi App")
|
|
//
|
|
// DeviceMetricsService.PublishDeviceMetrics(utils.NAVI_USER_APP, cronTime)
|
|
// })
|
|
// if err != nil {
|
|
// log.Error("Cron Failed For Device Metrics For Navi App:", zap.Error(err))
|
|
// return
|
|
// }
|
|
// log.Info("Cron Success for Device Metrics For Navi App")
|
|
// }()
|
|
//
|
|
// go func() {
|
|
// schedule := config.GetCoreConfig().DeviceMonitoringConfig.DeviceMonitoringCronScheduleMap[utils.COSMOS]
|
|
// cronTime := utils.GetCronTime(schedule)
|
|
// _, err := infra.ScheduleJob(schedule, func() {
|
|
//
|
|
// err := shedlock.Lock(utils.DEVICE_METRICS_ALERT_CRON_COSMOS, config.GetCoreConfig().ShedlockConfig.DeviceMetricsCronLockedUntil, repositories)
|
|
// if err != nil {
|
|
// log.Error("Cron Already Locked for Device Metrics", zap.Error(err))
|
|
// return
|
|
// }
|
|
//
|
|
// log.Info("Cron Initiated for Device Metrics For Cosmos")
|
|
//
|
|
// DeviceMetricsService.PublishDeviceMetrics(utils.COSMOS, cronTime)
|
|
// })
|
|
// if err != nil {
|
|
// log.Error("Cron Failed For Device Metrics For Cosmos:", zap.Error(err))
|
|
// return
|
|
// }
|
|
// log.Info("Cron Success for Device Metrics For Cosmos")
|
|
// }()
|
|
//}
|