Skip to main content

WorkerRuntimeDeps

@forge/monorepo

@forge/monorepo / backend/src / WorkerRuntimeDeps

Type Alias: WorkerRuntimeDeps

WorkerRuntimeDeps = object

Defined in: backend/src/worker/main.ts:71

Properties​

config?​

readonly optional config?: Partial<WorkerConfig>

Defined in: backend/src/worker/main.ts:76

consumer​

readonly consumer: JobConsumer

Defined in: backend/src/worker/main.ts:73

dispatcher​

readonly dispatcher: JobDispatcher

Defined in: backend/src/worker/main.ts:75

Reaped runs are re-enqueued rather than executed inline, so recovery goes through the same path.

log?​

readonly optional log?: (message, detail?) => void

Defined in: backend/src/worker/main.ts:77

Parameters​

message​

string

detail?​

Readonly<Record<string, unknown>>

Returns​

void

onError?​

readonly optional onError?: (job, error) => void

Defined in: backend/src/worker/main.ts:80

Parameters​

job​

RunJob

error​

unknown

Returns​

void

onOutcome?​

readonly optional onOutcome?: (job, result) => void

Defined in: backend/src/worker/main.ts:79

Observability hook; also what the tests assert on.

Parameters​

job​

RunJob

result​

ProcessResult

Returns​

void

setInterval?​

readonly optional setInterval?: (fn, ms) => object

Defined in: backend/src/worker/main.ts:82

Injectable so a test can drive the reaper without waiting on wall clock.

Parameters​

fn​

() => void

ms​

number

Returns​

object

clear​

readonly clear: () => void

Returns​

void

worker​

readonly worker: DurableWorker

Defined in: backend/src/worker/main.ts:72