concurrency

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

type BatchingChannel[T any] interface {
	In() chan<- T
	Out() <-chan []T
}

type BufferedConcurrentChannel[T any] interface {
	In() chan<- T
	Run(context.Context, func(T)) error
}

type KeyedLimiter interface {
	Allow(key string) bool
	Wait(ctx context.Context, key string) error
}