feat: Batcher.Add made variadic to allow passing of multiple points

influxdb3/batching/batcher.go

@@ -103,13 +103,13 @@ func NewBatcher(options ...Option) *Batcher {
 	return b
 }
 
-// Add a metric to the batcher and call the given callbacks if any
-func (b *Batcher) Add(p *influxdb3.Point) {
+// Add metric(s) to the batcher and call the given callbacks if any
+func (b *Batcher) Add(p ...*influxdb3.Point) {
 	b.Lock()
 	defer b.Unlock()
 
 	// Add the point
-	b.points = append(b.points, p)
+	b.points = append(b.points, p...)
 
 	// Call callbacks if a new batch is ready
 	if b.isReady() {

influxdb3/batching/batcher_test.go

@@ -79,9 +79,8 @@ func TestReady(t *testing.T) {
 		WithSize(batchSize),
 	)
 
-	for range batchSize {
-		b.Add(&influxdb3.Point{})
-	}
+	points := []*influxdb3.Point{{}, {}, {}, {}, {}}
+	b.Add(points...)
 
 	assert.True(t, b.Ready(), "Batcher should be ready when the batch size is reached")
 }
@@ -115,13 +114,13 @@ func TestPartialEmit(t *testing.T) {
 		}),
 	)
 
-	b.Add(&influxdb3.Point{})
+	b.Add(&influxdb3.Point{}, &influxdb3.Point{})
 	b.Add(&influxdb3.Point{})
 
 	points := b.Emit()
 
 	assert.False(t, emitted, "Emit callback should not have been called automatically")
-	assert.Len(t, points, 2, "Emit should return all points when batch size is not reached")
+	assert.Len(t, points, 3, "Emit should return all points when batch size is not reached")
 }
 
 func TestThreadSafety(t *testing.T) {