rkubectl-app 0.0.0-alpha.5

The application logic for rkubectl, a Kubernetes CLI tool
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

use super::*;

#[derive(Clone, Debug, Args)]
pub struct ApiResources {
    /// If false, only non-namespaced resources are shown
    #[arg(long)]
    namespaced: Option<bool>,

    /// Show also subresources
    #[arg(long)]
    subresources: bool,
}

impl ApiResources {
    pub async fn exec(self, context: &Context) -> RkResult<()> {
        let ar = context
            .kubeapi()
            .server_preferred_resources()
            .await?
            .into_iter()
            .flat_map(|group| self.collect(group))
            .collect::<Vec<_>>();

        let mut table = tabled::Table::new(ar);
        table.with(Style::blank()).with(Padding::new(0, 2, 0, 0));
        if matches!(context.output_deprecated(), cli::OutputFormat::Normal) {
            table
                .with(Remove::column(ByColumnName::new("VERBS")))
                .with(Remove::column(ByColumnName::new("CATEGORIES")));
        }
        println!("{table}");

        Ok(())
    }

    fn collect(&self, list: metav1::APIResourceList) -> Vec<ApiResource> {
        let metav1::APIResourceList {
            group_version,
            resources,
        } = list;

        resources
            .into_iter()
            .filter(|resource| self.subresources || !resource.name.contains("/"))
            .filter(|resource| {
                self.namespaced.is_none() || self.namespaced == Some(resource.namespaced)
            })
            .map(|resource| ApiResource::new(&group_version, resource))
            .collect()
    }
}

#[derive(Debug, tabled::Tabled)]
#[tabled(rename_all = "UPPERCASE")]
pub struct ApiResource {
    name: String,
    shortnames: String,
    apiversion: String,
    namespaced: bool,
    kind: String,
    verbs: String,
    categories: String,
}

impl ApiResource {
    pub fn new(apiversion: &str, resource: metav1::APIResource) -> Self {
        let metav1::APIResource {
            categories,
            // group,
            kind,
            name,
            namespaced,
            short_names,
            // singular_name,
            // storage_version_hash,
            verbs,
            // version,
            ..
        } = resource;
        let apiversion = apiversion.to_string();
        let shortnames = option_vec(short_names);
        let verbs = verbs.join(",");
        let categories = option_vec(categories);
        Self {
            name,
            shortnames,
            apiversion,
            namespaced,
            kind,
            verbs,
            categories,
        }
    }
}

fn option_vec(value: Option<Vec<String>>) -> String {
    value
        .as_deref()
        .map(|values| values.join(","))
        .unwrap_or_default()
}