curlew

Oct 27, 2019

Changes in this version

type Dispatcher

+ func (d *Dispatcher) NewWorker() *Worker

Sep 24, 2019

Changes in this version

type Dispatcher

+ func (d *Dispatcher) EnableDebug()

Sep 20, 2019

Changes in this version

type Dispatcher

+ func (d *Dispatcher) Submit(j *Job)

type Worker

+ func (w *Worker) IsClosed() bool

Aug 17, 2019

Changes in this version

+ type Handler func(ctx context.Context, arg interface{}) error

Aug 12, 2019

Changes in this version

+ type Dispatcher struct

+ JobSize int

+ MaxJobRunningTimeout time.Duration

+ MaxWorkerNum int

+ WorkerIdleTimeout time.Duration

+ WorkerPool chan *Worker

+ func New(setters ...Setter) (*Dispatcher, error)

+ func (d *Dispatcher) Add(w *Worker)

+ func (d *Dispatcher) Remove(w *Worker)

+ func (d *Dispatcher) RunningWorkerNum() int

+ func (d *Dispatcher) SubmitAsync(j *Job)

+ type Handle func(ctx context.Context, arg interface{}) error

+ type Job struct

+ Arg interface{}

+ Fn Handle

+ func NewJob() *Job

+ type Monitor func(j *Job, err error)

+ type Setter func(d *Dispatcher) error

+ func WithJobSize(size int) Setter

+ func WithMaxWorkerNum(num int) Setter

+ func WithMonitor(monitor Monitor) Setter

+ func WithWorkerIdleTimeout(t time.Duration) Setter

+ type Worker struct

+ Jobs chan *Job

+ func NewWorker(d *Dispatcher) *Worker

+ func (w *Worker) LastBusyTime() time.Time

+ func (w *Worker) Running() bool

+ func (w *Worker) SetLastBusyTime()

+ func (w *Worker) SetRunning(b bool)