batch

type Batch ¶

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

Batch similar to errgroup, but can control the maximum number of concurrent

func New[T any](ctx context.Context, opts ...Option[T]) (*Batch[T], context.Context)

func (b *Batch[T]) Go(key string, fn func() (T, error))

func (b *Batch[T]) Result() map[string]Result[T]

func (b *Batch[T]) Wait() *Error

func (b *Batch[T]) WaitAndGetResult() (map[string]Result[T], *Error)

type Error ¶

type Error struct {
	Key string
	Err error
}

type Option ¶

type Option[T any] func(b *Batch[T])

func WithConcurrencyNum[T any](n int) Option[T]

type Result ¶

type Result[T any] struct {
	Value T
	Err   error
}