poc

exporter/exporterbatcher/batcher.go

@@ -0,0 +1,35 @@
+// Copyright The OpenTelemetry Authors
+// SPDX-License-Identifier: Apache-2.0
+
+package exporterbatcher // import "go.opentelemetry.io/collector/exporter/exporterbatcher"
+
+// type Batcher[T any] struct {
+// 	batches batch*
+
+// 	flushTimeout int // TODO
+// 	flushFunc func(req T) err
+// }
+
+// func (b *Batcher[T]) FlushIfNecessary() error {
+//     mu.Lock()
+
+// 	var batchToExport
+// 	var now = time.Now()
+// 	if now - lastFlushTime > flushTimeout || activeBatch.size() > minBatchSize {
+// 		lastFlushTime = now
+// 		batchToExport = activeBatch
+// 		activeBatch = pendingBatches[0]
+// 		pendingBatches = pendingBatches[1:]
+// 	}
+// 	qc.timer.Reset(batcher.FlushTimeout)
+// 	mu.Unlock()
+// 	flushFunc(req)
+// }
+
+
+// func (b *Batcher[T]) Push(item T) error {
+// 	if maxSize != 0 && batches[0].size() + item.size() > maxSize:
+// 		sdlfj
+
+
+// }