Function Start

internal/scheduler/scheduler.go:49–69

Start runs a new scheduler that will call getItems() to get the list of items to schedule.

(ctx context.Context, getItems GetItemsFunc, opts Options)

// Start runs a new scheduler that will call getItems() to get the list of items to schedule.
func Start(ctx context.Context, getItems GetItemsFunc, opts Options) *Scheduler {
	timeNow := opts.TimeNow

	if timeNow == nil {
		timeNow = clock.Now
	}

	s := &Scheduler{
		TimeNow:          timeNow,
		refreshRequested: opts.RefreshChannel,
		closed:           make(chan struct{}),
		getItems:         getItems,
		Debug:            opts.Debug,
	}

	s.wg.Go(func() {
		s.run(context.WithoutCancel(ctx))
	})

	return s
}

const sleepTimeWhenNoUpcomingSnapshots = 8 * time.Hour