Versions in this module Expand all Collapse all v1 v1.2.1 May 30, 2024 Changes in this version + 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)) error + type Option func(*options) + func WithBuffer(n int) Option + func WithWorker(n int) Option
Go to main page