CorrID returns job id or an empty string when not set.

Enqueue sends an existing job to the worker queue.

InitDummyWorker initializes the dummy (testing) worker queue with an in-memory worker.

InitMemoryWorker initializes the default worker queue with an in-memory worker.

JobID returns job id or an empty string when not set.

New creates new job and sets identity and correlation id from passed context.

NewAndEnqueue sends an existing job to the fast worker queue.

NewAndEnqueueSlow sends an existing job to the slow worker queue.

RegisterHandlers registers a job handler for a specific job type.

WithCorrID returns context copy with trace id value.

WithJobID returns context copy with trace id value.

Worker returns the default worker queue.

FastQueue is a queue for jobs that should be processed quickly.

SlowQueue is a queue for jobs that can be processed slowly.

IgnoredJobHandler is a handler that does nothing.

Dummy worker is useful for unit tests - it immediately processes the job, there is no queue or background goroutines.

Job represents a single job.

Stats provides monitoring statistics.

JobEnqueuer sends Job messages into worker queue.

JobWorker receives and handles Job messages.

JobHandler is a function that processes a job.

JobQueue represents a queue where job is enqueued.

JobType represents a "channel" for jobs.