From 9937a575d17a8bea80b24e306f54573cb7bc55da Mon Sep 17 00:00:00 2001
From: withchao <993506633@qq.com>
Date: Thu, 24 Aug 2023 13:48:48 +0800
Subject: [PATCH] fix: minio bucket url

---
 pkg/common/db/s3/minio/minio.go | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/pkg/common/db/s3/minio/minio.go b/pkg/common/db/s3/minio/minio.go
index 1f848d1b4..bfe40a594 100644
--- a/pkg/common/db/s3/minio/minio.go
+++ b/pkg/common/db/s3/minio/minio.go
@@ -77,15 +77,15 @@ func NewMinio() (s3.Interface, error) {
 		return nil, err
 	}
 	m := &Minio{
-		bucket:    conf.Bucket,
-		bucketURL: conf.Endpoint + "/" + conf.Bucket + "/",
-		core:      &minio.Core{Client: client},
-		lock:      &sync.Mutex{},
-		init:      false,
+		bucket: conf.Bucket,
+		core:   &minio.Core{Client: client},
+		lock:   &sync.Mutex{},
+		init:   false,
 	}
 	if conf.SignEndpoint == "" || conf.SignEndpoint == conf.Endpoint {
 		m.opts = opts
 		m.sign = m.core.Client
+		m.bucketURL = conf.Endpoint + "/" + conf.Bucket + "/"
 	} else {
 		su, err := url.Parse(conf.SignEndpoint)
 		if err != nil {
@@ -99,6 +99,7 @@ func NewMinio() (s3.Interface, error) {
 		if err != nil {
 			return nil, err
 		}
+		m.bucketURL = conf.SignEndpoint + "/" + conf.Bucket + "/"
 	}
 	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
 	defer cancel()