From 31cee46524a0671577b94d5af96ed1e165c0a9d6 Mon Sep 17 00:00:00 2001 From: washcycle Date: Wed, 26 Apr 2023 21:50:19 -0500 Subject: build fixes --- pkg/driver/driver.go | 2 +- pkg/driver/utils.go | 12 ++---------- 2 files changed, 3 insertions(+), 11 deletions(-) (limited to 'pkg') diff --git a/pkg/driver/driver.go b/pkg/driver/driver.go index 976717e..fcef08a 100644 --- a/pkg/driver/driver.go +++ b/pkg/driver/driver.go @@ -93,7 +93,7 @@ func (n *SeaweedFsDriver) Run() { s := NewNonBlockingGRPCServer() s.Start(n.endpoint, NewIdentityServer(n), - NewControllerServer(n) + NewControllerServer(n), NewNodeServer(n)) s.Wait() } diff --git a/pkg/driver/utils.go b/pkg/driver/utils.go index 8343ae7..837d5a4 100644 --- a/pkg/driver/utils.go +++ b/pkg/driver/utils.go @@ -12,7 +12,6 @@ import ( "github.com/seaweedfs/seaweedfs/weed/glog" "golang.org/x/net/context" "google.golang.org/grpc" - "k8s.io/client-go/rest" "k8s.io/utils/mount" ) @@ -33,18 +32,11 @@ func NewIdentityServer(d *SeaweedFsDriver) *IdentityServer { } } -func NewControllerServer(d *SeaweedFsDriver) (*ControllerServer, error) { - - // Get the Kubernetes configuration - c, err := rest.InClusterConfig() - if err != nil { - fmt.Errorf("failed to get Kubernetes config: %v", err) - } +func NewControllerServer(d *SeaweedFsDriver) *ControllerServer { return &ControllerServer{ Driver: d, - config: c, - }, nil + } } func NewControllerServiceCapability(cap csi.ControllerServiceCapability_RPC_Type) *csi.ControllerServiceCapability { -- cgit v1.2.3