Versions in this module Expand all Collapse all v0 v0.1.1 Jul 22, 2022 v0.1.0 Jul 22, 2022 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