Warp
Entry point for the :kuilt-warp module — distributed task scheduling over a connected mesh.
Warp spreads a pile of work across whoever is connected, with no central boss and no peer doing the same job twice. See module.md for the full design walk and docs/warp-foundation.md for the architectural detail.
The implementation types are TaskRing, WorkQueue, and WarpNode. See those types for per-component detail and module.md for the design walk across both execution paths.
Draft builder
Use shuttle to begin building a Draft — an immutable, inspectable dataflow graph that records a distributed computation without running it:
val draft: Draft<ByteArray> = Warp.shuttle(OpId("docs"))
.map(OpId("score"))
.filter(OpId("above-threshold"))
.embroider(OpId("rank"))The returned Draft stores only symbolic OpIds. Nothing executes until E-5 provides a runtime.
Functions
Creates a new Draft whose first stage is a DraftStage.Source identified by sourceOpId.