Versions in this module Expand all Collapse all v0 v0.0.1 Aug 16, 2015 Changes in this version + const JOB_STATUS_PREFIX + type ConnectionOptions struct + Addr string + DB int64 + DialTimeout time.Duration + IdleTimeout time.Duration + MaxRetries int + Password string + PoolSize int + PoolTimeout time.Duration + ReadTimeout time.Duration + WriteTimeout time.Duration + type ErrorHandler func(error) + type Job struct + ID string + JSON string + Status *Status + func (j *Job) GetStatus() error + func (j *Job) SetStatus(code, progress uint8) error + type Options struct + Concurrency uint8 + Connection *ConnectionOptions + ErrorHandler ErrorHandler + Processor Processor + QueueName string + type Processor func(*Job) + type Queue struct + func New(opt *Options) *Queue + func (q *Queue) Enqueue(jobJSON string) (string, error) + func (q *Queue) QueueStatus() (*QueueStatus, error) + func (q *Queue) Run() + type QueueStatus struct + QueueLength int64 + type Status struct + Code uint8 + Progress uint8
Go to main page