batch

Documentation

Index

• type Batch
  • func New(ctx context.Context, opts ...Option) (*Batch, context.Context)
  • func (b *Batch) Go(key string, fn func() (interface{}, error))
  • func (b *Batch) Result() map[string]Result
  • func (b *Batch) Wait() *Error
  • func (b *Batch) WaitAndGetResult() (map[string]Result, *Error)
• type Error
• type Option
  • func WithConcurrencyNum(n int) Option
• type Result

Types

type Batch

type Batch struct {
	// contains filtered or unexported fields
}

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

func New

func New(ctx context.Context, opts ...Option) (*Batch, context.Context)

func (*Batch) Go

func (b *Batch) Go(key string, fn func() (interface{}, error))

func (*Batch) Result

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

func (*Batch) Wait

func (b *Batch) Wait() *Error

func (*Batch) WaitAndGetResult

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

type Error

type Error struct {
	Key string
	Err error
}

type Option

type Option = func(b *Batch)

func WithConcurrencyNum

func WithConcurrencyNum(n int) Option

type Result

type Result struct {
	Value interface{}
	Err   error
}