Move data at Rust speed.
Govern it in flight.

# orders → warehouse, incremental + upsert
version: 1
name: orders_to_warehouse

pipeline:
  source:
    type: postgres
    config:
      connection_url: ${env:PG_URL}
      query: SELECT * FROM orders
      replication:
        method: incremental
        cursor_field: updated_at
  transforms:
    - sql: SELECT *, amount_cents/100.0 AS amount FROM batch
    - redact: { fields: [email] }
  sink:
    type: bigquery
    config:
      dataset: analytics
      table: orders
      write_mode: upsert
      primary_key: [id]
  state:
    type: file
    path: .faucet/state

// same engine, embedded in your service
use faucet_stream::prelude::*;

let source = PostgresSource::new(pg_cfg)?;
let sink   = BigQuerySink::new(bq_cfg)?;

Pipeline::new(&source, &sink)
    .with_state_store(state)   // durable bookmarks
    .run()
    .await?;

// → streams pages, checkpoints after each
//   confirmed write. Bounded memory throughout.

# run it over the HTTP control plane (faucet serve)
curl -X POST http://localhost:8080/v1/runs \
  -H 'authorization: Bearer $FAUCET_TOKEN' \
  -H 'content-type: application/json' \
  --data-binary @pipeline.json

# → 202 Accepted
#   { "id": "run_01H...", "status": "queued" }

# then poll / stream:
curl http://localhost:8080/v1/runs/run_01H...
curl -N .../v1/runs/run_01H.../logs   # SSE