Reqon

Declarative DSL for fetch, map, validate pipelines. File extension: .vague

Quick Start

mission SyncData {
  source API { auth: bearer, base: "https://api.example.com" }
  store items: memory("items")

  action Fetch {
    get "/items" { paginate: page(page, 100), until: length(response) == 0 }
    store response -> items { key: .id }
  }

  run Fetch
}

Core Constructs

• mission - Pipeline container (sources, stores, schemas, actions, schedule)
• source - API: auth (bearer/basic/api_key/oauth2/none), base, headers, rateLimit
• source Name from "./spec.yaml" - OAS-based source
• store - Storage: memory("name"), file("path"), sql("table"), postgrest("table")
• action - Pipeline step: fetch, map, validate, store, wait
• run [A, B] then C - Parallel then sequential execution
• match response { Schema -> ..., _ -> skip } - Pattern matching
• for item in store where .active { ... } - Iteration with filter
• call Source.operationId - OAS-based fetch by operationId
• wait { timeout, path, eventFilter, storage } - Webhook/callback waiting
• schedule: every N hours or schedule: cron "..." or schedule: at "datetime"

Flow Control

continue, skip, abort "msg", retry {...}, queue dlq, jump Action then retry

Reference Files

• references/syntax.md - Full DSL syntax
• references/examples.md - Complete examples