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 Debug struct {
	// contains filtered or unexported fields
}

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

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

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

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

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

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

type LogBuilder func(w io.Writer) (logr.Logger, error)

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

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

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

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

type Next func(ctx 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 StepContext, stepName, short string) (io.Writer, io.Writer, OutputCloser)

type OutputParam struct {
	Name string
	Path string
}

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

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 Recover struct {
	// contains filtered or unexported fields
}

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

type Reporter interface {
	Report(ctx StepContext, name string) error
}

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

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

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

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

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

type SkipDone 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 {
	context.Context `json:"-"`
	Dir             string
	DataDir         string
	Matrix          map[string]string
	Inputs          map[string]v1beta1.ParamValue
	Steps           map[string]*StepContext `json:"-"`
	Envs            map[string]string
	Secrets         map[string]string
	Containers      map[string]cruntime.ContainerStatus

	NamePrefix       string
	Secret           string
	Env              string
	Outputs          []OutputParam
	Stdin            io.Reader
	Stdout           io.Writer
	Stderr           io.Writer
	AdditionalStdout []io.Writer
	AdditionalStderr []io.Writer
	Template         *v1beta1.Template
	StartedAt        time.Time
	EndedAt          time.Time
	OutputVars       map[string]v1beta1.ParamValue
	Error            error
	// contains filtered or unexported fields
}

type Tag struct {
	Key   string
	Value string
	Color string
}

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

type Teardown func(ctx context.Context, timeout time.Duration) 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
}