batcher

type Batcher ¶

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

Batcher is a one to many event batcher. It batches events and sends them to the added event channel subscribers. Events are sent to the channels after the interval has elapsed. If events with the same key are received within the interval, the timer is reset.

func New[K comparable, T any](opts Options) *Batcher[K, T]

func (b *Batcher[K, T]) Batch(key K, value T)

func (b *Batcher[K, T]) Close()

func (b *Batcher[K, T]) Subscribe(ctx context.Context, ch ...chan<- T)

type Options ¶ added in v0.15.2

type Options struct {
	Interval time.Duration
	Clock    clock.Clock
}