Weave any API into a resilient orchestration
VaakLoom is an ultra-lightweight, reactive API orchestration engine and control plane. Run your DAG workflows, Hub control plane, Anvesh / Multi-DB telemetry, Snapline regression tests, and RBAC in a single resilient process without heavyweight runtimes.
import { workflow, map, when, fanOut, branch, mockApi } from "@vaakloom/engine";
export const orderFlow = workflow("orders-create")
.route("POST", "/orders")
.search("orderId", "tenantId")
.steps(
map("annotate", { mergeInput: true, set: { tenantId: "{{attrs.tenantId}}" } }),
when("{{input.amount}} > 1000", [
map("flagVIP", { mergeInput: true, set: { vip: true } })
]),
fanOut("weave", [
branch("inventory", mockApi("checkInv", { stock: true, ms: 12 })),
branch("fraudCheck", mockApi("evalScore", { score: 98, ms: 18 })),
], { id: "join", kind: "map", config: { set: { status: "approved" } } })
)
.build();Built for High-Throughput API Orchestration
Everything needed to compose, execute, observe, and test microservice workflows without operational sprawl.
Fluent DSL & DAG Engine
Compose declarative workflows with type safety. Branch, join, retry, delay, and template with clean, self-documenting syntax.
Nested Parallelism
Run asynchronous tasks inside parallel fanouts. Merge results dynamically with built-in concurrency controls and soft timeouts.
Zero-Leak Telemetry
Every step emits app and data telemetry. Persisted asynchronously to Anvesh distributed store (or Postgres/Mongo) and Prometheus without bloating request memory.
Visual Hub Control Plane
Interactive web UI for workflow authoring, live trace inspection, Prometheus metrics, RBAC management, and deploy bundle export.
Operational Adapters
8 operational adapters for REST, GraphQL, gRPC, WebSocket, SSE, SOAP, SQL, and NoSQL with production-tested handlers and unit tests.
Snapline Regression Tests
Built-in deterministic snapshot testing. Verify API orchestration outputs, latency contracts, and state diffs automatically in CI/CD.