A Simple boltDB based Worker which can be used with gobuffalo's background worker interface.
Suitable for managing background tasks for single standalone binaries.
Works with grift tasks of your buffalo app
w := actions.App().Worker
w.Perform(worker.Job{
Queue: "default",
Handler: "send_mail",
Args: worker.Args{
"user_id": 123,
},
})The task will be performed by the background workers spawned by your buffalo App server
Default boltWorker can be configured by providing a DB filepath
import "github.com/astutic/boltWorker"
// ...
buffalo.New(buffalo.Options {
// ...
Worker: boltworker.NewBoltWorker(boltworker.Options{
FilePath: "worker.db",
MaxConcurrency: 10,
}),
// ...
})The following options can be configured for boltWorker
FilePath is where the boltDB will be created/accessed. Must Have parameter.
Boltoptions are options which can be passed for boltDB
Logger if passed will be used for logging, else a logrus TextFormatter with InfoLevel will be used
Name is for future use if any. Default value is 'buffalo'
MaxConcurrency determines how many workers will be spawned. Default is 10.
Name of the bucket where completed jobs will be saved. Default 'completed'.
Name of the bucket where jobs which are incomplete will be saved. Default 'pending'.
Name of the bucket where jobs which fail will be saved. Default 'failed'.
A time.Duration string used as in interval to sync boltDB to read jobs from the DB. Default '30s'.
Number of attempts for jobs which return RetryJobError after which the job will be declared failed. Default 10.
A time.Duration string which determines the sleep time when there are no jobs in the Queue. Default '5s'
A function of type ***func(worker.Job) string** which will be called to set the key of the job.
Default is UUID version 4 generator
type JobNameGenerator func(worker.Job) string
func DefaultJobNameGenerator(job worker.Job) string {
return uuid.Must(uuid.NewV4()).String()
}An example
import "github.com/gobuffalo/uuid"
jn := func(job worker.Job) string {
return job.Args.String()
}
app = buffalo.New(buffalo.Options{
// ...
Worker: boltworker.NewBoltWorker(boltworker.Options{
FilePath: "worker.db",
MaxConcurrency: 5,
JobNameHandler: jn,
}),
//...
})- Not developed for performance.
- Not optimized for memory, Holds the entire DB in memory.
- Not suitable for large and/or distributed workloads.
- No Live updates to the boltDB about the working status, the DB is only updated after the job is performed.
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent