workmen

Example demonstrating basic usage and core features of the library.

package main

import (
	"fmt"

	"github.com/michaelkrukov/workmen"
)

func main() {
	memoryDatabase := "file::memory:?mode=memory&cache=shared"

	// Create repository with sqlite3 in-memory database as jobs storage.
	repository := workmen.MakeRepository("sqlite3", memoryDatabase)

	// Create manager with maximum of 16 simultaneous jobs processing
	// and created repository.
	manager := workmen.MakeManager(16, repository)

	// Workaroud for using memory with connections pooling
	manager.Repository.SetMaxOpenConns(1)

	// Register processor for the specified job type. The processor accepts
	// Job and returns two values - job output and failure flag.
	manager.CreateJobType("echo", func(job workmen.Job) (string, bool) {
		return job.Input, false
	})

	// Reset all started jobs (worker wasn't running, that means that all
	// started jobs are never going to complete).
	manager.ResetStartedJobs()

	// Start the processing loop in the background.
	go manager.Loop()

	// Create job with specified type and input.
	job, _ := manager.CreateJob("echo", "msg")

	// Wait for manager to receive jobs at least once and wait
	// until it's finished processing received jobs. In real world you
	// probably should just use `manager.Stop()`.
	manager.PingAndStop()

	// You can get job from manager by it's ID. It will have
	// curent job's state. Jobs is just values.
	job, _ = manager.GetJob(job.ID)

	if job.Completed {
		fmt.Println(job.Output)
	} else {
		fmt.Println("Job is not completed")
	}

}

Output:

msg