batch

type Options struct {
	Interval    time.Duration // Interval after which writing happens
	MaxItems    int           // MaxItems specifies number of items in a queue to be written
	MaxCapacity int           // MaxCapacity capacity of channel before locking
}

type Worker[T any] interface {
	// Start starts worker
	Start(ctx context.Context)
	// Write calls to pass a single item to be written
	Write(ctx context.Context, item *T)
	// Close closes worker
	Close(ctx context.Context)
}

type Writer[T any] interface {
	// Write writes batch items somewhere
	Write(ctx context.Context, items []*T) error
}