batch

Documentation

Index

• Variables
• type Batch
• type Batcher
• type BatcherFactory
  • func (b *BatcherFactory) NewBatcher(batchFactory func() Batch) Batcher

Variables

var ErrShuttingDown = errors.New("shutting down")

Types

type Batch

type Batch interface {
	CanAdd(any) bool
	Add(any)
	Size() int
	Complete()
	Fail(error)
}

type Batcher

type Batcher interface {
	io.Closer
	Add(request any)
	Run()
}

type BatcherFactory

type BatcherFactory struct {
	Linger              time.Duration
	MaxRequestsPerBatch int
}

func (*BatcherFactory) NewBatcher

func (b *BatcherFactory) NewBatcher(batchFactory func() Batch) Batcher