jobs

Aug 25, 2015

Changes in this version

type Pool

+ func (p *Pool) SetAfterFunc(f func(*Job))

Jul 12, 2015

Changes in this version

type Job

+ func (j *Job) Data() []byte

+ func (j *Job) Freq() int64

+ func (j *Job) PoolId() string

+ func (j *Job) Priority() int

+ func (j *Job) Retries() uint

+ func (j *Job) Time() int64

May 20, 2015

Changes in this version

+ type ErrorJobNotFound struct

+ func (e ErrorJobNotFound) Error() string

May 15, 2015

Changes in this version

+ var Keys = struct{ ... }

type Job

+ func (j *Job) IsRecurring() bool

+ func (j *Job) Key() string

+ func (j *Job) NextTime() int64

type Status

+ func (status Status) Key() string

Apr 15, 2015

Changes in this version

+ type HandlerFunc interface

Feb 25, 2015

Changes in this version

+ var Types = map[string]*Type

type Job

+ func FindById(id string) (*Job, error)

+ func (j *Job) Reschedule(time time.Time) error

+ type Status string

+ func (status Status) Count() (int, error)

+ func (status Status) JobIds() ([]string, error)

+ func (status Status) Jobs() ([]*Job, error)

+ type Type struct

+ func RegisterType(name string, retries uint, handler interface{}) (*Type, error)

+ func (jt *Type) Schedule(priority int, time time.Time, data interface{}) (*Job, error)

+ func (jt *Type) ScheduleRecurring(priority int, time time.Time, freq time.Duration, data interface{}) (*Job, error)

+ func (jt *Type) String() string

Feb 21, 2015

Changes in this version

+ var Config = configType

+ var DefaultPoolConfig = &PoolConfig

+ type ErrorNameAlreadyRegistered struct

+ func (e ErrorNameAlreadyRegistered) Error() string

+ type Job struct

+ func (j *Job) Cancel() error

+ func (j *Job) Destroy() error

+ func (j *Job) Duration() time.Duration

+ func (j *Job) Enqueue() error

+ func (j *Job) Error() error

+ func (j *Job) Finished() time.Time

+ func (j *Job) Id() string

+ func (j *Job) Refresh() error

+ func (j *Job) Started() time.Time

+ func (j *Job) Status() JobStatus

+ type JobStatus string

+ const StatusCancelled

+ const StatusDestroyed

+ const StatusExecuting

+ const StatusFailed

+ const StatusFinished

+ const StatusQueued

+ const StatusSaved

+ func (status JobStatus) Count() (int, error)

+ type JobType struct

+ func RegisterJobType(name string, retries uint, handler interface{}) (*JobType, error)

+ func (jt *JobType) Schedule(priority int, time time.Time, data interface{}) (*Job, error)

+ func (jt *JobType) ScheduleRecurring(priority int, time time.Time, freq time.Duration, data interface{}) (*Job, error)

+ func (jt *JobType) String() string

+ type Pool struct

+ func NewPool(config *PoolConfig) *Pool

+ func (p *Pool) Close()

+ func (p *Pool) Start() error

+ func (p *Pool) Wait() error

+ type PoolConfig struct

+ BatchSize int

+ MinWait time.Duration

+ NumWorkers int

+ StaleTimeout time.Duration