async

Documentation

Index

• func Watcher(ctx context.Context, frequency time.Duration) *watcher
• type Job
  • func (job *Job) Do(action func() error, handler func(error))
  • func (job *Job) Wait()

Functions

func Watcher

func Watcher(ctx context.Context, frequency time.Duration) *watcher

Types

type Job

type Job sync.WaitGroup

A Job provides a top level API above the sync.WaitGroup.

job := new(async.Job)
for _, action := range jobs {
	job.Do(action, logger)
}
job.Wait()

It looks a little bit similar to the golang.org/x/sync/errgroup.

func (*Job) Do

func (job *Job) Do(action func() error, handler func(error))

Do calls the given function in a new goroutine. If an error is not nil, it passes it to the handler.

func (*Job) Wait

func (job *Job) Wait()

Wait blocks until the sync.WaitGroup counter is zero.