Documentation ¶
Index ¶
- type BuildFactory
- type BuildScheduler
- type BuildStarter
- type Runner
- type Scanner
- type Scheduler
- func (s *Scheduler) SaveNextInputMapping(logger lager.Logger, job atc.JobConfig) error
- func (s *Scheduler) Schedule(logger lager.Logger, versions *algorithm.VersionsDB, jobConfigs atc.JobConfigs, ...) (map[string]time.Duration, error)
- func (s *Scheduler) TriggerImmediately(logger lager.Logger, jobConfig atc.JobConfig, ...) (dbng.Build, Waiter, error)
- type Waiter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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, jobConfigs atc.JobConfigs, resourceConfigs atc.ResourceConfigs, resourceTypes atc.VersionedResourceTypes, ) (map[string]time.Duration, error) TriggerImmediately( logger lager.Logger, jobConfig atc.JobConfig, resourceConfigs atc.ResourceConfigs, resourceTypes atc.VersionedResourceTypes, ) (dbng.Build, Waiter, error) SaveNextInputMapping(logger lager.Logger, job atc.JobConfig) error }
type BuildStarter ¶
type BuildStarter interface { TryStartPendingBuildsForJob( logger lager.Logger, jobConfig atc.JobConfig, resourceConfigs atc.ResourceConfigs, 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 DB db.PipelineDB Pipeline dbng.Pipeline Scheduler BuildScheduler Noop bool Interval time.Duration }
type Scheduler ¶
type Scheduler struct { Pipeline dbng.Pipeline InputMapper inputmapper.InputMapper BuildStarter BuildStarter Scanner Scanner }
func (*Scheduler) SaveNextInputMapping ¶
func (*Scheduler) Schedule ¶
func (s *Scheduler) Schedule( logger lager.Logger, versions *algorithm.VersionsDB, jobConfigs atc.JobConfigs, resourceConfigs atc.ResourceConfigs, resourceTypes atc.VersionedResourceTypes, ) (map[string]time.Duration, error)
func (*Scheduler) TriggerImmediately ¶
Directories ¶
Path | Synopsis |
---|---|
factoryfakes
This file was generated by counterfeiter
|
This file was generated by counterfeiter |
inputconfig/inputconfigfakes
This file was generated by counterfeiter This file was generated by counterfeiter
|
This file was generated by counterfeiter This file was generated by counterfeiter |
inputmapperfakes
This file was generated by counterfeiter This file was generated by counterfeiter
|
This file was generated by counterfeiter This file was generated by counterfeiter |
maxinflightfakes
This file was generated by counterfeiter This file was generated by counterfeiter
|
This file was generated by counterfeiter This file was generated by counterfeiter |
This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter
|
This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter |
Click to show internal directories.
Click to hide internal directories.