CLI Reference
Overview
verify
Statically validate a pipeline. Checks schema, topology invariants (no cycles, no orphans, source has no in-edges, sink has no out-edges, at least one source→sink path), CEL predicate compilation, Starlark script compilation, job configuration, and semantic lint.
| Flag | Default | Description |
|---|---|---|
--config | (required) | Pipeline YAML file |
--strict | false | Upgrade warnings to errors |
test
Run contract test suites against the real in-process engine. Test files declare injection points, expected captures, and DLQ assertions.
run
Execute a pipeline. Job pipelines (with run.mode: job) run under the
jobs manager with scheduling and catchup. --config-dir starts a
multi-pipeline daemon with the admin surface.
| Flag | Default | Description |
|---|---|---|
--config | — | Single pipeline file |
--config-dir | — | Directory of pipeline files (daemon mode) |
--runtime | ./eventboat.yaml | Runtime config (telemetry endpoints) |
--data-dir | data | SQLite storage directory |
--ephemeral | false | In-memory store (nothing persists) |
trigger
Manually fire a job pipeline once, optionally with parameters (backfill).
explain
Deterministic walkthrough of a pipeline. With --message, performs real
CEL evaluation and Starlark dry-run on the sample. With --topology,
renders the DAG (mermaid + ASCII).
replay
Re-inject dead letters (--dlq), a spool window (--spool --from N),
or one job run’s dead letters (--job <run-id>) into a live pipeline.
repl
Evaluate CEL predicates and Starlark scripts against one sample message without running a pipeline.
mcp
Start the MCP server for AI agents.
| Flag | Description |
|---|---|
--stdio | Speak MCP over stdin/stdout (for agent hosts) |
--http | Serve MCP over HTTP with Admin REST + SSE + UI |
--config-dir | Deploy pipelines at startup |