Method UploadFile

storage/object_storage_client.go:30–66

(ctx context.Context, bucketName string, objectKey string, fileName string)

}

func (basics *Bucket) UploadFile(ctx context.Context, bucketName string, objectKey string, fileName string) (*int64, error) {
	fileInfo, err := os.Stat(fileName)
	if err != nil {
		return nil, fmt.Errorf("Couldn't get file info for %v. Here's why: %v\n", fileName, err)
	}

	file, err := os.Open(fileName)
	if err != nil {
		return nil, fmt.Errorf("Couldn't open file %v to upload. Here's why: %v\n", fileName, err)
	} else {
		defer file.Close()

		uploader := manager.NewUploader(basics.S3Client, func(u *manager.Uploader) {
			u.PartSize = uploadPartSize
		})

		_, err := uploader.Upload(ctx, &s3.PutObjectInput{
			Bucket: aws.String(bucketName),
			Key:    aws.String(objectKey),
			Body:   file,
		})

		if err != nil {
			var mu manager.MultiUploadFailure
			if errors.As(err, &mu) {
				return nil, fmt.Errorf("Error while uploading object to %s.\n"+
					"The UploadId is %s. Error is %v\n", bucketName, mu.UploadID(), err)
			} else {
				return nil, fmt.Errorf("Error while uploading object to %s.\n"+
					"Error is %v\n", bucketName, err)
			}
		}

		fileSize := fileInfo.Size()
		return &fileSize, nil
	}
}

func (basics *Bucket) DownloadFile(ctx context.Context, bucketName string, objectKey string, fileName string) (*int64, error) {
	f, err := os.Create(fileName)