Class DeliveryExecution<TPayload>

Runs one handler for one delivery: context, lease heartbeats, lease horizon, processing cap, outcome, settle.

Type Parameters

TPayload extends WorkJson = WorkJson

Index

Constructors

Accessors

DeliveryID ExecutionKey StopReason

Methods

Constructors

constructor

new DeliveryExecution<TPayload extends WorkJson = WorkJson>(
options: DeliveryExecutionOptions<TPayload>,
): DeliveryExecution<TPayload>
Type Parameters
- TPayload extends WorkJson = WorkJson
Parameters
- options: DeliveryExecutionOptions<TPayload>
Returns DeliveryExecution<TPayload>
- Defined in packages/WorkQueue/core/src/runtime/DeliveryExecution.ts:72

Accessors

DeliveryID

get DeliveryID(): string
Returns string
- Defined in packages/WorkQueue/core/src/runtime/DeliveryExecution.ts:80

ExecutionKey

get ExecutionKey(): string
Returns string
- Defined in packages/WorkQueue/core/src/runtime/DeliveryExecution.ts:84

StopReason

get StopReason(): WorkAbortReason | null
The first reason the handler was asked to stop, or null.

Returns WorkAbortReason | null
- Defined in packages/WorkQueue/core/src/runtime/DeliveryExecution.ts:89

Methods

Abort

Abort(reason: WorkAbortReason): void
Requests the handler to stop. The signal keeps its first reason; a shutdown is remembered regardless.
Parameters
- reason: WorkAbortReason
Returns void
- Defined in packages/WorkQueue/core/src/runtime/DeliveryExecution.ts:94

Run

Run(): Promise<SettleResult>
Returns Promise<SettleResult>
- Defined in packages/WorkQueue/core/src/runtime/DeliveryExecution.ts:106