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

clean up waitgroup usage

Browse Source
This commit is contained in:
nyanotech 2024-04-04 22:46:42 -07:00
parent c2bc4cacc9
commit e735423715
Signed by: nyanotech
GPG Key ID: D2D0A9E8F160472B
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
main.go
View File

@ -31,7 +31,7 @@ func main() {
cfg, err := config.LoadDefaultConfig(context.TODO(), cfg, err := config.LoadDefaultConfig(context.TODO(),
// just a placeholder because it needs to be defined // just a placeholder because it needs to be defined
// should be using teh one from the endpoint regardless // should be using the one from the endpoint regardless
config.WithRegion("us-east-1"), config.WithRegion("us-east-1"),
config.WithEndpointResolver(aws.EndpointResolverFunc( config.WithEndpointResolver(aws.EndpointResolverFunc(
func(service, region string) (aws.Endpoint, error) { func(service, region string) (aws.Endpoint, error) {
@ -60,7 +60,10 @@ func main() {
for _, item := range page.Contents { for _, item := range page.Contents {
wg.Add(1) wg.Add(1)
go checkAndRenewObjectLock(svc, *item.Key) go func(svc *s3.Client, key string) {
defer wg.Done()
checkAndRenewObjectLock(svc, key)
}(svc, *item.Key)
} }
} }
@ -68,8 +71,6 @@ func main() {
} }
func checkAndRenewObjectLock(svc *s3.Client, object string) { func checkAndRenewObjectLock(svc *s3.Client, object string) {
defer wg.Done()
retention, err := svc.GetObjectRetention(context.TODO(), &s3.GetObjectRetentionInput{ retention, err := svc.GetObjectRetention(context.TODO(), &s3.GetObjectRetentionInput{
Bucket: bucket, Bucket: bucket,
Key: &object, Key: &object,