processor

type AllowFailure struct {
}

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

type Bootstraper interface {
	Bootstrap(pipeline Pipeline, next Next) (Next, error)
}

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

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

type Executable func(ctx context.Context) (StepContext, map[string]v1beta1.ParamValue, error)

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

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

type Indexable interface {
	Index() map[string]string
}

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

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

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

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

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

type Next func(ctx context.Context, stepContext StepContext) (StepContext, error)

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

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

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

type OutputCloser func(err error) error

type OutputFactory func(ctx context.Context, stepContext StepContext, stepName string) (io.Writer, io.Writer, OutputCloser)

type OutputParam struct {
	Name string
	Path string
}

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

type Pipeline interface {
	Step(name string) (Step, error)
	Entrypoint(name string) (Next, error)
	EntrypointName() (string, error)
	Name() string
	ID() string
}

type PipelineBuilder interface {
	Build(pipeline v1beta1.Pipeline, entrypoint string, inputs map[string]v1beta1.ParamValue, stepCtx StepContext) (Executable, error)
}

type ProcessorBuilder func(spec *v1beta1.Step) Bootstraper

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

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

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

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

type ResultStore interface {
	Add(stepName string, result *StepResult)
}

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

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

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

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

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

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

type Step interface {
	Processors() []Bootstraper
	Entrypoint() (Next, error)
}

type StepContext struct {
	Dir              string
	DataDir          string
	Matrix           map[string]string
	Inputs           map[string]v1beta1.ParamValue
	Steps            map[string]*StepResult
	Envs             map[string]string
	Containers       map[string]cruntime.ContainerStatus
	Tags             map[string]string
	NamePrefix       string
	Env              string
	Outputs          []OutputParam
	Stdin            io.Reader
	Stdout           io.Writer
	Stderr           io.Writer
	AdditionalStdout []io.Writer
	AdditionalStderr []io.Writer
	Template         *v1beta1.Template
}

type StepResult struct {
	StartedAt time.Time
	EndedAt   time.Time
	Outputs   map[string]v1beta1.ParamValue
	Error     error
	DataDir   string
}

type Teardown func(ctx context.Context) error

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

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

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