deskribe 0.1.0

Native Kubernetes resource descriptions using a caller-provided kube client
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

// Copyright 2014 The Kubernetes Authors.
// Copyright 2026 Nikola Milojević.
// SPDX-License-Identifier: Apache-2.0
// Adapted from kubectl v0.35.1 pkg/describe/describe.go. See LICENSE-APACHE.

use crate::events::with_events;
use crate::json::text;
use crate::metadata::metadata_header;
use crate::time::timestamp;
use k8s_openapi::api::core::v1::Event;
use k8s_openapi::jiff::Timestamp;
use k8s_openapi::jiff::tz::TimeZone;
use kube::api::DynamicObject;
use std::fmt::Write;

pub(crate) mod endpoints;
pub(crate) mod ingress;
pub(crate) mod service;

pub(crate) fn render_ingress_class(
    object: &DynamicObject,
    events: Option<&[Event]>,
    now: Timestamp,
) -> String {
    let value = &object.data;
    let mut out = metadata_header(&object.metadata, false);

    writeln!(out, "Controller:\t{}", text(&value["spec"]["controller"])).unwrap();
    let p = &value["spec"]["parameters"];
    if !p.is_null() {
        out.push_str("Parameters:\n");
        if !p["apiGroup"].is_null() {
            writeln!(out, "  APIGroup:\t{}", text(&p["apiGroup"])).unwrap();
        }
        writeln!(
            out,
            "  Kind:\t{}\n  Name:\t{}",
            text(&p["kind"]),
            text(&p["name"])
        )
        .unwrap();
    }

    with_events(out, events, now)
}

pub(crate) fn render_ip_address(
    object: &DynamicObject,
    events: Option<&[Event]>,
    now: Timestamp,
) -> String {
    let value = &object.data;
    let mut out = metadata_header(&object.metadata, false);

    let p = &value["spec"]["parentRef"];
    if !p.is_null() {
        out.push_str("Parent Reference:\n");
        for (field, label) in [
            ("group", "Group"),
            ("resource", "Resource"),
            ("namespace", "Namespace"),
            ("name", "Name"),
        ] {
            writeln!(out, "  {label}:\t{}", text(&p[field])).unwrap();
        }
    }

    with_events(out, events, now)
}

pub(crate) fn render_service_cidr(
    object: &DynamicObject,
    events: Option<&[Event]>,
    now: Timestamp,
    zone: &TimeZone,
) -> String {
    let value = &object.data;
    let mut out = metadata_header(&object.metadata, false);

    let cidrs: Vec<_> = value["spec"]["cidrs"]
        .as_array()
        .into_iter()
        .flatten()
        .map(text)
        .collect();
    writeln!(out, "CIDRs:\t{}", cidrs.join(", ")).unwrap();
    let conditions = value["status"]["conditions"]
        .as_array()
        .cloned()
        .unwrap_or_default();
    if !conditions.is_empty() {
        out.push_str("Status:\nConditions:\n  Type\tStatus\tLastTransitionTime\tReason\tMessage\n  ----\t------\t------------------\t------\t-------\n");
        for c in conditions {
            writeln!(
                out,
                "  {}\t{}\t{}\t{}\t{}",
                text(&c["type"]),
                text(&c["status"]),
                timestamp(text(&c["lastTransitionTime"]), zone),
                text(&c["reason"]),
                text(&c["message"])
            )
            .unwrap();
        }
    }

    with_events(out, events, now)
}