WorkPool.Priority — API

WorkPool.Prioritytypesrc/internal/workPool.ts:161

Priority

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)

models

Source src/internal/workPool.ts:1611 lines

export type Priority = "high" | "normal" | "low";

Referenced by 5 symbols

WorkPool.EffectContext WorkPool.QueueBatch WorkPool.QueueEncodedEntry WorkPool.QueueEntry WorkPool.QueueEvent

PriorityTagConfig<F, Success> & { readonly node: NodeKey<HSelf> }, ): NodeBoundTag<Self, PriorityInstanceSpec<F>, HSelf>; function build< F extends Schema.Struct.Fields, Success extends Schema.Top = typeof Schema.Void, >( key: string, config: PriorityTagConfig<F, Success>, ): HyperlinkTag<Self, PriorityInstanceSpec<F>>; function build<F extends Schema.Struct.Fields, Success extends Schema.Top>( key: string, config: PriorityTagConfig<F, Success>, ): HyperlinkTag<Self, PriorityInstanceSpec<F>> { const laneConfig: PriorityTagLaneConfig = { laneCount: config.laneCount, namedLanes: config.namedLanes ?? {}, }; const wire = { success: config.success, error: config.error }; const spec = assertPriorityInstanceSpec<F>( prioritySpec(config.payload, laneConfig, wire), prioritySpec(config.payload, laneConfig), wire, ); const base = config.node === undefined ? Hyperlink.Tag<Self>()(key, spec, { description: config.description, kind: priorityKind }) : Hyperlink.Tag<Self>()(key, spec, { description: config.description, kind: priorityKind, node: config.node, }); const ready = Hyperlink.withReadiness(base, (svc) => Effect.map(svc.status.get, (status) => ({ ready: status.phase === "running", ...(status.phase === "running" ? {} : { detail: `phase: ${status.phase}` }), })), ); return stampQueueWireSchemas(ready, { success: config.success, error: config.error, }); } return build; };