Function parse_export

src/clusterd-test-driver/src/text.rs:302–327

Parse an `export` sub-command into an [`ExportSpec`]. The `kind=` argument selects the variant (defaulting to `index`); each kind takes its own arguments.

(args: &BTreeMap<String, String>)

/// Parse an `export` sub-command into an [`ExportSpec`]. The `kind=` argument
/// selects the variant (defaulting to `index`); each kind takes its own arguments.
fn parse_export(args: &BTreeMap<String, String>) -> anyhow::Result<ExportSpec> {
    let on_id = req_u64(args, "on")?;
    Ok(
        match args.get("kind").map(String::as_str).unwrap_or("index") {
            "index" => ExportSpec::Index {
                index_id: req_u64(args, "index")?,
                on_id,
                key: parse_usize_list(req(args, "key")?)?,
            },
            "materialized-view" => ExportSpec::MaterializedView {
                sink_id: req_u64(args, "sink")?,
                on_id,
                shard: req(args, "shard")?.to_string(),
                schema: opt_string(args, "schema"),
            },
            "subscribe" => ExportSpec::Subscribe {
                sink_id: req_u64(args, "sink")?,
                on_id,
                schema: opt_string(args, "schema"),
                up_to: opt_u64(args, "up-to")?,
            },
            "copy-to" => bail!("copy-to export is not implemented"),
            other => bail!("unknown export kind `{other}`"),
        },
    )
}

/// Parse body lines as rows of raw space-separated value tokens (quotes intact).
/// The tokens are typed against the schema server-side; see `cell_from_token`.