🐧 Add use legacy list flag

Signed-off-by: Rintaro Okamura <rintaro.okamura@gmail.com>
vdaas · May 19, 2020 · bd77569 · bd77569
1 parent f2e0675
commit bd77569
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 1 deletion.
diff --git a/internal/config/blob.go b/internal/config/blob.go
@@ -58,6 +58,7 @@ type S3Config struct {
 	AccessKey       string `json:"access_key" yaml:"access_key"`
 	SecretAccessKey string `json:"secret_access_key" yaml:"secret_access_key"`
 	Token           string `json:"token" yaml:"token"`
+	UseLegacyList   bool   `json:"use_legacy_list" yaml:"use_legacy_list"`
 }
 
 func (b *Blob) Bind() *Blob {

diff --git a/internal/db/storage/blob/s3/option.go b/internal/db/storage/blob/s3/option.go
@@ -51,3 +51,9 @@ func WithToken(tk string) Option {
 		s.token = tk
 	}
 }
+
+func WithUseLegacyList(flg bool) Option {
+	return func(s *sess) {
+		s.useLegacyList = flg
+	}
+}
diff --git a/internal/db/storage/blob/s3/s3.go b/internal/db/storage/blob/s3/s3.go
@@ -31,6 +31,7 @@ type sess struct {
 	accessKey       string
 	secretAccessKey string
 	token           string
+	useLegacyList   bool
 }
 
 type Session interface {
@@ -68,7 +69,7 @@ func (s *sess) URLOpener() (*URLOpener, error) {
 	return &URLOpener{
 		ConfigProvider: session,
 		Options: s3blob.Options{
-			UseLegacyList: false,
+			UseLegacyList: s.useLegacyList,
 		},
 	}, nil
 }