EffectContext<T, EEnqueue, R>Context passed to the effect callback during item processing.
Provides guarded enqueue operations for spawning derived/follow-up work.
Attempting to enqueue the same item (by reference or by key) logs a warning
and silently drops the item to prevent infinite processing loops.
For intentional re-processing, fail the worker effect (auto re-enqueue applies up to
WorkPoolConfigBase.attempts) or re-inject via queue.enqueue off the events stream.
export interface interface EffectContext<T, EEnqueue = never, R = never>Context passed to the effect callback during item processing.
Provides guarded enqueue operations for spawning derived/follow-up work.
Attempting to enqueue the same item (by reference or by key) logs a warning
and silently drops the item to prevent infinite processing loops.
For intentional re-processing, fail the worker effect (auto re-enqueue applies up to
WorkPoolConfigBase.attempts
) or re-inject via queue.enqueue off the events stream.
EffectContext<function (type parameter) T in EffectContext<T, EEnqueue = never, R = never>T, function (type parameter) EEnqueue in EffectContext<T, EEnqueue = never, R = never>EEnqueue = never, function (type parameter) R in EffectContext<T, EEnqueue = never, R = never>R = never> {
/** Enqueue derived items at normal priority. Self-enqueue is warned and dropped. */
readonly EffectContext<T, EEnqueue = never, R = never>.add: QueueEnqueue<T, EEnqueue, R>Enqueue derived items at normal priority. Self-enqueue is warned and dropped.
add: interface QueueEnqueue<T, E = never, R = never>Enqueue a single item or a readonly batch of items.
QueueEnqueue<function (type parameter) T in EffectContext<T, EEnqueue = never, R = never>T, function (type parameter) EEnqueue in EffectContext<T, EEnqueue = never, R = never>EEnqueue, function (type parameter) R in EffectContext<T, EEnqueue = never, R = never>R>;
/** Enqueue derived items at high priority. Self-enqueue is warned and dropped. */
readonly EffectContext<T, EEnqueue = never, R = never>.prioritize: QueueEnqueue<T, EEnqueue, R>Enqueue derived items at high priority. Self-enqueue is warned and dropped.
prioritize: interface QueueEnqueue<T, E = never, R = never>Enqueue a single item or a readonly batch of items.
QueueEnqueue<function (type parameter) T in EffectContext<T, EEnqueue = never, R = never>T, function (type parameter) EEnqueue in EffectContext<T, EEnqueue = never, R = never>EEnqueue, function (type parameter) R in EffectContext<T, EEnqueue = never, R = never>R>;
/** Enqueue derived items at low priority. Self-enqueue is warned and dropped. */
readonly EffectContext<T, EEnqueue = never, R = never>.defer: QueueEnqueue<T, EEnqueue, R>Enqueue derived items at low priority. Self-enqueue is warned and dropped.
defer: interface QueueEnqueue<T, E = never, R = never>Enqueue a single item or a readonly batch of items.
QueueEnqueue<function (type parameter) T in EffectContext<T, EEnqueue = never, R = never>T, function (type parameter) EEnqueue in EffectContext<T, EEnqueue = never, R = never>EEnqueue, function (type parameter) R in EffectContext<T, EEnqueue = never, R = never>R>;
/** How many times this item has been processed (1 = first attempt). */
readonly EffectContext<T, EEnqueue = never, R = never>.attempts: numberHow many times this item has been processed (1 = first attempt).
attempts: number;
/** When the item first entered the queue as epoch millis (preserved across retries). */
readonly EffectContext<T, EEnqueue = never, R = never>.enqueuedAt: numberWhen the item first entered the queue as epoch millis (preserved across retries).
enqueuedAt: number;
/** The priority level this item was enqueued at. */
readonly EffectContext<T, EEnqueue = never, R = never>.priority: PriorityThe priority level this item was enqueued at.
priority: type Priority = "high" | "normal" | "low"Priority level for queue items.
"high" — processed first (use for urgent/time-sensitive items)"normal" — default priority"low" — processed last (use for background/deferrable work)
Priority;
}