Exemples
Applications d'exemple prêtes à cloner, exécuter, adapter. Chaque exemple ship avec les commandes exactes et la sortie attendue.
La forme de chaque exemple
Un seul pulse.yaml déclare le pipeline. Zéro code de plomberie, zéro état caché, zéro build.
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/hookPar catégorie
Streaming
Fenêtres, timers par clé, jointures stream-stream, union multi-topic.
llm · mcpStages IA
Triage LLM, sortie structurée, appels d'outils MCP, plafonds de coût.
multi-agentMulti-agent
Chaîne, fan-out, fan-in, corrélation — composés par topics.
sources · sinksIntégrations
HTTP, SSE, webhooks, Kafka, S3, Postgres, MQTT.
productionOpérations
Secrets, observabilité, replay, crash-resume.
industryDe bout en bout
Triage fraude, garde-inventaire, surveillance vitale/conditionnelle/flotte.
Exemples en avant
Triage fraude carte (Banque)
Les quatre moteurs : agrégation streaming, filtre rule-based, narratif LLM, blocage MCP.
Surveillance vitale (Santé)
Fenêtres par patient, escalade sur tendance, humain confirme.
Surveillance conditionnelle (Industrie)
Baselines par actif, détection de dérive, work order MCP.
Surveillance de flotte (IoT)
Timers par device, agrégats fenêtrés, edge-first.