gemma: pkg/scheduler/scheduler.go comparison

Added DELETE /imports/scheduler/{id:[0-9]+} to delete a schedule from the scheduler.

author	Sascha L. Teichmann <sascha.teichmann@intevation.de>
date	Fri, 14 Dec 2018 12:34:12 +0100
parents	62171cd9a42b
children	f39957ea08aa

comparison

equal deleted inserted replaced

-:e0bd82f6ee14
+:2fdd8e57542d
 // an optional configuration id.
 func UnbindAction(name, user string, cfgID *int64) {
 	global.unbindAction(name, user, cfgID)
 }
+// UnbindByID unbinds all schedules with a given id.
+func UnbindByID(cfgID int64) {
+	global.unbindByID(cfgID)
+}
 // UnbindUser unbinds all schedules for a given user.
 func UnbindUser(user string) {
 	global.unbindUser(user)
 }
 	s.cr.Stop()
 	s.cr = cron.New()
 	for _, entry := range entries {
 		ua := entry.Job.(*userAction)
 		if ua.user != user {
+			s.cr.Schedule(entry.Schedule, entry.Job)
+		}
+	}
+	s.cr.Start()
+}
+func (s *scheduler) unbindByID(cfgID int64) {
+	s.mu.Lock()
+	defer s.mu.Unlock()
+	entries := s.cr.Entries()
+	var found bool
+	for _, entry := range entries {
+		ua := entry.Job.(*userAction)
+		if ua.cfgID != nil && *ua.cfgID == cfgID {
+			found = true
+			break
+		}
+	}
+	if !found {
+		return
+	}
+	s.cr.Stop()
+	s.cr = cron.New()
+	for _, entry := range entries {
+		ua := entry.Job.(*userAction)
+		if ua.cfgID == nil || *ua.cfgID != cfgID {
 			s.cr.Schedule(entry.Schedule, entry.Job)
 		}
 	}
 	s.cr.Start()
 }

Mercurial > gemma