|
|
@ -24,7 +24,7 @@ func (s3sink *S3Sink) deleteObject(key string) error { |
|
|
|
result, err := s3sink.conn.DeleteObject(input) |
|
|
|
|
|
|
|
if err == nil { |
|
|
|
glog.V(0).Infof("[%s] delete %s: %v", s3sink.bucket, key, result) |
|
|
|
glog.V(2).Infof("[%s] delete %s: %v", s3sink.bucket, key, result) |
|
|
|
} else { |
|
|
|
glog.Errorf("[%s] delete %s: %v", s3sink.bucket, key, err) |
|
|
|
} |
|
|
@ -43,7 +43,7 @@ func (s3sink *S3Sink) createMultipartUpload(key string, entry *filer_pb.Entry) ( |
|
|
|
result, err := s3sink.conn.CreateMultipartUpload(input) |
|
|
|
|
|
|
|
if err == nil { |
|
|
|
glog.V(0).Infof("[%s] createMultipartUpload %s: %v", s3sink.bucket, key, result) |
|
|
|
glog.V(2).Infof("[%s] createMultipartUpload %s: %v", s3sink.bucket, key, result) |
|
|
|
} else { |
|
|
|
glog.Errorf("[%s] createMultipartUpload %s: %v", s3sink.bucket, key, err) |
|
|
|
return "", err |
|
|
@ -94,7 +94,7 @@ func (s3sink *S3Sink) completeMultipartUpload(ctx context.Context, key, uploadId |
|
|
|
|
|
|
|
result, err := s3sink.conn.CompleteMultipartUpload(input) |
|
|
|
if err == nil { |
|
|
|
glog.V(1).Infof("[%s] completeMultipartUpload %s: %v", s3sink.bucket, key, result) |
|
|
|
glog.V(2).Infof("[%s] completeMultipartUpload %s: %v", s3sink.bucket, key, result) |
|
|
|
} else { |
|
|
|
glog.Errorf("[%s] completeMultipartUpload %s: %v", s3sink.bucket, key, err) |
|
|
|
return fmt.Errorf("[%s] completeMultipartUpload %s: %v", s3sink.bucket, key, err) |
|
|
@ -123,7 +123,7 @@ func (s3sink *S3Sink) uploadPart(key, uploadId string, partId int, chunk *filer. |
|
|
|
|
|
|
|
result, err := s3sink.conn.UploadPart(input) |
|
|
|
if err == nil { |
|
|
|
glog.V(0).Infof("[%s] uploadPart %s %d upload: %v", s3sink.bucket, key, partId, result) |
|
|
|
glog.V(2).Infof("[%s] uploadPart %s %d upload: %v", s3sink.bucket, key, partId, result) |
|
|
|
} else { |
|
|
|
glog.Errorf("[%s] uploadPart %s %d upload: %v", s3sink.bucket, key, partId, err) |
|
|
|
} |
|
|
|