mirrors/diun
1
0
Fork 0
mirror of https://github.com/crazy-max/diun.git synced 2025-12-24 22:39:22 +01:00
Code Issues Packages Projects Releases Wiki Activity

switch from durafmt to github.com/dromara/carbon

Browse Source
This commit is contained in:
CrazyMax
2024-12-21 00:26:14 +01:00
parent 753855b16e
commit ce62dfd722
76 changed files with 13143 additions and 704 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
internal/app/diun.go
View File

@@ -4,7 +4,6 @@ import (
"net/url"
"sync"
"sync/atomic"
"time"
"github.com/crazy-max/cron/v3"
"github.com/crazy-max/diun/v4/internal/config"
@@ -20,7 +19,7 @@ import (
nomadPrd "github.com/crazy-max/diun/v4/internal/provider/nomad"
swarmPrd "github.com/crazy-max/diun/v4/internal/provider/swarm"
"github.com/crazy-max/gohealthchecks"
"github.com/hako/durafmt"
"github.com/dromara/carbon/v2"
"github.com/panjf2000/ants/v2"
"github.com/pkg/errors"
"github.com/rs/zerolog/log"
@@ -120,7 +119,7 @@ func (di *Diun) Start() error {
// Start scheduler
di.cron.Start()
log.Info().Msgf("Next run in %s (%s)",
durafmt.Parse(time.Until(di.cron.Entry(di.jobID).Next)).LimitFirstN(2).String(),
carbon.CreateFromStdTime(di.cron.Entry(di.jobID).Next).DiffAbsInString(),
di.cron.Entry(di.jobID).Next)
select {}
@@ -135,7 +134,7 @@ func (di *Diun) Run() {
defer atomic.StoreUint32(&di.locker, 0)
if di.jobID > 0 {
defer log.Info().Msgf("Next run in %s (%s)",
durafmt.Parse(time.Until(di.cron.Entry(di.jobID).Next)).LimitFirstN(2).String(),
carbon.CreateFromStdTime(di.cron.Entry(di.jobID).Next).DiffAbsInString(),
di.cron.Entry(di.jobID).Next)
}