add pkg/flags directory for kubelet dev purposes and go mod tidy/vendor

Signed-off-by: Jason Cho <[email protected]>

Author: jcho02

go.mod

@@ -0,0 +1,69 @@
+module github.com/IBM/power-dra-driver
+
+go 1.23.3
+
+require (
+	github.com/spf13/pflag v1.0.6
+	github.com/urfave/cli/v2 v2.27.5
+	k8s.io/apimachinery v0.32.1
+	k8s.io/client-go v0.32.1
+	k8s.io/component-base v0.32.1
+)
+
+require (
+	github.com/beorn7/perks v1.0.1 // indirect
+	github.com/blang/semver/v4 v4.0.0 // indirect
+	github.com/cespare/xxhash/v2 v2.3.0 // indirect
+	github.com/cpuguy83/go-md2man/v2 v2.0.5 // indirect
+	github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc // indirect
+	github.com/emicklei/go-restful/v3 v3.11.0 // indirect
+	github.com/fxamacker/cbor/v2 v2.7.0 // indirect
+	github.com/go-logr/logr v1.4.2 // indirect
+	github.com/go-logr/zapr v1.3.0 // indirect
+	github.com/go-openapi/jsonpointer v0.21.0 // indirect
+	github.com/go-openapi/jsonreference v0.20.2 // indirect
+	github.com/go-openapi/swag v0.23.0 // indirect
+	github.com/gogo/protobuf v1.3.2 // indirect
+	github.com/golang/protobuf v1.5.4 // indirect
+	github.com/google/gnostic-models v0.6.8 // indirect
+	github.com/google/go-cmp v0.6.0 // indirect
+	github.com/google/gofuzz v1.2.0 // indirect
+	github.com/google/uuid v1.6.0 // indirect
+	github.com/inconshreveable/mousetrap v1.1.0 // indirect
+	github.com/josharian/intern v1.0.0 // indirect
+	github.com/json-iterator/go v1.1.12 // indirect
+	github.com/mailru/easyjson v0.7.7 // indirect
+	github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
+	github.com/modern-go/reflect2 v1.0.2 // indirect
+	github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect
+	github.com/pkg/errors v0.9.1 // indirect
+	github.com/prometheus/client_golang v1.19.1 // indirect
+	github.com/prometheus/client_model v0.6.1 // indirect
+	github.com/prometheus/common v0.55.0 // indirect
+	github.com/prometheus/procfs v0.15.1 // indirect
+	github.com/russross/blackfriday/v2 v2.1.0 // indirect
+	github.com/spf13/cobra v1.8.1 // indirect
+	github.com/x448/float16 v0.8.4 // indirect
+	github.com/xrash/smetrics v0.0.0-20240521201337-686a1a2994c1 // indirect
+	go.opentelemetry.io/otel v1.28.0 // indirect
+	go.opentelemetry.io/otel/trace v1.28.0 // indirect
+	go.uber.org/multierr v1.11.0 // indirect
+	go.uber.org/zap v1.27.0 // indirect
+	golang.org/x/net v0.30.0 // indirect
+	golang.org/x/oauth2 v0.23.0 // indirect
+	golang.org/x/sys v0.26.0 // indirect
+	golang.org/x/term v0.25.0 // indirect
+	golang.org/x/text v0.19.0 // indirect
+	golang.org/x/time v0.7.0 // indirect
+	google.golang.org/protobuf v1.35.1 // indirect
+	gopkg.in/evanphx/json-patch.v4 v4.12.0 // indirect
+	gopkg.in/inf.v0 v0.9.1 // indirect
+	gopkg.in/yaml.v3 v3.0.1 // indirect
+	k8s.io/api v0.32.1 // indirect
+	k8s.io/klog/v2 v2.130.1 // indirect
+	k8s.io/kube-openapi v0.0.0-20241105132330-32ad38e42d3f // indirect
+	k8s.io/utils v0.0.0-20241104100929-3ea5e8cea738 // indirect
+	sigs.k8s.io/json v0.0.0-20241010143419-9aa6b5e7a4b3 // indirect
+	sigs.k8s.io/structured-merge-diff/v4 v4.4.2 // indirect
+	sigs.k8s.io/yaml v1.4.0 // indirect
+)

go.sum

@@ -0,0 +1,105 @@
+/*
+ * Copyright 2023 The Kubernetes Authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package flags
+
+import (
+	"fmt"
+
+	"github.com/urfave/cli/v2"
+
+	coreclientset "k8s.io/client-go/kubernetes"
+	"k8s.io/client-go/rest"
+	"k8s.io/client-go/tools/clientcmd"
+)
+
+type KubeClientConfig struct {
+	KubeConfig   string
+	KubeAPIQPS   float64
+	KubeAPIBurst int
+}
+
+type ClientSets struct {
+	Core coreclientset.Interface
+}
+
+func (k *KubeClientConfig) Flags() []cli.Flag {
+	flags := []cli.Flag{
+		&cli.StringFlag{
+			Category:    "Kubernetes client:",
+			Name:        "kubeconfig",
+			Usage:       "Absolute path to the `KUBECONFIG` file. Either this flag or the KUBECONFIG env variable need to be set if the driver is being run out of cluster.",
+			Destination: &k.KubeConfig,
+			EnvVars:     []string{"KUBECONFIG"},
+		},
+		&cli.Float64Flag{
+			Category:    "Kubernetes client:",
+			Name:        "kube-api-qps",
+			Usage:       "`QPS` to use while communicating with the Kubernetes apiserver.",
+			Value:       5,
+			Destination: &k.KubeAPIQPS,
+			EnvVars:     []string{"KUBE_API_QPS"},
+		},
+		&cli.IntFlag{
+			Category:    "Kubernetes client:",
+			Name:        "kube-api-burst",
+			Usage:       "`Burst` to use while communicating with the Kubernetes apiserver.",
+			Value:       10,
+			Destination: &k.KubeAPIBurst,
+			EnvVars:     []string{"KUBE_API_BURST"},
+		},
+	}
+
+	return flags
+}
+
+func (k *KubeClientConfig) NewClientSetConfig() (*rest.Config, error) {
+	var csconfig *rest.Config
+
+	var err error
+	if k.KubeConfig == "" {
+		csconfig, err = rest.InClusterConfig()
+		if err != nil {
+			return nil, fmt.Errorf("create in-cluster client configuration: %v", err)
+		}
+	} else {
+		csconfig, err = clientcmd.BuildConfigFromFlags("", k.KubeConfig)
+		if err != nil {
+			return nil, fmt.Errorf("create out-of-cluster client configuration: %v", err)
+		}
+	}
+
+	csconfig.QPS = float32(k.KubeAPIQPS)
+	csconfig.Burst = k.KubeAPIBurst
+
+	return csconfig, nil
+}
+
+func (k *KubeClientConfig) NewClientSets() (ClientSets, error) {
+	csconfig, err := k.NewClientSetConfig()
+	if err != nil {
+		return ClientSets{}, fmt.Errorf("create client configuration: %v", err)
+	}
+
+	coreclient, err := coreclientset.NewForConfig(csconfig)
+	if err != nil {
+		return ClientSets{}, fmt.Errorf("create core client: %v", err)
+	}
+
+	return ClientSets{
+		Core: coreclient,
+	}, nil
+}

pkg/flags/kubeclient.go

@@ -0,0 +1,87 @@
+/*
+ * Copyright 2023 The Kubernetes Authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package flags
+
+import (
+	"strings"
+
+	"github.com/spf13/pflag"
+	"github.com/urfave/cli/v2"
+
+	utilruntime "k8s.io/apimachinery/pkg/util/runtime"
+	"k8s.io/component-base/featuregate"
+	logsapi "k8s.io/component-base/logs/api/v1"
+
+	_ "k8s.io/component-base/logs/json/register" // for JSON log output support
+)
+
+type LoggingConfig struct {
+	featureGate featuregate.MutableFeatureGate
+	config      *logsapi.LoggingConfiguration
+}
+
+func NewLoggingConfig() *LoggingConfig {
+	fg := featuregate.NewFeatureGate()
+	var _ pflag.Value = fg // compile-time check for the type conversion below
+	l := &LoggingConfig{
+		featureGate: fg,
+		config:      logsapi.NewLoggingConfiguration(),
+	}
+	utilruntime.Must(logsapi.AddFeatureGates(l.featureGate))
+	utilruntime.Must(l.featureGate.SetFromMap(map[string]bool{string(logsapi.ContextualLogging): true}))
+	return l
+}
+
+// Apply should be called in a cli.App.Before directly after parsing command
+// line flags and before running any code which emits log entries.
+func (l *LoggingConfig) Apply() error {
+	return logsapi.ValidateAndApply(l.config, l.featureGate)
+}
+
+// Flags returns the flags for the configuration.
+func (l *LoggingConfig) Flags() []cli.Flag {
+	var fs pflag.FlagSet
+	logsapi.AddFlags(l.config, &fs)
+
+	// Adding the feature gates flag to fs means that its going to be added
+	// with "logging" as category. In practice, the logging code is the
+	// only code which uses the flag, therefore that seems like a good
+	// place to report it.
+	fs.AddFlag(&pflag.Flag{
+		Name: "feature-gates",
+		Usage: "A set of key=value pairs that describe feature gates for alpha/experimental features. " +
+			"Options are:\n     " + strings.Join(l.featureGate.KnownFeatures(), "\n     "),
+		Value: l.featureGate.(pflag.Value), //nolint:forcetypeassert // No need for type check: l.featureGate is a *featuregate.featureGate, which implements pflag.Value.
+	})
+
+	var flags []cli.Flag
+	fs.VisitAll(func(flag *pflag.Flag) {
+		flags = append(flags, pflagToCLI(flag, "Logging:"))
+	})
+	return flags
+}
+
+func pflagToCLI(flag *pflag.Flag, category string) cli.Flag {
+	return &cli.GenericFlag{
+		Name:        flag.Name,
+		Category:    category,
+		Usage:       flag.Usage,
+		Value:       flag.Value,
+		Destination: flag.Value,
+		EnvVars:     []string{strings.ToUpper(strings.ReplaceAll(flag.Name, "-", "_"))},
+	}
+}