-
Notifications
You must be signed in to change notification settings - Fork 787
/
gc_pods.go
129 lines (113 loc) · 3.26 KB
/
gc_pods.go
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
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
package cmd
import (
"io"
"strings"
"time"
"github.com/jenkins-x/jx/pkg/jx/cmd/templates"
"github.com/jenkins-x/jx/pkg/log"
"github.com/jenkins-x/jx/pkg/util"
"github.com/spf13/cobra"
"gopkg.in/AlecAivazis/survey.v1/terminal"
corev1 "k8s.io/api/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)
// GCPodsOptions containers the CLI options
type GCPodsOptions struct {
CommonOptions
Selector string
Namespace string
Age time.Duration
}
var (
GCPodsLong = templates.LongDesc(`
Garbage collect old Pods that have completed or failed
`)
GCPodsExample = templates.Examples(`
# garbage collect old pods of the default age
jx gc pods
# garbage collect pods older than 10 minutes
jx gc pods -a 10m
`)
)
// NewCmdGCPods creates the command object
func NewCmdGCPods(f Factory, in terminal.FileReader, out terminal.FileWriter, errOut io.Writer) *cobra.Command {
options := &GCPodsOptions{
CommonOptions: CommonOptions{
Factory: f,
In: in,
Out: out,
Err: errOut,
},
}
cmd := &cobra.Command{
Use: "pods",
Short: "garbage collection for pods",
Aliases: []string{"pod"},
Long: GCPodsLong,
Example: GCPodsExample,
Run: func(cmd *cobra.Command, args []string) {
options.Cmd = cmd
options.Args = args
err := options.Run()
CheckErr(err)
},
}
cmd.Flags().StringVarP(&options.Selector, "selector", "s", "", "The selector to use to filter the pods")
cmd.Flags().StringVarP(&options.Namespace, "namespace", "n", "", "The namespace to look for the pods. Defaults to the current namespace")
cmd.Flags().DurationVarP(&options.Age, "age", "a", time.Hour, "The minimum age of pods to garbage collect. Any newer pods will be kept")
options.addCommonFlags(cmd)
return cmd
}
// Run implements this command
func (o *GCPodsOptions) Run() error {
kubeClient, ns, err := o.KubeClientAndNamespace()
if err != nil {
return err
}
if o.Namespace != "" {
ns = o.Namespace
}
opts := metav1.ListOptions{
LabelSelector: o.Selector,
}
podInterface := kubeClient.CoreV1().Pods(ns)
podList, err := podInterface.List(opts)
if err != nil {
return err
}
deleteOptions := &metav1.DeleteOptions{}
errors := []error{}
for _, pod := range podList.Items {
matches, age := o.MatchesPod(&pod)
if matches {
err := podInterface.Delete(pod.Name, deleteOptions)
if err != nil {
log.Warnf("Failed to delete pod %s in namespace %s: %s\n", pod.Name, ns, err)
errors = append(errors, err)
} else {
ageText := strings.TrimSuffix(age.Round(time.Minute).String(), "0s")
log.Infof("Deleted pod %s in namespace %s with phase %s as its age is: %s\n", pod.Name, ns, string(pod.Status.Phase), ageText)
}
}
}
return util.CombineErrors(errors...)
}
// MatchesPod returns true if this pod can be garbage collected
func (o *GCPodsOptions) MatchesPod(pod *corev1.Pod) (bool, time.Duration) {
phase := pod.Status.Phase
now := time.Now()
finished := now.Add(-1000 * time.Hour)
for _, s := range pod.Status.ContainerStatuses {
terminated := s.State.Terminated
if terminated != nil {
if terminated.FinishedAt.After(finished) {
finished = terminated.FinishedAt.Time
}
}
}
age := now.Sub(finished)
if phase != corev1.PodSucceeded && phase != corev1.PodFailed {
return false, age
}
return age > o.Age, age
}