batcher

Documentation

Index

• type Batcher
  • func NewBatcher[K comparable, V any](config Config[K, V]) *Batcher[K, V]
  • func (b *Batcher[K, V]) Queue(key K, value V)
• type Config

Types

type Batcher

type Batcher[K comparable, V any] struct {
	// contains filtered or unexported fields
}

func NewBatcher

func NewBatcher[K comparable, V any](config Config[K, V]) *Batcher[K, V]

func (*Batcher[K, V]) Queue

func (b *Batcher[K, V]) Queue(key K, value V)

type Config

type Config[K comparable, V any] struct {
	Context      context.Context
	MaxBatchSize int
	Interval     time.Duration
	Process      func(context.Context, K, []V)
}