[chore] Change QueueBatch implementation to use the final config

Signed-off-by: Bogdan Drutu <[email protected]>

Author: bogdandrutu

exporter/exporterhelper/internal/queue_sender.go

@@ -51,7 +51,10 @@ func newQueueBatchConfig(qCfg exporterqueue.Config, bCfg exporterbatcher.Config)
 		QueueSize:       qCfg.QueueSize,
 		NumConsumers:    qCfg.NumConsumers,
 		BlockOnOverflow: qCfg.Blocking,
+<<<<<<< HEAD
 		StorageID:       qCfg.StorageID,
+=======
+>>>>>>> 918e0fb47 ([chore] Change QueueBatch implementation to use the final config)
 	}
 	if bCfg.Enabled {
 		qbCfg.Batch = &queuebatch.BatchConfig{

exporter/exporterhelper/internal/queuebatch/config.go

@@ -5,12 +5,27 @@ package queuebatch // import "go.opentelemetry.io/collector/exporter/exporterhel
 
 import (
 	"errors"
+	"runtime"
 	"time"
 
 	"go.opentelemetry.io/collector/component"
 	"go.opentelemetry.io/collector/exporter/exporterbatcher"
 )
 
+func NewDefaultConfig() Config {
+	return Config{
+		Enabled:         true,
+		Sizer:           exporterbatcher.SizerTypeItems,
+		NumConsumers:    runtime.NumCPU(),
+		QueueSize:       100_000,
+		BlockOnOverflow: true,
+		Batch: &BatchConfig{
+			FlushTimeout: 200 * time.Millisecond,
+			MinSize:      2048,
+		},
+	}
+}
+
 // Config defines configuration for queueing and batching incoming requests.
 type Config struct {
 	// Enabled indicates whether to not enqueue and batch before exporting.