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

data ArchiveJob payloadSource #

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 completion. archivedResult :: Maybe Value Handler result stored for a completed root job (one with no parent).

Instances

Instances details

FromJSON payload => FromJSON (ArchiveJob payload) Source #

Instance details

Defined in Arbiter.Core.Job.Archive

Methods

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

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

omittedField :: Maybe (ArchiveJob payload)#

ToJSON payload => ToJSON (ArchiveJob payload) Source #

Instance details

Defined in Arbiter.Core.Job.Archive

Methods

toJSON :: ArchiveJob payload -> Value#

toEncoding :: ArchiveJob payload -> Encoding#

toJSONList :: [ArchiveJob payload] -> Value#

toEncodingList :: [ArchiveJob payload] -> Encoding#

omitField :: ArchiveJob payload -> Bool#

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)))))