// 配置客戶(hù)端的三個(gè)步驟
// 1. AccessKey and SecretKey : 創(chuàng)建Minio集群后獲取訪(fǎng)問(wèn)key和密鑰key
// 2. endpoint : Minio Cluster 訪(fǎng)問(wèn)地址
// 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存儲(chǔ)桶并配置桶通知
func CreateBucket(bucketName, mArn string, minioClient *minio.Client) error {
    // 1. 創(chuàng)建存儲(chǔ)桶
    ctx := context.Background()
    err := minioClient.MakeBucket(ctx, bucketName, minio.MakeBucketOptions{})
    if err!= nil {
        // 檢查存儲(chǔ)桶是否已存在，如果是因?yàn)橐汛嬖趯?dǎo)致的錯(cuò)誤則忽略
        exists, errBucketExists := minioClient.BucketExists(ctx, bucketName)
        if errBucketExists == nil && exists {
            fmt.Printf("存儲(chǔ)桶 %s 已存在，無(wú)需重復(fù)創(chuàng)建\n", bucketName)
            return nil
        }
        return fmt.Errorf("創(chuàng)建存儲(chǔ)桶失敗: %v", err)
    }
    fmt.Printf("存儲(chǔ)桶 %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è)置存儲(chǔ)桶通知失敗: %v", err)
    }
    fmt.Printf("存儲(chǔ)桶 %s 的通知配置成功\n", bucketName)

    return nil
}

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

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

    // 調(diào)用創(chuàng)建存儲(chǔ)桶并配置通知的函數(shù)
    err = CreateBucket(bucketName, mArn, minioClient)
    if err!= nil {
        log.Fatalf("執(zhí)行創(chuàng)建存儲(chǔ)桶及配置通知操作失敗: %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(""), // 這里可以指定前綴來(lái)限制規(guī)則應(yīng)用到特定前綴的對(duì)象，空字符串表示應(yīng)用到桶內(nèi)所有對(duì)象
        Expiration: lifecycle.Expiration{
            Days: &days, // 設(shè)置過(guò)期天數(shù)，對(duì)象創(chuàng)建后達(dá)到這個(gè)天數(shù)就會(huì)被自動(dòng)刪除
        },
    }

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

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

    fmt.Printf("存儲(chǔ)桶 %s 的過(guò)期策略設(shè)置成功，對(duì)象將在創(chuàng)建后 %d 天過(guò)期\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è)置對(duì)象30天后過(guò)期，你可以按需修改

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

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