From 3b853d0b8656d116798e31cffa2db4dab84724a2 Mon Sep 17 00:00:00 2001 From: Jeremy Shih Date: Mon, 28 Oct 2024 18:10:56 +0800 Subject: [PATCH] fix(minio): set life cycle config on existing bucket (#25) Because - life cycle rule config should be set on existing buckets This commit - set life cycle config on existing buckets --- minio/minio.go | 17 ++++++++--------- 1 file changed, 8 insertions(+), 9 deletions(-) diff --git a/minio/minio.go b/minio/minio.go index fc2a4ae..5a29cc8 100644 --- a/minio/minio.go +++ b/minio/minio.go @@ -67,17 +67,16 @@ func NewMinioClientAndInitBucket(ctx context.Context, cfg *Config, logger *zap.L } if exists { logger.Info("Bucket already exists", zap.String("bucket", cfg.BucketName)) - return &minio{client: client, bucket: cfg.BucketName}, nil + } else { + if err = client.MakeBucket(ctx, cfg.BucketName, miniogo.MakeBucketOptions{ + Region: Location, + }); err != nil { + logger.Error("creating Bucket failed", zap.Error(err)) + return nil, err + } + logger.Info("Successfully created bucket", zap.String("bucket", cfg.BucketName)) } - if err = client.MakeBucket(ctx, cfg.BucketName, miniogo.MakeBucketOptions{ - Region: Location, - }); err != nil { - logger.Error("creating Bucket failed", zap.Error(err)) - return nil, err - } - logger.Info("Successfully created bucket", zap.String("bucket", cfg.BucketName)) - lccfg := lifecycle.NewConfiguration() lccfg.Rules = []lifecycle.Rule{ {