Package com.kingsrook.qqq.backend.core.jobs.runtime

package com.kingsrook.qqq.backend.core.jobs.runtime
  • Classes
    Class
    Description
    DurableJobsRuntime
    The per-pod durable jobs runtime: worker threads that claim and run chunks, a heartbeat per running chunk (every ttl/3), the lease reaper (every pod, every reaperIntervalSeconds), stall detection, and graceful drain.
    JobClaimer
    Picks the next chunk for this pod and claims it (spec section 2.8).
    JobCompletionEffectsRunner
    Asks the registered JobCompletionEffects providers for a completing job's job-level effects and writes them to the outbox.
    JobFinalizer
    Moves a job to the status its chunks imply, once nothing is running: CANCELLING -> CANCELLED, PAUSING -> PAUSED, and RUNNING (or QUEUED) with no work left -> COMPLETED, COMPLETED_WITH_ERRORS, FAILED or NEEDS_REVIEW.
    JobSignals
    Everything a job tells the outside world: realtime events (job.status on every change, job.progress throttled to one per second per job - counts only, never row values), alerts (jobs.job-failed, jobs.job-stalled) and the owner's completion notification.