nyanotech/object-holder
1
0
Fork 0
mirror of https://github.com/nyanotech/object-holder.git synced 2025-12-16 11:30:24 -08:00
Code Issues Packages Projects Releases Wiki Activity

accept region via flag, use default aws endpoint if unspecified

Browse Source
This commit is contained in:
nyanotech 2024-04-08 22:03:07 -07:00
parent fbf4229e96
commit 68d8130c4e
Signed by: nyanotech
GPG Key ID: D2D0A9E8F160472B
1 changed files with 13 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
main.go
View File

@ -15,13 +15,14 @@ import (
)
var endpoint = flag.String("endpoint", "", "s3 endpoint")
var bucket = flag.String("bucket", "", "bucket name")
var prefix = flag.String("prefix", "", "only operate on objects starting with this prefix")
var region = flag.String("region", "us-east-1", "s3 region")
// todo - default to other credentials providers
var accessKeyId = flag.String("access-key-id", "", "aws access key")
var secretAccessKey = flag.String("secret-access-key", "", "aws secret key")
var bucket = flag.String("bucket", "", "bucket name")
var prefix = flag.String("prefix", "", "only operate on objects starting with this prefix")
var updateExpiresWithin = flag.Int("update-expires-within", 0, "only update objects whose lock expires within this many seconds (default 0)")
var lockFor = flag.Int("lock-for", 90*24*3600, "how many seconds to renew the object lock for (default 90 days)")
@ -32,25 +33,25 @@ func main() {
options := []func(*config.LoadOptions) error{}
options = append(options,
// TODO: figure out what to do with this
config.WithRegion("us-east-1"),
config.WithEndpointResolverWithOptions(aws.EndpointResolverWithOptionsFunc(
if *region != "" {
options = append(options, config.WithRegion(*region))
}
if *endpoint != "" {
options = append(options, config.WithEndpointResolverWithOptions(aws.EndpointResolverWithOptionsFunc(
func(service, region string, options ...interface{}) (aws.Endpoint, error) {
return aws.Endpoint{
URL: *endpoint,
}, nil
},
)),
)
)))
}
if *accessKeyId != "" && *secretAccessKey != "" {
options = append(options, config.WithCredentialsProvider(credentials.NewStaticCredentialsProvider(*accessKeyId, *secretAccessKey, "")))
}
cfg, err := config.LoadDefaultConfig(context.TODO(),
options...,
)
cfg, err := config.LoadDefaultConfig(context.TODO(), options...)
if err != nil {
log.Fatalln("Failed to create AWS config", err)
}