Uses of Record Class
com.kingsrook.qqq.backend.core.jobs.model.JobLease
Packages that use JobLease
Package
Description
-
Uses of JobLease in com.kingsrook.qqq.backend.core.jobs.plans
Methods in com.kingsrook.qqq.backend.core.jobs.plans that return JobLeaseConstructors in com.kingsrook.qqq.backend.core.jobs.plans with parameters of type JobLeaseModifierConstructorDescriptionChunkContext(QRecord job, QRecord chunk, JobLease lease, DurableJobStore store, BooleanSupplier draining) Constructor -
Uses of JobLease in com.kingsrook.qqq.backend.core.jobs.progress
Constructors in com.kingsrook.qqq.backend.core.jobs.progress with parameters of type JobLeaseModifierConstructorDescriptionJobLogWriter(DurableJobStore store, Integer jobId, JobLease lease, Runnable lostLease) Construct a chunk writer, or a kernel writer with no lease. -
Uses of JobLease in com.kingsrook.qqq.backend.core.jobs.runtime
Methods in com.kingsrook.qqq.backend.core.jobs.runtime that return types with arguments of type JobLease -
Uses of JobLease in com.kingsrook.qqq.backend.core.jobs.store
Methods in com.kingsrook.qqq.backend.core.jobs.store that return types with arguments of type JobLeaseModifier and TypeMethodDescriptionDurableJobStore.claimChunk(QRecord chunk, String podId, int leaseTtlSeconds) Try to claim one specific claimable chunk.DurableJobStore.claimChunk(QRecord chunk, String podId, int leaseTtlSeconds, QBackendTransaction transaction) Claim one specific chunk, optionally in a (claiming) transaction.DurableJobStore.claimNextChunkSkipLocked(Integer jobId, String podId, int leaseTtlSeconds) Claim the job's next claimable chunk (lowest seq) that no other claimer has locked: FOR UPDATE SKIP LOCKED plus the fenced conditional update, in one transaction.Methods in com.kingsrook.qqq.backend.core.jobs.store with parameters of type JobLeaseModifier and TypeMethodDescriptionvoidDurableJobStore.checkpoint(JobLease lease, String checkpointJson, QBackendTransaction transaction) Save a mid-chunk checkpoint (e.g., process values after a step).voidDurableJobStore.completeChunk(JobLease lease, ChunkOutcome outcome, QBackendTransaction transaction) Mark a chunk DONE with its outcome.A chunk run threw.booleanRenew a lease.booleanDurableJobStore.heartbeat(JobLease lease, int leaseTtlSeconds, QBackendTransaction transaction) Renew under the progress transaction, holding the fence until its commit.booleanDurableJobStore.releaseChunk(JobLease lease, ChunkStatus to) Give a chunk back without counting the attempt (graceful drain, pause): RUNNING -> PENDING.