Class: FlowProducer
Defined in: glide-mq/src/flow-producer.ts:29
Constructors
Constructor
new FlowProducer(opts): FlowProducer;Defined in: glide-mq/src/flow-producer.ts:36
Parameters
| Parameter | Type |
|---|---|
opts | FlowProducerOptions |
Returns
FlowProducer
Methods
add()
add(flow): Promise<JobNode>;Defined in: glide-mq/src/flow-producer.ts:70
Add a flow (parent with children) atomically. Children can have their own children (recursive flows), which are flattened into multiple addFlow calls (one per level with children).
Parameters
| Parameter | Type |
|---|---|
flow | FlowJob |
Returns
Promise<JobNode>
addBulk()
addBulk(flows): Promise<JobNode[]>;Defined in: glide-mq/src/flow-producer.ts:88
Add multiple independent flows.
Parameters
| Parameter | Type |
|---|---|
flows | FlowJob[] |
Returns
Promise<JobNode[]>
addDAG()
addDAG(dag): Promise<Map<string, Job<any, any>>>;Defined in: glide-mq/src/flow-producer.ts:330
Add a DAG (Directed Acyclic Graph) flow where jobs can have multiple parents. Validates the graph for cycles, performs topological sort, and submits nodes bottom-up (leaves first). For nodes with multiple parents, registers each parent dependency.
Returns a map of node name to Job instance.
Parameters
| Parameter | Type |
|---|---|
dag | DAGFlow |
Returns
Promise<Map<string, Job<any, any>>>
close()
close(): Promise<void>;Defined in: glide-mq/src/flow-producer.ts:636
Close the FlowProducer and release the underlying client connection. Idempotent: safe to call multiple times.
Returns
Promise<void>