Method Add

cron/cron.go:54–86

Add adds a new job to the cron scheduler.A list of middleware can be supplied. Note the error returned by the runner will be discarded. It is the user's responsibility to handle the error via middleware.

(spec string, runner func(ctx context.Context) error, middleware ...JobOption)

// Note the error returned by the runner will be discarded. It is the user's
// responsibility to handle the error via middleware.
func (c *Cron) Add(spec string, runner func(ctx context.Context) error, middleware ...JobOption) (JobID, error) {
	schedule, err := c.parser.Parse(spec)
	if err != nil {
		return 0, err
	}

	jobDescriptor := JobDescriptor{
		RawSpec:  spec,
		Run:      runner,
		Schedule: schedule,
		next:     schedule.Next(c.now()),
	}

	middleware = append(c.globalMiddleware, middleware...)

	for i := len(middleware) - 1; i >= 0; i-- {
		middleware[i](&jobDescriptor)
	}

	c.lock.L.Lock()
	defer c.lock.L.Unlock()
	defer c.lock.Broadcast()

	jobDescriptor.ID = JobID(c.nextID)
	c.nextID++

	if jobDescriptor.Name == "" {
		jobDescriptor.Name = fmt.Sprintf("job-%d", jobDescriptor.ID)
	}

	heap.Push(&c.jobDescriptors, &jobDescriptor)
	return jobDescriptor.ID, nil
}

// Remove removes a job from the cron scheduler.
func (c *Cron) Remove(id JobID) {