Merge pull request #1530 from itpey/main

Add MaxRetry for MinIO operations

Author: ReneWerner87

minio/README.md

@@ -94,6 +94,10 @@ type Config struct {
     // Optional. Default is false
     Reset bool
 
+    // The maximum number of times requests that encounter retryable failures should be attempted.
+    // Optional. Default is 10, same as the MinIO client.
+    MaxRetry int
+
     // Credentials Minio access key and Minio secret key.
     // Need to be defined
     Credentials Credentials
@@ -124,6 +128,7 @@ var ConfigDefault = Config{
     Token:               "",
     Secure:              false,
     Reset:               false,
+
     Credentials:         Credentials{},
     GetObjectOptions:    minio.GetObjectOptions{},
     PutObjectOptions:    minio.PutObjectOptions{},

minio/config.go

@@ -29,6 +29,10 @@ type Config struct {
 	// Optional. Default is false
 	Reset bool
 
+	// The maximum number of times requests that encounter retryable failures should be attempted.
+	// Optional. Default is 10, same as the MinIO client.
+	MaxRetry int
+
 	// Credentials Minio access key and Minio secret key.
 	// Need to be defined
 	Credentials Credentials
@@ -62,6 +66,7 @@ var ConfigDefault = Config{
 	Token:               "",
 	Secure:              false,
 	Reset:               false,
+	MaxRetry:            minio.MaxRetry,
 	Credentials:         Credentials{},
 	GetObjectOptions:    minio.GetObjectOptions{},
 	PutObjectOptions:    minio.PutObjectOptions{},
@@ -84,5 +89,9 @@ func configDefault(config ...Config) Config {
 		cfg.Bucket = ConfigDefault.Bucket
 	}
 
+	if cfg.MaxRetry < 1 {
+		cfg.MaxRetry = ConfigDefault.MaxRetry
+	}
+
 	return cfg
 }

minio/minio.go

@@ -28,6 +28,9 @@ func New(config ...Config) *Storage {
 	// Set default config
 	cfg := configDefault(config...)
 
+	// Set MaxRetry
+	minio.MaxRetry = cfg.MaxRetry
+
 	// Minio instance
 	minioClient, err := minio.New(cfg.Endpoint, &minio.Options{
 		Creds:  credentials.NewStaticV4(cfg.Credentials.AccessKeyID, cfg.Credentials.SecretAccessKey, cfg.Token),