semerrgroup

Documentation

Overview

Package semerrgroup wraps a error group with a semaphore with configurable size, so you can control the number of tasks being executed simultaneously.

Index

• type Group
  • func New(size int) Group
  • func NewSkipAware(g Group) Group

Types

type Group

type Group interface {
	Go(func() error)
	Wait() error
}

Group is the Semphore ErrorGroup itself.

func New

func New(size int) Group

New returns a new Group of a given size.

func NewSkipAware

func NewSkipAware(g Group) Group

NewSkipAware returns a new Group of a given size and aware of pipe skips.