aboutsummaryrefslogtreecommitdiff
path: root/weed/pb/filer_pb_tail.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/pb/filer_pb_tail.go')
-rw-r--r--weed/pb/filer_pb_tail.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/weed/pb/filer_pb_tail.go b/weed/pb/filer_pb_tail.go
index b7cca7585..f5ffac129 100644
--- a/weed/pb/filer_pb_tail.go
+++ b/weed/pb/filer_pb_tail.go
@@ -41,7 +41,7 @@ func FollowMetadata(filerAddress ServerAddress, grpcDialOption grpc.DialOption,
err := WithFilerClient(true, option.SelfSignature, filerAddress, grpcDialOption, makeSubscribeMetadataFunc(option, processEventFn))
if err != nil {
- return fmt.Errorf("subscribing filer meta change: %v", err)
+ return fmt.Errorf("subscribing filer meta change: %w", err)
}
return err
}
@@ -50,7 +50,7 @@ func WithFilerClientFollowMetadata(filerClient filer_pb.FilerClient, option *Met
err := filerClient.WithFilerClient(true, makeSubscribeMetadataFunc(option, processEventFn))
if err != nil {
- return fmt.Errorf("subscribing filer meta change: %v", err)
+ return fmt.Errorf("subscribing filer meta change: %w", err)
}
return nil
@@ -72,7 +72,7 @@ func makeSubscribeMetadataFunc(option *MetadataFollowOption, processEventFn Proc
UntilNs: option.StopTsNs,
})
if err != nil {
- return fmt.Errorf("subscribe: %v", err)
+ return fmt.Errorf("subscribe: %w", err)
}
for {