README
¶
wq, a basic Worker Queue in Go
Example
fn := func(key string) error { ... }
nb, err := wq.Queue(
8, // number of workers
fn, // payload function
[]string{"key1", ...},
)
Detailed usage
conf := wq.NewConfig(workers)
job, err := conf.NewJob(fn, tasks)
if err != nil {
...
}
job.Print()
ok := job.Run() // ok is the number of successful tasks
...
About
This project was originally written in 2015 while playing with Go.
It was a very simple worker/queue where the payload for each job will update state in a SQL database, later rewritten without the database/sql dependency.
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrNoJob = errors.New("nothing to do")
ErrNoJob is the error used when there is nothing to do.
Functions ¶
Types ¶
type Config ¶
type Config struct {
Workers int // number of workers
Verbose bool // verbose flag
WaitBeforeStart bool // wait 3 seconds before starting
ProgressBar bool // display progress bar
}
Config describes the configuration of a job queue.
type Job ¶
type Job struct {
// contains filtered or unexported fields
}
Job defines a list of tasks to execute.
Source Files
Click to show internal directories.
Click to hide internal directories.