aboutsummaryrefslogtreecommitdiff
path: root/weed/remote_storage
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2021-08-08 22:30:36 -0700
committerChris Lu <chris.lu@gmail.com>2021-08-08 22:30:36 -0700
commitc5f38c365d7d5cd4dc74e5cafefc0c461a0d478e (patch)
tree3e36e477503bd355e1a3d43af7a462eb653735d4 /weed/remote_storage
parentdf85f7a1ebf81e1f8fe8bed5089bf5be71d7c76f (diff)
downloadseaweedfs-c5f38c365d7d5cd4dc74e5cafefc0c461a0d478e.tar.xz
seaweedfs-c5f38c365d7d5cd4dc74e5cafefc0c461a0d478e.zip
go fmt
Diffstat (limited to 'weed/remote_storage')
-rw-r--r--weed/remote_storage/s3/s3_storage_client.go10
1 files changed, 5 insertions, 5 deletions
diff --git a/weed/remote_storage/s3/s3_storage_client.go b/weed/remote_storage/s3/s3_storage_client.go
index 5be64406e..5292f4bc4 100644
--- a/weed/remote_storage/s3/s3_storage_client.go
+++ b/weed/remote_storage/s3/s3_storage_client.go
@@ -174,13 +174,13 @@ func toTagging(attributes map[string][]byte) *s3.Tagging {
func (s *s3RemoteStorageClient) readFileRemoteEntry(loc *filer_pb.RemoteStorageLocation) (*filer_pb.RemoteEntry, error) {
resp, err := s.conn.HeadObject(&s3.HeadObjectInput{
- Bucket: aws.String(loc.Bucket),
- Key: aws.String(loc.Path[1:]),
+ Bucket: aws.String(loc.Bucket),
+ Key: aws.String(loc.Path[1:]),
})
if err != nil {
return nil, err
}
-
+
return &filer_pb.RemoteEntry{
LastModifiedAt: resp.LastModified.Unix(),
Size: *resp.ContentLength,
@@ -200,8 +200,8 @@ func (s *s3RemoteStorageClient) UpdateFileMetadata(loc *filer_pb.RemoteStorageLo
})
} else {
_, err = s.conn.DeleteObjectTagging(&s3.DeleteObjectTaggingInput{
- Bucket: aws.String(loc.Bucket),
- Key: aws.String(loc.Path[1:]),
+ Bucket: aws.String(loc.Bucket),
+ Key: aws.String(loc.Path[1:]),
})
}
return