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 (s *Group) Go(fn func() error)
  • func (s *Group) Wait() error

Types

type Group

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

Group is the Semphore ErrorGroup itself

func New

func New(size int) *Group

New returns a new Group of a given size.

func (*Group) Go

func (s *Group) Go(fn func() error)

Go execs one function respecting the group and semaphore.

func (*Group) Wait

func (s *Group) Wait() error

Wait waits for the group to complete and return an error if any.