ecto_job v2.1.0 API Reference


EctoJob Configuration struct

Mixin for defining an Ecto schema for a Job Queue table in the database

Defines a migration to create a table to be used as a job queue. This migration can be run multiple times with different values to create multiple queues

Defines migrations for installing shared functions

GenStage producer responsible for reserving available jobs from a job queue, and passing them on to the consumer module

Internal state of the Producer GenStage

Job Queue supervisor that can be started with client applications

Worker module responsible for executing a single Job

GenStage ConsumerSupervisor that will spawn EctoJob.Worker tasks for jobs