Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type JobManager ¶
type JobManager struct {
// contains filtered or unexported fields
}
JobManager manages set number of parallel running jobs and queues up extra incoming jobs.
func NewJobManager ¶
func NewJobManager(numWorkers int, log *logging.Logger) *JobManager
NewJobManager job manager factory
Click to show internal directories.
Click to hide internal directories.