Faktory.Worker

High-level interface for a Worker

Runs forever, FETCH-ing Jobs from the given Queue and handing each to your processing function.

Documentation

data WorkerHalt

If processing functions throw this, runWorker will exit

Constructors

WorkerHalt

Instances

Eq WorkerHalt

Defined in Faktory.Worker

Methods

(==) :: WorkerHalt -> WorkerHalt -> Bool

(/=) :: WorkerHalt -> WorkerHalt -> Bool

Show WorkerHalt

Defined in Faktory.Worker

Methods

showsPrec :: Int -> WorkerHalt -> ShowS

show :: WorkerHalt -> String

showList :: [WorkerHalt] -> ShowS

Exception WorkerHalt

Defined in Faktory.Worker

Methods

toException :: WorkerHalt -> SomeException

fromException :: SomeException -> Maybe WorkerHalt

displayException :: WorkerHalt -> String

runWorker :: (HasCallStack, FromJSON args) => Settings -> WorkerSettings -> (Job args -> IO ()) -> IO ()

runWorkerEnv :: FromJSON args => (Job args -> IO ()) -> IO ()

jobArg :: Job arg -> arg