| Safe Haskell | None |
|---|---|
| Language | GHC2024 |
Arbiter.Worker.Heartbeat
Description
Internal to the arbiter packages. Not covered by the PVP.
The pool's heartbeat guard, run in IO. These are the IO wrappers over Arbiter.Worker.Heartbeat.Guard.
Synopsis
- type PoolGuard payload = HeartbeatGuard IO (JobRead payload)
- newHeartbeatGuard :: JobOperation m payload => WorkerConfig m payload -> m (PoolGuard payload)
- runHeartbeatGuard :: MonadIO m => PoolGuard payload -> m Void
- recheckJob :: MonadIO m => PoolGuard payload -> JobId -> m ()
Documentation
type PoolGuard payload = HeartbeatGuard IO (JobRead payload)Source #
The pool's guard, run in IO and keyed on the job.
newHeartbeatGuard :: JobOperation m payload => WorkerConfig m payload -> m (PoolGuard payload)Source #
Build the pool's guard from its config. IO wrapper over newHeartbeatGuard.
runHeartbeatGuard :: MonadIO m => PoolGuard payload -> m VoidSource #
Run the guard loop. IO wrapper over runHeartbeatGuard.