cmd/kubetest2-eksapi-janitor/main.go

package main

import (
	"context"
	"flag"
	"time"

	"github.com/aws/aws-k8s-tester/internal/deployers/eksapi"
	"k8s.io/klog/v2"
)

func main() {
	var maxResourceAge time.Duration
	flag.DurationVar(&maxResourceAge, "max-resource-age", time.Hour*3, "Maximum resource age")
	var workers int
	flag.IntVar(&workers, "workers", 1, "number of workers to processes resources in parallel")
	var stackStatus string
	flag.StringVar(&stackStatus, "stack-status", "", "only process stacks with a specific status")
	var emitMetrics bool
	flag.BoolVar(&emitMetrics, "emit-metrics", false, "Send metrics to CloudWatch")
	flag.Parse()
	j := eksapi.NewJanitor(maxResourceAge, emitMetrics, workers, stackStatus)
	if err := j.Sweep(context.Background()); err != nil {
		klog.Fatalf("failed to sweep resources: %v", err)
	}
}