Interface: AddAndWaitOptions
Defined in: glide-mq/src/types.ts:214
Extends
Properties
attempts?
optional attempts?: number;Defined in: glide-mq/src/types.ts:196
Inherited from
backoff?
optional backoff?: object;Defined in: glide-mq/src/types.ts:197
delay
delay: number;jitter?
optional jitter?: number;type
type: string;Inherited from
cost?
optional cost?: number;Defined in: glide-mq/src/types.ts:195
Job cost in tokens for token bucket rate limiting. Default: 1.
Inherited from
deduplication?
optional deduplication?: object;Defined in: glide-mq/src/types.ts:201
id
id: string;mode?
optional mode?: "simple" | "throttle" | "debounce";ttl?
optional ttl?: number;Inherited from
delay?
optional delay?: number;Defined in: glide-mq/src/types.ts:174
Inherited from
jobId?
optional jobId?: string;Defined in: glide-mq/src/types.ts:173
Custom job ID. Max 256 characters, must not contain control characters, curly braces, or colons. If a job with this ID already exists, Queue.add returns null and FlowProducer.add throws. When combined with deduplication, the dedup check runs first.
Inherited from
lifo?
optional lifo?: boolean;Defined in: glide-mq/src/types.ts:177
Process jobs in LIFO (last-in-first-out) order. Cannot be combined with ordering keys.
Inherited from
ordering?
optional ordering?: object;Defined in: glide-mq/src/types.ts:185
Per-key ordering and group concurrency control. Jobs sharing the same key are constrained to run at most concurrency instances simultaneously across all workers. When concurrency is 1 (default), jobs run sequentially in enqueue order. When concurrency > 1, up to N jobs per key run in parallel.
concurrency?
optional concurrency?: number;Max concurrent jobs for this ordering key. Default: 1 (sequential).
key
key: string;rateLimit?
optional rateLimit?: RateLimitConfig;Per-group rate limit: max N jobs per time window for this ordering key.
tokenBucket?
optional tokenBucket?: TokenBucketConfig;Cost-based token bucket: capacity + refill rate. Jobs consume tokens based on cost.
Inherited from
parent?
optional parent?: object;Defined in: glide-mq/src/types.ts:202
id
id: string;queue
queue: string;Inherited from
parents?
optional parents?: object[];Defined in: glide-mq/src/types.ts:209
Multiple parent dependencies for DAG flows. When set, this job waits for ALL parents to complete before it can run. Each parent tracks this job as a child in its deps SET. Mutually exclusive with parent - use one or the other.
id
id: string;queue
queue: string;Inherited from
priority?
optional priority?: number;Defined in: glide-mq/src/types.ts:175
Inherited from
removeOnComplete?
optional removeOnComplete?:
| number
| boolean
| {
age: number;
count: number;
};Defined in: glide-mq/src/types.ts:199
Inherited from
removeOnFail?
optional removeOnFail?:
| number
| boolean
| {
age: number;
count: number;
};Defined in: glide-mq/src/types.ts:200
Inherited from
timeout?
optional timeout?: number;Defined in: glide-mq/src/types.ts:198
Inherited from
ttl?
optional ttl?: number;Defined in: glide-mq/src/types.ts:211
Time-to-live in milliseconds. Jobs not processed within this window are failed as 'expired'.
Inherited from
waitTimeout?
optional waitTimeout?: number;Defined in: glide-mq/src/types.ts:216
Maximum time to wait for a completed/failed event before rejecting. Default: 30000ms.