jobs

type J struct {
	// id is the unique job id.
	ID bson.ObjectId `bson:"_id" json:"id"`
	// Status is the current status of the job.
	Status Status `json:"status"`
	// Tries holds history of attempts.
	Tries []*Try `json:"tries"`
	// Created is when the job was created.
	Created time.Time `json:"created"`
	// RunAt is the time this job should run at (or after).
	RunAt time.Time `json:"runat" bson:"runat"`
	// Data is the user data for this job.
	Data map[string]interface{} `json:"data" bson:"data"`
	// Retries is the number of remaining attempts that will
	// be made to run this job.
	Retries int
	// RetryInterval is the time to wait after a failure before
	// trying to run the job again.
	RetryInterval time.Duration
	// Kind is the kind for this job. Only runners with the same kind
	// will be asked to process this job.
	Kind string
}

type JobFunc func(job *J) error

type Runner struct {
	Interval time.Duration
	// contains filtered or unexported fields
}

type Status int8

type Try struct {
	// Runner is the name of the runner that tried to
	// run this job.
	Runner string `json:"runner" bson:"runner"`
	// When is a timestamp of when the attempt took place.
	When time.Time `json:"when" bson:"when"`
	// Err is the error that was returned by JobFunc.
	Err string `json:"err,omitempty" bson:"err,omitempty"`
}