[chore] Use int64 for queue_size in the queuebatch.Config, simplifies conversions (#12745)

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

Author: bogdandrutu

exporter/exporterhelper/internal/queue_sender.go

@@ -58,7 +58,7 @@ type QueueConfig struct {
 	Sizer request.SizerType `mapstructure:"sizer"`
 
 	// QueueSize represents the maximum data size allowed for concurrent storage and processing.
-	QueueSize int `mapstructure:"queue_size"`
+	QueueSize int64 `mapstructure:"queue_size"`
 
 	// NumConsumers is the number of consumers from the queue.
 	NumConsumers int `mapstructure:"num_consumers"`

exporter/exporterhelper/internal/queuebatch/config.go

@@ -25,7 +25,7 @@ type Config struct {
 	Sizer request.SizerType `mapstructure:"sizer"`
 
 	// QueueSize represents the maximum data size allowed for concurrent storage and processing.
-	QueueSize int `mapstructure:"queue_size"`
+	QueueSize int64 `mapstructure:"queue_size"`
 
 	// BlockOnOverflow determines the behavior when the component's TotalSize limit is reached.
 	// If true, the component will wait for space; otherwise, operations will immediately return a retryable error.

exporter/exporterhelper/internal/queuebatch/queue_batch.go

@@ -58,14 +58,14 @@ func NewQueueBatch(
 	if cfg.StorageID == nil {
 		q = newAsyncQueue(newMemoryQueue[request.Request](memoryQueueSettings[request.Request]{
 			sizer:           sizer,
-			capacity:        int64(cfg.QueueSize),
+			capacity:        cfg.QueueSize,
 			waitForResult:   cfg.WaitForResult,
 			blockOnOverflow: cfg.BlockOnOverflow,
 		}), cfg.NumConsumers, b.Consume)
 	} else {
 		q = newAsyncQueue(newPersistentQueue[request.Request](persistentQueueSettings[request.Request]{
 			sizer:           sizer,
-			capacity:        int64(cfg.QueueSize),
+			capacity:        cfg.QueueSize,
 			blockOnOverflow: cfg.BlockOnOverflow,
 			signal:          qSet.Signal,
 			storageID:       *cfg.StorageID,