Documentation

A looper definition

Construct a NominalDiffTime from a number of seconds

Construct a NominalDiffTime from a number of minutes

Construct a NominalDiffTime from a number of hours

A structure to parse command-line flags for a looper into

An optparse applicative parser for LooperFlags

A structure to parse environment variables for a looper into

Get a LooperEnvironment from the environment

Get a LooperEnvironment from a pure environment

An envparse parser for a LooperEnvironment

A structure to configuration for a looper into

Settings that you might want to pass into a looper using mkLooperDef

Simply run loopers

runLoopers = runLoopersIgnoreOverrun looperDefFunc

see runLoopersIgnoreOverrun

Note that this function will loop forever, you need to wrap it using async yourself.

Run loopers with a custom runner, ignoring any overruns

runLoopersIgnoreOverrun = runLoopersRaw (pure ())

see runLoopersRaw

Note that this function will loop forever, you need to wrap it using async yourself.

Run loopers, with a custom runner and overrun handler

• The overrun handler is run when the looper function takes longer than its period. You can use this to log a warning, for example.
• The runner function is used to run the looper function You can use looperDefFunc :: LooperDef m -> m () to run a LooperDef, and you can wrap this function in some custom logic before you pass it into runLoopersRaw In this manner you can add logging or metrics, for example.

Note that this function will loop forever, you need to wrap it using async yourself.

Wait for a given NominalDiffTime

This takes care of the conversion to microseconds to pass to threadDelay for you.

waitNominalDiffTime ndt = liftIO $ threadDelay $ round (toRational ndt * (1000 * 1000))