arbiter-core-0.1.0.0

arbiter-core

Safe Haskell	None
Language	GHC2024

Arbiter.Core.Job.Archive

Description

Completed-job archive types. Arbiter archives an acked job when archiveFor is positive and removes it after the retention period. Re-enqueue entries with reEnqueueFromArchive.

Synopsis

data ArchiveJob payload = ArchiveJob {
- archivePrimaryKey :: Int64
- completedAt :: UTCTime
- jobSnapshot :: JobSnapshot payload
- archivedResult :: Maybe Value
}

Documentation

Source #data ArchiveJob payload

A completed job in the archive.

Constructors

ArchiveJob
Fields archivePrimaryKey :: Int64 Archive table primary key. The snapshot keeps its own job id. completedAt :: UTCTime When the job was acked and archived jobSnapshot :: JobSnapshot payload Full job state at time of completion (payload, attempts, etc.) archivedResult :: Maybe Value Handler result stored for a completed root job (one with no parent).

Instances

Instances details

Eq payload => Eq (ArchiveJob payload) Source #

Instance details

Defined in Arbiter.Core.Job.Archive

Methods

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

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

Generic (ArchiveJob payload) Source #

Instance details

Defined in Arbiter.Core.Job.Archive

Associated Types

type Rep (ArchiveJob payload)

Instance details

Defined in Arbiter.Core.Job.Archive

type Rep (ArchiveJob payload) = D1 ('MetaData "ArchiveJob" "Arbiter.Core.Job.Archive" "arbiter-core-0.1.0.0-inplace" 'False) (C1 ('MetaCons "ArchiveJob" 'PrefixI 'True) ((S1 ('MetaSel ('Just "archivePrimaryKey") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int64) :*: S1 ('MetaSel ('Just "completedAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UTCTime)) :*: (S1 ('MetaSel ('Just "jobSnapshot") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (JobSnapshot payload)) :*: S1 ('MetaSel ('Just "archivedResult") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe Value)))))

Methods

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

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

Show payload => Show (ArchiveJob payload) Source #

Instance details

Defined in Arbiter.Core.Job.Archive

Methods

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

#show :: ArchiveJob payload -> String

#showList :: [ArchiveJob payload] -> ShowS

type Rep (ArchiveJob payload) Source #

Instance details

Defined in Arbiter.Core.Job.Archive

type Rep (ArchiveJob payload) = D1 ('MetaData "ArchiveJob" "Arbiter.Core.Job.Archive" "arbiter-core-0.1.0.0-inplace" 'False) (C1 ('MetaCons "ArchiveJob" 'PrefixI 'True) ((S1 ('MetaSel ('Just "archivePrimaryKey") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int64) :*: S1 ('MetaSel ('Just "completedAt") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UTCTime)) :*: (S1 ('MetaSel ('Just "jobSnapshot") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (JobSnapshot payload)) :*: S1 ('MetaSel ('Just "archivedResult") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe Value)))))