Documentation / @super-line/plugin-queue / QueueDefinition

Interface: QueueDefinition<I, R>

Defined in: packages/plugin-queue/src/index.ts:135

Type Parameters

I

I extends Schema = Schema

R

R extends Schema = Schema

Properties

concurrency

concurrency: number

Defined in: packages/plugin-queue/src/index.ts:139

---

input

input: I

Defined in: packages/plugin-queue/src/index.ts:136

---

leaseMs?

optional leaseMs?: number

Defined in: packages/plugin-queue/src/index.ts:140

---

result

result: R

Defined in: packages/plugin-queue/src/index.ts:137

---

retention?

optional retention?: Partial<RetentionConfig>

Defined in: packages/plugin-queue/src/index.ts:143

---

retry?

optional retry?: object

Defined in: packages/plugin-queue/src/index.ts:142

backoff?

optional backoff?: BackoffConfig

maxAttempts?

optional maxAttempts?: number

---

timeoutMs?

optional timeoutMs?: number

Defined in: packages/plugin-queue/src/index.ts:141

---

worker?

optional worker?: (input, ctx) => InferIn<R> | Promise<InferIn<R>>

Defined in: packages/plugin-queue/src/index.ts:138

Parameters

input

InferOut<I>

ctx

WorkerContext

Returns

InferIn<R> | Promise<InferIn<R>>