diff options
| author | chrislu <chris.lu@gmail.com> | 2022-08-25 00:05:42 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-08-25 00:05:42 -0700 |
| commit | 3e3d202acdc9cb523ae3f7e71b3e1b595f4d5450 (patch) | |
| tree | 38508c000594829995af931f7a1f2ae017d2750b /pkg/driver/driver.go | |
| parent | a2b53896525a94bb98e42b2100fd932f544cb165 (diff) | |
| download | seaweedfs-csi-driver-3e3d202acdc9cb523ae3f7e71b3e1b595f4d5450.tar.xz seaweedfs-csi-driver-3e3d202acdc9cb523ae3f7e71b3e1b595f4d5450.zip | |
update dependencies
Diffstat (limited to 'pkg/driver/driver.go')
| -rw-r--r-- | pkg/driver/driver.go | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/pkg/driver/driver.go b/pkg/driver/driver.go index 4605b54..55cf0a3 100644 --- a/pkg/driver/driver.go +++ b/pkg/driver/driver.go @@ -143,7 +143,7 @@ func (d *SeaweedFsDriver) WithFilerClient(streamingMode bool, fn func(filer_pb.S err = pb.WithGrpcClient(streamingMode, func(grpcConnection *grpc.ClientConn) error { client := filer_pb.NewSeaweedFilerClient(grpcConnection) return fn(client) - }, d.filers[i].ToGrpcAddress(), d.grpcDialOption) + }, d.filers[i].ToGrpcAddress(), false, d.grpcDialOption) if err != nil { glog.V(0).Infof("WithFilerClient %d %v: %v", x, d.filers[i], err) @@ -165,3 +165,6 @@ func (d *SeaweedFsDriver) WithFilerClient(streamingMode bool, fn func(filer_pb.S func (d *SeaweedFsDriver) AdjustedUrl(location *filer_pb.Location) string { return location.Url } +func (d *SeaweedFsDriver) GetDataCenter() string { + return "" +} |