jayjay
/
k9s
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Show resource limit % next to request % in Pod view (fix #413)

mine
Benjamin Clauss 2020-01-14 12:55:20 +01:00
parent cf79622be0
commit dc2b0104de
3 changed files with 26 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/render/helpers.go
View File

@ -31,11 +31,11 @@ func asSelector(s *metav1.LabelSelector) string {
}
type metric struct {
cpu, mem string
cpu, mem, cpuLim, memLim string
}
func noMetric() metric {
return metric{cpu: NAValue, mem: NAValue}
return metric{cpu: NAValue, mem: NAValue, cpuLim: NAValue, memLim: NAValue}
}
// ToSelector flattens a map selector to a string selector.

26
internal/render/pod.go
View File

@ -78,8 +78,8 @@ func (Pod) Header(ns string) HeaderRow {
Header{Name: "RESTART", Align: tview.AlignRight},
Header{Name: "CPU", Align: tview.AlignRight},
Header{Name: "MEM", Align: tview.AlignRight},
Header{Name: "%CPU", Align: tview.AlignRight},
Header{Name: "%MEM", Align: tview.AlignRight},
Header{Name: "%CPU (LIM)", Align: tview.AlignRight},
Header{Name: "%MEM (LIM)", Align: tview.AlignRight},
Header{Name: "IP"},
Header{Name: "NODE"},
Header{Name: "QOS"},
@ -116,8 +116,8 @@ func (p Pod) Render(o interface{}, ns string, r *Row) error {
strconv.Itoa(rc),
c.cpu,
c.mem,
perc.cpu,
perc.mem,
perc.cpu+" ("+fmt.Sprintf("%3v",perc.cpuLim)+")",
perc.mem+" ("+fmt.Sprintf("%3v",perc.memLim)+")",
na(po.Status.PodIP),
na(po.Spec.NodeName),
p.mapQOS(po.Status.QOSClass),
@ -159,9 +159,12 @@ func (*Pod) gatherPodMX(pod *v1.Pod, mx *mv1beta1.PodMetrics) (c, p metric) {
}
rc, rm := requestedRes(pod)
lc, lm := resourceLimits(pod)
p = metric{
cpu: AsPerc(toPerc(float64(cpu.MilliValue()), float64(rc.MilliValue()))),
mem: AsPerc(toPerc(ToMB(mem.Value()), ToMB(rm.Value()))),
cpuLim: AsPerc(toPerc(float64(cpu.MilliValue()), float64(lc.MilliValue()))),
memLim: AsPerc(toPerc(ToMB(mem.Value()), ToMB(lm.Value()))),
}
return
@ -180,6 +183,21 @@ func containerResources(co v1.Container) (cpu, mem *resource.Quantity) {
return
}
func resourceLimits(po *v1.Pod) (cpu, mem resource.Quantity) {
for _, co := range po.Spec.Containers {
limit := co.Resources.Limits
if len(limit) != 0 {
if limit.Cpu() != nil {
cpu.Add(*limit.Cpu())
}
if limit.Memory() != nil {
mem.Add(*limit.Memory())
}
}
}
return
}
func requestedRes(po *v1.Pod) (cpu, mem resource.Quantity) {
for _, co := range po.Spec.Containers {
c, m := containerResources(co)

4
internal/render/pod_test.go
View File

@ -70,7 +70,7 @@ func TestPodRender(t *testing.T) {
assert.Nil(t, err)
assert.Equal(t, "default/nginx", r.ID)
e := render.Fields{"default", "nginx", "1/1", "Running", "0", "10", "10", "10", "14", "172.17.0.6", "minikube", "BE"}
e := render.Fields{"default", "nginx", "1/1", "Running", "0", "10", "10", "10 ( 0)", "14 ( 5)", "172.17.0.6", "minikube", "BE"}
assert.Equal(t, e, r.Fields[:12])
}
@ -101,7 +101,7 @@ func TestPodInitRender(t *testing.T) {
assert.Nil(t, err)
assert.Equal(t, "default/nginx", r.ID)
e := render.Fields{"default", "nginx", "1/1", "Init:0/1", "0", "10", "10", "10", "14", "172.17.0.6", "minikube", "BE"}
e := render.Fields{"default", "nginx", "1/1", "Init:0/1", "0", "10", "10", "10 ( 0)", "14 ( 5)", "172.17.0.6", "minikube", "BE"}
assert.Equal(t, e, r.Fields[:12])
}