Function SkipIfOverlap

cron/options.go:95–111

SkipIfOverlap returns a new JobDescriptor that will skip the job if it overlaps with another job.

()

// SkipIfOverlap returns a new JobDescriptor that will skip the job if it overlaps with another job.
func SkipIfOverlap() JobOption {
	ch := make(chan struct{}, 1)
	return func(descriptor *JobDescriptor) {
		innerRun := descriptor.Run
		descriptor.Run = func(ctx context.Context) error {
			select {
			case ch <- struct{}{}:
				defer func() {
					<-ch
				}()
				return innerRun(ctx)
			default:
				return errors.New("skipped due to overlap")
			}
		}
	}
}

// DelayIfOverlap returns a new JobDescriptor that will delay the job if it overlaps with another job.
func DelayIfOverlap() JobOption {