Faktory worker

main.go

package main

import (
	"context"
	"log"
	"os"

	worker "github.com/contribsys/faktory_worker_go"
)

func main() {

	// Expects FAKTORY_URL to be set in the environment
	// example: FAKTORY_URL=tcp://:password@localhost:7419
	if os.Getenv("FAKTORY_URL") == "" {
		log.Fatal("FAKTORY_URL must be set in the environment")
	}

	mgr := worker.NewManager()

	// Pick a name for the jobtype you will listen to, and provide a
	// callback function that does the work.
	mgr.Register("ExampleJobFunction", jobFunction)

	// Carefully consider the concurrency your worker process should support
	mgr.Concurrency = 1

	// One of the Process*Queues methods should be called before Run()
	mgr.ProcessStrictPriorityQueues("critical", "default", "bulk")
	mgr.Run()
}

func jobFunction(ctx context.Context, args ...interface{}) error {
	// Your job is called with a flat list of arguments. It is up to you to
	// parse these, or ignore them. If you want key-value pairs, the
	// caller process could do something like this:
	//
	// foo=baz, foo2=baz2 ...
	//
	// ... and your worker could split the args and use them, or hand them
	// to a subprocess, which acceps environment variables of this form.
	help := worker.HelperFor(ctx)
	log.Printf("Working on job %s\n", help.Jid())

	return nil
}