arbiter-core-0.1.0.0
arbiter-core
Safe HaskellNone
LanguageGHC2024

Arbiter.Core.Sql.Queues

Description

Queues SQL templates.

Synopsis

Documentation

Source #queueColumnList :: Text

The arbiter_queues read columns, in codec order.

Source #ensureQueueSQL :: SchemaName -> Text -> Query ()

Insert an arbiter_queues row with defaults if one doesn't already exist.

Source #setQueuePausedSQL :: SchemaName -> Text -> Bool -> Query Int64

Upsert the queue's paused flag and fan one NOTIFY per worker in the queue. paused_at is set on first pause, cleared on resume, untouched on re-pause.

Source #getQueueSQL :: SchemaName -> Text -> Query QueueRow

Get the arbiter_queues row for a single queue.

Source #listQueuesSQL :: SchemaName -> Query QueueRow

List all arbiter_queues rows.