The periodic task system client for go.
go get -v github.com/Lupino/go-preiodic
worker
import "github.com/Lupino/go-periodic"
var periodicServer = "unix:///tmp/periodic.sock"
var worker = periodic.NewWorker()
worker.Connect(periodicServer)
func handle(job periodic.Job) {
job.Done()
// job.Fail()
// job.SchedLater(3)
}
worker.AddFunc("funcName", handle)
worker.Work()
client
import "github.com/Lupino/go-periodic"
var periodicServer = "unix:///tmp/periodic.sock"
var client = periodic.NewClient()
client.Connect(periodicServer)
client.SubmitJob(...)
example see here