Fix: minio init
This commit is contained in:
@@ -2,19 +2,20 @@ package utils
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
"os"
|
|
||||||
|
|
||||||
"github.com/minio/minio-go/v7"
|
"github.com/minio/minio-go/v7"
|
||||||
|
"github.com/spf13/viper"
|
||||||
)
|
)
|
||||||
|
|
||||||
func InitMinIO(ctx context.Context, mc *minio.Client) error {
|
func InitMinIO(ctx context.Context, mc *minio.Client) error {
|
||||||
MINIO_BUCKET := os.Getenv("MINIO_BUCKET")
|
err := mc.MakeBucket(ctx,
|
||||||
|
viper.GetString("minio-bucket"),
|
||||||
err := mc.MakeBucket(ctx, MINIO_BUCKET, minio.MakeBucketOptions{
|
minio.MakeBucketOptions{
|
||||||
Region: "us-east-1",
|
Region: "us-east-1",
|
||||||
})
|
})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
exists, errBucketExists := mc.BucketExists(ctx, MINIO_BUCKET)
|
exists, errBucketExists := mc.BucketExists(ctx,
|
||||||
|
viper.GetString("minio-bucket"))
|
||||||
if errBucketExists != nil || !exists {
|
if errBucketExists != nil || !exists {
|
||||||
return errBucketExists
|
return errBucketExists
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user