From 92f48c4c2ba8e552d1e47874b81605158ccbbc01 Mon Sep 17 00:00:00 2001
From: Volker Schukai <volker.schukai@schukai.com>
Date: Wed, 8 Nov 2023 10:44:15 +0100
Subject: [PATCH] feat: new manager function for get jobs and check job is
active #10
---
manager.go | 15 +++++++++++++++
1 file changed, 15 insertions(+)
diff --git a/manager.go b/manager.go
index a3af4eb..dad53ee 100644
--- a/manager.go
+++ b/manager.go
@@ -100,6 +100,21 @@ func (m *Manager) NewEventScheduler(event EventName) *EventScheduler {
}
}
+// GetActiveJobs returns the active jobs
+func (m *Manager) GetActiveJobs() map[JobID]GenericJob {
+ m.mu.Lock()
+ defer m.mu.Unlock()
+ return m.activeJobs
+}
+
+// ContainsActiveJob checks if a job is active
+func (m *Manager) ContainsActiveJob(id JobID) bool {
+ m.mu.Lock()
+ defer m.mu.Unlock()
+ _, ok := m.activeJobs[id]
+ return ok
+}
+
func (m *Manager) SetDB(db *gorm.DB) *Manager {
m.mu.Lock()
defer m.mu.Unlock()
--
GitLab