workQueueScheduledReadinessProjector()

Translate workQueue-local delayed eligibility records into D432 shared readiness schedules.

The projector is intentionally visibility-only: it never claims work, expires leases, cancels, completes, fails, mutates queue records, or starts timers. D433 consumption/materialization stays owned by later workQueue domain projectors.

Import

import { workQueueScheduledReadinessProjector } from "@graphrefly/ts/orchestration/work-queue";

Signature

function workQueueScheduledReadinessProjector(
  graph: Graph,
  opts: {
    readonly name?: string;
    readonly records: Node<WorkQueueRecord<T>>;
  },
): WorkQueueScheduledReadinessBundle

Parameters

Parameter	Type	Description
graph	Graph	Graph that owns the created nodes or projector.
opts	{ readonly name?: string; readonly records: Node<WorkQueueRecord<T>>; }	Options that configure the helper.

Returns

A node bundle that emits the projected records.

Example

import { workQueueScheduledReadinessProjector } from "@graphrefly/ts/orchestration/work-queue";

Source

packages/ts/src/orchestration/work-queue-scheduled-readiness.ts