| Safe Haskell | None |
|---|---|
| Language | GHC2024 |
Arbiter.Core.Sql.Workers
Description
Workers SQL templates.
Synopsis
- workerColumnList :: Text
- workerHealthCaseSQL :: 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 ()
Documentation
Source #workerColumnList :: Text
The worker read columns, in codec order, with health derived from the heartbeat.
Source #workerHealthCaseSQL :: Text
Heartbeat-derived health, computed against the DB clock.
Source #upsertWorkerSQL :: SchemaName -> UUID -> Text -> Maybe Text -> Maybe Int32 -> Double -> Maybe Value -> Query Bool
Upsert a worker registration and return its effective paused state (worker OR queue).
Source #heartbeatWorkerSQL :: SchemaName -> UUID -> Query Bool
Bump last_heartbeat and return the worker's effective paused state (worker OR queue).
Source #setWorkerPausedSQL :: SchemaName -> Bool -> UUID -> Query Int64
Set paused for a worker and NOTIFY its effective pause state.
Source #markWorkerShuttingDownSQL :: SchemaName -> UUID -> Query ()
Mark a worker as gracefully draining.
Source #deleteWorkerSQL :: SchemaName -> UUID -> Query ()
Remove a worker row during clean shutdown.
Source #workerRegisteredSQL :: SchemaName -> UUID -> Query Bool
Whether the worker registry holds this identity.
Source #listWorkersSQL :: SchemaName -> Maybe Text -> Maybe Double -> Query (WorkerRow, Text)
List workers, with NULL parameters short-circuiting the corresponding filter.
Source #deleteStaleWorkersSQL :: SchemaName -> Query ()
Delete worker rows older than their own stale_threshold_secs.