diff options
| author | chrislu <chris.lu@gmail.com> | 2024-06-20 15:23:29 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-06-20 15:23:29 -0700 |
| commit | bf957fdf70400c276a862b44f0d74a06a2108d64 (patch) | |
| tree | 64741e522d177cbd82cca5bf210a0c0a8553cf4a /pkg | |
| parent | dafb0e283755007915cd348d23f24978bee0b4f3 (diff) | |
| download | seaweedfs-csi-driver-bf957fdf70400c276a862b44f0d74a06a2108d64.tar.xz seaweedfs-csi-driver-bf957fdf70400c276a862b44f0d74a06a2108d64.zip | |
deal with config error
fix https://github.com/seaweedfs/seaweedfs-csi-driver/issues/169
Diffstat (limited to 'pkg')
| -rw-r--r-- | pkg/k8s/client.go | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/pkg/k8s/client.go b/pkg/k8s/client.go index 8861d0a..e9d72a4 100644 --- a/pkg/k8s/client.go +++ b/pkg/k8s/client.go @@ -2,6 +2,7 @@ package k8s import ( "context" + "fmt" "time" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" @@ -9,11 +10,11 @@ import ( "k8s.io/client-go/rest" ) -func NewInCluster() (*kubernetes.Clientset, error) { +func newInCluster() (*kubernetes.Clientset, error) { //creates the in-cluster config config, err := rest.InClusterConfig() if err != nil { - panic(err.Error()) + return nil, fmt.Errorf("failed to get in-cluster config: %v", err) } // creates the clientset @@ -25,7 +26,7 @@ func NewInCluster() (*kubernetes.Clientset, error) { } func GetVolumeCapacity(volumeId string) (int64, error) { - client, err := NewInCluster() + client, err := newInCluster() if err != nil { return 0, err } |