buildstarter

Documentation

Index

• type BuildFactory
• type BuildStarter
  • func NewBuildStarter(db BuildStarterDB, maxInFlightUpdater maxinflight.Updater, ...) BuildStarter
• type BuildStarterBuildsDB
• type BuildStarterDB

Types

type BuildFactory

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

type BuildStarter

type BuildStarter interface {
	TryStartAllPendingBuilds(
		logger lager.Logger,
		jobConfig atc.JobConfig,
		resourceConfigs atc.ResourceConfigs,
		resourceTypes atc.ResourceTypes,
	) error
}

func NewBuildStarter

func NewBuildStarter(
	db BuildStarterDB,
	maxInFlightUpdater maxinflight.Updater,
	factory BuildFactory,
	execEngine engine.Engine,
) BuildStarter

type BuildStarterBuildsDB

type BuildStarterBuildsDB interface {
	FinishBuild(buildID int, pipelineID int, status db.Status) error
}

type BuildStarterDB

type BuildStarterDB interface {
	GetNextPendingBuild(job string) (db.Build, bool, error)
	GetNextBuildInputs(jobName string) ([]db.BuildInput, bool, error)
	IsPaused() (bool, error)
	GetJob(job string) (db.SavedJob, error)
	UpdateBuildToScheduled(int) (bool, error)
	UseInputsForBuild(buildID int, inputs []db.BuildInput) error
}