sisyphus.core — sisyphus 0.0.6

-main clj

(-main & args)

apoptosis clj

(apoptosis)

apoptosis-interval clj

apoptosis-timer clj

(apoptosis-timer delay)

connect! clj

(connect! config)

make-config clj

(make-config)

read-path clj

(read-path path)

reset-state! clj

(reset-state! state config)

run-state! clj

(run-state! state task)

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)

wait-interval clj