goworker

Mar 6, 2025

Changes in this version

+ func RegisterDecoder(decoder decoderFunc)

+ func Signals() <-chan bool

type WorkerSettings

+ Ctx context.Context

+ ForcePrune bool

+ Logger seelog.LoggerInterface

+ Redis *redis.Client

+ RetryDelay string

+ SkipTLSVerify bool

+ TLSCertPath string

Mar 29, 2017

Changes in this version

+ func Enqueue(job *Job) error

+ func SetSettings(settings WorkerSettings)

+ type Job struct

+ Payload Payload

+ Queue string

+ type WorkerSettings struct

+ Concurrency int

+ Connections int

+ ExitOnComplete bool

+ Interval intervalFlag

+ IntervalFloat float64

+ IsStrict bool

+ Namespace string

+ Queues queuesFlag

+ QueuesString string

+ URI string

+ UseNumber bool

Mar 16, 2015

Changes in this version

+ func Close()

+ func Init() error

+ func Namespace() string

+ func PutConn(conn *RedisConn)

+ type Payload struct

+ Args []interface{}

+ Class string

+ type RedisConn struct

+ func GetConn() (*RedisConn, error)

+ func (r *RedisConn) Close()

Sep 17, 2013

Changes in this version

+ func Register(class string, worker workerFunc)

+ func Work() error