diff options
| author | chrislu <chris.lu@gmail.com> | 2023-03-21 23:01:49 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2023-03-21 23:01:49 -0700 |
| commit | 5db9fcccd4194660a8503696ac44c3539c29d41e (patch) | |
| tree | 9c2afed1dcfb5b958208fbc095919152eb32fc7d /weed/command/filer_backup.go | |
| parent | de4545c28b8283fb80ae03dc95910a0ab3a67142 (diff) | |
| download | seaweedfs-5db9fcccd4194660a8503696ac44c3539c29d41e.tar.xz seaweedfs-5db9fcccd4194660a8503696ac44c3539c29d41e.zip | |
refactoring
Diffstat (limited to 'weed/command/filer_backup.go')
| -rw-r--r-- | weed/command/filer_backup.go | 15 |
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) } |
