11(ns cronut.integrant
22 (:require [cronut :as cronut]
3+ [cronut.trigger]
34 [integrant.core :as ig]))
45
56(defmethod ig /init-key :cronut/scheduler
6- [_ config]
7- (cronut/initialize config))
7+ [_ {:keys [schedule] :as config}]
8+ (let [scheduler (cronut/scheduler config)]
9+ (cronut/clear scheduler)
10+ (cronut/schedule-jobs scheduler schedule)
11+ (cronut/start scheduler)))
812
913(defmethod ig /halt-key! :cronut/scheduler
1014 [_ scheduler]
1115 (cronut/shutdown scheduler))
1216
1317(def data-readers
14- {'cronut/trigger cronut/trigger-builder
15- 'cronut/cron cronut/shortcut-cron
16- 'cronut/interval cronut/shortcut-interval})
17-
18- ; (ns cronut.integrant
19- ; (:require [cronut :as cronut]
20- ; [cronut.trigger]
21- ; [integrant.core :as ig]))
22- ;
23- ; (defmethod ig/init-key :cronut/scheduler
24- ; [_ {:keys [schedule] :as config}]
25- ; (let [scheduler (cronut/scheduler config)]
26- ; (cronut/clear scheduler)
27- ; (cronut/schedule-jobs scheduler schedule)
28- ; (cronut/start scheduler)))
29- ;
30- ; (defmethod ig/halt-key! :cronut/scheduler
31- ; [_ scheduler]
32- ; (cronut/shutdown scheduler))
33- ;
34- ; (def data-readers
35- ; {'cronut/trigger cronut.trigger/builder
36- ; 'cronut/cron cronut.trigger/cron
37- ; 'cronut/interval cronut.trigger/interval})
18+ {'cronut/trigger cronut.trigger/builder
19+ 'cronut/cron cronut.trigger/cron
20+ 'cronut/interval cronut.trigger/interval})
0 commit comments