Skip to content
Corex

JobService

Corex\Jobs\JobService · class · Core layer

Idempotent enqueue, status, cancellation, and retry orchestration.

Public API

Section titled “Public API”

__construct(JobRepository $jobs, JobDispatcher $dispatcher)

Section titled “__construct(JobRepository $jobs, JobDispatcher $dispatcher)”

enqueue(string $kind, int $actorId, int $total, string $inputHash, DateTimeImmutable $now): BoundedJob

Section titled “enqueue(string $kind, int $actorId, int $total, string $inputHash, DateTimeImmutable $now): BoundedJob”

find(int $id): ?BoundedJob

Section titled “find(int $id): ?BoundedJob”

cancel(int $id, DateTimeImmutable $now): ?BoundedJob

Section titled “cancel(int $id, DateTimeImmutable $now): ?BoundedJob”

retry(int $id, DateTimeImmutable $now): ?BoundedJob

Section titled “retry(int $id, DateTimeImmutable $now): ?BoundedJob”