diff options
Diffstat (limited to 'weed/replication')
| -rw-r--r-- | weed/replication/replicator.go | 2 | ||||
| -rw-r--r-- | weed/replication/sink/filersink/fetch_write.go | 4 | ||||
| -rw-r--r-- | weed/replication/sink/s3sink/s3_sink.go | 2 | ||||
| -rw-r--r-- | weed/replication/sub/notification_aws_sqs.go | 2 | ||||
| -rw-r--r-- | weed/replication/sub/notification_kafka.go | 2 |
5 files changed, 6 insertions, 6 deletions
diff --git a/weed/replication/replicator.go b/weed/replication/replicator.go index 57aa63e5f..654725725 100644 --- a/weed/replication/replicator.go +++ b/weed/replication/replicator.go @@ -84,7 +84,7 @@ func (r *Replicator) Replicate(ctx context.Context, key string, message *filer_p err = r.sink.DeleteEntry(key, message.OldEntry.IsDirectory, false, message.Signatures) if err != nil { - return fmt.Errorf("delete old entry %v: %v", key, err) + return fmt.Errorf("delete old entry %v: %w", key, err) } glog.V(4).Infof("creating missing %v", key) diff --git a/weed/replication/sink/filersink/fetch_write.go b/weed/replication/sink/filersink/fetch_write.go index 4bcbc7898..1f257941f 100644 --- a/weed/replication/sink/filersink/fetch_write.go +++ b/weed/replication/sink/filersink/fetch_write.go @@ -94,7 +94,7 @@ func (fs *FilerSink) fetchAndWrite(sourceChunk *filer_pb.FileChunk, path string) uploader, err := operation.NewUploader() if err != nil { glog.V(0).Infof("upload source data %v: %v", sourceChunk.GetFileIdString(), err) - return "", fmt.Errorf("upload data: %v", err) + return "", fmt.Errorf("upload data: %w", err) } fileId, uploadResult, err, _ := uploader.UploadWithRetry( @@ -128,7 +128,7 @@ func (fs *FilerSink) fetchAndWrite(sourceChunk *filer_pb.FileChunk, path string) if err != nil { glog.V(0).Infof("upload source data %v: %v", sourceChunk.GetFileIdString(), err) - return "", fmt.Errorf("upload data: %v", err) + return "", fmt.Errorf("upload data: %w", err) } if uploadResult.Error != "" { glog.V(0).Infof("upload failure %v: %v", filename, err) diff --git a/weed/replication/sink/s3sink/s3_sink.go b/weed/replication/sink/s3sink/s3_sink.go index 279108e16..28428545b 100644 --- a/weed/replication/sink/s3sink/s3_sink.go +++ b/weed/replication/sink/s3sink/s3_sink.go @@ -118,7 +118,7 @@ func (s3sink *S3Sink) initialize(awsAccessKeyId, awsSecretAccessKey string) erro sess, err := session.NewSession(config) if err != nil { - return fmt.Errorf("create aws session: %v", err) + return fmt.Errorf("create aws session: %w", err) } s3sink.conn = s3.New(sess) diff --git a/weed/replication/sub/notification_aws_sqs.go b/weed/replication/sub/notification_aws_sqs.go index 7fc5c3f46..5eb42c2aa 100644 --- a/weed/replication/sub/notification_aws_sqs.go +++ b/weed/replication/sub/notification_aws_sqs.go @@ -50,7 +50,7 @@ func (k *AwsSqsInput) initialize(awsAccessKeyId, awsSecretAccessKey, region, que sess, err := session.NewSession(config) if err != nil { - return fmt.Errorf("create aws session: %v", err) + return fmt.Errorf("create aws session: %w", err) } k.svc = sqs.New(sess) diff --git a/weed/replication/sub/notification_kafka.go b/weed/replication/sub/notification_kafka.go index 92f7ce609..4f5304cf6 100644 --- a/weed/replication/sub/notification_kafka.go +++ b/weed/replication/sub/notification_kafka.go @@ -135,7 +135,7 @@ func loadProgress(offsetFile string) *KafkaProgress { func (progress *KafkaProgress) saveProgress() error { data, err := json.Marshal(progress) if err != nil { - return fmt.Errorf("failed to marshal progress: %v", err) + return fmt.Errorf("failed to marshal progress: %w", err) } err = util.WriteFile(progress.offsetFile, data, 0640) if err != nil { |