Estuary Flow MCP by usefulapi

{
  "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."
    }
  }
}

{
  "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)."
    }
  }
}

{
  "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."
    }
  }
}

{
  "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)."
    }
  }
}

{
  "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)."
    }
  }
}

{
  "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)."
    }
  }
}

{
  "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."
    }
  }
}

{
  "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)."
    }
  }
}

{
  "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."
    }
  }
}

{
  "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)."
    }
  }
}

{
  "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)."
    }
  }
}

{
  "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)."
    }
  }
}

{
  "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."
    }
  }
}

{
  "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)."
    }
  }
}

{
  "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)."
    }
  }
}