gitcollector

Sep 26, 2019

Changes in this version

type WorkerPoolOpts

+ ScheduleJobTimeout time.Duration

Jun 25, 2019

Changes in this version

+ var ErrJobSource = errors.NewKind("job source is closed")

+ var ErrNewJobsNotFound = errors.NewKind("couldn't find new jobs to schedule")

+ var ErrProviderStop = errors.NewKind("provider failed on stop")

+ var ErrProviderStopped = errors.NewKind("provider stopped")

+ type Job interface

+ Process func(context.Context) error

+ type JobScheduleFn func(context.Context) (Job, error)

+ type MetricsCollector interface

+ Discover func(Job)

+ Fail func(Job)

+ Start func()

+ Stop func(immediate bool)

+ Success func(Job)

+ type Provider interface

+ Start func() error

+ Stop func() error

+ type WorkerPool struct

+ func NewWorkerPool(schedule JobScheduleFn, opts *WorkerPoolOpts) *WorkerPool

+ func (wp *WorkerPool) Close()

+ func (wp *WorkerPool) Run()

+ func (wp *WorkerPool) SetWorkers(n int)

+ func (wp *WorkerPool) Size() int

+ func (wp *WorkerPool) Stop()

+ func (wp *WorkerPool) Wait()

+ type WorkerPoolOpts struct

+ Metrics MetricsCollector

+ NotWaitNewJobs bool

+ SchedulerCapacity int

+ WaitJobTimeout time.Duration

+ WaitNewJobTimeout time.Duration