quasar_jobs/worker

Typed durable worker definitions.

Types

Context

pub type Context {
  Context(job_id: job.JobId, attempt: Int)
}

Constructors

Context(job_id: job.JobId, attempt: Int)

Definition

opaque </>

pub opaque type Definition

Worker

opaque </>

pub opaque type Worker(input)

Values

job

</>

pub fn job(worker: Worker(input), input: input) -> job.NewJob

Encodes typed input into a persistable job payload.

name

</>

pub fn name(worker: Worker(input)) -> String

new

</>

pub fn new(
  name name: String,
  encode encode: fn(input) -> String,
  decode decode: fn(String) -> Result(input, String),
  perform perform: fn(input, Context) -> Result(Nil, String),
) -> Worker(input)

Defines a typed durable worker without macros.