[chore] Extract queue logic into a separate internal package (#13175)

Signed-off-by: Bogdan Drutu <bogdandrutu@gmail.com>

Author: bogdandrutu

Makefile

@@ -250,7 +250,7 @@ genpdata:
 	pushd pdata/ && $(GOCMD) run ./internal/cmd/pdatagen/main.go && popd
 	$(MAKE) fmt
 
-INTERNAL_PROTO_SRC_DIRS := exporter/exporterhelper/internal/queuebatch/internal/persistentqueue
+INTERNAL_PROTO_SRC_DIRS := exporter/exporterhelper/internal/queue
 # INTERNAL_PROTO_SRC_DIRS += path/to/other/proto/dirs
 INTERNAL_PROTO_FILES := $(foreach dir,$(INTERNAL_PROTO_SRC_DIRS),$(wildcard $(dir)/*.proto))
 INTERNAL_PROTOC := $(DOCKERCMD) run --rm -u ${shell id -u} -v${PWD}:${PWD} -w${PWD} ${DOCKER_PROTOBUF} --proto_path=${PWD} --go_out=${PWD}

…elper/internal/queuebatch/async_queue.go …rterhelper/internal/queue/async_queue.goexporter/exporterhelper/internal/queuebatch/async_queue.go renamed to exporter/exporterhelper/internal/queue/async_queue.go exporter/exporterhelper/internal/queuebatch/async_queue.go renamed to exporter/exporterhelper/internal/queue/async_queue.go

@@ -1,7 +1,7 @@
 // Copyright The OpenTelemetry Authors
 // SPDX-License-Identifier: Apache-2.0
 
-package queuebatch // import "go.opentelemetry.io/collector/exporter/exporterhelper/internal/queuebatch"
+package queue // import "go.opentelemetry.io/collector/exporter/exporterhelper/internal/queue"
 
 import (
 	"context"

…/internal/queuebatch/async_queue_test.go …elper/internal/queue/async_queue_test.goexporter/exporterhelper/internal/queuebatch/async_queue_test.go renamed to exporter/exporterhelper/internal/queue/async_queue_test.go exporter/exporterhelper/internal/queuebatch/async_queue_test.go renamed to exporter/exporterhelper/internal/queue/async_queue_test.go

@@ -1,7 +1,7 @@
 // Copyright The OpenTelemetry Authors
 // SPDX-License-Identifier: Apache-2.0
 
-package queuebatch
+package queue
 
 import (
 	"context"

…porterhelper/internal/queuebatch/cond.go …er/exporterhelper/internal/queue/cond.goexporter/exporterhelper/internal/queuebatch/cond.go renamed to exporter/exporterhelper/internal/queue/cond.go exporter/exporterhelper/internal/queuebatch/cond.go renamed to exporter/exporterhelper/internal/queue/cond.go

@@ -1,7 +1,7 @@
 // Copyright The OpenTelemetry Authors
 // SPDX-License-Identifier: Apache-2.0
 
-package queuebatch // import "go.opentelemetry.io/collector/exporter/exporterhelper/internal/queuebatch"
+package queue // import "go.opentelemetry.io/collector/exporter/exporterhelper/internal/queue"
 
 import (
 	"context"

…lper/internal/queuebatch/memory_queue.go …terhelper/internal/queue/memory_queue.goexporter/exporterhelper/internal/queuebatch/memory_queue.go renamed to exporter/exporterhelper/internal/queue/memory_queue.go exporter/exporterhelper/internal/queuebatch/memory_queue.go renamed to exporter/exporterhelper/internal/queue/memory_queue.go

@@ -1,7 +1,7 @@
 // Copyright The OpenTelemetry Authors
 // SPDX-License-Identifier: Apache-2.0
 
-package queuebatch // import "go.opentelemetry.io/collector/exporter/exporterhelper/internal/queuebatch"
+package queue // import "go.opentelemetry.io/collector/exporter/exporterhelper/internal/queue"
 
 import (
 	"context"

…internal/queuebatch/memory_queue_test.go …lper/internal/queue/memory_queue_test.goexporter/exporterhelper/internal/queuebatch/memory_queue_test.go renamed to exporter/exporterhelper/internal/queue/memory_queue_test.go exporter/exporterhelper/internal/queuebatch/memory_queue_test.go renamed to exporter/exporterhelper/internal/queue/memory_queue_test.go

@@ -1,7 +1,7 @@
 // Copyright The OpenTelemetry Authors
 // SPDX-License-Identifier: Apache-2.0
 
-package queuebatch
+package queue
 
 import (
 	"context"

exporter/exporterhelper/internal/queue/meta.pb.go

@@ -1,8 +1,8 @@
 syntax = "proto3";
 
-package opentelemetry.collector.exporter.exporterhelper.internal.queuebatch.internal.persistentqueue;
+package opentelemetry.collector.exporter.exporterhelper.internal.queue;
 
-option go_package = "go.opentelemetry.io/collector/exporter/exporterhelper/internal/queuebatch/internal/persistentqueue";
+option go_package = "go.opentelemetry.io/collector/exporter/exporterhelper/internal/queue";
 
 // Sizer type configuration
 enum SizerType {

…atch/internal/persistentqueue/meta.proto …exporterhelper/internal/queue/meta.protoexporter/exporterhelper/internal/queuebatch/internal/persistentqueue/meta.proto renamed to exporter/exporterhelper/internal/queue/meta.proto exporter/exporterhelper/internal/queuebatch/internal/persistentqueue/meta.proto renamed to exporter/exporterhelper/internal/queue/meta.proto

@@ -1,7 +1,7 @@
 // Copyright The OpenTelemetry Authors
 // SPDX-License-Identifier: Apache-2.0
 
-package queuebatch // import "go.opentelemetry.io/collector/exporter/exporterhelper/internal/queuebatch"
+package queue // import "go.opentelemetry.io/collector/exporter/exporterhelper/internal/queue"
 
 import (
 	"context"
@@ -15,7 +15,6 @@ import (
 
 	"go.opentelemetry.io/collector/component"
 	"go.opentelemetry.io/collector/exporter/exporterhelper/internal/experr"
-	"go.opentelemetry.io/collector/exporter/exporterhelper/internal/queuebatch/internal/persistentqueue"
 	"go.opentelemetry.io/collector/exporter/exporterhelper/internal/request"
 	"go.opentelemetry.io/collector/extension/xextension/storage"
 	"go.opentelemetry.io/collector/pipeline"
@@ -96,7 +95,7 @@ type persistentQueue[T any] struct {
 	mu              sync.Mutex
 	hasMoreElements *sync.Cond
 	hasMoreSpace    *cond
-	metadata        persistentqueue.QueueMetadata
+	metadata        QueueMetadata
 	refClient       int64
 	stopped         bool
 }

…/internal/queuebatch/persistent_queue.go …elper/internal/queue/persistent_queue.goexporter/exporterhelper/internal/queuebatch/persistent_queue.go renamed to exporter/exporterhelper/internal/queue/persistent_queue.go exporter/exporterhelper/internal/queuebatch/persistent_queue.go renamed to exporter/exporterhelper/internal/queue/persistent_queue.go

@@ -1,7 +1,7 @@
 // Copyright The OpenTelemetry Authors
 // SPDX-License-Identifier: Apache-2.0
 
-package queuebatch
+package queue
 
 import (
 	"context"