diff options
Diffstat (limited to 'weed/command/filer_meta_backup.go')
| -rw-r--r-- | weed/command/filer_meta_backup.go | 17 |
1 files changed, 15 insertions, 2 deletions
diff --git a/weed/command/filer_meta_backup.go b/weed/command/filer_meta_backup.go index f2cba9382..ff4a61e41 100644 --- a/weed/command/filer_meta_backup.go +++ b/weed/command/filer_meta_backup.go @@ -196,8 +196,21 @@ func (metaBackup *FilerMetaBackupOptions) streamMetadataBackup() error { }) metaBackup.clientEpoch++ - return pb.FollowMetadata(pb.ServerAddress(*metaBackup.filerAddress), metaBackup.grpcDialOption, "meta_backup", metaBackup.clientId, metaBackup.clientEpoch, - *metaBackup.filerDirectory, nil, startTime.UnixNano(), 0, 0, processEventFnWithOffset, pb.TrivialOnError) + + metadataFollowOption := &pb.MetadataFollowOption{ + ClientName: "meta_backup", + ClientId: metaBackup.clientId, + ClientEpoch: metaBackup.clientEpoch, + SelfSignature: 0, + PathPrefix: *metaBackup.filerDirectory, + AdditionalPathPrefixes: nil, + DirectoriesToWatch: nil, + StartTsNs: startTime.UnixNano(), + StopTsNs: 0, + EventErrorType: pb.TrivialOnError, + } + + return pb.FollowMetadata(pb.ServerAddress(*metaBackup.filerAddress), metaBackup.grpcDialOption, metadataFollowOption, processEventFnWithOffset) } |
