Implemented sized channel with size -1

exporter/exporterhelper/internal/base_exporter.go

@@ -103,7 +103,7 @@ func NewBaseExporter(set exporter.Settings, signal pipeline.Signal, osf ObsrepSe
 
 	if usePullingBasedExporterQueueBatcher.IsEnabled() && be.BatcherCfg.Enabled && !be.queueCfg.Enabled {
 		be.queueFactory = exporterqueue.NewBlockingMemoryQueueFactory[internal.Request]()
-		be.queueCfg.QueueSize = 20
+		be.queueCfg.QueueSize = -1
 		q := be.queueFactory(
 			context.Background(),
 			exporterqueue.Settings{

exporter/exporterqueue/sized_channel.go

@@ -12,6 +12,7 @@ type sizedChannel[T any] struct {
 
 	// We need to store the capacity in a separate field because the capacity of the channel can be higher.
 	// It happens when we restore a persistent queue from a disk that is bigger than the pre-configured capacity.
+	// If cap is set to -1, sizedChannel
 	cap int64
 	ch  chan T
 }
@@ -45,7 +46,7 @@ func newSizedChannel[T any](capacity int64, els []T, totalSize int64) *sizedChan
 // If the callback returns an error, the element is not put into the queue and the error is returned.
 // The size is the size of the element MUST be positive.
 func (vcq *sizedChannel[T]) push(el T, size int64, callback func() error) error {
-	if vcq.used.Add(size) > vcq.cap {
+	if vcq.cap != -1 && vcq.used.Add(size) > vcq.cap {
 		vcq.used.Add(-size)
 		return ErrQueueIsFull
 	}
@@ -62,6 +63,10 @@ func (vcq *sizedChannel[T]) push(el T, size int64, callback func() error) error
 	case vcq.ch <- el:
 		return nil
 	default:
+		if vcq.cap == -1 {
+			vcq.ch <- el
+			return nil
+		}
 		vcq.used.Add(-size)
 		return ErrQueueIsFull
 	}