From 311477639e678b30f639a21301001684a599526b Mon Sep 17 00:00:00 2001
From: pacinochen <pacinochen@easyops.cn>
Date: Sun, 27 Feb 2022 21:21:54 +0800
Subject: [PATCH] =?UTF-8?q?chore():=20=E8=B0=83=E5=BA=A6=E8=80=85=E9=98=9F?=
 =?UTF-8?q?=E5=88=97=E4=BB=BB=E5=8A=A1=E8=BF=87=E6=9C=9F=E6=97=B6=E9=97=B4?=
 =?UTF-8?q?=E8=AE=BE=E7=BD=AE=E4=B8=BA60s?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 scheduler.go | 27 +--------------------------
 1 file changed, 1 insertion(+), 26 deletions(-)

diff --git a/scheduler.go b/scheduler.go
index 9f74f9d..6a87e66 100644
--- a/scheduler.go
+++ b/scheduler.go
@@ -276,7 +276,7 @@ func (s *Scheduler) beat() {
 		entries = append(entries, e)
 	}
 	s.logger.Debugf("Writing entries %v", entries)
-	if err := s.rdb.WriteSchedulerEntries(s.id, entries, 5*time.Second); err != nil {
+	if err := s.rdb.WriteSchedulerEntries(s.id, entries, 60*time.Second); err != nil {
 		s.logger.Warnf("Scheduler could not write heartbeat data: %v", err)
 	}
 }
@@ -297,28 +297,3 @@ func (s *Scheduler) clearHistory() {
 		}
 	}
 }
-
-func (s *Scheduler) GetEntries() ([]*SchedulerEntry, error) {
-	var entries []*SchedulerEntry
-
-	for _, entry := range s.cron.Entries() {
-		job := entry.Job.(*enqueueJob)
-		var opts []Option
-		opt := stringifyOptions(job.opts)
-		for _, s := range opt {
-			if o, err := parseOption(s); err == nil {
-				// ignore bad data
-				opts = append(opts, o)
-			}
-		}
-		entries = append(entries, &SchedulerEntry{
-			ID:   job.id.String(),
-			Spec: job.cronspec,
-			Task: job.task,
-			Opts: opts,
-			Next: entry.Next,
-			Prev: entry.Prev,
-		})
-	}
-	return entries, nil
-}