INNER CODE UNIT · Go
setupFlags
kubernetes-sigs/kueue · cmd/experimental/webhook-conversion-repro/main.go:60
func setupFlags(cfg *Config) {
flag.IntVar(&cfg.Count, "count", -1, "Number of workloads to create (required)")
flag.IntVar(&cfg.Start, "start", 0, "First workload index (wl-<start>)")
flag.Float64Var(&cfg.QPS, "qps", 50.0, "API server QPS limit")
flag.IntVar(&cfg.Workers, "workers", -1, "Concurrent create workers (required)")
flag.IntVar(&cfg.Containers, "containers", -1, "Containers per workload (required)")
flag.IntVar(&cfg.Envs, "envs", -1, "Env vars per container (required)")
flag.StringVar(&cfg.Kubeconfig, "kubeconfig", "", "absolute path to the kubeconfig file")
}
func validateFlags(cfg *Config) error {
if cfg.Count <= 0 || cfg.QPS <= 0 || cfg.Workers <= 0 || cfg.Containers <= 0 || cfg.Envs < 0 {
return errors.New("--count, --qps, --workers, and --containers must be strictly positive (> 0). --envs must be >= 0")
}
return nil
}
func getKubeClient(kubeconfig string, qps float64) (dynamic.Interface, error) {