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
|
package tools
import (
"io"
"strconv"
"time"
"github.com/dustin/go-humanize"
"github.com/fatih/color"
"github.com/olekukonko/tablewriter"
"github.com/spiral/roadrunner/v2/pkg/process"
)
// WorkerTable renders table with information about rr server workers.
func WorkerTable(writer io.Writer, workers []process.State) *tablewriter.Table {
tw := tablewriter.NewWriter(writer)
tw.SetHeader([]string{"PID", "Status", "Execs", "Memory", "CPU%", "Created"})
tw.SetColMinWidth(0, 7)
tw.SetColMinWidth(1, 9)
tw.SetColMinWidth(2, 7)
tw.SetColMinWidth(3, 7)
tw.SetColMinWidth(4, 7)
tw.SetColMinWidth(5, 18)
for i := 0; i < len(workers); i++ {
tw.Append([]string{
strconv.Itoa(workers[i].Pid),
renderStatus(workers[i].Status),
renderJobs(workers[i].NumJobs),
humanize.Bytes(workers[i].MemoryUsage),
renderCPU(workers[i].CPUPercent),
renderAlive(time.Unix(0, workers[i].Created)),
})
}
return tw
}
// ServiceWorkerTable renders table with information about rr server workers.
func ServiceWorkerTable(writer io.Writer, workers []process.State) *tablewriter.Table {
tw := tablewriter.NewWriter(writer)
tw.SetAutoWrapText(false)
tw.SetHeader([]string{"PID", "Memory", "CPU%", "Command"})
tw.SetColMinWidth(0, 7)
tw.SetColMinWidth(1, 7)
tw.SetColMinWidth(2, 7)
tw.SetColMinWidth(3, 18)
tw.SetAlignment(tablewriter.ALIGN_LEFT)
for i := 0; i < len(workers); i++ {
tw.Append([]string{
strconv.Itoa(workers[i].Pid),
humanize.Bytes(workers[i].MemoryUsage),
renderCPU(workers[i].CPUPercent),
workers[i].Command,
})
}
return tw
}
//go:inline
func renderCPU(cpu float64) string {
return strconv.FormatFloat(cpu, 'f', 2, 64)
}
func renderStatus(status string) string {
switch status {
case "inactive":
return color.YellowString("inactive")
case "ready":
return color.CyanString("ready")
case "working":
return color.GreenString("working")
case "invalid":
return color.YellowString("invalid")
case "stopped":
return color.RedString("stopped")
case "errored":
return color.RedString("errored")
}
return status
}
func renderJobs(number uint64) string {
// TODO overflow
return humanize.Comma(int64(number))
}
func renderAlive(t time.Time) string {
return humanize.RelTime(t, time.Now(), "ago", "")
}
|
