Versions in this module Expand all Collapse all v0 v0.1441.2 Jan 13, 2016 Changes in this version + const EXIT_TIMEOUT + const ErrCopyStreamToTmp + const ErrCreateTmpDir + const ErrCreateTmpFile + const ErrEstablishStream + const ErrReadTar + const TERMINATE_TIMEOUT + var CodependentStepExitedError = errors.New("Codependent step exited") + var ErrCancelled = errors.New("cancelled") + var ErrExitTimeout = errors.New("process did not exit") + func NewCodependent(substeps []Step, errorOnExit bool) *codependentStep + func NewDownload(container garden.Container, model models.DownloadAction, ...) *downloadStep + func NewEmitProgress(substep Step, startMessage, successMessage, failureMessage string, ...) *emitProgressStep + func NewParallel(substeps []Step) *parallelStep + func NewRun(container garden.Container, model models.RunAction, ...) *runStep + func NewSerial(steps []Step) *serialStep + func NewTimeout(substep Step, timeout time.Duration, logger lager.Logger) *timeoutStep + func NewTry(substep Step, logger lager.Logger) *tryStep + func NewUpload(container garden.Container, model models.UploadAction, ...) *uploadStep + type EmittableError struct + func NewEmittableError(wrappedError error, message string, args ...interface{}) *EmittableError + func (e *EmittableError) Error() string + func (e *EmittableError) WrappedError() error + type Step interface + Cancel func() + Perform func() error + func NewMonitor(checkFunc func() Step, hasStartedRunning chan<- struct{}, logger lager.Logger, ...) Step