sisyphus.core — sisyphus 0.0.5

-main clj

(-main & args)

apoptosis clj

(apoptosis)

apoptosis-interval clj

apoptosis-timer clj

(apoptosis-timer config)

connect! clj

(connect! config)

make-config clj

(make-config)

read-path clj

(read-path path)

signature clj

(signature)

sisyphus-handle-kafka clj

(sisyphus-handle-kafka state topic message)

sisyphus-handle-rabbit clj

(sisyphus-handle-rabbit state channel metadata payload)

Handle an incoming task message by performing the task it represents.

start! clj

(start! config)

Start the system by making all the required connections and returning the state map.

terminate? clj

(terminate? message id)

timer clj

(timer wait f)