batch

Documentation

Index

• type Batch
  • 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
  • func (e *Error) Error() string
• type Option
  • func WithConcurrencyNum[T any](n int) Option[T]
• type Result

Types

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

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

func (*Batch[T]) Go

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

func (*Batch[T]) Result

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

func (*Batch[T]) Wait

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

func (*Batch[T]) WaitAndGetResult

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

type Error

type Error struct {
	Key string
	Err error
}

func (*Error) Error

func (e *Error) Error() string

type Option

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

func WithConcurrencyNum

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

type Result

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