chore: migrate workerpool in its own package (#2444)

* chore: migrate workerpool in its own package

* fix

Author: remyleone

internal/workerpool.go renamed to internal/workerpool/workerpool.go

@@ -1,23 +1,21 @@
-package internal
+package workerpool
 
-import (
-	"sync"
-)
+import "sync"
 
-type WorkerPoolTask func() error
+type Task func() error
 
 type WorkerPool struct {
-	tasksToDispatch   chan WorkerPoolTask
-	tasksToRun        chan WorkerPoolTask
+	tasksToDispatch   chan Task
+	tasksToRun        chan Task
 	errors            []error
 	errorsMutex       sync.Mutex
 	tasksWaitingGroup sync.WaitGroup
 }
 
 func NewWorkerPool(size int) *WorkerPool {
 	p := &WorkerPool{
-		tasksToDispatch: make(chan WorkerPoolTask),
-		tasksToRun:      make(chan WorkerPoolTask, size),
+		tasksToDispatch: make(chan Task),
+		tasksToRun:      make(chan Task, size),
 	}
 
 	for i := 0; i < size; i++ {
@@ -30,7 +28,7 @@ func NewWorkerPool(size int) *WorkerPool {
 }
 
 func (p *WorkerPool) dispatcher() {
-	var pendingTasks []WorkerPoolTask
+	var pendingTasks []Task
 
 	for {
 		if len(pendingTasks) > 0 {
@@ -75,7 +73,7 @@ func (p *WorkerPool) worker() {
 	}
 }
 
-func (p *WorkerPool) AddTask(task WorkerPoolTask) {
+func (p *WorkerPool) AddTask(task Task) {
 	p.tasksWaitingGroup.Add(1)
 	p.tasksToDispatch <- task
 }

internal/workerpool_test.go renamed to internal/workerpool/workerpool_test.go

@@ -1,4 +1,4 @@
-package internal
+package workerpool
 
 import (
 	"errors"

scaleway/helpers_object.go

@@ -25,7 +25,7 @@ import (
 	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/logging"
 	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
 	"github.com/scaleway/scaleway-sdk-go/scw"
-	"github.com/scaleway/terraform-provider-scaleway/v2/internal"
+	"github.com/scaleway/terraform-provider-scaleway/v2/internal/workerpool"
 )
 
 const (
@@ -375,7 +375,7 @@ func deleteS3ObjectVersions(ctx context.Context, conn *s3.S3, bucketName string,
 	}
 
 	listErr := conn.ListObjectVersionsPagesWithContext(ctx, listInput, func(page *s3.ListObjectVersionsOutput, _ bool) bool {
-		pool := internal.NewWorkerPool(deletionWorkers)
+		pool := workerpool.NewWorkerPool(deletionWorkers)
 
 		for _, objectVersion := range page.Versions {
 			objectVersion := objectVersion
@@ -420,7 +420,7 @@ func deleteS3ObjectVersions(ctx context.Context, conn *s3.S3, bucketName string,
 	}
 
 	listErr = conn.ListObjectVersionsPagesWithContext(ctx, listInput, func(page *s3.ListObjectVersionsOutput, _ bool) bool {
-		pool := internal.NewWorkerPool(deletionWorkers)
+		pool := workerpool.NewWorkerPool(deletionWorkers)
 
 		for _, deleteMarkerEntry := range page.DeleteMarkers {
 			deleteMarkerEntry := deleteMarkerEntry