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 Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. 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 Source Files ¶ View all Source files lazy_send.go model.go pool.go run.go sched.go send.go stop.go Click to show internal directories. Click to hide internal directories.