39 lines
773 B
Go
39 lines
773 B
Go
|
package main
|
||
|
|
||
|
import (
|
||
|
"log"
|
||
|
"os"
|
||
|
|
||
|
minio "github.com/minio/minio-go"
|
||
|
)
|
||
|
|
||
|
var minioClient *minio.Client
|
||
|
|
||
|
func init() {
|
||
|
var err error
|
||
|
|
||
|
s3Endpoint := os.Getenv("S3_ENDPOINT")
|
||
|
if len(s3Endpoint) == 0 {
|
||
|
s3Endpoint = "s3.amazonaws.com"
|
||
|
}
|
||
|
|
||
|
s3AccessKeyID := os.Getenv("S3_ACCESS_KEY_ID")
|
||
|
if len(s3AccessKeyID) == 0 {
|
||
|
log.Fatalln("Please set S3_ACCESS_KEY_ID")
|
||
|
}
|
||
|
|
||
|
s3SecretAccessKey := os.Getenv("S3_SECRET_ACCESS_KEY")
|
||
|
if len(s3SecretAccessKey) == 0 {
|
||
|
log.Fatalln("Please set S3_SECRET_ACCESS_KEY")
|
||
|
}
|
||
|
|
||
|
if os.Getenv("V2_SIGNING") == "true" {
|
||
|
minioClient, err = minio.NewV2(s3Endpoint, s3AccessKeyID, s3SecretAccessKey, true)
|
||
|
} else {
|
||
|
minioClient, err = minio.New(s3Endpoint, s3AccessKeyID, s3SecretAccessKey, true)
|
||
|
}
|
||
|
if err != nil {
|
||
|
log.Fatalln(err)
|
||
|
}
|
||
|
}
|