MCP Radar
Serveur MCP

estuary-flow

io.usefulapi/estuary-flow
Cloud et infrastructure Public et accessible MCP 2026-07-28

Ce que fait ce MCP

Inspects and manages Estuary Flow data pipelines, catalog entities, connectors, drafts, publications, statistics, and task logs.

Capacités

Outils

15 outils
estuary_create_draft
Create draft
WRITE: create a new empty draft workspace (a staging area for catalog changes; does not affect live pipelines). Estuary control-plane: POST /drafts. Returns the created row.
Destructif
Schéma d’entrée 
{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'properties': {'detail': {'type': 'string', 'description': "Optional human-readable note describing the draft's purpose."}}}
estuary_get_catalog_spec
Get catalog spec
Get one live catalog entity by its exact catalog_name, including the full serialized `spec` and compiled `built_spec`. Estuary control-plane view live_specs_ext. PostgREST: GET /live_specs_ext?catalog_name=eq.<name>&limit=1.
Lecture seule
Schéma d’entrée 
{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'required': ['catalog_name'], 'properties': {'catalog_name': {'type': 'string', 'description': 'The exact catalog name (e.g. acmeCo/inventory/products).'}}}
estuary_get_catalog_stats
Get catalog stats
Get usage/throughput stats for one catalog entity — bytes & docs read/written (both directions), usage_seconds, warnings/errors/failures, and txn_count — per time grain. Optionally bound by a timestamp range. Estuary control-plane view catalog_stats. PostgREST: GET /catalog_stats.
Lecture seule
Schéma d’entrée 
{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'required': ['catalog_name'], 'properties': {'grain': {'enum': ['monthly', 'daily', 'hourly'], 'type': 'string', 'description': 'Time grain of each stats row (default daily).'}, 'limit': {'type': 'integer', 'maximum': 9007199254740991, 'minimum': -9007199254740991, 'description': 'Max rows to return (PostgREST limit).'}, 'ts_end': {'type': 'string', 'description': 'Filter: stats at/before this ISO 8601 timestamp (ts lte).'}, 'ts_start': {'type': 'string', 'description': 'Filter: stats at/after this ISO 8601 timestamp (ts gte).'}, 'catalog_name': {'type': 'string', 'description': 'The exact catalog name to report stats for.'}}}
estuary_get_tenant
Get tenant
Get the user's tenant(s) — quotas (tasks/collections), billing tiers, recurring charge, trial start, and payment provider. Estuary control-plane table tenants. PostgREST: GET /tenants.
Lecture seule
Schéma d’entrée 
{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'properties': {'limit': {'type': 'integer', 'maximum': 9007199254740991, 'minimum': -9007199254740991, 'description': 'Max rows to return (PostgREST limit).'}}}
estuary_list_catalog
List catalog entities
List live catalog entities (captures, collections, materializations, tests) the user can read, with connector + last-publication metadata. Optionally filter by a catalog-name prefix and spec_type. Estuary control-plane view live_specs_ext. PostgREST: GET /live_specs_ext.
Lecture seule
Schéma d’entrée 
{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'properties': {'limit': {'type': 'integer', 'maximum': 9007199254740991, 'minimum': -9007199254740991, 'description': 'Max rows to return (PostgREST limit).'}, 'offset': {'type': 'integer', 'maximum': 9007199254740991, 'minimum': -9007199254740991, 'description': 'Row offset for paging (PostgREST offset).'}, 'spec_type': {'enum': ['capture', 'collection', 'materialization', 'test'], 'type': 'string', 'description': 'Filter by entity type.'}, 'name_prefix': {'type': 'string', 'description': 'Filter to catalog names starting with this prefix (PostgREST like.<prefix>* wildcard).'}}}
estuary_list_connectors
List connectors
List the connector catalog — available capture/materialization Docker connectors, with titles, descriptions, and logos. Optionally filter to recommended connectors. Estuary control-plane table connectors. PostgREST: GET /connectors.
Lecture seule
Schéma d’entrée 
{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'properties': {'limit': {'type': 'integer', 'maximum': 9007199254740991, 'minimum': -9007199254740991, 'description': 'Max rows to return (PostgREST limit).'}, 'recommended': {'type': 'boolean', 'description': 'Filter to recommended (true) / non-recommended (false) connectors.'}}}
estuary_list_connector_versions
List connector versions
List available versions (image tags) of connectors, with protocol and documentation URL. Optionally filter by connector_id. Estuary control-plane table connector_tags. PostgREST: GET /connector_tags.
Lecture seule
Schéma d’entrée 
{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'properties': {'limit': {'type': 'integer', 'maximum': 9007199254740991, 'minimum': -9007199254740991, 'description': 'Max rows to return (PostgREST limit).'}, 'connector_id': {'type': 'string', 'description': 'Filter by connector id (from estuary_list_connectors).'}}}
estuary_list_discovers
List discovers
List connector discovery jobs (auto-detecting bindings/resources for a capture). Estuary control-plane table discovers. PostgREST: GET /discovers.
Lecture seule
Schéma d’entrée 
{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'properties': {'limit': {'type': 'integer', 'maximum': 9007199254740991, 'minimum': -9007199254740991, 'description': 'Max rows to return (PostgREST limit).'}}}
estuary_list_drafts
List drafts
List the user's draft workspaces (staging areas for catalog edits before publishing). Estuary control-plane table drafts. PostgREST: GET /drafts.
Lecture seule
Schéma d’entrée 
{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'properties': {'limit': {'type': 'integer', 'maximum': 9007199254740991, 'minimum': -9007199254740991, 'description': 'Max rows to return (PostgREST limit).'}}}
estuary_list_draft_specs
List draft specs
List the staged spec entries within a draft (each an insert/replace of a catalog entity pending publication). Estuary control-plane table draft_specs. PostgREST: GET /draft_specs.
Lecture seule
Schéma d’entrée 
{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'required': ['draft_id'], 'properties': {'limit': {'type': 'integer', 'maximum': 9007199254740991, 'minimum': -9007199254740991, 'description': 'Max rows to return (PostgREST limit).'}, 'draft_id': {'type': 'string', 'description': 'The draft id to list staged specs for.'}}}
estuary_list_publications
List publications
List publication history/status — each publish attempt of a draft; job_status carries the queued/success/failed outcome. Estuary control-plane table publications. PostgREST: GET /publications.
Lecture seule
Schéma d’entrée 
{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'properties': {'limit': {'type': 'integer', 'maximum': 9007199254740991, 'minimum': -9007199254740991, 'description': 'Max rows to return (PostgREST limit).'}}}
estuary_list_roles
List roles
List the roles/capabilities the current credential is granted — which catalog prefixes it can read/write/admin. Read-only RPC. Estuary control-plane: POST /rpc/auth_roles.
Lecture seule
Schéma d’entrée 
{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'properties': {'min_capability': {'enum': ['x_00', 'read', 'write', 'admin'], 'type': 'string', 'description': 'Only return grants at/above this capability (default x_00 = all).'}}}
estuary_publish_draft
Publish draft
WRITE (DESTRUCTIVE when dry_run=false): publish a draft. dry_run=true (default) only VALIDATES the draft without changing anything. dry_run=false APPLIES the draft to the LIVE catalog — this can create, modify, or DELETE running data pipelines and their data. Set dry_run=false only when you intend to change live infrastructure. Estuary control-plane: POST /publications. Returns the publication row.
Destructif
Schéma d’entrée 
{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'required': ['draft_id'], 'properties': {'detail': {'type': 'string', 'description': 'Optional human-readable note for this publication.'}, 'dry_run': {'type': 'boolean', 'description': 'If true (DEFAULT), only validate without applying. Set false to APPLY to the live catalog.'}, 'draft_id': {'type': 'string', 'description': 'The draft id to publish.'}}}
estuary_upsert_draft_spec
Upsert draft spec
WRITE: stage (insert or replace) a catalog spec inside a draft. Edits only the draft — live pipelines are unaffected until the draft is published. Estuary control-plane: POST /draft_specs (upsert on draft_id,catalog_name). Returns the staged row.
Destructif
Schéma d’entrée 
{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'required': ['draft_id', 'catalog_name', 'spec_type', 'spec'], 'properties': {'spec': {'type': 'object', 'description': 'The catalog spec JSON object (passed through verbatim).', 'propertyNames': {'type': 'string'}, 'additionalProperties': {}}, 'draft_id': {'type': 'string', 'description': 'The draft id to stage the spec into.'}, 'spec_type': {'enum': ['capture', 'collection', 'materialization', 'test'], 'type': 'string', 'description': 'The entity type of the staged spec.'}, 'catalog_name': {'type': 'string', 'description': 'The catalog name of the entity being staged (e.g. acmeCo/inventory/products).'}}}
estuary_view_task_logs
View task logs
Fetch the log lines for a job by its logs_token (a UUID found on a publication, discover, or connector-tag record). Optionally page from a last-seen timestamp. Read-only RPC. Estuary control-plane: POST /rpc/view_logs.
Lecture seule
Schéma d’entrée 
{'type': 'object', '$schema': 'https://json-schema.org/draft/2020-12/schema', 'required': ['bearer_token'], 'properties': {'bearer_token': {'type': 'string', 'description': 'The logs_token (UUID) from a publications/discovers/connector_tags row.'}, 'last_logged_at': {'type': 'string', 'description': 'ISO 8601 timestamp — return log lines after this point (2-arg view_logs overload).'}}}
Historique

Modifications récentes des outils

Modifié
estuary_publish_draft
2 October 2026 02:40
Modifié
estuary_upsert_draft_spec
2 October 2026 02:40
Modifié
estuary_create_draft
2 October 2026 02:40
Modifié
estuary_view_task_logs
2 October 2026 02:40
Modifié
estuary_get_tenant
2 October 2026 02:40
Modifié
estuary_list_roles
2 October 2026 02:40
Modifié
estuary_list_discovers
2 October 2026 02:40
Modifié
estuary_list_publications
2 October 2026 02:40
Modifié
estuary_list_draft_specs
2 October 2026 02:40
Modifié
estuary_list_drafts
2 October 2026 02:40
Modifié
estuary_list_connector_versions
2 October 2026 02:40
Modifié
estuary_list_connectors
2 October 2026 02:40
Modifié
estuary_get_catalog_stats
2 October 2026 02:40
Modifié
estuary_get_catalog_spec
2 October 2026 02:40
Modifié
estuary_list_catalog
2 October 2026 02:40
Ajouté
estuary_publish_draft
30 September 2026 02:40
Ajouté
estuary_upsert_draft_spec
30 September 2026 02:40
Ajouté
estuary_create_draft
30 September 2026 02:40
Ajouté
estuary_view_task_logs
30 September 2026 02:40
Ajouté
estuary_get_tenant
30 September 2026 02:40
Ajouté
estuary_list_roles
30 September 2026 02:40
Ajouté
estuary_list_discovers
30 September 2026 02:40
Ajouté
estuary_list_publications
30 September 2026 02:40
Ajouté
estuary_list_draft_specs
30 September 2026 02:40
Ajouté
estuary_list_drafts
30 September 2026 02:40
Ajouté
estuary_list_connector_versions
30 September 2026 02:40
Ajouté
estuary_list_connectors
30 September 2026 02:40
Ajouté
estuary_get_catalog_stats
30 September 2026 02:40
Ajouté
estuary_get_catalog_spec
30 September 2026 02:40
Ajouté
estuary_list_catalog
30 September 2026 02:40
Découvrir

Serveurs MCP similaires

BorealHost

ai.borealhost/mcp

Provides web hosting and infrastructure management, including site deployment, DNS, domains, containers, compute, backups, cachin…

Algenta MCP Server

io.github.thyn-ai/algenta

Provides governed data onboarding, connector browsing, deterministic simulations, agent-run lifecycles, capability routing, deplo…

mcphost

dev.mcphost/mcphost

Hosts MCP tools over HTTP and provides tenant billing, tool publishing and discovery, agent directories, inter-agent messaging, g…

Contabo (VPS) MCP Server

ai.com.mcp/contabo

Provides tools to provision and manage Contabo VPS, bare metal, object storage, networks, DNS, snapshots, images, users, roles, a…

shiply

now.shiply/shiply

Publishes and manages web applications with SQL databases, serverless functions, domains, email tests, client intake, contracts, …

OSIR Domain Registrar

com.osir/domain-registrar

Manages domain registration and transfers, DNS, VPS instances, SSH keys, hosted email, account funding, and related infrastructur…

Fine Structure

ai.finestructure/fine-structure

Builds and hosts full-stack applications from prompts and supports agent communication through WhatsApp and email.

mcp

cloud.redu/mcp

Provisions and manages cloud instances, networks, storage, databases, backups, VPNs, application deployments, and autocoding-agen…