diff options
Diffstat (limited to 'pkg')
| -rw-r--r-- | pkg/driver/driver.go | 2 | ||||
| -rw-r--r-- | pkg/driver/utils.go | 12 |
2 files changed, 3 insertions, 11 deletions
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 { |