Pipelinesdeclared, not coded.On any platform.

• linux · darwin · windows

  One binary, any OS.

  Static Go build for Linux, macOS, and Windows. No runtime, no Python venv, no Docker required — just a CLI you can drop in a CI image.

• json-schema · cannectors validate

  YAML you can read at 2 AM.

  Pipelines validate against a JSON Schema. cannectors validate gives line-accurate errors before anything runs. Reviewers see intent, not glue code.

• exponential · jittered · capped

  Retries that match reality.

  Backoff, max delay, retryable status codes, and Retry-After header support — declared once at the defaults level, inherited everywhere unless overridden.

• oauth2 · bearer · basic · api-key

  Auth out of the box.

  OAuth2 client_credentials, Bearer, Basic, and API key (header or query). Secrets stay in env vars — never in the YAML, never in logs.

• --dry-run · output preview

  Dry-run before you ship.

  cannectors run --dry-run executes everything up to the output stage and previews what would be sent. Confidence before a destination ever sees a byte.

• cursor · id · timestamp

  State for incremental loads.

  Cursors, last-seen IDs, and timestamps persist between runs. Restart-safe by default. Schedule on CRON and resume where you left off.

— Poll an API on a schedule, transform, ship a batch.

1name: sync-orders
2version: 1.0.0
3
4input:
5  type: httpPolling
6  schedule: "*/15 * * * *"
7  endpoint: https://source.example.com/api/orders
8  dataField: orders
9  authentication:
10    type: oauth2
11    credentials:
12      tokenUrl: ${OAUTH_TOKEN_URL}
13      clientId: ${OAUTH_CLIENT_ID}
14      clientSecret: ${OAUTH_CLIENT_SECRET}
15
16filters:
17  - type: mapping
18    mappings:
19      - source: order_id
20        target: id
21      - source: customer.email
22        target: email
23        transforms:
24          - op: lowercase
25
26  - type: condition
27    expression: "status == 'paid'"
28    else:
29      - type: drop
30
31output:
32  type: httpRequest
33  endpoint: https://warehouse.example.com/api/orders/import
34  method: POST
35  requestMode: batch
36  retry:
37    maxAttempts: 3
38    delayMs: 500
39    backoffMultiplier: 2
40    retryableStatusCodes: [429, 500, 502, 503, 504]