Documentation ¶
Index ¶
- type BuildScheduler
- 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, ...) (db.Build, Waiter, error)
- type SchedulerDB
- type Waiter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BuildScheduler ¶
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 ¶
type Runner struct { Logger lager.Logger DB db.PipelineDB Scheduler BuildScheduler Noop bool Interval time.Duration }
type Scheduler ¶
type Scheduler struct { DB SchedulerDB InputMapper inputmapper.InputMapper BuildStarter 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.ResourceTypes, ) (map[string]time.Duration, error)
func (*Scheduler) TriggerImmediately ¶
type SchedulerDB ¶
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) }
Directories ¶
Path | Synopsis |
---|---|
buildstarterfakes
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 |
maxinflight/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 |
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 |
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.