scheduler

type BuildScheduler interface {
	Schedule(
		logger lager.Logger,
		versions *algorithm.VersionsDB,
		jobConfigs atc.JobConfigs,
		resourceConfigs atc.ResourceConfigs,
		resourceTypes atc.ResourceTypes,
	) (map[string]time.Duration, error)
	TriggerImmediately(
		logger lager.Logger,
		jobConfig atc.JobConfig,
		resourceConfigs atc.ResourceConfigs,
		resourceTypes atc.ResourceTypes,
	) (db.Build, Waiter, error)
	SaveNextInputMapping(logger lager.Logger, job atc.JobConfig) error
}

type Runner struct {
	Logger lager.Logger

	DB db.PipelineDB

	Scheduler BuildScheduler

	Noop bool

	Interval time.Duration
}

type Scanner interface {
	Scan(lager.Logger, string) error
}

type Scheduler struct {
	DB           SchedulerDB
	InputMapper  inputmapper.InputMapper
	BuildStarter buildstarter.BuildStarter
	Scanner      Scanner
}

type SchedulerDB interface {
	AcquireSchedulingLock(lager.Logger, time.Duration) (db.Lock, bool, error)
	LoadVersionsDB() (*algorithm.VersionsDB, error)
	GetPipelineName() string
	Reload() (bool, error)
	Config() atc.Config
	CreateJobBuild(job string) (db.Build, error)
	EnsurePendingBuildExists(jobName string) error
	AcquireResourceCheckingForJobLock(logger lager.Logger, job string) (db.Lock, bool, error)
	GetAllPendingBuilds() (map[string][]db.Build, error)
	GetPendingBuildsForJob(jobName string) ([]db.Build, error)
}

type Waiter interface {
	Wait()
}