INNER CODE UNIT · Go

setFlags

kubernetes-sigs/kueue · cmd/importer/main.go:75

func setFlags(cmd *cobra.Command) {
	cmd.Flags().StringSliceP(NamespaceFlag, NamespaceFlagShort, nil, "target namespaces (at least one should be provided)")
	cmd.Flags().String(QueueLabelFlag, "", "label used to identify the target local queue")
	cmd.Flags().StringToString(QueueMappingFlag, nil, "mapping from \""+QueueLabelFlag+"\" label values to local queue names")
	cmd.Flags().StringToString(AddLabelsFlag, nil, "additional label=value pairs to be added to the imported pods and created workloads")
	cmd.Flags().StringSlice(ExcludeResourcePrefixesFlag, nil, "resource name prefixes ignored by Kueue during workload quota accounting")
	cmd.Flags().String(QueueMappingFileFlag, "", "yaml file containing extra mappings from \""+QueueLabelFlag+"\" label values to local queue names")
	cmd.Flags().Float32(QPSFlag, 50, "client QPS, as described in https://kubernetes.io/docs/reference/config-api/apiserver-eventratelimit.v1alpha1/#eventratelimit-admission-k8s-io-v1alpha1-Limit")
	cmd.Flags().Int(BurstFlag, 50, "client Burst, as described in https://kubernetes.io/docs/reference/config-api/apiserver-eventratelimit.v1alpha1/#eventratelimit-admission-k8s-io-v1alpha1-Limit")
	cmd.Flags().UintP(ConcurrencyFlag, ConcurrencyFlagShort, 8, "number of concurrent import workers")
	cmd.Flags().Bool(DryRunFlag, true, "don't import, check the config only")

	_ = cmd.MarkFlagRequired(NamespaceFlag)
	cmd.MarkFlagsRequiredTogether(QueueLabelFlag, QueueMappingFlag)
	cmd.MarkFlagsOneRequired(QueueLabelFlag, QueueMappingFileFlag)
	cmd.MarkFlagsMutuallyExclusive(QueueLabelFlag, QueueMappingFileFlag)
}

View source record →

📰 Research Paper
Loading…
⏳ Fetching content…