diff --git a/skills/hotdata/SKILL.md b/skills/hotdata/SKILL.md index 8b12b35..d805420 100644 --- a/skills/hotdata/SKILL.md +++ b/skills/hotdata/SKILL.md @@ -384,13 +384,13 @@ hotdata ingest create --source "prod postgres" --table orders --schema public \ # --stream shorthand for --type continuous (still needs --every). # Offered only where `hotdata ingest sources fields # ` says `continuous: yes` — today filesystem, -# derived, kafka, iggy; the server refuses it elsewhere. +# kafka, iggy; the server refuses it elsewhere. # Destination flags instead of --destination: # --database-id (required) --dest-schema (default public) --write-mode (default replace) # --dest-table for sources that land ONE table: buckets, delta, # --raw-sql (defaults to --table there) # --dest-table-prefix

for sources that land SEVERAL (sql --table/--sql, -# iceberg, ducklake, kafka, rest): `orders` lands as +# iceberg, ducklake, kafka, iggy, rest): `orders` lands as # `

_orders`. Optional, but only one prefix-less # ingest can own a database+schema — a second one # must pick a prefix or it overwrites the first. diff --git a/src/commands/datasource.rs b/src/commands/datasource.rs index 79df02e..3cfdeb6 100644 --- a/src/commands/datasource.rs +++ b/src/commands/datasource.rs @@ -64,7 +64,7 @@ pub enum DatasourceCommands { #[command(name = "test")] Validate { /// Source family — the shape of --config: sql, filesystem, iceberg, - /// delta, ducklake, kafka, rest. Use `sql` for any SQL dialect (the + /// delta, ducklake, kafka, iggy, rest. Use `sql` for any SQL dialect (the /// dialect goes in the config) and `filesystem` for buckets. /// /// Not validated here on purpose: the service decides which families @@ -93,7 +93,7 @@ pub enum DatasourceCommands { #[command(name = "add")] Create { /// Source family — the shape of --config: sql, filesystem, iceberg, - /// delta, ducklake, kafka, rest. Use `sql` for any SQL dialect (the + /// delta, ducklake, kafka, iggy, rest. Use `sql` for any SQL dialect (the /// dialect goes in the config) and `filesystem` for buckets. /// /// Omit it on a terminal to pick a source type from the catalog. @@ -184,7 +184,7 @@ pub enum DatasourceCommands { /// script to build a form from. Fields { /// Family to describe — the FAMILY column of `hotdata ingest sources - /// types`, e.g. sql, filesystem, iceberg, kafka, rest + /// types`, e.g. sql, filesystem, iceberg, kafka, iggy, rest family: Option, }, } @@ -509,7 +509,7 @@ fn create( let from_flags = (!payload.is_empty() || !util::is_interactive()).then(|| { let Some(family) = family else { fail( - "--family is required (sql, filesystem, iceberg, delta, ducklake, kafka, rest). \ + "--family is required (sql, filesystem, iceberg, delta, ducklake, kafka, iggy, rest). \ Run 'hotdata ingest sources add' in a terminal to be asked instead.", ); }; diff --git a/src/commands/ingest.rs b/src/commands/ingest.rs index 90a11d6..f05011a 100644 --- a/src/commands/ingest.rs +++ b/src/commands/ingest.rs @@ -228,8 +228,8 @@ pub enum IngestCommands { dest_table: Option, /// Common prefix for the destination tables of a source that lands - /// SEVERAL: SQL --table/--sql, Iceberg, DuckLake, Kafka, REST. Each - /// source table `orders` lands as `_orders`. + /// SEVERAL: SQL --table/--sql, Iceberg, DuckLake, Kafka, Iggy, REST. + /// Each source table `orders` lands as `_orders`. /// /// Optional. Without it the source names are used unchanged, which is /// what a raw mirror of a schema or a catalog wants — but only one @@ -839,8 +839,9 @@ fn build_selector(plan: &CreatePlan) -> Result<(serde_json::Value, Option (SQL, Iceberg, DuckLake), --table-path \ - (Delta), --topic (Kafka; Iggy as stream/topic), --format with an optional --glob \ - (buckets), --sql, --raw-sql, --all, or the whole --selector as JSON. A REST \ + (Delta), --topic (Kafka; Iggy as stream/topic), --format with an \ + optional --glob (buckets), --sql, --raw-sql, --all, or the whole --selector as \ + JSON. A REST \ source is --selector only: its resources carry endpoints, not just names \ ('hotdata ingest sources fields rest')" .into(),