pcvolkmer/docker-pps
1
0
Fork 0
mirror of https://github.com/pcvolkmer/docker-pps.git synced 2025-04-19 17:56:50 +00:00
Code Issues Releases Activity

Extract method to fetch container processes

Browse Source
This commit is contained in:
Paul-Christian Volkmer 2022-12-25 11:29:19 +01:00
parent 1be4efc450
commit c9712d8876
1 changed files with 39 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

67
main.go
View File

@ -74,34 +74,8 @@ func getProcesses(dc *client.Client) ([]Process, error) {
if containers, err := dc.ContainerList(context.Background(), types.ContainerListOptions{All: true}); err == nil { if containers, err := dc.ContainerList(context.Background(), types.ContainerListOptions{All: true}); err == nil {
for _, container := range containers { for _, container := range containers {
tops, err := dc.ContainerTop(context.Background(), container.ID, []string{}) if containerProcesses, err := containerProcesses(dc, container); err == nil {
if err != nil { processes = append(processes, containerProcesses...)
continue
}
uid := 0
pid := 0
cmd := 0
for idx, title := range tops.Titles {
if title == "UID" {
uid = idx
}
if title == "PID" {
pid = idx
}
if title == "CMD" {
cmd = idx
}
}
for _, process := range tops.Processes {
processes = append(processes, Process{
ContainerID: container.ID,
Image: strings.Split(container.Image, "@sha256")[0],
PID: process[pid],
UID: process[uid],
Command: process[cmd],
})
} }
} }
} else { } else {
@ -111,6 +85,43 @@ func getProcesses(dc *client.Client) ([]Process, error) {
return processes, nil return processes, nil
} }
// Get all processes running in current docker container
func containerProcesses(dc *client.Client, container types.Container) ([]Process, error) {
var processes []Process
tops, err := dc.ContainerTop(context.Background(), container.ID, []string{})
if err != nil {
return nil, err
}
uid := 0
pid := 0
cmd := 0
for idx, title := range tops.Titles {
if title == "UID" {
uid = idx
}
if title == "PID" {
pid = idx
}
if title == "CMD" {
cmd = idx
}
}
for _, process := range tops.Processes {
processes = append(processes, Process{
ContainerID: container.ID,
Image: strings.Split(container.Image, "@sha256")[0],
PID: process[pid],
UID: process[uid],
Command: process[cmd],
})
}
return processes, nil
}
// Print out table if processes, running within docker containers // Print out table if processes, running within docker containers
func printTable(processes []Process) { func printTable(processes []Process) {
imageColumnLength := 5 imageColumnLength := 5