Skip to content

Commit 84d9e58

Browse files
committed
fix: add api upload object
1 parent 3fa9e76 commit 84d9e58

1 file changed

Lines changed: 5 additions & 1 deletion

File tree

pkg/obs/minio/minio.go

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@ package minio
22

33
import (
44
"context"
5+
"io"
56
"os"
67

78
log "github.com/eric-tech01/simple-log"
@@ -29,8 +30,11 @@ func (c *MinioClient) UploadFile(filePath string, bucket string, keyName string)
2930
log.Error(err.Error())
3031
return err
3132
}
33+
return c.UploadFromReader(c.ctx, bucket, keyName, file, fileStat.Size())
34+
}
3235

33-
info, err := c.client.PutObject(c.ctx, bucket, keyName, file, fileStat.Size(), minio.PutObjectOptions{ContentType: "application/octet-stream"})
36+
func (c *MinioClient) UploadFromReader(ctx context.Context, bucketName, objectName string, reader io.Reader, objectSize int64) error {
37+
info, err := c.client.PutObject(c.ctx, bucketName, objectName, reader, objectSize, minio.PutObjectOptions{ContentType: "application/octet-stream"})
3438
if err != nil {
3539
log.Error(err.Error())
3640
return err

0 commit comments

Comments
 (0)