chronology

A lightweight task scheduler and cron utilities

License	MIT License
GroupId	com.vodori
ArtifactId	chronology
Last Version	0.1.1
Release Date	Mar 27, 2019
Type	jar
Description	chronology A lightweight task scheduler and cron utilities
Project URL	https://github.com/vodori/chronology
Source Code Management	https://github.com/vodori/chronology

Download chronology

Filename	Size
chronology-0.1.1.pom
chronology-0.1.1.jar	7 KB

How to add to project

Apache Maven

<!-- https://jarcasting.com/artifacts/com.vodori/chronology/ -->
<dependency>
    <groupId>com.vodori</groupId>
    <artifactId>chronology</artifactId>
    <version>0.1.1</version>
</dependency>

Gradle Groovy

// https://jarcasting.com/artifacts/com.vodori/chronology/
implementation 'com.vodori:chronology:0.1.1'

Gradle Kotlin

// https://jarcasting.com/artifacts/com.vodori/chronology/
implementation ("com.vodori:chronology:0.1.1")

Apache Buildr

'com.vodori:chronology:jar:0.1.1'

Apache Ivy

<dependency org="com.vodori" name="chronology" rev="0.1.1">
  <artifact name="chronology" type="jar" />
</dependency>

Groovy Grape

@Grapes(
@Grab(group='com.vodori', module='chronology', version='0.1.1')
)

Scala SBT

libraryDependencies += "com.vodori" % "chronology" % "0.1.1"

Leiningen

[com.vodori/chronology "0.1.1"]

Dependencies

compile (5)

Group / Artifact	Type	Version
org.clojure : clojure	jar	1.10.0
org.clojure : core.async	jar	0.4.490
com.cronutils : cron-utils	jar	7.0.5
jarohen » chime	jar	0.2.2
clj-time » clj-time	jar	0.14.4

Project Modules

There are no modules declared in this project.

Chronology

A library for scheduling tasks using core.async according to cron expressions. Chronology also provides forward and backward infinite sequences of DateTime objects for a given cron expression. Cron expressions are in the style of quartz.

Install

[com.vodori/chronology "0.1.0"]

Usage

---

Cron sequences:

Chronology lets you convert a cron expression into an infinite sequence of DateTime instances. Internally it just does this and then converts the sequence into a channel by using chime.

(require '[chronology.utils :refer :all])

(def tick (f/parse "2000-01-01T00:00:00.000Z"))

(def cron "0 */5 * * * ?")

(defn datetime->iso [dt] 
  (f/unparse (f/formatter :date-time) dt))
  
(def human-readable (explain-cron cron))
;=> "every 5 minutes"

(->> (forward-cron-sequence tick cron)
     (map datetime->iso)
     (take 5))
     
;=> ("2000-01-01T00:05:00.000Z" 
;    "2000-01-01T00:10:00.000Z" 
;    "2000-01-01T00:15:00.000Z" 
;    "2000-01-01T00:20:00.000Z" 
;    "2000-01-01T00:25:00.000Z")


(->> (backward-cron-sequence tick cron)
     (map datetime->iso)
     (take 5))
     
;=> ("1999-12-31T23:55:00.000Z" 
;    "1999-12-31T23:50:00.000Z" 
;    "1999-12-31T23:45:00.000Z" 
;    "1999-12-31T23:40:00.000Z" 
;    "1999-12-31T23:35:00.000Z")

---

Scheduling tasks:

Tasks in chronology are just functions that receive a single ctx map. The context is whatever context you provide when scheduling the function merged with information maintained by the library itself (the task group, task key, and the tick DateTime).

Your function is always executed on a dedicated thread and the result is put onto a result channel which is returned when you schedule the task. The result channel contains records of type Success or type Failure depending on if the function threw. Each result also contains the full context and a duration of how long the task took to complete (or throw). The result channel is unbuffered so you must take the result in order for the task to keep executing.

(require '[chronology.core :refer :all])

(def key     (make-key "group1" "task1"))
(def cron    "* * * * * ?")
(def context {:customerId 1})

(defn task [{:keys [group key tick customerId] :as ctx}]
  (send-emails-for customerId))

(def result-chan (schedule-cron key cron task context))

(async/go-loop []
  (when-some [result (async/<! result-chan)]
    (if (failure? result) 
       (.printStackTrace (:error result))
       (println (:result result))) 
    (recur)))

---

License

This project is licensed under MIT license.

Vodori

We create content management products suitable for regulated domains.

Versions

Version
0.1.1 Mar 27, 2019
0.1.0 Sep 9, 2018