semerrgroup

Documentation

Overview

Package semerrgroup wraps an 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 NewBlockingFirst(g Group) Group
  • func NewSkipAware(g Group) Group

Types

type Group

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

Group is the Semaphore ErrorGroup itself.

func New

func New(size int) Group

New returns a new Group of a given size.

func NewBlockingFirst

func NewBlockingFirst(g Group) Group

NewBlockingFirst creates a new group that runs the first item, waiting for its return, and only then starts scheduling/running the other tasks.

func NewSkipAware

func NewSkipAware(g Group) Group

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