aboutsummaryrefslogtreecommitdiff
path: root/pkg/driver/driver.go
diff options
context:
space:
mode:
authorwashcycle <litho23@gmail.com>2023-04-26 21:37:27 -0500
committerwashcycle <litho23@gmail.com>2023-04-26 21:37:27 -0500
commitceb40f2444d9b409b187a72ca8e8abeb437af62e (patch)
treea18517ebeeb16cecbf3d0d9b3397352691ae15d1 /pkg/driver/driver.go
parentb9cdc91ecb6008a33438d6a6407d5d4ddad9e361 (diff)
downloadseaweedfs-csi-driver-ceb40f2444d9b409b187a72ca8e8abeb437af62e.tar.xz
seaweedfs-csi-driver-ceb40f2444d9b409b187a72ca8e8abeb437af62e.zip
Implement CSI Test Suite
Fixes #115
Diffstat (limited to 'pkg/driver/driver.go')
-rw-r--r--pkg/driver/driver.go7
1 files changed, 5 insertions, 2 deletions
diff --git a/pkg/driver/driver.go b/pkg/driver/driver.go
index 5a375e1..f26d59b 100644
--- a/pkg/driver/driver.go
+++ b/pkg/driver/driver.go
@@ -91,9 +91,12 @@ func (n *SeaweedFsDriver) initClient() error {
func (n *SeaweedFsDriver) Run() {
s := NewNonBlockingGRPCServer()
+
+ c, _ := NewControllerServer(n)
+
s.Start(n.endpoint,
NewIdentityServer(n),
- NewControllerServer(n),
+ c,
NewNodeServer(n))
s.Wait()
}
@@ -171,5 +174,5 @@ func (d *SeaweedFsDriver) AdjustedUrl(location *filer_pb.Location) string {
return location.Url
}
func (d *SeaweedFsDriver) GetDataCenter() string {
- return ""
+ return d.DataCenter
}