dag-worker / Exports

dag-worker

Table of contents

Classes

• DlqReinjectService
• WorkerLoopService

Interfaces

• IWorkerLoopDependencies
• IWorkerLoopPolicyOptions
• IDlqReinjectResult
• IWorkerLoopOptions
• IWorkerLoopResult

Variables

• DAG_WORKER_PACKAGE_NAME

Functions

• createWorkerLoopService

Variables

DAG_WORKER_PACKAGE_NAME

• Const DAG_WORKER_PACKAGE_NAME: "@robota-sdk/dag-worker"

Package name constant for the DAG worker package.

Defined in

index.ts:9

Functions

createWorkerLoopService

▸ createWorkerLoopService(dependencies, options): WorkerLoopService

Factory function that creates a fully configured WorkerLoopService, applying defaults for retry and dead-letter policies.

Parameters

Name	Type	Description
dependencies	IWorkerLoopDependencies	Port implementations (storage, queue, lease, executor, clock).
options	IWorkerLoopPolicyOptions	Policy options with optional retry/dead-letter flags (default: disabled).

Returns

WorkerLoopService

A configured WorkerLoopService instance.

Defined in

composition/create-worker-loop-service.ts:35