scheduler

Documentation

Index

• type BuildFactory
• type BuildScheduler
• type BuildStarter
  • func NewBuildStarter(pipeline dbng.Pipeline, maxInFlightUpdater maxinflight.Updater, ...) BuildStarter
• type Runner
  • func (runner *Runner) Run(signals <-chan os.Signal, ready chan<- struct{}) error
• type Scanner
• type Scheduler
  • func (s *Scheduler) SaveNextInputMapping(logger lager.Logger, job dbng.Job) error
  • func (s *Scheduler) Schedule(logger lager.Logger, versions *algorithm.VersionsDB, jobs []dbng.Job, ...) (map[string]time.Duration, error)
  • func (s *Scheduler) TriggerImmediately(logger lager.Logger, job dbng.Job, resources dbng.Resources, ...) (dbng.Build, Waiter, error)
• type Waiter

Types

type BuildFactory

type BuildFactory interface {
	Create(atc.JobConfig, atc.ResourceConfigs, atc.VersionedResourceTypes, []dbng.BuildInput) (atc.Plan, error)
}

type BuildScheduler

type BuildScheduler interface {
	Schedule(
		logger lager.Logger,
		versions *algorithm.VersionsDB,
		jobs []dbng.Job,
		resources dbng.Resources,
		resourceTypes atc.VersionedResourceTypes,
	) (map[string]time.Duration, error)

	TriggerImmediately(
		logger lager.Logger,
		job dbng.Job,
		resources dbng.Resources,
		resourceTypes atc.VersionedResourceTypes,
	) (dbng.Build, Waiter, error)

	SaveNextInputMapping(logger lager.Logger, job dbng.Job) error
}

type BuildStarter

type BuildStarter interface {
	TryStartPendingBuildsForJob(
		logger lager.Logger,
		job dbng.Job,
		resources dbng.Resources,
		resourceTypes atc.VersionedResourceTypes,
		nextPendingBuilds []dbng.Build,
	) error
}

func NewBuildStarter

func NewBuildStarter(
	pipeline dbng.Pipeline,
	maxInFlightUpdater maxinflight.Updater,
	factory BuildFactory,
	scanner Scanner,
	inputMapper inputmapper.InputMapper,
	execEngine engine.Engine,
) BuildStarter

type Runner

type Runner struct {
	Logger lager.Logger

	Pipeline dbng.Pipeline

	Scheduler BuildScheduler

	Noop bool

	Interval time.Duration
}

func (*Runner) Run

func (runner *Runner) Run(signals <-chan os.Signal, ready chan<- struct{}) error

type Scanner

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

type Scheduler

type Scheduler struct {
	Pipeline     dbng.Pipeline
	InputMapper  inputmapper.InputMapper
	BuildStarter BuildStarter
	Scanner      Scanner
}

func (*Scheduler) SaveNextInputMapping

func (s *Scheduler) SaveNextInputMapping(logger lager.Logger, job dbng.Job) error

func (*Scheduler) Schedule

func (s *Scheduler) Schedule(
	logger lager.Logger,
	versions *algorithm.VersionsDB,
	jobs []dbng.Job,
	resources dbng.Resources,
	resourceTypes atc.VersionedResourceTypes,
) (map[string]time.Duration, error)

func (*Scheduler) TriggerImmediately

func (s *Scheduler) TriggerImmediately(
	logger lager.Logger,
	job dbng.Job,
	resources dbng.Resources,
	resourceTypes atc.VersionedResourceTypes,
) (dbng.Build, Waiter, error)

type Waiter

type Waiter interface {
	Wait()
}