aboutsummaryrefslogtreecommitdiff
path: root/weed/command/filer_remote_gateway_buckets.go
diff options
context:
space:
mode:
authorChris Lu <chrislusf@users.noreply.github.com>2022-01-02 01:11:27 -0800
committerGitHub <noreply@github.com>2022-01-02 01:11:27 -0800
commit077f831749e6bbf12ff52fd369b493e4dd751817 (patch)
tree81912d857c0dcc0dba64661aa8f06ba81e68a40a /weed/command/filer_remote_gateway_buckets.go
parent9b941773805400c520558d83aed633adc821988c (diff)
parent42c849e0df74610d38453db67670db715ceb80aa (diff)
downloadseaweedfs-077f831749e6bbf12ff52fd369b493e4dd751817.tar.xz
seaweedfs-077f831749e6bbf12ff52fd369b493e4dd751817.zip
Merge pull request #2550 from chrislusf/metadata_follow_with_client_id
add client id for all metadata listening clients
Diffstat (limited to 'weed/command/filer_remote_gateway_buckets.go')
-rw-r--r--weed/command/filer_remote_gateway_buckets.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/command/filer_remote_gateway_buckets.go b/weed/command/filer_remote_gateway_buckets.go
index fc11cdbc5..4f65b5842 100644
--- a/weed/command/filer_remote_gateway_buckets.go
+++ b/weed/command/filer_remote_gateway_buckets.go
@@ -38,7 +38,7 @@ func (option *RemoteGatewayOptions) followBucketUpdatesAndUploadToRemote(filerSo
lastOffsetTs := collectLastSyncOffset(option, option.grpcDialOption, pb.ServerAddress(*option.filerAddress), option.bucketsDir, *option.timeAgo)
- return pb.FollowMetadata(pb.ServerAddress(*option.filerAddress), option.grpcDialOption, "filer.remote.sync",
+ return pb.FollowMetadata(pb.ServerAddress(*option.filerAddress), option.grpcDialOption, "filer.remote.sync", option.clientId,
option.bucketsDir, []string{filer.DirectoryEtcRemote}, lastOffsetTs.UnixNano(), 0, processEventFnWithOffset, false)
}