crictl: add option to filter by container name in ps

Signed-off-by: Antonio Murdaca <[email protected]>

Author: runcom

cmd/crictl/constants.go

@@ -19,6 +19,7 @@ package main
 const (
 	// This labels are copied from kubelet directly, and may change
 	// without warning in the future.
-	kubePodNameLabel      = "io.kubernetes.pod.name"
-	kubePodNamespaceLabel = "io.kubernetes.pod.namespace"
+	kubePodNameLabel       = "io.kubernetes.pod.name"
+	kubePodNamespaceLabel  = "io.kubernetes.pod.namespace"
+	kubeContainerNameLabel = "io.kubernetes.container.name"
 )

cmd/crictl/container.go

@@ -264,6 +264,11 @@ var listContainersCommand = cli.Command{
 			Value: "",
 			Usage: "Filter by container id",
 		},
+		cli.StringFlag{
+			Name:  "name",
+			Value: "",
+			Usage: "filter by container name regular expression pattern",
+		},
 		cli.StringFlag{
 			Name:  "pod, p",
 			Value: "",
@@ -310,16 +315,17 @@ var listContainersCommand = cli.Command{
 		}
 
 		opts := listOptions{
-			id:      context.String("id"),
-			podID:   context.String("pod"),
-			state:   context.String("state"),
-			verbose: context.Bool("verbose"),
-			quiet:   context.Bool("quiet"),
-			output:  context.String("output"),
-			all:     context.Bool("all"),
-			latest:  context.Bool("latest"),
-			last:    context.Int("last"),
-			noTrunc: context.Bool("no-trunc"),
+			id:         context.String("id"),
+			podID:      context.String("pod"),
+			state:      context.String("state"),
+			verbose:    context.Bool("verbose"),
+			quiet:      context.Bool("quiet"),
+			output:     context.String("output"),
+			all:        context.Bool("all"),
+			nameRegexp: context.String("name"),
+			latest:     context.Bool("latest"),
+			last:       context.Int("last"),
+			noTrunc:    context.Bool("no-trunc"),
 		}
 		opts.labels, err = parseLabelStringSlice(context.StringSlice("label"))
 		if err != nil {
@@ -617,6 +623,10 @@ func ListContainers(client pb.RuntimeServiceClient, opts listOptions) error {
 		fmt.Fprintln(w, "CONTAINER ID\tIMAGE\tCREATED\tSTATE\tNAME\tATTEMPT\tPOD ID")
 	}
 	for _, c := range r.Containers {
+		// Filter by pod name/namespace regular expressions.
+		if !matchesRegex(opts.nameRegexp, c.Labels[kubeContainerNameLabel]) {
+			continue
+		}
 		if opts.quiet {
 			fmt.Printf("%s\n", c.Id)
 			continue

cmd/crictl/sandbox.go

@@ -227,7 +227,7 @@ var listPodCommand = cli.Command{
 			latest:             context.Bool("latest"),
 			last:               context.Int("last"),
 			noTrunc:            context.Bool("no-trunc"),
-			podNameRegexp:      context.String("name"),
+			nameRegexp:         context.String("name"),
 			podNamespaceRegexp: context.String("namespace"),
 		}
 		opts.labels, err = parseLabelStringSlice(context.StringSlice("label"))
@@ -383,7 +383,7 @@ func PodSandboxStatus(client pb.RuntimeServiceClient, ID, output string, quiet b
 	return nil
 }
 
-func podMatchesRegex(pattern, target string) bool {
+func matchesRegex(pattern, target string) bool {
 	if pattern == "" {
 		return true
 	}
@@ -447,10 +447,10 @@ func ListPodSandboxes(client pb.RuntimeServiceClient, opts listOptions) error {
 	}
 	for _, pod := range r.Items {
 		// Filter by pod name/namespace regular expressions.
-		if !podMatchesRegex(opts.podNameRegexp, pod.Labels[kubePodNameLabel]) {
+		if !matchesRegex(opts.nameRegexp, pod.Labels[kubePodNameLabel]) {
 			continue
 		}
-		if !podMatchesRegex(opts.podNamespaceRegexp, pod.Labels[kubePodNamespaceLabel]) {
+		if !matchesRegex(opts.podNamespaceRegexp, pod.Labels[kubePodNamespaceLabel]) {
 			continue
 		}
 

cmd/crictl/util.go

@@ -48,8 +48,8 @@ type listOptions struct {
 	id string
 	// podID of container
 	podID string
-	// Regular expression pattern to match pod name
-	podNameRegexp string
+	// Regular expression pattern to match pod or container
+	nameRegexp string
 	// Regular expression pattern to match the pod namespace
 	podNamespaceRegexp string
 	// state of the sandbox