Versions in this module Expand all Collapse all v0 v0.6.3 May 27, 2021 v0.6.2 Jan 28, 2021 Changes in this version + var ErrFull = errors.New("fanout: chan full") + type Fanout struct + func New(name string, opts ...Option) *Fanout + func (c *Fanout) Close() error + func (c *Fanout) Do(ctx context.Context, f func(ctx context.Context)) (err error) + type Option func(*options) + func Buffer(n int) Option + func Worker(n int) Option
Go to main page