Move data at Rust speed.
Govern it in flight.

# orders → warehouse: CDC, masked, upserted
version: 1
name: orders_to_warehouse

pipeline:
  source:
    type: postgres-cdc
    config:
      connection_url: ${env:PG_URL}
      slot_name: orders_slot
      publication_name: orders_pub
  transforms:
    - type: cdc_unwrap
      config: {}
  masking:
    key: ${env:MASKING_KEY}
    rules:
      - name: emails
        match: { fields: [email] }
        action: { type: hash }
  sink:
    type: bigquery
    config:
      project_id: my-project
      dataset_id: analytics
      table_id: orders
      write_mode: upsert
      key: [id]
      delete_marker: { field: __op, values: [d] }
      auth:
        type: service_account_key
        config: { json: "${env:GCP_KEY_JSON}" }
  state:
    type: file
    config: { path: ./.faucet-state }

// same engine, embedded in your service
use faucet_stream::Pipeline;
use faucet_stream::source::postgres_cdc::PostgresCdcSource;
use faucet_stream::sink::bigquery::BigQuerySink;

let source = PostgresCdcSource::new(cdc_cfg).await?;
let sink   = BigQuerySink::new(bq_cfg).await?;

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