semerrgroup

package
v0.92.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 27, 2018 License: MIT Imports: 1 Imported by: 0

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

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL