Versions in this module Expand all Collapse all v0 v0.1442.0 Feb 27, 2024 Changes in this version + const ContainerSetupFailedDuration + const ContainerSetupSucceededDuration + const ErrParsingURL + const ExitTimeout + func NewBackground(substep ifrit.Runner, logger lager.Logger) ifrit.Runner + func NewConsistentlySucceedsStep(create func() ifrit.Runner, frequency time.Duration, clock clock.Clock) ifrit.Runner + func NewEventuallySucceedsStep(create func() ifrit.Runner, frequency, timeout time.Duration, ...) ifrit.Runner + func NewHealthCheckStep(startupCheck ifrit.Runner, livenessCheck ifrit.Runner, logger lager.Logger, ...) ifrit.Runner + func NewOutputWrapper(substep ifrit.Runner, reader io.Reader) ifrit.Runner + func NewOutputWrapperWithPrefix(substep ifrit.Runner, reader io.Reader, prefix string) ifrit.Runner + func NewReadinessHealthCheckStep(untilReadyCheck ifrit.Runner, untilFailureCheck ifrit.Runner, ...) ifrit.Runner + func NewRunWithSidecar(container garden.Container, model models.RunAction, ...) *runStep + func NewThrottle(substep ifrit.Runner, workPool *workpool.WorkPool) *throttleStep + func NewTimedStep(logger lager.Logger, step ifrit.Runner, ...) ifrit.Runner + type CancelledError struct + func (e *CancelledError) Error() string + func (e *CancelledError) IsDisplayable() bool + type ExceededGracefulShutdownIntervalError struct + func (e *ExceededGracefulShutdownIntervalError) Error() string + func (e *ExceededGracefulShutdownIntervalError) IsDisplayable() bool + type ExitTimeoutError struct + func (e *ExitTimeoutError) Error() string + type IsDisplayableError interface + IsDisplayable func() bool + type ReadSizer struct + func (r *ReadSizer) BytesRead() int + func (r *ReadSizer) Read(dest []byte) (int, error) + type ReadinessState int + const IsNotReady + const IsReady + type Sidecar struct + BindMounts []garden.BindMount + Image garden.ImageRef + Name string + OverrideContainerLimits *garden.ProcessLimits 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