icepick 0.4.1

Experimental Rust client for Apache Iceberg with WASM support for AWS S3 Tables and Cloudflare R2
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59

//! Catalog commands

use crate::cli::catalog::CatalogConfig;
use crate::cli::output::{print, OutputFormat, Outputable};
use clap::Subcommand;
use serde::Serialize;

/// Catalog commands
#[derive(Debug, Subcommand)]
pub enum CatalogCommand {
    /// Show catalog information
    Info,
}

/// Catalog info output
#[derive(Debug, Serialize)]
pub struct CatalogInfo {
    pub catalog_type: String,
    pub catalog_url: Option<String>,
}

impl Outputable for CatalogInfo {
    fn to_text(&self) -> String {
        let mut lines = vec![format!("Catalog Type:  {}", self.catalog_type)];

        if let Some(ref url) = self.catalog_url {
            lines.push(format!("Catalog URL:   {}", url));
        }

        lines.push("Status:        Connected".to_string());

        lines.join("\n")
    }
}

/// Execute a catalog command
pub async fn execute(
    command: CatalogCommand,
    config: &CatalogConfig,
    format: OutputFormat,
) -> Result<(), String> {
    match command {
        CatalogCommand::Info => {
            // Try to connect to verify the catalog works
            config
                .create_catalog()
                .await
                .map_err(|e| format!("Failed to connect to catalog: {}", e))?;

            let info = CatalogInfo {
                catalog_type: config.catalog_type().to_string(),
                catalog_url: config.catalog_url.clone(),
            };

            print(&info, format);
            Ok(())
        }
    }
}