aboutsummaryrefslogtreecommitdiff
path: root/weed/command/filer_sync.go
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2022-05-30 15:04:19 -0700
committerchrislu <chris.lu@gmail.com>2022-05-30 15:04:19 -0700
commita2b101a737de0a4085f560971f6f25cb8f4e6050 (patch)
treea6ffa22530ba91f7b2011b700d97e4bf4888827b /weed/command/filer_sync.go
parent5b9347c9380100ef5f44178263700309991a2766 (diff)
downloadseaweedfs-a2b101a737de0a4085f560971f6f25cb8f4e6050.tar.xz
seaweedfs-a2b101a737de0a4085f560971f6f25cb8f4e6050.zip
subscribe metadata between a range
Diffstat (limited to 'weed/command/filer_sync.go')
-rw-r--r--weed/command/filer_sync.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/command/filer_sync.go b/weed/command/filer_sync.go
index e3d3b97bc..2dd780a75 100644
--- a/weed/command/filer_sync.go
+++ b/weed/command/filer_sync.go
@@ -178,7 +178,7 @@ func doSubscribeFilerMetaChanges(clientId int32, grpcDialOption grpc.DialOption,
})
return pb.FollowMetadata(sourceFiler, grpcDialOption, "syncTo_"+string(targetFiler), clientId,
- sourcePath, nil, sourceFilerOffsetTsNs, targetFilerSignature, processEventFnWithOffset, false)
+ sourcePath, nil, sourceFilerOffsetTsNs, 0, targetFilerSignature, processEventFnWithOffset, false)
}