neoris/core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix check for existing bucket

Browse Source
This commit is contained in:
Ingo Oppermann 2022-08-20 10:51:17 +03:00
parent e4fc61617a
commit 9a49e371e3
No known key found for this signature in database
GPG Key ID: 2AB32426E9DD229E
1 changed files with 12 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
io/fs/s3.go
View File

@ -76,18 +76,20 @@ func NewS3Filesystem(config S3Config) (Filesystem, error) {
ctx, cancel := context.WithDeadline(context.Background(), time.Now().Add(30*time.Second))
defer cancel()
err = client.MakeBucket(ctx, fs.bucket, minio.MakeBucketOptions{Region: fs.region})
if err != nil {
exists, errBucketExists := client.BucketExists(ctx, fs.bucket)
if errBucketExists != nil {
return nil, err
}
exists, errBucketExists := client.BucketExists(ctx, fs.bucket)
if errBucketExists != nil {
return nil, err
}
if exists {
fs.logger.Debug().Log("Bucket already exists")
}
if exists {
fs.logger.Debug().Log("Bucket already exists")
} else {
fs.logger.Debug().Log("Bucket created")
err = client.MakeBucket(ctx, fs.bucket, minio.MakeBucketOptions{Region: fs.region})
if err != nil {
return nil, err
} else {
fs.logger.Debug().Log("Bucket created")
}
}
fs.client = client