Versions in this module Expand all Collapse all v0 v0.9.1 Dec 2, 2020 Changes in this version + func DetermineStageStatus(sig StopSignalType, ori, got model.StageStatus) model.StageStatus + func NewStopSignal() (StopSignal, StopSignalHandler) + type AppLiveResourceLister interface + ListKubernetesResources func() ([]provider.Manifest, bool) + type CommandLister interface + ListCommands func() []model.ReportableCommand + type Executor interface + Execute func(sig StopSignal) model.StageStatus + type Factory func(in Input) Executor + type Input struct + AppLiveResourceLister AppLiveResourceLister + AppManifestsCache cache.Cache + Application *model.Application + CommandLister CommandLister + Deployment *model.Deployment + LogPersister LogPersister + Logger *zap.Logger + MetadataStore MetadataStore + PipedConfig *config.PipedSpec + RunningDSP deploysource.Provider + Stage *model.PipelineStage + StageConfig config.PipelineStage + TargetDSP deploysource.Provider + type LogPersister interface + Error func(log string) + Errorf func(format string, a ...interface{}) + Info func(log string) + Infof func(format string, a ...interface{}) + Success func(log string) + Successf func(format string, a ...interface{}) + Write func(log []byte) (int, error) + type MetadataStore interface + Get func(key string) (string, bool) + GetStageMetadata func(stageID string) (map[string]string, bool) + Set func(ctx context.Context, key, value string) error + SetStageMetadata func(ctx context.Context, stageID string, metadata map[string]string) error + type StopSignal interface + Ch func() <-chan StopSignalType + Context func() context.Context + Signal func() StopSignalType + Stopped func() bool + type StopSignalHandler interface + Cancel func() + Terminate func() + Timeout func() + type StopSignalType string + const StopSignalCancel + const StopSignalNone + const StopSignalTerminate + const StopSignalTimeout