| Safe Haskell | None |
|---|---|
| Language | GHC2024 |
Arbiter.Worker.WorkerState
Synopsis
- data WorkerState
- newWorkerState :: IO (TVar WorkerState)
- signalShutdown :: TVar WorkerState -> IO ()
Documentation
data WorkerState Source #
State for worker pool coordination.
Controls whether workers claim new jobs:
Running: Normal operation, claim jobs continuouslyPaused: Stop claiming new jobs, finish in-flight jobs, wait for resumeShuttingDown: Stop claiming new jobs, finish in-flight jobs, then exit
Constructors
| Running | Normal operation |
| Paused | Paused (stop claiming, finish in-flight, wait for resume) |
| ShuttingDown | Graceful shutdown in progress (drain and exit) |
Instances
| Show WorkerState Source # | |
Defined in Arbiter.Worker.WorkerState Methods showsPrec :: Int -> WorkerState -> ShowS # show :: WorkerState -> String # showList :: [WorkerState] -> ShowS # | |
| Eq WorkerState Source # | |
Defined in Arbiter.Worker.WorkerState | |
newWorkerState :: IO (TVar WorkerState) Source #
Create a new worker state initialized to Running.
signalShutdown :: TVar WorkerState -> IO () Source #
Signal graceful shutdown on a worker state.
Workers will stop claiming new jobs, finish in-flight work, then exit.