Interface JobDefinition<I, P, O>

Versioned contract shared by producers and workers.

interface JobDefinition<
    I extends JobSchema,
    P extends JobSchema,
    O extends JobSchema,
> {
    input: I;
    name: string;
    output: O;
    policy: Readonly<RunPolicy>;
    progress: P;
    version: number;
    handle(handler: JobHandler<JobDefinition<I, P, O>>): JobBinding;
    thread(moduleUrl: URL): JobBinding;
}

Type Parameters

I extends JobSchema
P extends JobSchema
O extends JobSchema

Index

Properties

input name output policy progress version

Methods

Properties

`Readonly`input

input: I

`Readonly`name

name: string

`Readonly`output

output: O

`Readonly`policy

policy: Readonly<RunPolicy>

`Readonly`progress

progress: P

`Readonly`version

version: number

Methods

handle

handle(handler: JobHandler<JobDefinition<I, P, O>>): JobBinding
Bind a handler imported from a separate module.
Parameters
- handler: JobHandler<JobDefinition<I, P, O>>
Returns JobBinding
- Defined in libs/scheduler/src/contracts.ts:74

thread

thread(moduleUrl: URL): JobBinding
Bind a module whose default export is a compatible handler.
Parameters
- moduleUrl: URL
Returns JobBinding
- Defined in libs/scheduler/src/contracts.ts:76