Control.Concurrent.Capataz.Internal.Worker

This module contains all logic related to error handling when spawning threads to execute Worker sub-routines

Documentation

workerMain :: ParentSupervisorEnv -> WorkerOptions -> WorkerId -> RestartCount -> IO Worker

Decorates the given IO () sub-routine with failure handling

forkWorker :: ParentSupervisorEnv -> WorkerOptions -> Maybe (WorkerId, RestartCount) -> IO Worker

Internal function that forks a worker thread on the Capataz thread; note this is different from the public forkWorker function which sends a message to the capataz loop