| Safe Haskell | None |
|---|---|
| Language | GHC2024 |
Arbiter.Core.Job.Types.Internal
Synopsis
- data JobRecord payload key q insertedAt adm = Job {
- primaryKey :: key
- payload :: payload
- queueName :: q
- groupKey :: Maybe Text
- insertedAt :: insertedAt
- updatedAt :: Maybe UTCTime
- attempts :: Int32
- lastError :: Maybe Text
- priority :: Int32
- lastAttemptedAt :: Maybe UTCTime
- notVisibleUntil :: Maybe UTCTime
- dedupKey :: Maybe DedupKey
- maxAttempts :: Maybe Int32
- parentId :: Maybe Int64
- parentState :: Maybe Value
- traceContext :: Maybe TraceContext
- suspended :: Bool
- claimedBy :: Maybe UUID
- claimSeq :: Int64
- archiveFor :: Maybe Int32
- payloadKeys :: adm
- primaryKey :: JobRecord payload key q insertedAt adm -> key
- payload :: JobRecord payload key q insertedAt adm -> payload
- queueName :: JobRecord payload key q insertedAt adm -> q
- groupKey :: JobRecord payload key q insertedAt adm -> Maybe Text
- insertedAt :: JobRecord payload key q insertedAt adm -> insertedAt
- updatedAt :: JobRecord payload Int64 q insertedAt adm -> Maybe UTCTime
- attempts :: JobRecord payload Int64 q insertedAt adm -> Int32
- lastError :: JobRecord payload Int64 q insertedAt adm -> Maybe Text
- priority :: JobRecord payload key q insertedAt adm -> Int32
- lastAttemptedAt :: JobRecord payload Int64 q insertedAt adm -> Maybe UTCTime
- notVisibleUntil :: JobRecord payload key q insertedAt adm -> Maybe UTCTime
- dedupKey :: JobRecord payload key q insertedAt adm -> Maybe DedupKey
- maxAttempts :: JobRecord payload key q insertedAt adm -> Maybe Int32
- parentId :: JobRecord payload Int64 q insertedAt adm -> Maybe Int64
- parentState :: JobRecord payload Int64 q insertedAt adm -> Maybe Value
- traceContext :: JobRecord payload key q insertedAt adm -> Maybe TraceContext
- suspended :: JobRecord payload Int64 q insertedAt adm -> Bool
- claimedBy :: JobRecord payload Int64 q insertedAt adm -> Maybe UUID
- claimSeq :: JobRecord payload Int64 q insertedAt adm -> Int64
- archiveFor :: JobRecord payload key q insertedAt adm -> Maybe Int32
- payloadKeys :: JobRecord payload key q insertedAt adm -> adm
Documentation
Source #data JobRecord payload key q insertedAt adm
Internal representation shared by writable and stored jobs.
Constructors
| Job | |
Fields
| |
Instances
| FromJSON payload => FromJSON (JobRead payload) Source # | Decode the complete persisted representation of a job. |
Defined in Arbiter.Core.Job.Types | |
| (Eq key, Eq payload, Eq q, Eq insertedAt, Eq adm) => Eq (JobRecord payload key q insertedAt adm) Source # | |
| (Show key, Show payload, Show q, Show insertedAt, Show adm) => Show (JobRecord payload key q insertedAt adm) Source # | |
Source #primaryKey :: JobRecord payload key q insertedAt adm -> key
Database-assigned identifier for a stored job.
Source #payload :: JobRecord payload key q insertedAt adm -> payload
User-defined payload stored as JSONB.
Source #groupKey :: JobRecord payload key q insertedAt adm -> Maybe Text
Serial-processing group, or Nothing for an ungrouped job.
Source #insertedAt :: JobRecord payload key q insertedAt adm -> insertedAt
Time at which the job was inserted.
Source #updatedAt :: JobRecord payload Int64 q insertedAt adm -> Maybe UTCTime
Time at which the job was last updated.
Source #attempts :: JobRecord payload Int64 q insertedAt adm -> Int32
Number of attempts made so far.
Source #lastError :: JobRecord payload Int64 q insertedAt adm -> Maybe Text
Error message from the last failed attempt.
Source #priority :: JobRecord payload key q insertedAt adm -> Int32
Claim priority. Lower numbers have higher priority.
Source #lastAttemptedAt :: JobRecord payload Int64 q insertedAt adm -> Maybe UTCTime
Time at which a worker last claimed the job.
Source #notVisibleUntil :: JobRecord payload key q insertedAt adm -> Maybe UTCTime
Earliest time at which the job can be claimed.
Source #dedupKey :: JobRecord payload key q insertedAt adm -> Maybe DedupKey
Deduplication strategy and key.
Source #maxAttempts :: JobRecord payload key q insertedAt adm -> Maybe Int32
Attempt limit before the job moves to the DLQ.
Source #parentId :: JobRecord payload Int64 q insertedAt adm -> Maybe Int64
Identifier of this job's parent in a job tree.
Source #parentState :: JobRecord payload Int64 q insertedAt adm -> Maybe Value
Snapshot of accumulated child results for a rollup finalizer.
Source #traceContext :: JobRecord payload key q insertedAt adm -> Maybe TraceContext
W3C trace context captured at enqueue.
Source #suspended :: JobRecord payload Int64 q insertedAt adm -> Bool
Whether the job is currently ineligible for claiming.
Source #claimedBy :: JobRecord payload Int64 q insertedAt adm -> Maybe UUID
Worker pool that most recently claimed the job.
Source #claimSeq :: JobRecord payload Int64 q insertedAt adm -> Int64
Monotonically increasing claim identifier.
Source #archiveFor :: JobRecord payload key q insertedAt adm -> Maybe Int32
Completed-job archive retention in seconds.
Source #payloadKeys :: JobRecord payload key q insertedAt adm -> adm
The labels and keys stamped from the payload at enqueue.