Documentation ¶
Index ¶
- Variables
- func Error(f string, v ...interface{}) error
- func SetLogger(alogger *log.FactorLog)
- type Client
- func (c *Client) Close() error
- func (c *Client) Delete(job *Job) (err error)
- func (c *Client) Drop()
- func (c *Client) Exit()
- func (c *Client) Put(job *Job) (id uint64, err error)
- func (c *Client) Release(job *Job, err error)
- func (c *Client) Reserve() (job *Job, found bool, err error)
- func (c *Client) Stats()
- func (c *Client) StatsJob(jobId uint64) (map[string]string, error)
- func (c *Client) TubeStats(tube string) (map[string]string, error)
- type Job
- type JobCallback
- type JobHandler
- type JobPanic
- type Master
- type Stats
- type Worker
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrJobTimeout = errors.New("job timed out")
)
Functions ¶
Types ¶
type Client ¶
type Job ¶
type JobHandler ¶
type Master ¶
func (*Master) RegisterHandler ¶
func (m *Master) RegisterHandler(name string, hfn JobHandler, cfn JobCallback, to time.Duration)
Click to show internal directories.
Click to hide internal directories.