From 3e3d202acdc9cb523ae3f7e71b3e1b595f4d5450 Mon Sep 17 00:00:00 2001 From: chrislu Date: Thu, 25 Aug 2022 00:05:42 -0700 Subject: update dependencies --- pkg/driver/driver.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'pkg') 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 "" +} -- cgit v1.2.3