Warp

object 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

Link copied to clipboard
fun shuttle(sourceOpId: OpId): Draft<ByteArray>

Creates a new Draft whose first stage is a DraftStage.Source identified by sourceOpId.