Estuary
Estuary builds Estuary Flow, a real-time data movement platform for streaming ETL and change data capture (CDC). Flow captures data from databases, warehouses, and SaaS systems into durable collections and materializes those collections back out to destinations. The Flow control plane exposes a Supabase/PostgREST-based REST API (Bearer refresh/access tokens) covering captures, materializations, collections, catalog drafts and publications, connectors, and tenants/billing, while the data plane is driven declaratively via the flowctl CLI and a Gitops model.
APIs
Estuary Captures API
Manage capture task specifications that continuously ingest data from source databases, warehouses, and SaaS systems into Flow collections, modeled as live_specs of catalogType ...
Estuary Materializations API
Manage materialization task specifications that push Flow collections out to destination systems (databases, warehouses, queues), modeled as live_specs of catalogType 'materiali...
Estuary Collections API
Read and manage collections - durable, schematized, real-time datasets of JSON documents keyed and stored in cloud object storage - exposed as live_specs of catalogType 'collect...
Estuary Catalog Drafts API
Create and edit drafts and their draft_specs - the staging area where proposed changes to captures, materializations, and collections are assembled and tested before being publi...
Estuary Publications API
Submit a draft for publication, validating and promoting its specs into the running data plane as live_specs; asynchronous jobs recorded in the publications table with a job sta...
Estuary Connectors API
Browse the catalog of available capture and materialization connectors and their tagged image versions (connectors, connector_tags), and run schema discovery against a configure...
Estuary Tenants & Billing API
Read tenant configuration, catalog usage statistics (catalog_stats - bytes and docs captured/materialized), and monthly billing estimates via the billing_report_202308 RPC used ...
Estuary Auth & Tokens API
Manage long-lived refresh_tokens and exchange a refresh token for a short-lived access token via the generate_access_token RPC; inspect roles and capability grants (user_grants,...