// 配置客戶端的三個步驟
// 1. AccessKey and SecretKey : 創(chuàng)建Minio集群后獲取訪問key和密鑰key
// 2. endpoint : Minio Cluster 訪問地址
// 3. useSSL : 是否需要SSL 檢查 ? (true or false)
import  "github.com/minio/minio-go/v7"

func getMinioClient(accessKey string, secretKey string, endpoint string, 
                     useSSL bool)(*minio.Client, error) {
 // Context you want to use
 context := context.Background()
 minioClient, err := getMinioClient(accessKey, secretKey, endpoint, useSsl)
 return minioClient, err
}

set MINIO_NOTIFY_WEBHOOK_ENABLE_PRIMARY=”on”
set MINIO_NOTIFY_WEBHOOK_ENDPOINT_PRIMARY=”ENDPOINT”

package main

import (
    "context"
    "fmt"
    "log"

    "github.com/minio/minio-go/v7"
    "github.com/minio/minio-go/v7/pkg/notification"
)

// CreateBucket創(chuàng)建Minio存儲桶并配置桶通知
func CreateBucket(bucketName, mArn string, minioClient *minio.Client) error {
    // 1. 創(chuàng)建存儲桶
    ctx := context.Background()
    err := minioClient.MakeBucket(ctx, bucketName, minio.MakeBucketOptions{})
    if err!= nil {
        // 檢查存儲桶是否已存在，如果是因為已存在導(dǎo)致的錯誤則忽略
        exists, errBucketExists := minioClient.BucketExists(ctx, bucketName)
        if errBucketExists == nil && exists {
            fmt.Printf("存儲桶 %s 已存在，無需重復(fù)創(chuàng)建\n", bucketName)
            return nil
        }
        return fmt.Errorf("創(chuàng)建存儲桶失敗: %v", err)
    }
    fmt.Printf("存儲桶 %s 創(chuàng)建成功\n", bucketName)

    // 2. 配置桶通知
    arn, err := notification.NewArnFromString(mArn)
    if err!= nil {
        return fmt.Errorf("解析ARN失敗: %v", err)
    }

    config := notification.NewConfig(arn)
    config.AddEvents(
        notification.ObjectCreatedAll,
        notification.ObjectRemovedAll,
        notification.ObjectAccessedAll,
    )

    notificationConfig := notification.Configuration{}
    notificationConfig.AddQueue(config)

    err = minioClient.SetBucketNotification(ctx, bucketName, &notificationConfig)
    if err!= nil {
        return fmt.Errorf("設(shè)置存儲桶通知失敗: %v", err)
    }
    fmt.Printf("存儲桶 %s 的通知配置成功\n", bucketName)

    return nil
}

func main() {
    // Minio服務(wù)端的訪問端點、訪問密鑰和秘密密鑰
    endpoint := "your_minio_endpoint"
    accessKey := "your_access_key"
    secretKey := "your_secret_key"
    bucketName := "your_bucket_name"
    mArn := "your_webhook_arn"

    // 創(chuàng)建Minio客戶端對象
    minioClient, err := minio.New(endpoint, &minio.Options{
        Credentials: minio.Credentials{
            AccessKey: accessKey,
            SecretKey: secretKey,
        },
    })
    if err!= nil {
        log.Fatalf("創(chuàng)建Minio客戶端失敗: %v", err)
    }

    // 調(diào)用創(chuàng)建存儲桶并配置通知的函數(shù)
    err = CreateBucket(bucketName, mArn, minioClient)
    if err!= nil {
        log.Fatalf("執(zhí)行創(chuàng)建存儲桶及配置通知操作失敗: %v", err)
    }
}

func ReadObject(bucketName string, filePath string)([]byte, error) {
     contentBuffer, err := minioClient.GetObject(context, bucketName, filePath, minio.GetObjectOptions{})
     if err != nil {
       return nil, err
     }

     // read the content from the buffer
     contentBytes := new(bytes.Buffer)
     if _, err := io.Copy(contentBytes, contentBuffer); err != nil {
      return nil, err
     }
     return contentBytes.Bytes(), nil
}

func uploadObject(bucketName string, objectName string, file *os.File) error {
    // get the stat of file
    fileStat, err := file.Stat()
    if err != nil {
    	return err
    }

    // upload the file
    uploadInfo, err := minioClient.PutObject(
        context, 
        bucketName, 
        objectName, 
        file, 
        fileStat.Size(), 
        minio.PutObjectOptions{})

    fmt.Printf("Uploaded Info : %v", uploadInfo)
    return err
}

import (
    "context"
    "fmt"
    "log"

    "github.com/minio/minio-go/v7"
    "github.com/minio/minio-go/v7/pkg/lifecycle"
)

func SetBucketLifecycle(bucketName string, days int, minioClient *minio.Client) error {
    ctx := context.Background()

    // 構(gòu)建生命周期配置規(guī)則
    rule := lifecycle.NewRule{
        ID:     "rule1",
        Status: "Enabled",
        Filter: lifecycle.NewPrefixFilter(""), // 這里可以指定前綴來限制規(guī)則應(yīng)用到特定前綴的對象，空字符串表示應(yīng)用到桶內(nèi)所有對象
        Expiration: lifecycle.Expiration{
            Days: &days, // 設(shè)置過期天數(shù)，對象創(chuàng)建后達到這個天數(shù)就會被自動刪除
        },
    }

    // 將規(guī)則添加到生命周期配置對象中
    config := lifecycle.NewConfiguration()
    config.Rules = append(config.Rules, rule)

    // 使用Minio客戶端設(shè)置存儲桶的生命周期配置（即過期策略）
    err := minioClient.SetBucketLifecycle(ctx, bucketName, config)
    if err!= nil {
        return fmt.Errorf("設(shè)置存儲桶 %s 生命周期配置失敗: %v", bucketName, err)
    }

    fmt.Printf("存儲桶 %s 的過期策略設(shè)置成功，對象將在創(chuàng)建后 %d 天過期\n", bucketName, days)
    return nil
}

func main() {
    endpoint := "your_minio_endpoint"
    accessKey := "your_access_key"
    secretKey := "your_secret_key"
    bucketName := "your_bucket_name"
    days := 30 // 這里假設(shè)設(shè)置對象30天后過期，你可以按需修改

    // 創(chuàng)建Minio客戶端實例
    minioClient, err := minio.New(endpoint, &minio.Options{
        Credentials: minio.Credentials{
            AccessKey: accessKey,
            SecretKey: secretKey,
        },
    })
    if err!= nil {
        log.Fatalf("創(chuàng)建Minio客戶端失敗: %v", err)
    }

    // 調(diào)用函數(shù)設(shè)置存儲桶過期策略
    err = SetBucketLifecycle(bucketName, days, minioClient)
    if err!= nil {
        log.Fatalf("設(shè)置存儲桶過期策略時出現(xiàn)錯誤: %v", err)
    }
}