aboutsummaryrefslogtreecommitdiff
path: root/weed/command/filer_backup.go
diff options
context:
space:
mode:
authorchrislu <chris.lu@gmail.com>2023-03-21 23:01:49 -0700
committerchrislu <chris.lu@gmail.com>2023-03-21 23:01:49 -0700
commit5db9fcccd4194660a8503696ac44c3539c29d41e (patch)
tree9c2afed1dcfb5b958208fbc095919152eb32fc7d /weed/command/filer_backup.go
parentde4545c28b8283fb80ae03dc95910a0ab3a67142 (diff)
downloadseaweedfs-5db9fcccd4194660a8503696ac44c3539c29d41e.tar.xz
seaweedfs-5db9fcccd4194660a8503696ac44c3539c29d41e.zip
refactoring
Diffstat (limited to 'weed/command/filer_backup.go')
-rw-r--r--weed/command/filer_backup.go15
1 files changed, 14 insertions, 1 deletions
diff --git a/weed/command/filer_backup.go b/weed/command/filer_backup.go
index 6f379a6d6..b51dd65b6 100644
--- a/weed/command/filer_backup.go
+++ b/weed/command/filer_backup.go
@@ -138,6 +138,19 @@ func doFilerBackup(grpcDialOption grpc.DialOption, backupOption *FilerBackupOpti
}()
}
- return pb.FollowMetadata(sourceFiler, grpcDialOption, "backup_"+dataSink.GetName(), clientId, clientEpoch, sourcePath, nil, startFrom.UnixNano(), 0, 0, processEventFnWithOffset, pb.TrivialOnError)
+ metadataFollowOption := &pb.MetadataFollowOption{
+ ClientName: "backup_" + dataSink.GetName(),
+ ClientId: clientId,
+ ClientEpoch: clientEpoch,
+ SelfSignature: 0,
+ PathPrefix: sourcePath,
+ AdditionalPathPrefixes: nil,
+ DirectoriesToWatch: nil,
+ StartTsNs: startFrom.UnixNano(),
+ StopTsNs: 0,
+ EventErrorType: pb.TrivialOnError,
+ }
+
+ return pb.FollowMetadata(sourceFiler, grpcDialOption, metadataFollowOption, processEventFnWithOffset)
}