quasar_jobs/worker

Typed durable worker definitions.

Types

CompletionMode

pub type CompletionMode {
  RuntimeManaged
  WorkerManaged
}

Constructors

```
RuntimeManaged
```
```
WorkerManaged
```

Context

</>

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

Constructors

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

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.

with_managed_completion

</>

pub fn with_managed_completion(
  worker: Worker(input),
) -> Worker(input)

Marks a worker as responsible for atomically persisting its own completion.

Store adapters use this for transactional workers. The callback must not return Ok until its business effect and fenced completion are committed.