aboutsummaryrefslogtreecommitdiff
path: root/weed/replication/source/filer_source.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2021-01-28 14:36:29 -0800
committerChris Lu <chris.lu@gmail.com>2021-01-28 14:36:29 -0800
commit990fa69bfeac65a72bec1539993e32633858c8f5 (patch)
tree00b90626c590534b64a581da8807117459b91ecb /weed/replication/source/filer_source.go
parent9292796ec2d8f796f3e9162fcd1362cba801e7e4 (diff)
downloadseaweedfs-990fa69bfeac65a72bec1539993e32633858c8f5.tar.xz
seaweedfs-990fa69bfeac65a72bec1539993e32633858c8f5.zip
add back AdjustedUrl() related code
Diffstat (limited to 'weed/replication/source/filer_source.go')
-rw-r--r--weed/replication/source/filer_source.go4
1 files changed, 4 insertions, 0 deletions
diff --git a/weed/replication/source/filer_source.go b/weed/replication/source/filer_source.go
index eff1da8dc..3982360b0 100644
--- a/weed/replication/source/filer_source.go
+++ b/weed/replication/source/filer_source.go
@@ -124,6 +124,10 @@ func (fs *FilerSource) WithFilerClient(fn func(filer_pb.SeaweedFilerClient) erro
}
+func (fs *FilerSource) AdjustedUrl(location *filer_pb.Location) string {
+ return location.Url
+}
+
func volumeId(fileId string) string {
lastCommaIndex := strings.LastIndex(fileId, ",")
if lastCommaIndex > 0 {