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

type Executable func(ctx context.Context) (StepContext, error)

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

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

type OutputCloser func(err error)

type OutputFactory func(name string, stdin io.Reader, stdout, stderr io.Writer) (io.Reader, io.Writer, io.Writer, OutputCloser)

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

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

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

type ProcessorBuilder func(spec *v1beta1.Step) Bootstraper

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

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

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

type StepContext struct {
	Matrix map[string]interface{}

	Steps      map[string]*StepResult
	Envs       map[string]string
	Containers map[string]cruntime.ContainerStatus
	NamePrefix string
	Env        string
	Parent     string
	Output     string
	Stdin      io.Reader
	Stdout     io.Writer
	Stderr     io.Writer
	// contains filtered or unexported fields
}

type StepResult struct {
	StartedAt  time.Time
	EndedAt    time.Time
	Outputs    map[string]string
	Envs       map[string]string
	Containers map[string]cruntime.ContainerStatus
	Error      error
}

type Teardown func(ctx context.Context) error

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