Documentation ¶
Index ¶
- type AddOptions
- type GetOptions
- type Job
- type Pool
- func (p *Pool) Ack(jobs ...Job) error
- func (p *Pool) Add(q, job string, t time.Duration, o *AddOptions) (string, error)
- func (p *Pool) FastAck(jobs ...Job) error
- func (p *Pool) Get(o *GetOptions, q ...string) ([]Job, error)
- func (p *Pool) Len(queue string) (int, error)
- func (p *Pool) Nack(jobs ...Job) error
- func (p *Pool) Ping() (string, error)
- func (p *Pool) Stat(queue string) (map[string]interface{}, error)
- func (p *Pool) Working(job Job) (time.Duration, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AddOptions ¶
type GetOptions ¶
Click to show internal directories.
Click to hide internal directories.