quentin/s3lat
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Fix bug

Browse source
This commit is contained in:
Quentin 2021-12-07 18:26:16 +01:00
parent c16070cae9
commit 8713253df0
Signed by: quentin
GPG key ID: A98E9B769E4FF428
1 changed files with 22 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

31
main.go
View file

@ -11,6 +11,7 @@ import (
"strings" "strings"
"net/http" "net/http"
"crypto/tls" "crypto/tls"
"strconv"
"github.com/minio/minio-go/v7" "github.com/minio/minio-go/v7"
"github.com/minio/minio-go/v7/pkg/credentials" "github.com/minio/minio-go/v7/pkg/credentials"
@ -22,12 +23,21 @@ import (
func main() { func main() {
mc, err := minio.New(os.Getenv("ENDPOINT"), &minio.Options{ _, isSSL := os.LookupEnv("SSL");
opts := minio.Options {
Creds: credentials.NewStaticV4(os.Getenv("AWS_ACCESS_KEY_ID"), os.Getenv("AWS_SECRET_ACCESS_KEY"), ""), Creds: credentials.NewStaticV4(os.Getenv("AWS_ACCESS_KEY_ID"), os.Getenv("AWS_SECRET_ACCESS_KEY"), ""),
Secure: true, Secure: isSSL,
Region: os.Getenv("REGION"), }
Transport: &http.Transport{TLSClientConfig: &tls.Config{InsecureSkipVerify: true}},
}) if region, ok := os.LookupEnv("REGION"); ok {
opts.Region = region
}
if _, ok := os.LookupEnv("SSL_INSECURE"); ok {
opts.Transport = &http.Transport{TLSClientConfig: &tls.Config{InsecureSkipVerify: true}}
}
mc, err := minio.New(os.Getenv("ENDPOINT"), &opts)
if err != nil { if err != nil {
log.Fatal("failed connect", err) log.Fatal("failed connect", err)
@ -46,9 +56,10 @@ func main() {
} }
for i := 0; i < 100; i++ { for i := 0; i < 100; i++ {
content := string(i) + " hello world " + string(i) istr := strconv.Itoa(i)
content := istr + " hello world " + istr
start := time.Now() start := time.Now()
_, err := mc.PutObject(context.Background(), "bench1", "element"+string(i), strings.NewReader(content), int64(len(content)), minio.PutObjectOptions{ContentType:"application/octet-stream"}) _, err := mc.PutObject(context.Background(), "bench1", "element"+istr, strings.NewReader(content), int64(len(content)), minio.PutObjectOptions{ContentType:"application/octet-stream"})
elapsed := time.Since(start) elapsed := time.Since(start)
if err != nil { if err != nil {
log.Fatal("failed putObject: ",err) log.Fatal("failed putObject: ",err)
@ -76,8 +87,9 @@ func main() {
} }
for i := 0; i < 100; i++ { for i := 0; i < 100; i++ {
istr := strconv.Itoa(i)
start := time.Now() start := time.Now()
object, err := mc.GetObject(context.Background(), "bench1", "element"+string(i), minio.GetObjectOptions{}) object, err := mc.GetObject(context.Background(), "bench1", "element"+istr, minio.GetObjectOptions{})
if err != nil { if err != nil {
log.Fatal(err) log.Fatal(err)
return return
@ -91,8 +103,9 @@ func main() {
} }
for i := 0; i < 100; i++ { for i := 0; i < 100; i++ {
istr := strconv.Itoa(i)
start := time.Now() start := time.Now()
err = mc.RemoveObject(context.Background(), "bench1", "element"+string(i), minio.RemoveObjectOptions{}) err = mc.RemoveObject(context.Background(), "bench1", "element"+istr, minio.RemoveObjectOptions{})
elapsed := time.Since(start) elapsed := time.Since(start)
if err != nil { if err != nil {
log.Fatal(err) log.Fatal(err)