status-im
/
go-s3up
mirror of https://github.com/status-im/go-s3up.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

prametrize concurrency of uploader 

Signed-off-by: Jakub Sokołowski <jakub@status.im>
This commit is contained in:
Jakub Sokołowski 2022-01-12 18:39:35 +01:00
parent 09f8d76dd3
commit 7dd471bb78
No known key found for this signature in database
GPG Key ID: 4EF064D0E6D63020
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
main.go
View File

@ -23,6 +23,7 @@ var (
endpoint string
keyid string
secret string
threads int
)
const helpMessage string = `
@ -51,6 +52,7 @@ func flagsInit() {
flag.StringVar(&endpoint, "endpoint", envVar("AWS_DEFAULT_ENDPOINT", "ams3.digitaloceanspaces.com"), "S3 API endpoint.")
flag.StringVar(&keyid, "keyid", envVar("AWS_ACCESS_KEY_ID", ""), "API key ID.")
flag.StringVar(&secret, "secret", envVar("AWS_SECRET_ACCESS_KEY", ""), "API secret key.")
flag.IntVar(&threads, "threads", 5, "Number of concurrent threads used for upload.")
flag.Parse()
}
@ -88,6 +90,8 @@ func main() {
Bucket: aws.String(bucket),
Key: aws.String(target),
Body: file,
}, func(u *s3manager.Uploader) {
u.Concurrency = threads
})
if err != nil {
l.Println("Failed to upload file: ", err)