Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

jobs

package module

Go to main page

Versions in this module

v0

v0.2.1

Apr 21, 2015

v0.2.0

Apr 15, 2015

Changes in this version

+ type HandlerFunc interface

v0.1.1

Feb 25, 2015

v0.1.0

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

v0.0.1

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