Update storage.go to suit s3

pull/361/head
overBaker 2 years ago committed by GitHub
parent b534032325
commit b74ffde782
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

@ -21,6 +21,9 @@ import (
"github.com/rocboss/paopao-ce/internal/core" "github.com/rocboss/paopao-ce/internal/core"
"github.com/sirupsen/logrus" "github.com/sirupsen/logrus"
"github.com/tencentyun/cos-go-sdk-v5" "github.com/tencentyun/cos-go-sdk-v5"
"github.com/aws/aws-sdk-go/aws"
"github.com/aws/aws-sdk-go/aws/session"
"github.com/aws/aws-sdk-go/service/s3"
) )
func MustAliossService() (core.ObjectStorageService, core.VersionInfo) { func MustAliossService() (core.ObjectStorageService, core.VersionInfo) {
@ -229,11 +232,8 @@ func MustMinioService() (core.ObjectStorageService, core.VersionInfo) {
} }
func MustS3Service() (core.ObjectStorageService, core.VersionInfo) { func MustS3Service() (core.ObjectStorageService, core.VersionInfo) {
// Initialize s3 client object use minio-go. // Initialize AWS S3 client object.
client, err := minio.New(conf.S3Setting.Endpoint, &minio.Options{ client, err := s3.NewClient(conf.S3Setting.Region, conf.S3Setting.AccessKey, conf.S3Setting.SecretKey)
Creds: credentials.NewStaticV4(conf.S3Setting.AccessKey, conf.S3Setting.SecretKey, ""),
Secure: conf.S3Setting.Secure,
})
if err != nil { if err != nil {
logrus.Fatalf("storage.MustS3Service create client failed: %s", err) logrus.Fatalf("storage.MustS3Service create client failed: %s", err)
} }

Loading…
Cancel
Save