nyl 0.4.0

Kubernetes manifest generator with Helm integration
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
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119

use clap::{Args, ValueEnum};
use serde::Serialize;

use crate::{
    config::ProjectConfig,
    kubernetes::{KubeClient, KubeRsClient},
    profiles::Profile,
    NylError, Result,
};

/// Display Kubernetes cluster version information
#[derive(Args, Debug)]
pub struct ClusterInfoArgs {
    /// Profile to use for connecting to the cluster
    #[arg(short, long)]
    pub profile: Option<String>,

    /// Output format
    #[arg(long, default_value = "text", value_enum)]
    pub output: OutputFormat,
}

/// Output format for cluster info
#[derive(Debug, Clone, Copy, ValueEnum)]
pub enum OutputFormat {
    /// Human-readable text output
    Text,
    /// JSON output
    Json,
    /// YAML output
    Yaml,
    /// CSV output (for scripting with --offline mode)
    Csv,
}

/// Cluster information structure
#[derive(Debug, Serialize)]
#[serde(rename_all = "camelCase")]
struct ClusterInfo {
    kube_version: String,
    api_versions: Vec<String>,
}

pub async fn execute(args: ClusterInfoArgs) -> Result<()> {
    // 1. Load profile configuration
    let project_config = ProjectConfig::load_with_warning(None)?;

    // 2. Get profile
    let env_name = args.profile.as_deref().unwrap_or("default");
    let profile: Profile = if let Some(values) = project_config.get_profile_values(env_name) {
        Profile {
            values: values.iter().map(|(k, v)| (k.clone(), v.clone())).collect(),
            ..Default::default()
        }
    } else if args.profile.is_some() {
        // User explicitly requested a profile that doesn't exist
        return Err(NylError::Config(format!("Profile '{}' not found", env_name)));
    } else if !project_config.has_profiles() {
        // No profiles configured at all - use default (current kubecontext)
        Profile::default()
    } else {
        // Profiles exist but "default" doesn't - user must specify which one
        return Err(NylError::Config(format!(
            "Profile '{}' not found. Available profiles: {}",
            env_name,
            project_config.profile_names().join(", ")
        )));
    };

    // 3. Initialize Kubernetes client
    let client = KubeRsClient::from_profile(&profile, None).await?;

    // 4. Fetch cluster information
    let kube_version = client.get_server_version().await?;
    let api_versions = client.get_api_versions().await?;

    let info = ClusterInfo {
        kube_version,
        api_versions,
    };

    // 5. Output in requested format
    match args.output {
        OutputFormat::Text => output_text(&info),
        OutputFormat::Json => output_json(&info)?,
        OutputFormat::Yaml => output_yaml(&info)?,
        OutputFormat::Csv => output_csv(&info),
    }

    Ok(())
}

fn output_text(info: &ClusterInfo) {
    println!("Kubernetes Version: {}", info.kube_version);
    println!("API Versions:");
    for version in &info.api_versions {
        println!("  - {}", version);
    }
}

fn output_json(info: &ClusterInfo) -> Result<()> {
    let json =
        serde_json::to_string_pretty(info).map_err(|e| NylError::Config(format!("Failed to serialize JSON: {}", e)))?;
    println!("{}", json);
    Ok(())
}

fn output_yaml(info: &ClusterInfo) -> Result<()> {
    let yaml = serde_norway::to_string(info)?;
    print!("{}", yaml);
    Ok(())
}

fn output_csv(info: &ClusterInfo) {
    // First line: kube version
    println!("{}", info.kube_version);
    // Second line: comma-separated API versions
    println!("{}", info.api_versions.join(","));
}