engine

Documentation

Index

• func NewBuildStepDelegate(build db.Build, planID atc.PlanID, state exec.RunState, clock clock.Clock, ...) *buildStepDelegate
• func NewCheckDelegate(build db.Build, plan atc.Plan, state exec.RunState, clock clock.Clock, ...) exec.CheckDelegate
• func NewGetDelegate(build db.Build, planID atc.PlanID, state exec.RunState, clock clock.Clock, ...) exec.GetDelegate
• func NewPutDelegate(build db.Build, planID atc.PlanID, state exec.RunState, clock clock.Clock, ...) exec.PutDelegate
• func NewSetPipelineStepDelegate(build db.Build, planID atc.PlanID, state exec.RunState, clock clock.Clock) *setPipelineStepDelegate
• func NewTaskDelegate(build db.Build, planID atc.PlanID, state exec.RunState, clock clock.Clock, ...) exec.TaskDelegate
• type CoreStepFactory
  • func NewCoreStepFactory(pool worker.Pool, client worker.Client, ...) CoreStepFactory
• type DelegateFactory
  • func (delegate DelegateFactory) BuildStepDelegate(state exec.RunState) exec.BuildStepDelegate
  • func (delegate DelegateFactory) CheckDelegate(state exec.RunState) exec.CheckDelegate
  • func (delegate DelegateFactory) GetDelegate(state exec.RunState) exec.GetDelegate
  • func (delegate DelegateFactory) PutDelegate(state exec.RunState) exec.PutDelegate
  • func (delegate DelegateFactory) SetPipelineStepDelegate(state exec.RunState) exec.SetPipelineStepDelegate
  • func (delegate DelegateFactory) TaskDelegate(state exec.RunState) exec.TaskDelegate
• type Engine
  • func NewEngine(stepperFactory StepperFactory, secrets creds.Secrets, ...) Engine
• type RateLimiter
• type Runnable
  • func NewBuild(build db.Build, builder StepperFactory, globalSecrets creds.Secrets, ...) Runnable
• type StepperFactory
  • func NewStepperFactory(coreFactory CoreStepFactory, externalURL string, rateLimiter RateLimiter, ...) StepperFactory

Functions

func NewBuildStepDelegate

func NewBuildStepDelegate(
	build db.Build,
	planID atc.PlanID,
	state exec.RunState,
	clock clock.Clock,
	policyChecker policy.Checker,
) *buildStepDelegate

func NewCheckDelegate

func NewCheckDelegate(
	build db.Build,
	plan atc.Plan,
	state exec.RunState,
	clock clock.Clock,
	limiter RateLimiter,
	policyChecker policy.Checker,
) exec.CheckDelegate

func NewGetDelegate

func NewGetDelegate(
	build db.Build,
	planID atc.PlanID,
	state exec.RunState,
	clock clock.Clock,
	policyChecker policy.Checker,
) exec.GetDelegate

func NewPutDelegate

func NewPutDelegate(
	build db.Build,
	planID atc.PlanID,
	state exec.RunState,
	clock clock.Clock,
	policyChecker policy.Checker,
) exec.PutDelegate

func NewSetPipelineStepDelegate

func NewSetPipelineStepDelegate(
	build db.Build,
	planID atc.PlanID,
	state exec.RunState,
	clock clock.Clock,
) *setPipelineStepDelegate

func NewTaskDelegate

func NewTaskDelegate(
	build db.Build,
	planID atc.PlanID,
	state exec.RunState,
	clock clock.Clock,
	policyChecker policy.Checker,
) exec.TaskDelegate

Types

type CoreStepFactory

type CoreStepFactory interface {
	GetStep(atc.Plan, exec.StepMetadata, db.ContainerMetadata, DelegateFactory) exec.Step
	PutStep(atc.Plan, exec.StepMetadata, db.ContainerMetadata, DelegateFactory) exec.Step
	TaskStep(atc.Plan, exec.StepMetadata, db.ContainerMetadata, DelegateFactory) exec.Step
	CheckStep(atc.Plan, exec.StepMetadata, db.ContainerMetadata, DelegateFactory) exec.Step
	SetPipelineStep(atc.Plan, exec.StepMetadata, DelegateFactory) exec.Step
	LoadVarStep(atc.Plan, exec.StepMetadata, DelegateFactory) exec.Step
	ArtifactInputStep(atc.Plan, db.Build) exec.Step
	ArtifactOutputStep(atc.Plan, db.Build) exec.Step
}

func NewCoreStepFactory

func NewCoreStepFactory(
	pool worker.Pool,
	client worker.Client,
	resourceFactory resource.ResourceFactory,
	teamFactory db.TeamFactory,
	buildFactory db.BuildFactory,
	resourceCacheFactory db.ResourceCacheFactory,
	resourceConfigFactory db.ResourceConfigFactory,
	defaultLimits atc.ContainerLimits,
	strategy worker.ContainerPlacementStrategy,
	lockFactory lock.LockFactory,
	defaultCheckTimeout time.Duration,
) CoreStepFactory

type DelegateFactory

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

func (DelegateFactory) BuildStepDelegate

func (delegate DelegateFactory) BuildStepDelegate(state exec.RunState) exec.BuildStepDelegate

func (DelegateFactory) CheckDelegate

func (delegate DelegateFactory) CheckDelegate(state exec.RunState) exec.CheckDelegate

func (DelegateFactory) GetDelegate

func (delegate DelegateFactory) GetDelegate(state exec.RunState) exec.GetDelegate

func (DelegateFactory) PutDelegate

func (delegate DelegateFactory) PutDelegate(state exec.RunState) exec.PutDelegate

func (DelegateFactory) SetPipelineStepDelegate

func (delegate DelegateFactory) SetPipelineStepDelegate(state exec.RunState) exec.SetPipelineStepDelegate

func (DelegateFactory) TaskDelegate

func (delegate DelegateFactory) TaskDelegate(state exec.RunState) exec.TaskDelegate

type Engine

type Engine interface {
	NewBuild(db.Build) Runnable

	Drain(context.Context)
}

func NewEngine

func NewEngine(
	stepperFactory StepperFactory,
	secrets creds.Secrets,
	varSourcePool creds.VarSourcePool,
) Engine

type RateLimiter

type RateLimiter interface {
	Wait(context.Context) error
}

type Runnable

type Runnable interface {
	Run(context.Context)
}

func NewBuild

func NewBuild(
	build db.Build,
	builder StepperFactory,
	globalSecrets creds.Secrets,
	varSourcePool creds.VarSourcePool,
	release chan bool,
	trackedStates *sync.Map,
	waitGroup *sync.WaitGroup,
) Runnable

type StepperFactory

type StepperFactory interface {
	StepperForBuild(db.Build) (exec.Stepper, error)
}

func NewStepperFactory

func NewStepperFactory(
	coreFactory CoreStepFactory,
	externalURL string,
	rateLimiter RateLimiter,
	policyChecker policy.Checker,
) StepperFactory