processor

Sep 29, 2025

Changes in this version

+ var ErrTimeout = errors.New("operation timed out")

Jul 9, 2025

Changes in this version

type ProcessorBuilder

+ func WithTags(globalTags []Tag) ProcessorBuilder

+ type Tags struct

+ func (s *Tags) Bootstrap(pipeline Pipeline, next Next) (Next, error)

Jul 3, 2025

Changes in this version

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

+ type Monitor struct

+ func (s *Monitor) Bootstrap(pipeline Pipeline, next Next) (Next, error)

type ProcessorBuilder

+ func WithMonitor(enabled bool, interval time.Duration, dev io.Writer) ProcessorBuilder

Jun 23, 2025

Changes in this version

+ func ContainerSpec(container *runtime.ContainerSpec, template *v1beta1.Template)

+ func SuffixName(name, suffix string) string

type Bootstraper

+ func WithDebug(logger logr.Logger, debug bool, spec *v1beta1.Step, processors ...Bootstraper) []Bootstraper

+ type Debug struct

+ func (s *Debug) Bootstrap(pipeline Pipeline, next Next) (Next, error)

type ProcessorBuilder

+ func WithSecretVars(osEnv, defaultSecret map[string]string, secretWriter mask.SecretStore) ProcessorBuilder

+ type Reporter interface

+ Report func(ctx StepContext, name string) error

+ type SecretVars struct

+ Secret map[string]string

+ func (s *SecretVars) Bootstrap(pipeline Pipeline, next Next) (Next, error)

type StepContext

+ EndedAt time.Time

+ Error error

+ OutputVars map[string]v1beta1.ParamValue

+ Secret string

+ Secrets map[string]string

+ StartedAt time.Time

+ func (t StepContext) HasTag(key string) bool

+ func (t StepContext) WithTag(tag Tag) StepContext

May 12, 2025

Changes in this version

+ type Tag struct

+ Color string

+ Key string

+ Value string

May 8, 2025

Changes in this version

+ type EnvVars struct

+ func (s *EnvVars) Bootstrap(pipeline Pipeline, next Next) (Next, error)

+ type InputVars struct

+ func (s *InputVars) Bootstrap(pipeline Pipeline, next Next) (Next, error)

+ type OutputVars struct

+ func (s *OutputVars) Bootstrap(pipeline Pipeline, next Next) (Next, error)

type ProcessorBuilder

+ func WithEnvVars(osEnv, defaultEnv map[string]string) ProcessorBuilder

+ func WithInputVars(celEnv *cel.Env) ProcessorBuilder

+ func WithOutputVars() ProcessorBuilder

Apr 25, 2025

Changes in this version

+ var ErrEmptyMatrix = errors.New("empty matrix")

+ func Subst(index Indexable, substitute ...any) error

+ type Indexable interface

+ Index func() map[string]string

+ type Input struct

+ func (s *Input) Bootstrap(pipeline Pipeline, next Next) (Next, error)

+ type Logger struct

+ func (s *Logger) Bootstrap(pipeline Pipeline, next Next) (Next, error)

+ type Output struct

+ func (s *Output) Bootstrap(pipeline Pipeline, next Next) (Next, error)

+ type OutputParam struct

+ Name string

+ Path string

type Pipeline

+ EntrypointName func() (string, error)

type ProcessorBuilder

+ func WithInput(celEnv *cel.Env) ProcessorBuilder

+ func WithLogger(logger logr.Logger, zapConfig *zap.Config) ProcessorBuilder

+ func WithOutput() ProcessorBuilder

+ func WithProgress(progress bool) ProcessorBuilder

+ func WithRecover() ProcessorBuilder

+ func WithStdioRedirect(tee bool) ProcessorBuilder

+ func WithTemplate(template v1beta1.Template) ProcessorBuilder

+ type Progress struct

+ func (s *Progress) Bootstrap(pipeline Pipeline, next Next) (Next, error)

+ type Recover struct

+ func (s *Recover) Bootstrap(pipeline Pipeline, next Next) (Next, error)

+ type StdioRedirect struct

+ func (s *StdioRedirect) Bootstrap(pipelineCtx Pipeline, next Next) (Next, error)

type StepContext

+ AdditionalStderr []io.Writer

+ AdditionalStdout []io.Writer

+ DataDir string

+ Dir string

+ Inputs map[string]v1beta1.ParamValue

+ Outputs []OutputParam

+ Tags map[string]string

+ Template *v1beta1.Template

+ type Template struct

+ func (s *Template) Bootstrap(pipeline Pipeline, next Next) (Next, error)

Feb 11, 2025

Changes in this version

type ProcessorBuilder

+ func WithTmpDir() ProcessorBuilder

type StepResult

+ DataDir string

+ type TmpDir struct

+ func (s *TmpDir) Bootstrap(pipeline Pipeline, next Next) (Next, error)

Feb 10, 2025

Changes in this version

+ var ErrSkipBlacklist = errors.New("skip blacklisted step")

+ func InterfaceToAny(i interface{}) (*anypb.Any, error)

+ type Env struct

+ func (s *Env) Bootstrap(pipeline Pipeline, next Next) (Next, error)

+ func (s *Env) MarshalJSON() ([]byte, error)

+ func (s *Env) UnmarshalJSON(b []byte) error

+ type OtelMetrics struct

+ func (s *OtelMetrics) Bootstrap(pipeline Pipeline, next Next) (Next, error)

+ type OtelTrace struct

+ func (s *OtelTrace) Bootstrap(pipeline Pipeline, next Next) (Next, error)

type ProcessorBuilder

+ func WithEnv(defaultEnv map[string]string) ProcessorBuilder

+ func WithOtelMetrics(meter metric.Meter) ProcessorBuilder

+ func WithOtelTrace(logger logr.Logger, tracer trace.Tracer) ProcessorBuilder

+ func WithResult() ProcessorBuilder

+ func WithSkipBlacklist(blacklist []string) ProcessorBuilder

+ type Result struct

+ func (s *Result) Bootstrap(pipeline Pipeline, next Next) (Next, error)

+ type SkipBlacklist struct

+ func (s *SkipBlacklist) Bootstrap(pipeline Pipeline, next Next) (Next, error)

Jan 31, 2025

Changes in this version

+ var ErrAllowFailure = errors.New("ignore error returned from step")

+ var ErrConditionFalse = errors.New("conditional step skipped")

+ var ErrSkipDone = errors.New("skip step marked as successful")

+ func AbortOnError(err error) bool

+ func PrefixName(name, prefix string) string

+ type AllowFailure struct

+ func (s *AllowFailure) Bootstrap(pipeline Pipeline, next Next) (Next, error)

+ type And struct

+ func (s *And) Bootstrap(pipeline Pipeline, next Next) (Next, error)

+ type Bootstraper interface

+ Bootstrap func(pipeline Pipeline, next Next) (Next, error)

+ func Builder(spec *v1beta1.Step, builders ...ProcessorBuilder) []Bootstraper

+ type Concurrent struct

+ func (s *Concurrent) Bootstrap(pipeline Pipeline, next Next) (Next, error)

+ type EventEmitter struct

+ func (s *EventEmitter) Bootstrap(pipeline Pipeline, next Next) (Next, error)

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

+ type ExpressionParser struct

+ func (s *ExpressionParser) Bootstrap(pipeline Pipeline, next Next) (Next, error)

+ type GarbageCollector struct

+ func (s *GarbageCollector) Bootstrap(pipeline Pipeline, next Next) (Next, error)

+ type If struct

+ func (s *If) Bootstrap(pipeline Pipeline, next Next) (Next, error)

+ type Inherit struct

+ func (s *Inherit) Bootstrap(pipeline Pipeline, next Next) (Next, error)

+ func (s *Inherit) MarshalJSON() ([]byte, error)

+ func (s *Inherit) UnmarshalJSON(b []byte) error

+ type Matrix struct

+ func (s *Matrix) Bootstrap(pipeline Pipeline, next Next) (Next, error)

+ func (s *Matrix) MarshalJSON() ([]byte, error)

+ func (s *Matrix) UnmarshalJSON(b []byte) error

+ type Needs struct

+ func (s *Needs) Bootstrap(pipeline Pipeline, next Next) (Next, error)

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

+ func Chain(pipeline Pipeline, s ...Bootstraper) (Next, error)

+ type Otel struct

+ func (s *Otel) Bootstrap(pipeline Pipeline, next Next) (Next, error)

+ 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

+ func (s *Pipe) Bootstrap(pipeline Pipeline, next Next) (Next, error)

+ type Pipeline interface

+ Entrypoint func(name string) (Next, error)

+ ID func() string

+ Name func() string

+ Step func(name string) (Step, error)

+ type PipelineBuilder interface

+ Build func(pipeline v1beta1.Pipeline, entrypoint string, inputs map[string]string) (Executable, error)

+ type ProcessorBuilder func(spec *v1beta1.Step) Bootstraper

+ func WithAllowFailure() ProcessorBuilder

+ func WithAnd() ProcessorBuilder

+ func WithConcurrent() ProcessorBuilder

+ func WithEventEmitter() ProcessorBuilder

+ func WithExpressionParser(celEnv *cel.Env, processors ...Bootstraper) ProcessorBuilder

+ func WithGarbageCollector(noGC bool, driver runtime.Interface, teardown chan Teardown) ProcessorBuilder

+ func WithIf(celEnv *cel.Env) ProcessorBuilder

+ func WithInherit(builder PipelineBuilder, store storage.Interface) ProcessorBuilder

+ func WithMatrix() ProcessorBuilder

+ func WithNeeds() ProcessorBuilder

+ func WithOtel(logger logr.Logger, tracer trace.Tracer, meter metric.Meter) ProcessorBuilder

+ func WithPipe() ProcessorBuilder

+ func WithReport(store ResultStore, uniqueName string) ProcessorBuilder

+ func WithRetry() ProcessorBuilder

+ func WithRun(tee bool, defaultPullPolicy runtime.PullImagePolicy, driver runtime.Interface, ...) ProcessorBuilder

+ func WithSkipDone(skipDone bool) ProcessorBuilder

+ func WithStdio() ProcessorBuilder

+ func WithTimeout() ProcessorBuilder

+ type Report struct

+ func (s *Report) Bootstrap(pipeline Pipeline, next Next) (Next, error)

+ type ResultStore interface

+ Add func(stepName string, result *StepResult)

+ type Retry struct

+ func (s *Retry) Bootstrap(pipeline Pipeline, next Next) (Next, error)

+ type Run struct

+ func (s *Run) Bootstrap(pipeline Pipeline, next Next) (Next, error)

+ func (s *Run) MarshalJSON() ([]byte, error)

+ func (s *Run) UnmarshalJSON(b []byte) error

+ type SkipDone struct

+ func (s *SkipDone) Bootstrap(pipeline Pipeline, next Next) (Next, error)

+ type Stdio struct

+ func (s *Stdio) Bootstrap(pipelineCtx Pipeline, next Next) (Next, error)

+ func (s *Stdio) MarshalJSON() ([]byte, error)

+ func (s *Stdio) UnmarshalJSON(b []byte) error

+ type Step interface

+ Entrypoint func() (Next, error)

+ Processors func() []Bootstraper

+ type StepContext struct

+ Containers map[string]cruntime.ContainerStatus

+ Env string

+ Envs map[string]string

+ Matrix map[string]interface{}

+ NamePrefix string

+ Output string

+ Parent string

+ Stderr io.Writer

+ Stdin io.Reader

+ Stdout io.Writer

+ Steps map[string]*StepResult

+ func NewContext(tmpDir string, inputs map[string]interface{}) StepContext

+ func (c StepContext) DeepCopy() StepContext

+ func (t StepContext) Child() StepContext

+ func (t StepContext) FromV1Beta1(vars *v1beta1.RuntimeVars)

+ func (t StepContext) Merge(c StepContext) StepContext

+ func (t StepContext) RuntimeVars() map[string]interface{}

+ func (t StepContext) TmpDir() string

+ func (t StepContext) ToV1Beta1() *v1beta1.RuntimeVars

+ type StepResult struct

+ Containers map[string]cruntime.ContainerStatus

+ EndedAt time.Time

+ Envs map[string]string

+ Error error

+ Outputs map[string]string

+ StartedAt time.Time

+ func (t *StepResult) Duration() time.Duration

+ type Teardown func(ctx context.Context) error

+ type Timeout struct

+ func (s *Timeout) Bootstrap(pipeline Pipeline, next Next) (Next, error)