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

use super::*;

/// Display one or many resources
///
///  Prints a table of the most important information about the specified resources. You can filter the list using a label
/// selector and the --selector flag. If the desired resource type is namespaced you will only see results in the current
/// namespace if you don't specify any namespace.
///
///  By specifying the output as 'template' and providing a Go template as the value of the --template flag, you can filter
/// the attributes of the fetched resources.
///
/// Use "kubectl api-resources" for a complete list of supported resources.
///
#[derive(Clone, Debug, Args)]

pub struct Get {
    #[command(flatten)]
    params: ShowParams,

    /// Raw URI to request from the server.  Uses the transport specified by the kubeconfig file.
    #[arg(long, conflicts_with = "regular")]
    raw: Option<String>,

    /// If specified, gets the subresource of the requested object.
    #[arg(group = "regular", long)]
    subresource: Option<String>,

    /// Resources to fetch
    #[arg(group = "regular", required = true)]
    resources: Option<Vec<String>>,
}

impl Get {
    pub async fn exec(&self, context: &Context) -> RkResult<()> {
        let kubeapi = context.kubeapi();
        if let Some(raw) = self.raw.as_deref() {
            let name = raw.strip_prefix("/").unwrap_or(raw);
            let text = kubeapi.raw_get(name).await?;
            println!("{text}");
        } else {
            let resources = self.resources(kubeapi)?;
            let mut params = self.params;
            params.show_kind |= resources.len() > 1;
            let namespace = kubeapi.show_namespace();
            for resource in resources {
                let data = resource.get(kubeapi).await?;
                let output = context.output_deprecated();
                println!("{}", data.output(namespace, params, output));
            }
        }
        Ok(())
    }

    fn resources(&self, kubeapi: &Kubeapi) -> kube::Result<Vec<ResourceArg>> {
        let resources = self.resources.as_deref().unwrap_or_default();
        ResourceArg::from_strings(resources, kubeapi)
            .inspect(|resources| info!(args=?self.resources, ?resources))
            .map_err(|_err| kube::Error::LinesCodecMaxLineLengthExceeded)
    }
}