Skip to content

Commit 9301068

Browse files
committed
Removed unused kubeclient creation function
1 parent 25b13f5 commit 9301068

File tree

1 file changed

+0
-25
lines changed

1 file changed

+0
-25
lines changed

cmd/gce-pd-csi-driver/main.go

Lines changed: 0 additions & 25 deletions
Original file line numberDiff line numberDiff line change
@@ -27,9 +27,6 @@ import (
2727
"strings"
2828
"time"
2929

30-
"k8s.io/client-go/kubernetes"
31-
"k8s.io/client-go/rest"
32-
"k8s.io/client-go/tools/clientcmd"
3330
"k8s.io/klog/v2"
3431
"k8s.io/utils/strings/slices"
3532
"sigs.k8s.io/gcp-compute-persistent-disk-csi-driver/pkg/common"
@@ -307,28 +304,6 @@ func handle() {
307304
gceDriver.Run(*endpoint, *grpcLogCharCap, *enableOtelTracing, metricsManager)
308305
}
309306

310-
func instantiateKubeClient() (*kubernetes.Clientset, error) {
311-
var cfg *rest.Config
312-
var err error
313-
314-
if *master != "" || *kubeconfig != "" {
315-
klog.Infof("Either master or kubeconfig specified. building kube config from that..")
316-
cfg, err = clientcmd.BuildConfigFromFlags(*master, *kubeconfig)
317-
} else {
318-
klog.Infof("No master or kubeconfig specified. building in-cluster kube config")
319-
cfg, err = rest.InClusterConfig()
320-
}
321-
if err != nil {
322-
return nil, fmt.Errorf("failed to create REST Config for k8s client: %w", err)
323-
}
324-
325-
kubeClient, err := kubernetes.NewForConfig(cfg)
326-
if err != nil {
327-
return nil, fmt.Errorf("failed to create k8s client: %w", err)
328-
}
329-
return kubeClient, nil
330-
}
331-
332307
func notEmpty(v string) bool {
333308
return v != ""
334309
}

0 commit comments

Comments
 (0)