scheduler

Documentation

Index

• type Algorithm
• type Build
• type BuildPlanner
• type BuildScheduler
• type BuildStarter
  • func NewBuildStarter(planner BuildPlanner, algorithm Algorithm) BuildStarter
• type Runner
  • func NewRunner(logger lager.Logger, jobFactory db.JobFactory, scheduler BuildScheduler, ...) *Runner
  • func (s *Runner) Run(ctx context.Context) error
• type Scheduler
  • func (s *Scheduler) Schedule(ctx context.Context, logger lager.Logger, job db.SchedulerJob) (bool, error)

Types

type Algorithm

type Algorithm interface {
	Compute(
		context.Context,
		db.Job,
		db.InputConfigs,
	) (db.InputMapping, bool, bool, error)
}

type Build

type Build interface {
	db.Build

	IsReadyToDetermineInputs(lager.Logger) (bool, error)
	BuildInputs(context.Context) ([]db.BuildInput, bool, error)
}

type BuildPlanner

type BuildPlanner interface {
	Create(atc.StepConfig, db.SchedulerResources, atc.VersionedResourceTypes, []db.BuildInput) (atc.Plan, error)
}

type BuildScheduler

type BuildScheduler interface {
	Schedule(
		ctx context.Context,
		logger lager.Logger,
		job db.SchedulerJob,
	) (bool, error)
}

type BuildStarter

type BuildStarter interface {
	TryStartPendingBuildsForJob(
		logger lager.Logger,
		job db.SchedulerJob,
		inputs db.InputConfigs,
	) (bool, error)
}

func NewBuildStarter

func NewBuildStarter(
	planner BuildPlanner,
	algorithm Algorithm,
) BuildStarter

type Runner

type Runner struct {
	// contains filtered or unexported fields
}

func NewRunner

func NewRunner(logger lager.Logger, jobFactory db.JobFactory, scheduler BuildScheduler, maxJobs uint64) *Runner

func (*Runner) Run

func (s *Runner) Run(ctx context.Context) error

type Scheduler

type Scheduler struct {
	Algorithm    Algorithm
	BuildStarter BuildStarter
}

func (*Scheduler) Schedule

func (s *Scheduler) Schedule(
	ctx context.Context,
	logger lager.Logger,
	job db.SchedulerJob,
) (bool, error)