batcher

Documentation

Index

• type Batcher
  • func NewBatcher[T any](nlimit int, tlimit time.Duration, handler func([]T)) *Batcher[T]
  • func (b *Batcher[T]) Done() <-chan struct{}
  • func (b *Batcher[T]) HasStopped() <-chan struct{}
  • func (b *Batcher[T]) Push(item T) bool
  • func (b *Batcher[T]) Run()
  • func (b *Batcher[T]) Stop()

Types

type Batcher

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

func NewBatcher

func NewBatcher[T any](nlimit int, tlimit time.Duration, handler func([]T)) *Batcher[T]

func (*Batcher[T]) Done

func (b *Batcher[T]) Done() <-chan struct{}

func (*Batcher[T]) HasStopped

func (b *Batcher[T]) HasStopped() <-chan struct{}

func (*Batcher[T]) Push

func (b *Batcher[T]) Push(item T) bool

func (*Batcher[T]) Run

func (b *Batcher[T]) Run()

func (*Batcher[T]) Stop

func (b *Batcher[T]) Stop()