- 优化心跳
continuous-integration/drone/push Build is failing Details
continuous-integration/drone/tag Build is failing Details

master v1.0.48
李光春 2 years ago
parent b964e771af
commit f56537c5f3

@ -1,3 +1,3 @@
package gojobs
const Version = "1.0.47"
const Version = "1.0.48"

@ -2,16 +2,17 @@ package gojobs
import (
"context"
"github.com/robfig/cron/v3"
"log"
)
// Ping 心跳
func (j *JobsGorm) Ping(ctx context.Context) error {
result, err := j.redisClient.Set(ctx, j.config.cornKeyIp, j.config.outsideIp, 5).Result()
if j.config.debug == true {
log.Println("gojobs.Ping", j.config.cornKeyIp, j.config.outsideIp, result, err)
}
return err
func (j *JobsGorm) Ping(ctx context.Context) {
c := cron.New(cron.WithSeconds())
_, _ = c.AddFunc(GetSeconds(2).Spec(), func() {
result, err := j.redisClient.Set(ctx, j.config.cornKeyIp, j.config.outsideIp, 3).Result()
if j.config.debug == true {
log.Println("JOBS心跳", j.config.cornKeyIp, j.config.outsideIp, result, err)
}
})
}

Loading…
Cancel
Save