FORK: allow bucket root query strings in minio

Signed-off-by: Mathew Wicks <[email protected]> (cherry picked from commit 8c00970) (cherry picked from commit 54742ca)
deployKF · Apr 21, 2024 · a4633e8 · a4633e8
1 parent b976ce5
commit a4633e8
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/v2/objectstore/object_store.go b/v2/objectstore/object_store.go
@@ -50,6 +50,14 @@ func OpenBucket(ctx context.Context, k8sClient kubernetes.Interface, namespace s
 		}
 	}()
 	if config.Scheme == "minio://" {
+		// if a query string is set, change schema to `s3://` and open the bucket directly
+		// they are probably using: https://gocloud.dev/howto/blob/#s3-compatible
+		if len(config.QueryString) > 0 {
+			bucketURL := config.bucketURL()
+			bucketURL = strings.Replace(bucketURL, "minio://", "s3://", 1)
+			return blob.OpenBucket(ctx, bucketURL)
+		}
+
 		cred, err := getMinioCredential(ctx, k8sClient, namespace)
 		if err != nil {
 			return nil, fmt.Errorf("Failed to get minio credential: %w", err)