feat: resource filtering

Signed-off-by: Luis Davim <[email protected]>

Author: Luis Davim

main.go

@@ -48,9 +48,11 @@ func main() {
 	output := ""
 	burst := 100
 	qps := 25
+	var groups []string
 	pflag.StringVarP(&output, "output", "o", output, "Output format. May be '' or 'json'.")
 	pflag.IntVar(&burst, "burst", burst, "API requests allowed per second (burst).")
 	pflag.IntVar(&qps, "qps", qps, "API requests allowed per second (steady state). Set to -1 to disable rate limiter.")
+	pflag.StringSliceVarP(&groups, "groups", "g", nil, "list of API groups")
 
 	// set up logging
 	klog.InitFlags(nil)
@@ -104,6 +106,8 @@ func main() {
 		Output:          output,
 		Stderr:          os.Stderr,
 		Stdout:          os.Stdout,
+		Namespace:       *configFlags.Namespace,
+		Groups:          groups,
 	}
 	checkErr(opts.Validate())
 	checkErr(opts.Run())

pkg/verify.go

@@ -22,6 +22,7 @@ import (
 	"errors"
 	"fmt"
 	"io"
+	"path/filepath"
 	"sort"
 	"strings"
 
@@ -46,6 +47,8 @@ type VerifyGCOptions struct {
 	Output          string
 	Stderr          io.Writer
 	Stdout          io.Writer
+	Namespace       string
+	Groups          []string
 }
 
 // Validate ensures the specified options are valid
@@ -106,6 +109,20 @@ func (v *VerifyGCOptions) Run() error {
 		return err
 	}
 	gcResources := discovery.FilteredBy(discovery.SupportsAllVerbs{Verbs: []string{"list", "get", "delete"}}, preferredResources)
+	if len(v.Groups) > 0 {
+		gcResources = discovery.FilteredBy(discovery.ResourcePredicateFunc(func(groupVersion string, r *metav1.APIResource) bool {
+			for _, g := range v.Groups {
+				match, _ := filepath.Match(g, groupVersion)
+				if match {
+					return true
+				}
+			}
+			if klog.V(2).Enabled() {
+				fmt.Fprintf(v.Stderr, "skipping: %s\n", groupVersion)
+			}
+			return false
+		}), gcResources)
+	}
 	gvrMap, err := discovery.GroupVersionResources(gcResources)
 	if err != nil {
 		return err
@@ -138,7 +155,7 @@ func (v *VerifyGCOptions) Run() error {
 			fmt.Fprintf(v.Stderr, "fetching %v, %v\n", gvr.GroupVersion().String(), gvr.Resource)
 		}
 		pager.New(func(ctx context.Context, opts metav1.ListOptions) (runtime.Object, error) {
-			list, err := v.MetadataClient.Resource(gvr).List(ctx, opts)
+			list, err := v.MetadataClient.Resource(gvr).Namespace(v.Namespace).List(ctx, opts)
 			if err != nil {
 				warningCount++
 				fmt.Fprintf(v.Stderr, "warning: could not list %v: %v\n", gvr, err.Error())