builder

Sep 27, 2021

Changes in this version

type WhenEvaluator

+ Describe func(input string, parameters map[string]interface{}) string

Jul 12, 2021

Changes in this version

+ func HandleExit(buildLogSteps []*contracts.BuildLogStep)

+ func RenderStats(buildLogSteps []*contracts.BuildLogStep)

+ func WaitForReadinessHttpGet(ctx context.Context, scheme, host string, port int, path, hostname string, ...) error

+ type CIBuilder interface

+ RunEstafetteBuildJob func(ctx context.Context, pipelineRunner PipelineRunner, ...)

+ RunEstafetteCLIBuild func() error

+ RunGocdAgentBuild func(ctx context.Context, pipelineRunner PipelineRunner, ...)

+ RunLocalBuild func(ctx context.Context, pipelineRunner PipelineRunner, ...)

+ RunReadinessProbe func(ctx context.Context, scheme, host string, port int, path, hostname string, ...)

+ func NewCIBuilder(applicationInfo foundation.ApplicationInfo) CIBuilder

+ type ContainerRunner interface

+ CreateDockerClient func() error

+ CreateNetworks func(ctx context.Context) error

+ DeleteNetworks func(ctx context.Context) error

+ GetImageSize func(ctx context.Context, containerImage string) (int64, error)

+ HasInjectedCredentials func(stageName string, containerImage string) bool

+ Info func(ctx context.Context) string

+ IsImagePulled func(ctx context.Context, stageName string, containerImage string) bool

+ IsTrustedImage func(stageName string, containerImage string) bool

+ PullImage func(ctx context.Context, stageName string, containerImage string) error

+ RunReadinessProbeContainer func(ctx context.Context, parentStage manifest.EstafetteStage, ...) (err error)

+ StartDockerDaemon func() error

+ StartServiceContainer func(ctx context.Context, envvars map[string]string, ...) (containerID string, err error)

+ StartStageContainer func(ctx context.Context, depth int, runIndex int, dir string, ...) (containerID string, err error)

+ StopAllContainers func(ctx context.Context)

+ StopMultiStageServiceContainers func(ctx context.Context)

+ StopSingleStageServiceContainers func(ctx context.Context, parentStage manifest.EstafetteStage)

+ TailContainerLogs func(ctx context.Context, containerID, parentStageName, stageName string, ...) (err error)

+ WaitForDockerDaemon func()

+ func NewDockerRunner(envvarHelper EnvvarHelper, obfuscator Obfuscator, ...) ContainerRunner

+ func NewKubernetesRunner(envvarHelper EnvvarHelper, obfuscator Obfuscator, ...) ContainerRunner

+ type EndOfLifeHelper interface

+ CancelJob func(ctx context.Context) error

+ HandleFatal func(context.Context, contracts.BuildLog, error, string)

+ SendBuildCleanEvent func(ctx context.Context, buildStatus contracts.LogStatus) error

+ SendBuildFinishedEvent func(ctx context.Context, buildStatus contracts.LogStatus) error

+ SendBuildJobLogEvent func(ctx context.Context, buildLog contracts.BuildLog) error

+ SendBuildStartedEvent func(ctx context.Context) error

+ func NewEndOfLifeHelper(runAsJob bool, config contracts.BuilderConfig, podName string) EndOfLifeHelper

+ type EnvvarHelper interface

+ CollectEstafetteEnvvarsAndLabels func(manifest.EstafetteManifest) (map[string]string, error)

+ CollectGlobalEnvvars func(manifest.EstafetteManifest) map[string]string

+ GetCiServer func() string

+ GetPipelineName func() string

+ GetPodName func() string

+ GetPodNamespace func() string

+ GetPodNodeName func() string

+ GetPodUID func() string

+ GetTempDir func() string

+ GetWorkDir func() string

+ OverrideEnvvars func(...map[string]string) map[string]string

+ SetEstafetteBuilderConfigEnvvars func(builderConfig contracts.BuilderConfig) error

+ SetEstafetteGlobalEnvvars func() error

+ SetPipelineName func(builderConfig contracts.BuilderConfig) error

+ UnsetEstafetteEnvvars func()

+ func NewEnvvarHelper(prefix string, secretHelper crypt.SecretHelper, obfuscator Obfuscator) EnvvarHelper

+ type LocalFatalHandler interface

+ HandleFatal func(error, string)

+ func NewLocalFatalHandler() LocalFatalHandler

+ type MapMutex struct

+ func NewMapMutex() *MapMutex

+ func (m *MapMutex) Lock(key string)

+ func (m *MapMutex) RLock(key string)

+ func (m *MapMutex) RUnlock(key string)

+ func (m *MapMutex) Unlock(key string)

+ type MockContainerRunner struct

+ func NewMockContainerRunner(ctrl *gomock.Controller) *MockContainerRunner

+ func (m *MockContainerRunner) CreateDockerClient() error

+ func (m *MockContainerRunner) CreateNetworks(ctx context.Context) error

+ func (m *MockContainerRunner) DeleteNetworks(ctx context.Context) error

+ func (m *MockContainerRunner) EXPECT() *MockContainerRunnerMockRecorder

+ func (m *MockContainerRunner) GetImageSize(ctx context.Context, containerImage string) (int64, error)

+ func (m *MockContainerRunner) HasInjectedCredentials(stageName, containerImage string) bool

+ func (m *MockContainerRunner) Info(ctx context.Context) string

+ func (m *MockContainerRunner) IsImagePulled(ctx context.Context, stageName, containerImage string) bool

+ func (m *MockContainerRunner) IsTrustedImage(stageName, containerImage string) bool

+ func (m *MockContainerRunner) PullImage(ctx context.Context, stageName, containerImage string) error

+ func (m *MockContainerRunner) RunReadinessProbeContainer(ctx context.Context, parentStage manifest.EstafetteStage, ...) error

+ func (m *MockContainerRunner) StartDockerDaemon() error

+ func (m *MockContainerRunner) StartServiceContainer(ctx context.Context, envvars map[string]string, ...) (string, error)

+ func (m *MockContainerRunner) StartStageContainer(ctx context.Context, depth, runIndex int, dir string, ...) (string, error)

+ func (m *MockContainerRunner) StopAllContainers(ctx context.Context)

+ func (m *MockContainerRunner) StopMultiStageServiceContainers(ctx context.Context)

+ func (m *MockContainerRunner) StopSingleStageServiceContainers(ctx context.Context, parentStage manifest.EstafetteStage)

+ func (m *MockContainerRunner) TailContainerLogs(ctx context.Context, containerID, parentStageName, stageName string, ...) error

+ func (m *MockContainerRunner) WaitForDockerDaemon()

+ type MockContainerRunnerMockRecorder struct

+ func (mr *MockContainerRunnerMockRecorder) CreateDockerClient() *gomock.Call

+ func (mr *MockContainerRunnerMockRecorder) CreateNetworks(ctx interface{}) *gomock.Call

+ func (mr *MockContainerRunnerMockRecorder) DeleteNetworks(ctx interface{}) *gomock.Call

+ func (mr *MockContainerRunnerMockRecorder) GetImageSize(ctx, containerImage interface{}) *gomock.Call

+ func (mr *MockContainerRunnerMockRecorder) HasInjectedCredentials(stageName, containerImage interface{}) *gomock.Call

+ func (mr *MockContainerRunnerMockRecorder) Info(ctx interface{}) *gomock.Call

+ func (mr *MockContainerRunnerMockRecorder) IsImagePulled(ctx, stageName, containerImage interface{}) *gomock.Call

+ func (mr *MockContainerRunnerMockRecorder) IsTrustedImage(stageName, containerImage interface{}) *gomock.Call

+ func (mr *MockContainerRunnerMockRecorder) PullImage(ctx, stageName, containerImage interface{}) *gomock.Call

+ func (mr *MockContainerRunnerMockRecorder) RunReadinessProbeContainer(ctx, parentStage, service, readiness interface{}) *gomock.Call

+ func (mr *MockContainerRunnerMockRecorder) StartDockerDaemon() *gomock.Call

+ func (mr *MockContainerRunnerMockRecorder) StartServiceContainer(ctx, envvars, service interface{}) *gomock.Call

+ func (mr *MockContainerRunnerMockRecorder) StartStageContainer(ctx, depth, runIndex, dir, envvars, stage, stageIndex interface{}) *gomock.Call

+ func (mr *MockContainerRunnerMockRecorder) StopAllContainers(ctx interface{}) *gomock.Call

+ func (mr *MockContainerRunnerMockRecorder) StopMultiStageServiceContainers(ctx interface{}) *gomock.Call

+ func (mr *MockContainerRunnerMockRecorder) StopSingleStageServiceContainers(ctx, parentStage interface{}) *gomock.Call

+ func (mr *MockContainerRunnerMockRecorder) TailContainerLogs(...) *gomock.Call

+ func (mr *MockContainerRunnerMockRecorder) WaitForDockerDaemon() *gomock.Call

+ type Obfuscator interface

+ CollectSecrets func(manifest manifest.EstafetteManifest, credentialsBytes []byte, pipeline string) (err error)

+ Obfuscate func(input string) string

+ ObfuscateSecrets func(input string) string

+ func NewObfuscator(secretHelper crypt.SecretHelper) Obfuscator

+ type PipelineRunner interface

+ EnableBuilderInfoStageInjection func()

+ RunParallelStages func(ctx context.Context, depth int, dir string, envvars map[string]string, ...) (err error)

+ RunService func(ctx context.Context, envvars map[string]string, ...) (err error)

+ RunServices func(ctx context.Context, envvars map[string]string, ...) (err error)

+ RunStage func(ctx context.Context, depth int, runIndex int, dir string, ...) (err error)

+ RunStageWithRetry func(ctx context.Context, depth int, dir string, envvars map[string]string, ...) (err error)

+ RunStages func(ctx context.Context, depth int, stages []*manifest.EstafetteStage, dir string, ...) (buildLogSteps []*contracts.BuildLogStep, err error)

+ StopPipelineOnCancellation func(ctx context.Context)

+ func NewPipelineRunner(envvarHelper EnvvarHelper, whenEvaluator WhenEvaluator, ...) PipelineRunner

+ type WhenEvaluator interface

+ Evaluate func(string, string, map[string]interface{}) (bool, error)

+ GetParameters func() map[string]interface{}

+ func NewWhenEvaluator(envvarHelper EnvvarHelper) WhenEvaluator