fanout

Documentation

Index

• type Fanout
  • 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 WithBuffer(n int) Option
  • func WithWorker(n int) Option

Types

type Fanout

type Fanout struct {
	// contains filtered or unexported fields
}

Fanout async consume data from chan.

func New

func New(name string, opts ...Option) *Fanout

New new a fanout struct.

func (*Fanout) Close

func (c *Fanout) Close() error

Close close fanout.

func (*Fanout) Do

func (c *Fanout) Do(ctx context.Context, f func(ctx context.Context)) error

Do save a callback func.

type Option

type Option func(*options)

Option is fanout option.

func WithBuffer

func WithBuffer(n int) Option

WithBuffer with the buffer of fanout.

func WithWorker

func WithWorker(n int) Option

WithWorker with the worker of fanout.