Safe Haskell	None
Language	GHC2024

Arbiter.Core.Queues

Description

Types and DDL for the arbiter_queues table. One row per queue, scoped to the schema. Holds operator-facing per-queue state (pause flag, metadata).

Synopsis

data QueueRow = QueueRow {
- queueName :: Text
- paused :: Bool
- pausedAt :: Maybe UTCTime
- metadata :: Maybe Value
- createdAt :: UTCTime
- updatedAt :: UTCTime
}
arbiterQueuesTable :: SchemaName -> Text
arbiterQueuesTableName :: Text
createQueuesTableSQL :: SchemaName -> Text

Documentation

Source #data QueueRow

A row of the arbiter_queues pause/resume table.

Constructors

QueueRow
Fields queueName :: Text paused :: Bool pausedAt :: Maybe UTCTime metadata :: Maybe Value createdAt :: UTCTime updatedAt :: UTCTime

Instances

Instances details

FromJSON QueueRow Source #

Instance details

Defined in Arbiter.Core.Queues

Methods

#parseJSON :: Value -> Parser QueueRow

#parseJSONList :: Value -> Parser [QueueRow]

#omittedField :: Maybe QueueRow

ToJSON QueueRow Source #

Instance details

Defined in Arbiter.Core.Queues

Methods

#toJSON :: QueueRow -> Value

#toEncoding :: QueueRow -> Encoding

#toJSONList :: [QueueRow] -> Value

#toEncodingList :: [QueueRow] -> Encoding

#omitField :: QueueRow -> Bool

Eq QueueRow Source #

Instance details

Defined in Arbiter.Core.Queues

Methods

#(==) :: QueueRow -> QueueRow -> Bool

#(/=) :: QueueRow -> QueueRow -> Bool

Generic QueueRow Source #

Instance details

Defined in Arbiter.Core.Queues

Associated Types

type Rep QueueRow

Instance details

Defined in Arbiter.Core.Queues

type Rep QueueRow = D1 ('MetaData "QueueRow" "Arbiter.Core.Queues" "arbiter-core-0.1.0.0-inplace" 'False) (C1 ('MetaCons "QueueRow" 'PrefixI 'True) ((S1 ('MetaSel ('Just "queueName") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text) :*: (S1 ('MetaSel ('Just "paused") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Bool) :*: S1 ('MetaSel ('Just "pausedAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe UTCTime)))) :*: (S1 ('MetaSel ('Just "metadata") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe Value)) :*: (S1 ('MetaSel ('Just "createdAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UTCTime) :*: S1 ('MetaSel ('Just "updatedAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UTCTime)))))

Methods

#from :: QueueRow -> Rep QueueRow x

#to :: Rep QueueRow x -> QueueRow

Show QueueRow Source #

Instance details

Defined in Arbiter.Core.Queues

Methods

#showsPrec :: Int -> QueueRow -> ShowS

#show :: QueueRow -> String

#showList :: [QueueRow] -> ShowS

type Rep QueueRow Source #

Instance details

Defined in Arbiter.Core.Queues

type Rep QueueRow = D1 ('MetaData "QueueRow" "Arbiter.Core.Queues" "arbiter-core-0.1.0.0-inplace" 'False) (C1 ('MetaCons "QueueRow" 'PrefixI 'True) ((S1 ('MetaSel ('Just "queueName") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text) :*: (S1 ('MetaSel ('Just "paused") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Bool) :*: S1 ('MetaSel ('Just "pausedAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe UTCTime)))) :*: (S1 ('MetaSel ('Just "metadata") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe Value)) :*: (S1 ('MetaSel ('Just "createdAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UTCTime) :*: S1 ('MetaSel ('Just "updatedAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UTCTime)))))

Source #arbiterQueuesTable :: SchemaName -> Text

Qualified table name for the arbiter_queues table.

Source #arbiterQueuesTableName :: Text

Bare name of the queues table, for catalog lookups by relname.

Source #createQueuesTableSQL :: SchemaName -> Text

DDL for the arbiter_queues table.