Back
    Developers

    Examples

    Working sample apps you can clone, run, and adapt. Every example ships with the exact commands and the expected output.

    The shape of every example

    A single pulse.yaml declares the pipeline. No glue code, no hidden state, no build step.

    yaml
    1# pulse.yaml — a runnable example
2app: hello-pulse
3source:
4  webhook:
5    path: /orders
6
7stages:
8  - id: enrich
9    type: streaming
10    window: { size: 1m, by: customer_id }
11
12  - id: screen
13    type: rule-based
14    when: "amount > 10000"
15    tag: high_value
16
17  - id: summarize
18    type: llm
19    prompt: "Explain this order in one sentence."
20
21  - id: notify
22    type: mcp
23    tool: slack.post
24    channel: "#orders"
25
26sink:
27  webhook:
28    url: https://ops.example.com/hook

    By category

    streaming

    Streaming

    Windows, keyed timers, stream-stream joins, multi-topic union.

    llm · mcp

    AI stages

    LLM triage, structured output, MCP tool calls, cost caps.

    multi-agent

    Multi-agent

    Chain, fan-out, fan-in, correlate — composed through topics.

    sources · sinks

    Integrations

    HTTP, SSE, webhooks, Kafka, S3, Postgres, MQTT.

    production

    Operations

    Secrets, observability, replay, crash-resume.

    industry

    End-to-end

    Fraud triage, inventory guard, vitals watch, condition watch, fleet watch.

    Featured examples

    Card-fraud triage (Banking)

    All four engines: streaming aggregation, rule-based screen, LLM narrative, MCP block.

    Vitals watch (Healthcare)

    Keyed windows on patient telemetry, escalate on trend, human confirms.

    Condition watch (Manufacturing)

    Per-asset baselines, drift detection, MCP work order.

    Fleet watch (IoT)

    Per-device timers, windowed aggregates, edge-first.

    Full example catalog