batchqueue

package

v1.1.0 Latest Latest Go to latest Published: Apr 30, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type BatchQueue[T any] struct {
	Name         string
	MaxBatchSize int
	FlushTimeout time.Duration
	// contains filtered or unexported fields
}

func New[T any](name string, size int, batchSize int, flushTimeout time.Duration) *BatchQueue[T]

func (q *BatchQueue[T]) Add(ctx context.Context, item T)

func (q *BatchQueue[T]) Close()

func (q *BatchQueue[T]) Consume(handler Handler[T])

type Handler[T any] func(context.Context, []T)

type Item[T any] struct {
	// contains filtered or unexported fields
}