Versions in this module Expand all Collapse all v6 v6.4.2 Aug 17, 2020 Changes in this version + const AbortedLogMessage + const TimeoutLogMessage + var ErrPutStepVersionMissing = errors.New("version is missing from put step") + type AggregateStep []Step + func (step AggregateStep) Run(ctx context.Context, state RunState) error + func (step AggregateStep) Succeeded() bool + type ArtifactInputStep struct + func (step *ArtifactInputStep) Run(ctx context.Context, state RunState) error + func (step *ArtifactInputStep) Succeeded() bool + type ArtifactNotFoundError struct + ArtifactName string + func (e ArtifactNotFoundError) Error() string + type ArtifactOutputStep struct + func (step *ArtifactOutputStep) Run(ctx context.Context, state RunState) error + func (step *ArtifactOutputStep) Succeeded() bool + type ArtifactVolumeNotFoundError struct + ArtifactName string + func (e ArtifactVolumeNotFoundError) Error() string + type BuildOutputFilter func(text string) string + type BuildStepDelegate interface + Errored func(lager.Logger, string) + Finished func(lager.Logger, bool) + ImageVersionDetermined func(db.UsedResourceCache) error + Initializing func(lager.Logger) + RedactImageSource func(source atc.Source) (atc.Source, error) + SelectedWorker func(lager.Logger, string) + Starting func(lager.Logger) + Stderr func() io.Writer + Stdout func() io.Writer + Variables func() vars.CredVarsTracker + type CheckDelegate interface + SaveVersions func(db.SpanContext, []atc.Version) error + type CheckStep struct + func NewCheckStep(planID atc.PlanID, plan atc.CheckPlan, metadata StepMetadata, ...) *CheckStep + func (step *CheckStep) Run(ctx context.Context, state RunState) error + func (step *CheckStep) Succeeded() bool + type EmptyVersionSource struct + func (p *EmptyVersionSource) Version(RunState) (atc.Version, error) + type EnsureStep struct + func Ensure(step Step, hook Step) EnsureStep + func (o EnsureStep) Run(ctx context.Context, state RunState) error + func (o EnsureStep) Succeeded() bool + type ErrPipelineNotFound struct + PipelineName string + func (e ErrPipelineNotFound) Error() string + type ErrResourceNotFound struct + ResourceName string + func (e ErrResourceNotFound) Error() string + type ExitStatus int + type FileConfigSource struct + Client worker.Client + ConfigPath string + func (configSource FileConfigSource) FetchConfig(ctx context.Context, logger lager.Logger, repo *build.Repository) (atc.TaskConfig, error) + func (configSource FileConfigSource) Warnings() []string + type GetDelegate interface + Errored func(lager.Logger, string) + Finished func(lager.Logger, ExitStatus, runtime.VersionResult) + ImageVersionDetermined func(db.UsedResourceCache) error + Initializing func(lager.Logger) + RedactImageSource func(source atc.Source) (atc.Source, error) + SelectedWorker func(lager.Logger, string) + Starting func(lager.Logger) + Stderr func() io.Writer + Stdout func() io.Writer + UpdateVersion func(lager.Logger, atc.GetPlan, runtime.VersionResult) + Variables func() vars.CredVarsTracker + type GetStep struct + func (step *GetStep) Run(ctx context.Context, state RunState) error + func (step *GetStep) Succeeded() bool + type IdentityStep struct + func (IdentityStep) Run(context.Context, RunState) error + func (IdentityStep) Succeeded() bool + type InParallelStep struct + func InParallel(steps []Step, limit int, failFast bool) InParallelStep + func (step InParallelStep) Run(ctx context.Context, state RunState) error + func (step InParallelStep) Succeeded() bool + type InputHandler func(io.ReadCloser) error + type InterpolateTemplateConfigSource struct + ConfigSource TaskConfigSource + ExpectAllKeys bool + Vars []vars.Variables + func (configSource InterpolateTemplateConfigSource) FetchConfig(ctx context.Context, logger lager.Logger, source *build.Repository) (atc.TaskConfig, error) + func (configSource InterpolateTemplateConfigSource) Warnings() []string + type InvalidLocalVarFile struct + Err error + File string + Format string + func (err InvalidLocalVarFile) Error() string + type LoadVarStep struct + func (step *LoadVarStep) Run(ctx context.Context, state RunState) error + func (step *LoadVarStep) Succeeded() bool + type LogErrorStep struct + func (step LogErrorStep) Run(ctx context.Context, state RunState) error + type LogErrorStepDelegate interface + Errored func(lager.Logger, string) + type MissingInputsError struct + Inputs []string + func (err MissingInputsError) Error() string + type MissingTaskImageSourceError struct + SourceName string + func (err MissingTaskImageSourceError) Error() string + type OnAbortStep struct + func OnAbort(step Step, hook Step) OnAbortStep + func (o OnAbortStep) Run(ctx context.Context, state RunState) error + func (o OnAbortStep) Succeeded() bool + type OnErrorStep struct + func OnError(step Step, hook Step) OnErrorStep + func (o OnErrorStep) Run(ctx context.Context, state RunState) error + func (o OnErrorStep) Succeeded() bool + type OnFailureStep struct + func OnFailure(firstStep Step, secondStep Step) OnFailureStep + func (o OnFailureStep) Run(ctx context.Context, state RunState) error + func (o OnFailureStep) Succeeded() bool + type OnSuccessStep struct + func (o OnSuccessStep) Run(ctx context.Context, state RunState) error + func (o OnSuccessStep) Succeeded() bool + type OutputHandler func(io.Writer) error + type OverrideParamsConfigSource struct + ConfigSource TaskConfigSource + Params atc.Params + WarningList []string + func (configSource *OverrideParamsConfigSource) FetchConfig(ctx context.Context, logger lager.Logger, source *build.Repository) (atc.TaskConfig, error) + func (configSource OverrideParamsConfigSource) Warnings() []string + type Privileged bool + type PutDelegate interface + Errored func(lager.Logger, string) + Finished func(lager.Logger, ExitStatus, runtime.VersionResult) + ImageVersionDetermined func(db.UsedResourceCache) error + Initializing func(lager.Logger) + RedactImageSource func(source atc.Source) (atc.Source, error) + SaveOutput func(lager.Logger, atc.PutPlan, atc.Source, atc.VersionedResourceTypes, ...) + SelectedWorker func(lager.Logger, string) + Starting func(lager.Logger) + Stderr func() io.Writer + Stdout func() io.Writer + Variables func() vars.CredVarsTracker + type PutInputNotFoundError struct + Input string + func (e PutInputNotFoundError) Error() string + type PutInputs interface + FindAll func(*build.Repository) (map[string]runtime.Artifact, error) + func NewAllInputs() PutInputs + func NewDetectInputs(params atc.Params) PutInputs + func NewSpecificInputs(inputs []string) PutInputs + type PutStep struct + func (step *PutStep) Run(ctx context.Context, state RunState) error + func (step *PutStep) Succeeded() bool + type PutStepVersionSource struct + func (p *PutStepVersionSource) Version(state RunState) (atc.Version, error) + type Retriable struct + Cause error + func (r Retriable) Error() string + type RetryErrorStep struct + func (step RetryErrorStep) Run(ctx context.Context, state RunState) error + type RetryErrorStepDelegate interface + Errored func(lager.Logger, string) + type RetryStep struct + Attempts []Step + LastAttempt Step + func (step *RetryStep) Run(ctx context.Context, state RunState) error + func (step *RetryStep) Succeeded() bool + type RunState interface + ArtifactRepository func() *build.Repository + Result func(atc.PlanID, interface{}) bool + StoreResult func(atc.PlanID, interface{}) + func NewRunState() RunState + type SetPipelineStep struct + func (step *SetPipelineStep) Run(ctx context.Context, state RunState) error + func (step *SetPipelineStep) Succeeded() bool + type StaticConfigSource struct + Config *atc.TaskConfig + func (configSource StaticConfigSource) FetchConfig(context.Context, lager.Logger, *build.Repository) (atc.TaskConfig, error) + func (configSource StaticConfigSource) Warnings() []string + type StaticVersionSource struct + func (p *StaticVersionSource) Version(RunState) (atc.Version, error) + type Step interface + Run func(context.Context, RunState) error + Succeeded func() bool + func LogError(step Step, delegate LogErrorStepDelegate) Step + func NewArtifactInputStep(plan atc.Plan, build db.Build, workerClient worker.Client, ...) Step + func NewArtifactOutputStep(plan atc.Plan, build db.Build, workerClient worker.Client, ...) Step + func NewGetStep(planID atc.PlanID, plan atc.GetPlan, metadata StepMetadata, ...) Step + func NewLoadVarStep(planID atc.PlanID, plan atc.LoadVarPlan, metadata StepMetadata, ...) Step + func NewPutStep(planID atc.PlanID, plan atc.PutPlan, metadata StepMetadata, ...) Step + func NewSetPipelineStep(planID atc.PlanID, plan atc.SetPipelinePlan, metadata StepMetadata, ...) Step + func NewTaskStep(planID atc.PlanID, plan atc.TaskPlan, defaultLimits atc.ContainerLimits, ...) Step + func OnSuccess(firstStep Step, secondStep Step) Step + func Retry(attempts ...Step) Step + func RetryError(step Step, delegate RetryErrorStepDelegate) Step + func Try(step Step) Step + type StepMetadata struct + BaseResourceTypeID int + BuildID int + BuildName string + ExternalURL string + JobID int + JobName string + PipelineID int + PipelineName string + ResourceConfigID int + ResourceConfigScopeID int + TeamID int + TeamName string + func (metadata StepMetadata) Env() []string + type TaskConfigSource interface + FetchConfig func(context.Context, lager.Logger, *build.Repository) (atc.TaskConfig, error) + Warnings func() []string + type TaskDelegate interface + Errored func(lager.Logger, string) + Finished func(lager.Logger, ExitStatus) + ImageVersionDetermined func(db.UsedResourceCache) error + Initializing func(lager.Logger) + RedactImageSource func(source atc.Source) (atc.Source, error) + SelectedWorker func(lager.Logger, string) + SetTaskConfig func(config atc.TaskConfig) + Starting func(lager.Logger) + Stderr func() io.Writer + Stdout func() io.Writer + Variables func() vars.CredVarsTracker + type TaskImageSourceParametersError struct + Err error + func (err TaskImageSourceParametersError) Error() string + type TaskStep struct + func (step *TaskStep) Run(ctx context.Context, state RunState) error + func (step *TaskStep) Succeeded() bool + type TimeoutStep struct + func Timeout(step Step, duration string) *TimeoutStep + func (ts *TimeoutStep) Run(ctx context.Context, state RunState) error + func (ts *TimeoutStep) Succeeded() bool + type TryStep struct + func (ts *TryStep) Run(ctx context.Context, state RunState) error + func (ts *TryStep) Succeeded() bool + type UnknownArtifactSourceError struct + ConfigPath string + SourceName build.ArtifactName + func (err UnknownArtifactSourceError) Error() string + type UnspecifiedArtifactSourceError struct + Path string + func (err UnspecifiedArtifactSourceError) Error() string + type UnspecifiedLoadVarStepFileError struct + File string + func (err UnspecifiedLoadVarStepFileError) Error() string + type ValidatingConfigSource struct + ConfigSource TaskConfigSource + func (configSource ValidatingConfigSource) FetchConfig(ctx context.Context, logger lager.Logger, source *build.Repository) (atc.TaskConfig, error) + func (configSource ValidatingConfigSource) Warnings() []string + type VersionSource interface + Version func(RunState) (atc.Version, error) + func NewVersionSourceFromPlan(getPlan *atc.GetPlan) VersionSource