Versions in this module Expand all Collapse all v0 v0.1.0 Oct 21, 2024 Changes in this version + func GetJobID(ctx context.Context) (jobID int64, ok bool) + func OnFinish(jobID int64, fn func()) (func(), error) + func SetInitialJobID(id int64) + func SetOpt(opt *rc.Options) + type Job struct + Duration float64 + EndTime time.Time + Error string + Finished bool + Group string + ID int64 + Output rc.Params + StartTime time.Time + Stop func() + Success bool + func GetJob(ctx context.Context) (job *Job, ok bool) + func NewJob(ctx context.Context, fn rc.Func, in rc.Params) (job *Job, out rc.Params, err error) + func (job *Job) OnFinish(fn func()) func() + type Jobs struct + func (jobs *Jobs) Expire() + func (jobs *Jobs) Get(ID int64) *Job + func (jobs *Jobs) IDs() (IDs []int64) + func (jobs *Jobs) NewJob(ctx context.Context, fn rc.Func, in rc.Params) (job *Job, out rc.Params, err error)
Go to main page