arbiter-core-0.1.0.0
arbiter-core
Safe HaskellNone
LanguageGHC2024

Arbiter.Core.Job.DLQ

Description

Dead-letter queue types. Arbiter moves jobs here after a permanent failure or the last retry. Recover a job with retryFromDLQ or delete it with deleteDLQJob.

Synopsis

Documentation

data DLQJob payloadSource #

A job in the dead-letter queue.

Constructors

DLQJob 

Fields

  • dlqPrimaryKey :: Int64

    DLQ table primary key. The snapshot keeps its own job id.

  • failedAt :: UTCTime

    When the job was moved to the DLQ.

  • jobSnapshot :: JobSnapshot payload

    Full job state at time of failure. Its lastError holds the final error. For DLQ rollup finalizers, parentState in the snapshot contains the accumulated child results captured before the descendants moved to the DLQ.

Instances

Instances details
FromJSON payload => FromJSON (DLQJob payload) Source # 
Instance details

Defined in Arbiter.Core.Job.DLQ

Methods

parseJSON :: Value -> Parser (DLQJob payload)#

parseJSONList :: Value -> Parser [DLQJob payload]#

omittedField :: Maybe (DLQJob payload)#

ToJSON payload => ToJSON (DLQJob payload) Source # 
Instance details

Defined in Arbiter.Core.Job.DLQ

Methods

toJSON :: DLQJob payload -> Value#

toEncoding :: DLQJob payload -> Encoding#

toJSONList :: [DLQJob payload] -> Value#

toEncodingList :: [DLQJob payload] -> Encoding#

omitField :: DLQJob payload -> Bool#

Eq payload => Eq (DLQJob payload) Source # 
Instance details

Defined in Arbiter.Core.Job.DLQ

Methods

(==) :: DLQJob payload -> DLQJob payload -> Bool#

(/=) :: DLQJob payload -> DLQJob payload -> Bool#

Generic (DLQJob payload) Source # 
Instance details

Defined in Arbiter.Core.Job.DLQ

Associated Types

type Rep (DLQJob payload) 
Instance details

Defined in Arbiter.Core.Job.DLQ

type Rep (DLQJob payload) = D1 ('MetaData "DLQJob" "Arbiter.Core.Job.DLQ" "arbiter-core-0.1.0.0-inplace" 'False) (C1 ('MetaCons "DLQJob" 'PrefixI 'True) (S1 ('MetaSel ('Just "dlqPrimaryKey") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int64) :*: (S1 ('MetaSel ('Just "failedAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UTCTime) :*: S1 ('MetaSel ('Just "jobSnapshot") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (JobSnapshot payload)))))

Methods

from :: DLQJob payload -> Rep (DLQJob payload) x#

to :: Rep (DLQJob payload) x -> DLQJob payload#

Show payload => Show (DLQJob payload) Source # 
Instance details

Defined in Arbiter.Core.Job.DLQ

Methods

showsPrec :: Int -> DLQJob payload -> ShowS#

show :: DLQJob payload -> String#

showList :: [DLQJob payload] -> ShowS#

type Rep (DLQJob payload) Source # 
Instance details

Defined in Arbiter.Core.Job.DLQ

type Rep (DLQJob payload) = D1 ('MetaData "DLQJob" "Arbiter.Core.Job.DLQ" "arbiter-core-0.1.0.0-inplace" 'False) (C1 ('MetaCons "DLQJob" 'PrefixI 'True) (S1 ('MetaSel ('Just "dlqPrimaryKey") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int64) :*: (S1 ('MetaSel ('Just "failedAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UTCTime) :*: S1 ('MetaSel ('Just "jobSnapshot") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (JobSnapshot payload)))))

type JobSnapshot payload = JobRead payloadSource #

Full job state when the job left the main queue.