Versions in this module Expand all Collapse all v1 v1.4.0 Dec 13, 2020 v1.2.0 Oct 22, 2020 Changes in this version + func InitJobPool(beforeCloseCallback func()) error v1.1.0 Oct 14, 2020 v1.0.3 Sep 5, 2020 Changes in this version + func GetJob(name string) (*job, error) + func NewJob(name, persistentPath string, num int64, conn *radix.Pool, handler handlerFn) *job + type Message struct + Data interface{} + Id string