| Safe Haskell | None |
|---|---|
| Language | GHC2024 |
Arbiter.Core.Sql.Workers
Description
Internal to the arbiter packages. Not covered by the PVP.
Workers SQL templates.
Synopsis
- workerColumnList :: Text
- upsertWorkerSQL :: SchemaName -> UUID -> Text -> Maybe Text -> Maybe Int32 -> Double -> Maybe Value -> Query Bool
- heartbeatWorkerSQL :: SchemaName -> UUID -> Query Bool
- setWorkerPausedSQL :: SchemaName -> Bool -> UUID -> Query Int64
- markWorkerShuttingDownSQL :: SchemaName -> UUID -> Query ()
- deleteWorkerSQL :: SchemaName -> UUID -> Query ()
- workerRegisteredSQL :: SchemaName -> UUID -> Query Bool
- listWorkersSQL :: SchemaName -> Maybe Text -> Maybe Double -> Query (WorkerRow, Text)
- deleteStaleWorkersSQL :: SchemaName -> Query ()
- workerStaleSQL :: Text
Documentation
workerColumnList :: TextSource #
The worker read columns, in codec order, with health derived from the heartbeat.
upsertWorkerSQL :: SchemaName -> UUID -> Text -> Maybe Text -> Maybe Int32 -> Double -> Maybe Value -> Query BoolSource #
Upsert a worker registration and return its effective paused state (worker or queue).
heartbeatWorkerSQL :: SchemaName -> UUID -> Query BoolSource #
Bump last_heartbeat and return the worker's effective paused state (worker or queue).
setWorkerPausedSQL :: SchemaName -> Bool -> UUID -> Query Int64Source #
Set paused for a worker and NOTIFY its effective pause state.
markWorkerShuttingDownSQL :: SchemaName -> UUID -> Query ()Source #
Mark a worker as gracefully draining.
deleteWorkerSQL :: SchemaName -> UUID -> Query ()Source #
Remove a worker row during clean shutdown.
workerRegisteredSQL :: SchemaName -> UUID -> Query BoolSource #
Whether the worker registry holds this identity.
listWorkersSQL :: SchemaName -> Maybe Text -> Maybe Double -> Query (WorkerRow, Text)Source #
List workers, with NULL parameters short-circuiting the corresponding filter.
deleteStaleWorkersSQL :: SchemaName -> Query ()Source #
Delete workers whose last heartbeat is older than their own stale_threshold_secs.
workerStaleSQL :: TextSource #
Whether a worker's last heartbeat is older than its own stale_threshold_secs.