Function NewRetentionProvider

modules/backendscheduler/provider/retention.go:38–46

(cfg RetentionConfig, logger kitlogger.Logger, store TenantLister, overrides overrides.Interface, scheduler Scheduler)

}

func NewRetentionProvider(cfg RetentionConfig, logger kitlogger.Logger, store TenantLister, overrides overrides.Interface, scheduler Scheduler) *RetentionProvider {
	return &RetentionProvider{
		cfg:       cfg,
		store:     store,
		overrides: overrides,
		sched:     scheduler,
		logger:    logger,
	}
}

func (p *RetentionProvider) Start(ctx context.Context) <-chan *work.Job {
	jobs := make(chan *work.Job, 1)