List catalog entities (captures, materializations, collections). Wraps flowctl catalog list.

Control-plane status for one task. Wraps flowctl catalog status <task> --output json. Status types include OK, WARNING, TASK_DISABLED, and error states.

Throughput and document counts for a task. Wraps flowctl raw stats --task <task> --since <since>.

Recent task logs, optionally filtered by level. Wraps flowctl logs --task <task> --since <since>.

End-to-end health check: combines status, throughput, and error-level logs in one call.

Discover available bindings for a source connector. Writes a temporary flow.yaml and runs flowctl discover --source flow.yaml, returning the discovered spec without publishing.

Publish a capture. Writes the spec to a temporary flow.yaml and runs flowctl catalog publish --source flow.yaml --auto-approve.

Publish a materialization. Writes the spec to a temporary flow.yaml and runs flowctl catalog publish --source flow.yaml --auto-approve.

Pull a task's live spec for local inspection. Wraps flowctl catalog pull-specs --name <task>.

Enable or disable a task by toggling shards.disable in its spec, then republishing. Disabling stops processing; re-enabling resumes from the last checkpoint with no data loss. After enabling, status reads WARNING for 30-120s while shards start, then OK.

Force a connector restart: disable the task, then re-enable it. Resumes from the last checkpoint, so no data is lost. Use to clear transient errors or load updated config.

Read documents from a collection to verify data is landing. Wraps flowctl collections read --collection <name>, which is non-blocking: it outputs everything currently available and exits.

Generate synthetic records for demo pipelines. Returns a sample plus the full payload size.