runner

Jan 21, 2026

Changes in this version

type OCIStepResource

+ func (r *OCIStepResource) Fetch(ctx context.Context, view *expression.InterpolationContext) (*FunctionDescriptor, error)

Jan 14, 2026

Changes in this version

+ type FunctionDescriptor struct

+ func NewFunctionDescriptor(spec *proto.Spec, definition *proto.Definition, dir string) *FunctionDescriptor

+ func (sd *FunctionDescriptor) DefinitionOutputs() map[string]*structpb.Value

+ func (sd *FunctionDescriptor) DelegateTo() string

+ func (sd *FunctionDescriptor) DescribeType() string

+ func (sd *FunctionDescriptor) Dir() string

+ func (sd *FunctionDescriptor) Env() map[string]string

+ func (sd *FunctionDescriptor) ExecCommand() []string

+ func (sd *FunctionDescriptor) ExecWorkDir() string

+ func (sd *FunctionDescriptor) FunctionName() string

+ func (sd *FunctionDescriptor) IsDelegateOutputs() bool

+ func (sd *FunctionDescriptor) IsTypeExec() bool

+ func (sd *FunctionDescriptor) IsTypeFunction() bool

+ func (sd *FunctionDescriptor) IsTypeSteps() bool

+ func (sd *FunctionDescriptor) SpecInputWithName(name string) (*proto.Spec_Content_Input, bool)

+ func (sd *FunctionDescriptor) SpecInputs() map[string]*proto.Spec_Content_Input

+ func (sd *FunctionDescriptor) SpecOutputs() map[string]*proto.Spec_Content_Output

+ func (sd *FunctionDescriptor) Steps() []*proto.Step

+ func (sd *FunctionDescriptor) ToProto() *proto.SpecDefinition

Nov 27, 2025

Changes in this version

type GlobalContext

+ func (gc *GlobalContext) LookupEnv(key string) (string, bool)

type StepsContext

+ func (s *StepsContext) LookupEnv(key string) (string, bool)

Nov 21, 2025

Changes in this version

type GlobalContext

+ func (gc *GlobalContext) ProjectDir() string

type JobVariables

+ func (v JobVariables) ProjectDir() string

type StepsContext

+ func (s *StepsContext) GetInputWithDefault(name string, kind Kind, inputSpec map[string]*proto.Spec_Content_Input) (*structpb.Value, error)

+ func (s *StepsContext) ProjectDir() string

Nov 6, 2025

Changes in this version

+ type FunctionStepResource struct

+ func NewFunctionStepResource(functionName string, findStepFunction StepFuncFinder) *FunctionStepResource

+ func (r *FunctionStepResource) Fetch(_ context.Context, _ *expression.InterpolationContext) (*SpecDefinition, error)

+ type Kind int

+ const KindBool

+ const KindList

+ const KindNull

+ const KindNumber

+ const KindString

+ const KindStruct

+ func ValueToKind(value *structpb.Value) (Kind, error)

+ func (k Kind) String() string

type SpecDefinition

+ func (sd *SpecDefinition) FunctionName() string

+ func (sd *SpecDefinition) IsTypeFunction() bool

+ type StepFunc func(ctx context.Context, stepsCtx *StepsContext) error

+ type StepFuncFinder func(stepName string) (*proto.Spec, StepFunc, error)

+ type StepFunction struct

+ func NewStepFunction(loadedFrom StepReference, params *Params, specDef *SpecDefinition, ...) *StepFunction

+ func (s *StepFunction) Describe() string

+ func (s *StepFunction) Run(ctx ctx.Context, stepsCtx *StepsContext) (*proto.StepResult, error)

+ type StepFunctionRepository struct

+ func NewStepFunctionRepository() *StepFunctionRepository

+ func (r *StepFunctionRepository) Find(step string) (*proto.Spec, StepFunc, error)

+ func (r *StepFunctionRepository) Register(step string, spec *proto.Spec, stepFunc StepFunc) error

type StepsContext

+ func (s *StepsContext) GetEnv(name string) string

+ func (s *StepsContext) GetExportFile() string

+ func (s *StepsContext) GetInput(name string, kind Kind) (*structpb.Value, error)

+ func (s *StepsContext) GetOutputFile() string

Sep 4, 2025

Changes in this version

+ type JobVariables map[string]*structpb.Value

+ func (v JobVariables) StringValueOf(key string) string

Apr 16, 2025

Changes in this version

type DistStepResource

+ func (sr *DistStepResource) Fetch(ctx context.Context, _ *expression.InterpolationContext) (*SpecDefinition, error)

+ type DynamicStepResource struct

+ func NewDynamicStepResource(parser stepResourceParser, shortRef string) *DynamicStepResource

+ func (sr *DynamicStepResource) Fetch(ctx context.Context, view *expression.InterpolationContext) (*SpecDefinition, error)

type FileSystemStepResource

+ func (sr *FileSystemStepResource) Fetch(_ context.Context, _ *expression.InterpolationContext) (*SpecDefinition, error)

+ type FixedStepResource struct

+ func NewFixedStepResource(specDef *SpecDefinition) *FixedStepResource

+ func (sr *FixedStepResource) Fetch(_ context.Context, _ *expression.InterpolationContext) (*SpecDefinition, error)

type GitStepResource

+ func (sr *GitStepResource) Fetch(ctx context.Context, view *expression.InterpolationContext) (*SpecDefinition, error)

+ type SpecDefinition struct

+ func NewSpecDefinition(spec *proto.Spec, definition *proto.Definition, dir string) *SpecDefinition

+ func (sd *SpecDefinition) DefinitionOutputs() map[string]*structpb.Value

+ func (sd *SpecDefinition) DelegateTo() string

+ func (sd *SpecDefinition) DescribeType() string

+ func (sd *SpecDefinition) Dir() string

+ func (sd *SpecDefinition) Env() map[string]string

+ func (sd *SpecDefinition) ExecCommand() []string

+ func (sd *SpecDefinition) ExecWorkDir() string

+ func (sd *SpecDefinition) IsDelegateOutputs() bool

+ func (sd *SpecDefinition) IsTypeExec() bool

+ func (sd *SpecDefinition) IsTypeSteps() bool

+ func (sd *SpecDefinition) SpecInputWithName(name string) (*proto.Spec_Content_Input, bool)

+ func (sd *SpecDefinition) SpecInputs() map[string]*proto.Spec_Content_Input

+ func (sd *SpecDefinition) SpecOutputs() map[string]*proto.Spec_Content_Output

+ func (sd *SpecDefinition) Steps() []*proto.Step

+ func (sd *SpecDefinition) ToProto() *proto.SpecDefinition

type StepResource

+ Fetch func(context.Context, *expression.InterpolationContext) (*SpecDefinition, error)

+ type StepResourceParser struct

+ func NewStepResourceParser(gitFetcher *git.GitFetcher, distFetcher *dist.Fetcher) *StepResourceParser

+ func (p *StepResourceParser) Parse(parentDir string, stepRef *proto.Step_Reference) (StepResource, error)

Apr 1, 2025

Changes in this version

+ type DistStepResource struct

+ func NewDistStepResource(path []string, filename string) *DistStepResource

+ func (sr *DistStepResource) Describe() string

+ func (sr *DistStepResource) Interpolate(_ *expression.InterpolationContext) (StepResource, error)

+ func (sr *DistStepResource) ToProtoStepRef() *proto.Step_Reference

Mar 20, 2025

Changes in this version

+ func WithStepsCtxExportFile(exportFile *StepFile) func(*StepsContext)

+ func WithStepsCtxOutputFile(outputFile *StepFile) func(*StepsContext)

+ func WithStepsCtxStepResults(results map[string]*proto.StepResult) func(*StepsContext)

type GlobalContext

+ func (gc *GlobalContext) AddGlobalEnv(env *Environment)

+ func (gc *GlobalContext) EnvWithLexicalScope(envVars map[string]string) *Environment

+ func (gc *GlobalContext) Pipe() (io.Writer, io.Writer)

type StepsContext

+ func (s *StepsContext) AddGlobalEnv(env *Environment)

+ func (s *StepsContext) EnvWithLexicalScope(envVars map[string]string) *Environment

+ func (s *StepsContext) Logln(format string, v ...any) error

+ func (s *StepsContext) Pipe() (io.Writer, io.Writer)

+ func (s *StepsContext) ReadExportedEnv() (*Environment, error)

+ func (s *StepsContext) ReadOutputStepResult() (*proto.StepResult, error)

+ func (s *StepsContext) ReadOutputValues(specOutputs map[string]*proto.Spec_Content_Output) (map[string]*structpb.Value, error)

+ func (s *StepsContext) WorkDir() string

Mar 17, 2025

Changes in this version

+ var LogLevelEnvName = "CI_STEPS_LOG_LEVEL"

+ type BuiltInStepResource struct

+ func NewBuiltInStepResource(path []string, filename string) *BuiltInStepResource

+ func (sr *BuiltInStepResource) Describe() string

+ func (sr *BuiltInStepResource) Interpolate(_ *expression.InterpolationContext) (StepResource, error)

+ func (sr *BuiltInStepResource) ToProtoStepRef() *proto.Step_Reference

type Environment

+ func GlobalEnvironment(parent *Environment, jobVars map[string]string) (*Environment, error)

type OCIStepResource

+ func (sr *OCIStepResource) NamedReference() (name.Reference, error)

Feb 14, 2025

Changes in this version

+ type OCIStepResource struct

+ func NewOCIStepResource(url string, tag string, path []string, filename string) *OCIStepResource

+ func (sr *OCIStepResource) Describe() string

+ func (sr *OCIStepResource) Interpolate(_ *expression.InterpolationContext) (StepResource, error)

+ func (sr *OCIStepResource) ToProtoStepRef() *proto.Step_Reference

Dec 6, 2024

Changes in this version

+ var RunningInDebugMode = strconv.ParseBool(os.Getenv("CI_STEPS_DEBUG"))

+ func WithErrCtxLogAdditionalCtx(logAdditionalCtx bool) func(*ErrorCtx)

+ type ErrorCtx struct

+ func NewErrorCtx(description string, additionalCxt []byte, options ...func(*ErrorCtx)) *ErrorCtx

+ func (e *ErrorCtx) Errorf(message string, v ...any) error

type GlobalContext

+ func (gc *GlobalContext) Logf(format string, v ...any) error

+ func (gc *GlobalContext) Logln(format string, v ...any) error

type NamedStepReference

+ func (sr *NamedStepReference) Describe() string

+ type StepFileLine struct

+ Name *string

+ Value *structpb.Value

Nov 19, 2024

Changes in this version

+ var StepDefinedInGitLabJob = NewNamedStepReference("", nil)

+ type Cache interface

+ Get func(ctx context.Context, parentDir string, stepResource StepResource) (*proto.SpecDefinition, error)

+ type Describer interface

+ Describe func() string

+ type Environment struct

+ func NewEmptyEnvironment() *Environment

+ func NewEnvironment(vars map[string]string) *Environment

+ func NewEnvironmentFromOS(names ...string) (*Environment, error)

+ func NewEnvironmentFromOSWithKnownVars() (*Environment, error)

+ func NewKVEnvironment(keyValues ...string) *Environment

+ func (e *Environment) AddLexicalScope(vars map[string]string) *Environment

+ func (e *Environment) Len() int

+ func (e *Environment) Mutate(env *Environment)

+ func (e *Environment) ValueOf(key string) string

+ func (e *Environment) Values() map[string]string

+ type ExecResult struct

+ func NewExecResult(workDir string, cmdArgs []string, exitCode int) *ExecResult

+ func (ec *ExecResult) ToProto() *proto.StepResult_ExecResult

+ type ExecutableStep struct

+ func NewExecutableStep(loadedFrom StepReference, params *Params, specDef *proto.SpecDefinition) *ExecutableStep

+ func (s *ExecutableStep) Describe() string

+ func (s *ExecutableStep) Run(ctx ctx.Context, stepsCtx *StepsContext) (*proto.StepResult, error)

+ type FileSystemStepResource struct

+ func NewFileSystemStepResource(path []string, filename string) *FileSystemStepResource

+ func (sr *FileSystemStepResource) Describe() string

+ func (sr *FileSystemStepResource) Interpolate(_ *expression.InterpolationContext) (StepResource, error)

+ func (sr *FileSystemStepResource) ToProtoStepRef() *proto.Step_Reference

+ type GitStepResource struct

+ func NewGitStepResource(url string, version string, path []string, filename string) *GitStepResource

+ func (sr *GitStepResource) Describe() string

+ func (sr *GitStepResource) Interpolate(view *expression.InterpolationContext) (StepResource, error)

+ func (sr *GitStepResource) ToProtoStepRef() *proto.Step_Reference

+ type GlobalContext struct

+ Env *Environment

+ Job map[string]string

+ Stderr io.Writer

+ Stdout io.Writer

+ WorkDir string

+ func NewGlobalContext(env *Environment) *GlobalContext

+ type LazilyLoadedStep struct

+ func NewLazilyLoadedStep(globalCtx *GlobalContext, resourceLoader Cache, parser StepParser, ...) *LazilyLoadedStep

+ func (s *LazilyLoadedStep) Describe() string

+ func (s *LazilyLoadedStep) Run(ctx ctx.Context, parentStepsCtx *StepsContext) (*proto.StepResult, error)

+ type NamedStepReference struct

+ func NewNamedStepReference(name string, ref *proto.Step_Reference) *NamedStepReference

+ func (sr *NamedStepReference) ToProtoStep(params *Params) *proto.Step

+ type Params struct

+ Env map[string]string

+ Inputs map[string]*context.Variable

+ func (p *Params) NewInputsWithDefault(specInputs map[string]*proto.Spec_Content_Input) map[string]*structpb.Value

+ type Parser struct

+ func NewParser(globalCtx *GlobalContext, stepCache Cache) *Parser

+ func (p *Parser) Parse(specDef *proto.SpecDefinition, params *Params, loadedFrom StepReference) (Step, error)

+ type SequenceOfSteps struct

+ func NewSequenceOfSteps(loadedFrom StepReference, params *Params, specDef *proto.SpecDefinition, ...) *SequenceOfSteps

+ func (s *SequenceOfSteps) Describe() string

+ func (s *SequenceOfSteps) Run(ctx ctx.Context, stepsCtx *StepsContext) (*proto.StepResult, error)

+ type Step interface

+ Run func(ctx ctx.Context, stepsCtx *StepsContext) (*proto.StepResult, error)

+ type StepFile struct

+ func NewStepFile(path string) *StepFile

+ func NewStepFileInDir(dir string) (*StepFile, error)

+ func NewStepFileInTmp() (*StepFile, error)

+ func (s *StepFile) Path() string

+ func (s *StepFile) ReadDotEnv() (map[string]string, error)

+ func (s *StepFile) ReadEnvironment() (*Environment, error)

+ func (s *StepFile) ReadKeyValueLines() (map[string]string, error)

+ func (s *StepFile) ReadStepResult() (*proto.StepResult, error)

+ func (s *StepFile) ReadValues(specOutputs map[string]*proto.Spec_Content_Output) (map[string]*structpb.Value, error)

+ func (s *StepFile) Remove() error

+ type StepParser interface

+ Parse func(specDef *proto.SpecDefinition, params *Params, loadedFrom StepReference) (Step, error)

+ type StepReference interface

+ ToProtoStep func(*Params) *proto.Step

+ type StepResource interface

+ Interpolate func(*expression.InterpolationContext) (StepResource, error)

+ ToProtoStepRef func() *proto.Step_Reference

+ type StepResultBuilder struct

+ func NewStepResultBuilder(loadedFrom StepReference, params *Params, specDef *proto.SpecDefinition) *StepResultBuilder

+ func (bldr *StepResultBuilder) Build() *proto.StepResult

+ func (bldr *StepResultBuilder) BuildFailure() *proto.StepResult

+ func (bldr *StepResultBuilder) ObserveEnv(env *Environment, err error) error

+ func (bldr *StepResultBuilder) ObserveExecutedCmd(execResult *ExecResult, err error) error

+ func (bldr *StepResultBuilder) ObserveExports(exports *Environment, err error) (*Environment, error)

+ func (bldr *StepResultBuilder) ObserveOutputs(outputs map[string]*structpb.Value, err error) error

+ func (bldr *StepResultBuilder) ObserveStepResult(stepResult *proto.StepResult, err error) (*proto.StepResult, error)

+ func (bldr *StepResultBuilder) WithEnv(env map[string]string) *StepResultBuilder

+ func (bldr *StepResultBuilder) WithExecResult(executedCmd *ExecResult) *StepResultBuilder

+ func (bldr *StepResultBuilder) WithExports(exports *Environment) *StepResultBuilder

+ func (bldr *StepResultBuilder) WithOutputs(outputs map[string]*structpb.Value) *StepResultBuilder

+ func (bldr *StepResultBuilder) WithSubStepResult(result *proto.StepResult) *StepResultBuilder

+ type StepsContext struct

+ Env *Environment

+ ExportFile *StepFile

+ Inputs map[string]*structpb.Value

+ OutputFile *StepFile

+ StepDir string

+ Steps map[string]*proto.StepResult

+ func NewStepsContext(globalCtx *GlobalContext, dir string, inputs map[string]*structpb.Value, ...) (*StepsContext, error)

+ func (s *StepsContext) Cleanup()

+ func (s *StepsContext) ExpandAndApplyEnv(env map[string]string) (*Environment, error)

+ func (s *StepsContext) GetEnvList() []string

+ func (s *StepsContext) GetEnvs() map[string]string

+ func (s *StepsContext) RecordResult(stepResult *proto.StepResult)

+ func (s *StepsContext) StepResults() []*proto.StepResult

+ func (s *StepsContext) View() *expression.InterpolationContext