wpool

Documentation

Index

• type Event
• type Options
• type Pool
  • func New(options Options) *Pool
  • func (p *Pool) Run(ctx context.Context)
  • func (p *Pool) Sched(ctx context.Context, e Event, period time.Duration)
  • func (p *Pool) Send(ctx context.Context, e Event)
  • func (p *Pool) Stop()
• type RunFunc

Types

type Event

type Event struct {
	Caller string
	Fn     RunFunc
	// contains filtered or unexported fields
}

type Options

type Options struct {
	NumWorkers   int
	SendDuration time.Duration
}

type Pool

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

func New

func New(options Options) *Pool

func (*Pool) Run

func (p *Pool) Run(ctx context.Context)

func (*Pool) Sched

func (p *Pool) Sched(ctx context.Context, e Event, period time.Duration)

func (*Pool) Send

func (p *Pool) Send(ctx context.Context, e Event)

func (*Pool) Stop

func (p *Pool) Stop()

type RunFunc

type RunFunc func(ctx context.Context) error