taskplugin

May 31, 2022

Changes in this version

+ func InstantiateBuildSysVariables(jobCtx *task.JobCtx) []*task.KeyVal

Oct 24, 2023

Changes in this version

+ const EventName

+ const ExtensionTaskTimeout

+ const ScanningTaskTimeout

+ const ScanningTypeOther

+ const ScanningTypeSonar

+ const ZadigEvent

+ func CreateEnvsFromRepoInfo(repos []*task.Repository) []*task.KeyVal

+ func GetK8sClients(hubServerAddr, clusterID string) (crClient.Client, kubernetes.Interface, *rest.Config, crClient.Reader, error)

+ func GetLink(p *task.Task, baseURI string, taskType config.PipelineType) string

+ func GetProductInfo(ctx context.Context, args *EnvArgs) (*types.Product, error)

+ func PrepareDefaultWorkflowTaskEnvs(t *task.Task) []*task.KeyVal

+ func ToExtensionTask(sb map[string]interface{}) (*task.Extension, error)

+ func ToScanningTask(sb map[string]interface{}) (*task.Scanning, error)

+ func UIType(pipelineType config.PipelineType) string

type ArtifactDeployTaskPlugin

+ Timeout <-chan time.Time

type BuildTaskPlugin

+ Timeout <-chan time.Time

type BuildTaskV3Plugin

+ Timeout <-chan time.Time

+ type CreateK8SEnvServiceVersionRequest struct

+ ContainerName string

+ Image string

+ ServiceName string

+ ServiceRevision int64

type DeployTaskPlugin

+ ClientSet kubernetes.Interface

type DockerBuildPlugin

+ Timeout <-chan time.Time

+ type ExtensionTaskPlugin struct

+ FileName string

+ JobName string

+ KubeNamespace string

+ Log *zap.SugaredLogger

+ Name config.TaskType

+ Task *task.Extension

+ func (p *ExtensionTaskPlugin) Complete(ctx context.Context, pipelineTask *task.Task, serviceName string)

+ func (p *ExtensionTaskPlugin) GetTask() interface{}

+ func (p *ExtensionTaskPlugin) Init(jobname, filename string, xl *zap.SugaredLogger)

+ func (p *ExtensionTaskPlugin) IsTaskDone() bool

+ func (p *ExtensionTaskPlugin) IsTaskEnabled() bool

+ func (p *ExtensionTaskPlugin) IsTaskFailed() bool

+ func (p *ExtensionTaskPlugin) ResetError()

+ func (p *ExtensionTaskPlugin) Run(ctx context.Context, pipelineTask *task.Task, pipelineCtx *task.PipelineCtx, ...)

+ func (p *ExtensionTaskPlugin) SetAckFunc(ack func())

+ func (p *ExtensionTaskPlugin) SetEndTime()

+ func (p *ExtensionTaskPlugin) SetExtensionStatusCompleted(status config.Status)

+ func (p *ExtensionTaskPlugin) SetStartTime()

+ func (p *ExtensionTaskPlugin) SetStatus(status config.Status)

+ func (p *ExtensionTaskPlugin) SetTask(t map[string]interface{}) error

+ func (p *ExtensionTaskPlugin) Status() config.Status

+ func (p *ExtensionTaskPlugin) TaskTimeout() int

+ func (p *ExtensionTaskPlugin) Type() config.TaskType

+ func (p *ExtensionTaskPlugin) Wait(ctx context.Context)

+ type HelmDeployTaskPlugin struct

+ ContentPlugins []*HelmDeployTaskPlugin

+ JobName string

+ Log *zap.SugaredLogger

+ Name config.TaskType

+ ReplaceImage string

+ Task *task.Deploy

+ func InitializeHelmDeployTaskPlugin(taskType config.TaskType) *HelmDeployTaskPlugin

+ func (p *HelmDeployTaskPlugin) Complete(ctx context.Context, pipelineTask *task.Task, serviceName string)

+ func (p *HelmDeployTaskPlugin) GetTask() interface{}

+ func (p *HelmDeployTaskPlugin) Init(jobname, filename string, xl *zap.SugaredLogger)

+ func (p *HelmDeployTaskPlugin) IsTaskDone() bool

+ func (p *HelmDeployTaskPlugin) IsTaskEnabled() bool

+ func (p *HelmDeployTaskPlugin) IsTaskFailed() bool

+ func (p *HelmDeployTaskPlugin) ResetError()

+ func (p *HelmDeployTaskPlugin) Run(ctx context.Context, pipelineTask *task.Task, _ *task.PipelineCtx, _ string)

+ func (p *HelmDeployTaskPlugin) SetAckFunc(func())

+ func (p *HelmDeployTaskPlugin) SetEndTime()

+ func (p *HelmDeployTaskPlugin) SetStartTime()

+ func (p *HelmDeployTaskPlugin) SetStatus(status config.Status)

+ func (p *HelmDeployTaskPlugin) SetTask(t map[string]interface{}) error

+ func (p *HelmDeployTaskPlugin) Status() config.Status

+ func (p *HelmDeployTaskPlugin) TaskTimeout() int

+ func (p *HelmDeployTaskPlugin) Type() config.TaskType

+ func (p *HelmDeployTaskPlugin) Wait(ctx context.Context)

type JenkinsBuildPlugin

+ Timeout <-chan time.Time

type ReleaseImagePlugin

+ HubServerAddr string

+ StorageURI string

+ Timeout <-chan time.Time

+ type ScanPlugin struct

+ FileName string

+ JobName string

+ KubeNamespace string

+ Log *zap.SugaredLogger

+ Name config.TaskType

+ Task *task.Scanning

+ Timeout <-chan time.Time

+ func (p *ScanPlugin) Complete(ctx context.Context, pipelineTask *task.Task, serviceName string)

+ func (p *ScanPlugin) GetTask() interface{}

+ func (p *ScanPlugin) Init(jobname, filename string, xl *zap.SugaredLogger)

+ func (p *ScanPlugin) IsTaskDone() bool

+ func (p *ScanPlugin) IsTaskEnabled() bool

+ func (p *ScanPlugin) IsTaskFailed() bool

+ func (p *ScanPlugin) ResetError()

+ func (p *ScanPlugin) Run(ctx context.Context, pipelineTask *task.Task, pipelineCtx *task.PipelineCtx, ...)

+ func (p *ScanPlugin) SetAckFunc(func())

+ func (p *ScanPlugin) SetEndTime()

+ func (p *ScanPlugin) SetStartTime()

+ func (p *ScanPlugin) SetStatus(status config.Status)

+ func (p *ScanPlugin) SetTask(t map[string]interface{}) error

+ func (p *ScanPlugin) Status() config.Status

+ func (p *ScanPlugin) TaskTimeout() int

+ func (p *ScanPlugin) Type() config.TaskType

+ func (p *ScanPlugin) Wait(ctx context.Context)

type TaskPlugin

+ func InitializeExtensionTaskPlugin(taskType config.TaskType) TaskPlugin

+ func InitializeScanningTaskPlugin(taskType config.TaskType) TaskPlugin

type TestPlugin

+ Timeout <-chan time.Time

Jan 7, 2022

Changes in this version

+ const ArtifactPackageBuildImageTaskTimeout

+ const BuildTaskV3Timeout

+ const DindServer

+ const KoderoverAgentNamespace

+ const NormalSchedule

+ const PackagerPlugin

+ const PreferredSchedule

+ const RequiredSchedule

+ const ResourceServer

+ const TriggerTaskTimeout

+ func ToArtifactPackageTask(sb map[string]interface{}) (*task.ArtifactPackageTaskArgs, error)

+ func ToTriggerTask(sb map[string]interface{}) (*task.Trigger, error)

+ type ArtifactPackageTaskPlugin struct

+ AckFunc func()

+ FileName string

+ JobName string

+ KubeNamespace string

+ Log *zap.SugaredLogger

+ Name config.TaskType

+ RealTimeProgress string

+ Task *task.ArtifactPackage

+ func (p *ArtifactPackageTaskPlugin) Complete(ctx context.Context, pipelineTask *task.Task, serviceName string)

+ func (p *ArtifactPackageTaskPlugin) GetTask() interface{}

+ func (p *ArtifactPackageTaskPlugin) Init(jobname, filename string, xl *zap.SugaredLogger)

+ func (p *ArtifactPackageTaskPlugin) IsTaskDone() bool

+ func (p *ArtifactPackageTaskPlugin) IsTaskEnabled() bool

+ func (p *ArtifactPackageTaskPlugin) IsTaskFailed() bool

+ func (p *ArtifactPackageTaskPlugin) ResetError()

+ func (p *ArtifactPackageTaskPlugin) Run(ctx context.Context, pipelineTask *task.Task, pipelineCtx *task.PipelineCtx, ...)

+ func (p *ArtifactPackageTaskPlugin) SetAckFunc(f func())

+ func (p *ArtifactPackageTaskPlugin) SetEndTime()

+ func (p *ArtifactPackageTaskPlugin) SetProgress(progress string)

+ func (p *ArtifactPackageTaskPlugin) SetStartTime()

+ func (p *ArtifactPackageTaskPlugin) SetStatus(status config.Status)

+ func (p *ArtifactPackageTaskPlugin) SetTask(t map[string]interface{}) error

+ func (p *ArtifactPackageTaskPlugin) Status() config.Status

+ func (p *ArtifactPackageTaskPlugin) TaskTimeout() int

+ func (p *ArtifactPackageTaskPlugin) Type() config.TaskType

+ func (p *ArtifactPackageTaskPlugin) Wait(ctx context.Context)

+ type BuildTaskV3Plugin struct

+ FileName string

+ JobName string

+ KubeNamespace string

+ Log *zap.SugaredLogger

+ Name config.TaskType

+ Task *task.Build

+ func (p *BuildTaskV3Plugin) Complete(ctx context.Context, pipelineTask *task.Task, serviceName string)

+ func (p *BuildTaskV3Plugin) GetTask() interface{}

+ func (p *BuildTaskV3Plugin) Init(jobname, filename string, xl *zap.SugaredLogger)

+ func (p *BuildTaskV3Plugin) IsTaskDone() bool

+ func (p *BuildTaskV3Plugin) IsTaskEnabled() bool

+ func (p *BuildTaskV3Plugin) IsTaskFailed() bool

+ func (p *BuildTaskV3Plugin) ResetError()

+ func (p *BuildTaskV3Plugin) Run(ctx context.Context, pipelineTask *task.Task, pipelineCtx *task.PipelineCtx, ...)

+ func (p *BuildTaskV3Plugin) SetAckFunc(ack func())

+ func (p *BuildTaskV3Plugin) SetBuildStatusCompleted(status config.Status)

+ func (p *BuildTaskV3Plugin) SetEndTime()

+ func (p *BuildTaskV3Plugin) SetStartTime()

+ func (p *BuildTaskV3Plugin) SetStatus(status config.Status)

+ func (p *BuildTaskV3Plugin) SetTask(t map[string]interface{}) error

+ func (p *BuildTaskV3Plugin) Status() config.Status

+ func (p *BuildTaskV3Plugin) TaskTimeout() int

+ func (p *BuildTaskV3Plugin) Type() config.TaskType

+ func (p *BuildTaskV3Plugin) Wait(ctx context.Context)

type TaskPlugin

+ func InitializeArtifactPackagePlugin(taskType config.TaskType) TaskPlugin

+ func InitializeBuildTaskV3Plugin(taskType config.TaskType) TaskPlugin

+ func InitializeTriggerTaskPlugin(taskType config.TaskType) TaskPlugin

+ type TriggerTaskPlugin struct

+ FileName string

+ JobName string

+ KubeNamespace string

+ Log *zap.SugaredLogger

+ Name config.TaskType

+ Task *task.Trigger

+ func (p *TriggerTaskPlugin) Complete(ctx context.Context, pipelineTask *task.Task, serviceName string)

+ func (p *TriggerTaskPlugin) GetTask() interface{}

+ func (p *TriggerTaskPlugin) Init(jobname, filename string, xl *zap.SugaredLogger)

+ func (p *TriggerTaskPlugin) IsTaskDone() bool

+ func (p *TriggerTaskPlugin) IsTaskEnabled() bool

+ func (p *TriggerTaskPlugin) IsTaskFailed() bool

+ func (p *TriggerTaskPlugin) ResetError()

+ func (p *TriggerTaskPlugin) Run(ctx context.Context, pipelineTask *task.Task, pipelineCtx *task.PipelineCtx, ...)

+ func (p *TriggerTaskPlugin) SetAckFunc(ack func())

+ func (p *TriggerTaskPlugin) SetEndTime()

+ func (p *TriggerTaskPlugin) SetStartTime()

+ func (p *TriggerTaskPlugin) SetStatus(status config.Status)

+ func (p *TriggerTaskPlugin) SetTask(t map[string]interface{}) error

+ func (p *TriggerTaskPlugin) SetTriggerStatusCompleted(status config.Status)

+ func (p *TriggerTaskPlugin) Status() config.Status

+ func (p *TriggerTaskPlugin) TaskTimeout() int

+ func (p *TriggerTaskPlugin) Type() config.TaskType

+ func (p *TriggerTaskPlugin) Wait(ctx context.Context)

Nov 16, 2021

Changes in this version

+ type ResourceComponentSet interface

+ GetAnnotations func() map[string]string

+ GetContainers func() []*resource.ContainerImage

+ GetKind func() string

+ GetName func() string

+ func RcsListFromDeployments(source []*appsv1.Deployment) []ResourceComponentSet

+ func RcsListFromStatefulSets(source []*appsv1.StatefulSet) []ResourceComponentSet

Nov 5, 2021

Changes in this version

+ const ArtifactDeployTaskV2Timeout

+ type ArtifactDeployTaskPlugin struct

+ FileName string

+ JobName string

+ KubeNamespace string

+ Log *zap.SugaredLogger

+ Name config.TaskType

+ Task *task.Build

+ func (p *ArtifactDeployTaskPlugin) Complete(ctx context.Context, pipelineTask *task.Task, serviceName string)

+ func (p *ArtifactDeployTaskPlugin) GetTask() interface{}

+ func (p *ArtifactDeployTaskPlugin) Init(jobname, filename string, xl *zap.SugaredLogger)

+ func (p *ArtifactDeployTaskPlugin) IsTaskDone() bool

+ func (p *ArtifactDeployTaskPlugin) IsTaskEnabled() bool

+ func (p *ArtifactDeployTaskPlugin) IsTaskFailed() bool

+ func (p *ArtifactDeployTaskPlugin) ResetError()

+ func (p *ArtifactDeployTaskPlugin) Run(ctx context.Context, pipelineTask *task.Task, pipelineCtx *task.PipelineCtx, ...)

+ func (p *ArtifactDeployTaskPlugin) SetAckFunc(ack func())

+ func (p *ArtifactDeployTaskPlugin) SetBuildStatusCompleted(status config.Status)

+ func (p *ArtifactDeployTaskPlugin) SetEndTime()

+ func (p *ArtifactDeployTaskPlugin) SetStartTime()

+ func (p *ArtifactDeployTaskPlugin) SetStatus(status config.Status)

+ func (p *ArtifactDeployTaskPlugin) SetTask(t map[string]interface{}) error

+ func (p *ArtifactDeployTaskPlugin) Status() config.Status

+ func (p *ArtifactDeployTaskPlugin) TaskTimeout() int

+ func (p *ArtifactDeployTaskPlugin) Type() config.TaskType

+ func (p *ArtifactDeployTaskPlugin) Wait(ctx context.Context)

type TaskPlugin

+ func InitializeArtifactTaskPlugin(taskType config.TaskType) TaskPlugin

Jul 29, 2021

Changes in this version

+ type Initiator func(taskType config.TaskType) TaskPlugin

Jul 6, 2021

Changes in this version

type JobCtxBuilder

+ TestReportFile string

Jun 18, 2021

Changes in this version

+ const BuildTaskV2Timeout

+ const ConfigBackupLabel

+ const DeployTimeout

+ const Distribute2S3TaskTimeout

+ const DockerBuildTimeout

+ const EnvNameLabel

+ const GroupLabel

+ const ImageRegexString

+ const JenkinsBuildTimeout

+ const JenkinsPlugin

+ const JiraTimeout

+ const PredatorPlugin

+ const ProductLabel

+ const RelealseImageTaskTimeout

+ const SecurityTaskTimeout

+ const ServiceLabel

+ const TestingV2TaskTimeout

+ const UpdateBy

+ const UpdateByID

+ const UpdateTime

+ var ImageRegex = regexp.MustCompile(ImageRegexString)

+ func GetBestDockerHost(hostList []string, pipelineType, namespace string, log *zap.SugaredLogger) (string, error)

+ func IToi(before interface{}, after interface{}) error

+ func Min(x, y int) int

+ func ToArtifactTask(sb map[string]interface{}) (*task.Artifact, error)

+ func ToBuildTask(sb map[string]interface{}) (*task.Build, error)

+ func ToDeployTask(sb map[string]interface{}) (*task.Deploy, error)

+ func ToDistributeToS3Task(sb map[string]interface{}) (*task.DistributeToS3, error)

+ func ToDockerBuildTask(sb map[string]interface{}) (*task.DockerBuild, error)

+ func ToJenkinsBuildTask(sb map[string]interface{}) (*task.JenkinsBuild, error)

+ func ToJiraTask(sb map[string]interface{}) (*task.Jira, error)

+ func ToReleaseImageTask(sb map[string]interface{}) (*task.ReleaseImage, error)

+ func ToSecurityTask(sb map[string]interface{}) (*task.Security, error)

+ func ToTestingTask(sb map[string]interface{}) (*task.Testing, error)

+ type BuildTaskPlugin struct

+ FileName string

+ JobName string

+ KubeNamespace string

+ Log *zap.SugaredLogger

+ Name config.TaskType

+ Task *task.Build

+ func (p *BuildTaskPlugin) Complete(ctx context.Context, pipelineTask *task.Task, serviceName string)

+ func (p *BuildTaskPlugin) GetTask() interface{}

+ func (p *BuildTaskPlugin) Init(jobname, filename string, xl *zap.SugaredLogger)

+ func (p *BuildTaskPlugin) IsTaskDone() bool

+ func (p *BuildTaskPlugin) IsTaskEnabled() bool

+ func (p *BuildTaskPlugin) IsTaskFailed() bool

+ func (p *BuildTaskPlugin) ResetError()

+ func (p *BuildTaskPlugin) Run(ctx context.Context, pipelineTask *task.Task, pipelineCtx *task.PipelineCtx, ...)

+ func (p *BuildTaskPlugin) SetAckFunc(ack func())

+ func (p *BuildTaskPlugin) SetBuildStatusCompleted(status config.Status)

+ func (p *BuildTaskPlugin) SetEndTime()

+ func (p *BuildTaskPlugin) SetStartTime()

+ func (p *BuildTaskPlugin) SetStatus(status config.Status)

+ func (p *BuildTaskPlugin) SetTask(t map[string]interface{}) error

+ func (p *BuildTaskPlugin) Status() config.Status

+ func (p *BuildTaskPlugin) TaskTimeout() int

+ func (p *BuildTaskPlugin) Type() config.TaskType

+ func (p *BuildTaskPlugin) Wait(ctx context.Context)

+ type DeployTaskPlugin struct

+ JobName string

+ Log *zap.SugaredLogger

+ Name config.TaskType

+ ReplaceImage string

+ Task *task.Deploy

+ func (p *DeployTaskPlugin) Complete(ctx context.Context, pipelineTask *task.Task, serviceName string)

+ func (p *DeployTaskPlugin) GetTask() interface{}

+ func (p *DeployTaskPlugin) Init(jobname, filename string, xl *zap.SugaredLogger)

+ func (p *DeployTaskPlugin) IsTaskDone() bool

+ func (p *DeployTaskPlugin) IsTaskEnabled() bool

+ func (p *DeployTaskPlugin) IsTaskFailed() bool

+ func (p *DeployTaskPlugin) ResetError()

+ func (p *DeployTaskPlugin) Run(ctx context.Context, pipelineTask *task.Task, _ *task.PipelineCtx, _ string)

+ func (p *DeployTaskPlugin) SetAckFunc(func())

+ func (p *DeployTaskPlugin) SetEndTime()

+ func (p *DeployTaskPlugin) SetStartTime()

+ func (p *DeployTaskPlugin) SetStatus(status config.Status)

+ func (p *DeployTaskPlugin) SetTask(t map[string]interface{}) error

+ func (p *DeployTaskPlugin) Status() config.Status

+ func (p *DeployTaskPlugin) TaskTimeout() int

+ func (p *DeployTaskPlugin) Type() config.TaskType

+ func (p *DeployTaskPlugin) Wait(ctx context.Context)

+ type Distribute2S3TaskPlugin struct

+ Log *zap.SugaredLogger

+ Name config.TaskType

+ Task *task.DistributeToS3

+ func (p *Distribute2S3TaskPlugin) Complete(ctx context.Context, pipelineTask *task.Task, serviceName string)

+ func (p *Distribute2S3TaskPlugin) GetTask() interface{}

+ func (p *Distribute2S3TaskPlugin) Init(jobname, filename string, xl *zap.SugaredLogger)

+ func (p *Distribute2S3TaskPlugin) IsTaskDone() bool

+ func (p *Distribute2S3TaskPlugin) IsTaskEnabled() bool

+ func (p *Distribute2S3TaskPlugin) IsTaskFailed() bool

+ func (p *Distribute2S3TaskPlugin) ResetError()

+ func (p *Distribute2S3TaskPlugin) Run(ctx context.Context, pipelineTask *task.Task, pipelineCtx *task.PipelineCtx, ...)

+ func (p *Distribute2S3TaskPlugin) SetAckFunc(func())

+ func (p *Distribute2S3TaskPlugin) SetEndTime()

+ func (p *Distribute2S3TaskPlugin) SetStartTime()

+ func (p *Distribute2S3TaskPlugin) SetStatus(status config.Status)

+ func (p *Distribute2S3TaskPlugin) SetTask(t map[string]interface{}) error

+ func (p *Distribute2S3TaskPlugin) Status() config.Status

+ func (p *Distribute2S3TaskPlugin) TaskTimeout() int

+ func (p *Distribute2S3TaskPlugin) Type() config.TaskType

+ func (p *Distribute2S3TaskPlugin) Wait(ctx context.Context)

+ type DockerBuildPlugin struct

+ FileName string

+ JobName string

+ KubeNamespace string

+ Log *zap.SugaredLogger

+ Name config.TaskType

+ Task *task.DockerBuild

+ func (p *DockerBuildPlugin) Complete(ctx context.Context, pipelineTask *task.Task, serviceName string)

+ func (p *DockerBuildPlugin) GetTask() interface{}

+ func (p *DockerBuildPlugin) Init(jobname, filename string, xl *zap.SugaredLogger)

+ func (p *DockerBuildPlugin) IsTaskDone() bool

+ func (p *DockerBuildPlugin) IsTaskEnabled() bool

+ func (p *DockerBuildPlugin) IsTaskFailed() bool

+ func (p *DockerBuildPlugin) ResetError()

+ func (p *DockerBuildPlugin) Run(ctx context.Context, pipelineTask *task.Task, pipelineCtx *task.PipelineCtx, ...)

+ func (p *DockerBuildPlugin) SetAckFunc(func())

+ func (p *DockerBuildPlugin) SetEndTime()

+ func (p *DockerBuildPlugin) SetStartTime()

+ func (p *DockerBuildPlugin) SetStatus(status config.Status)

+ func (p *DockerBuildPlugin) SetTask(t map[string]interface{}) error

+ func (p *DockerBuildPlugin) Status() config.Status

+ func (p *DockerBuildPlugin) TaskTimeout() int

+ func (p *DockerBuildPlugin) Type() config.TaskType

+ func (p *DockerBuildPlugin) Wait(ctx context.Context)

+ type EnvArgs struct

+ EnvName string

+ ProductName string

+ type JenkinsBuildPlugin struct

+ FileName string

+ JobName string

+ KubeNamespace string

+ Log *zap.SugaredLogger

+ Name config.TaskType

+ Task *task.JenkinsBuild

+ func (j *JenkinsBuildPlugin) Complete(ctx context.Context, pipelineTask *task.Task, serviceName string)

+ func (j *JenkinsBuildPlugin) GetTask() interface{}

+ func (j *JenkinsBuildPlugin) Init(jobname, filename string, xl *zap.SugaredLogger)

+ func (j *JenkinsBuildPlugin) IsTaskDone() bool

+ func (j *JenkinsBuildPlugin) IsTaskEnabled() bool

+ func (j *JenkinsBuildPlugin) IsTaskFailed() bool

+ func (j *JenkinsBuildPlugin) ResetError()

+ func (j *JenkinsBuildPlugin) Run(ctx context.Context, pipelineTask *task.Task, pipelineCtx *task.PipelineCtx, ...)

+ func (j *JenkinsBuildPlugin) SetAckFunc(ack func())

+ func (j *JenkinsBuildPlugin) SetEndTime()

+ func (j *JenkinsBuildPlugin) SetStartTime()

+ func (j *JenkinsBuildPlugin) SetStatus(status config.Status)

+ func (j *JenkinsBuildPlugin) SetTask(t map[string]interface{}) error

+ func (j *JenkinsBuildPlugin) Status() config.Status

+ func (j *JenkinsBuildPlugin) TaskTimeout() int

+ func (j *JenkinsBuildPlugin) Type() config.TaskType

+ func (j *JenkinsBuildPlugin) Wait(ctx context.Context)

+ type JiraPlugin struct

+ Log *zap.SugaredLogger

+ Name config.TaskType

+ Task *task.Jira

+ func (p *JiraPlugin) Complete(ctx context.Context, pipelineTask *task.Task, serviceName string)

+ func (p *JiraPlugin) GetTask() interface{}

+ func (p *JiraPlugin) Init(jobname, filename string, xl *zap.SugaredLogger)

+ func (p *JiraPlugin) IsTaskDone() bool

+ func (p *JiraPlugin) IsTaskEnabled() bool

+ func (p *JiraPlugin) IsTaskFailed() bool

+ func (p *JiraPlugin) ResetError()

+ func (p *JiraPlugin) Run(ctx context.Context, pipelineTask *task.Task, pipelineCtx *task.PipelineCtx, ...)

+ func (p *JiraPlugin) SetAckFunc(func())

+ func (p *JiraPlugin) SetEndTime()

+ func (p *JiraPlugin) SetStartTime()

+ func (p *JiraPlugin) SetStatus(status config.Status)

+ func (p *JiraPlugin) SetTask(t map[string]interface{}) error

+ func (p *JiraPlugin) Status() config.Status

+ func (p *JiraPlugin) TaskTimeout() int

+ func (p *JiraPlugin) Type() config.TaskType

+ func (p *JiraPlugin) Wait(ctx context.Context)

+ type JobCtxBuilder struct

+ ArchiveFile string

+ Installs []*task.Install

+ JobCtx task.JobCtx

+ JobName string

+ PipelineCtx *task.PipelineCtx

+ func (b *JobCtxBuilder) BuildReaperContext(pipelineTask *task.Task, serviceName string) *types.Context

+ type JobLabel struct

+ PipelineName string

+ PipelineType string

+ ServiceName string

+ TaskID int64

+ TaskType string

+ type Preview struct

+ Enabled bool

+ TaskType config.TaskType

+ func ToPreview(sb map[string]interface{}) (*Preview, error)

+ type ReleaseImagePlugin struct

+ FileName string

+ JobName string

+ KubeNamespace string

+ Log *zap.SugaredLogger

+ Name config.TaskType

+ Task *task.ReleaseImage

+ func (p *ReleaseImagePlugin) Complete(ctx context.Context, pipelineTask *task.Task, serviceName string)

+ func (p *ReleaseImagePlugin) GetTask() interface{}

+ func (p *ReleaseImagePlugin) Init(jobname, filename string, xl *zap.SugaredLogger)

+ func (p *ReleaseImagePlugin) IsTaskDone() bool

+ func (p *ReleaseImagePlugin) IsTaskEnabled() bool

+ func (p *ReleaseImagePlugin) IsTaskFailed() bool

+ func (p *ReleaseImagePlugin) ResetError()

+ func (p *ReleaseImagePlugin) Run(ctx context.Context, pipelineTask *task.Task, pipelineCtx *task.PipelineCtx, ...)

+ func (p *ReleaseImagePlugin) SetAckFunc(func())

+ func (p *ReleaseImagePlugin) SetEndTime()

+ func (p *ReleaseImagePlugin) SetStartTime()

+ func (p *ReleaseImagePlugin) SetStatus(status config.Status)

+ func (p *ReleaseImagePlugin) SetTask(t map[string]interface{}) error

+ func (p *ReleaseImagePlugin) Status() config.Status

+ func (p *ReleaseImagePlugin) TaskTimeout() int

+ func (p *ReleaseImagePlugin) Type() config.TaskType

+ func (p *ReleaseImagePlugin) Wait(ctx context.Context)

+ type SecurityPlugin struct

+ FileName string

+ JobName string

+ KubeNamespace string

+ Log *zap.SugaredLogger

+ Name config.TaskType

+ Task *task.Security

+ func (p *SecurityPlugin) Complete(ctx context.Context, pipelineTask *task.Task, serviceName string)

+ func (p *SecurityPlugin) GetTask() interface{}

+ func (p *SecurityPlugin) Init(jobname, filename string, xl *zap.SugaredLogger)

+ func (p *SecurityPlugin) IsTaskDone() bool

+ func (p *SecurityPlugin) IsTaskEnabled() bool

+ func (p *SecurityPlugin) IsTaskFailed() bool

+ func (p *SecurityPlugin) ResetError()

+ func (p *SecurityPlugin) Run(ctx context.Context, pipelineTask *task.Task, pipelineCtx *task.PipelineCtx, ...)

+ func (p *SecurityPlugin) SetAckFunc(func())

+ func (p *SecurityPlugin) SetEndTime()

+ func (p *SecurityPlugin) SetStartTime()

+ func (p *SecurityPlugin) SetStatus(status config.Status)

+ func (p *SecurityPlugin) SetTask(t map[string]interface{}) error

+ func (p *SecurityPlugin) Status() config.Status

+ func (p *SecurityPlugin) TaskTimeout() int

+ func (p *SecurityPlugin) Type() config.TaskType

+ func (p *SecurityPlugin) Wait(ctx context.Context)

+ type SelectorBuilder struct

+ ConfigBackup string

+ EnvName string

+ GroupName string

+ ProductName string

+ ServiceName string

+ type TaskPlugin interface

+ Complete func(ctx context.Context, pipelineTask *task.Task, serviceName string)

+ GetTask func() interface{}

+ Init func(jobname, filename string, xl *zap.SugaredLogger)

+ IsTaskDone func() bool

+ IsTaskEnabled func() bool

+ IsTaskFailed func() bool

+ ResetError func()

+ Run func(ctx context.Context, pipelineTask *task.Task, pipelineCtx *task.PipelineCtx, ...)

+ SetAckFunc func(func())

+ SetEndTime func()

+ SetStartTime func()

+ SetStatus func(status config.Status)

+ SetTask func(map[string]interface{}) error

+ Status func() config.Status

+ TaskTimeout func() int

+ Type func() config.TaskType

+ Wait func(ctx context.Context)

+ func InitializeBuildTaskPlugin(taskType config.TaskType) TaskPlugin

+ func InitializeDeployTaskPlugin(taskType config.TaskType) TaskPlugin

+ func InitializeDistribute2S3TaskPlugin(taskType config.TaskType) TaskPlugin

+ func InitializeDockerBuildTaskPlugin(taskType config.TaskType) TaskPlugin

+ func InitializeJenkinsBuildPlugin(taskType config.TaskType) TaskPlugin

+ func InitializeJiraTaskPlugin(taskType config.TaskType) TaskPlugin

+ func InitializeReleaseImagePlugin(taskType config.TaskType) TaskPlugin

+ func InitializeSecurityPlugin(taskType config.TaskType) TaskPlugin

+ func InitializeTestTaskPlugin(taskType config.TaskType) TaskPlugin

+ type TaskPluginInitiator func(taskType config.TaskType) TaskPlugin

+ type TestPlugin struct

+ FileName string

+ JobName string

+ KubeNamespace string

+ Log *zap.SugaredLogger

+ Name config.TaskType

+ Task *task.Testing

+ func (p *TestPlugin) Complete(ctx context.Context, pipelineTask *task.Task, serviceName string)

+ func (p *TestPlugin) GetTask() interface{}

+ func (p *TestPlugin) Init(jobname, filename string, xl *zap.SugaredLogger)

+ func (p *TestPlugin) IsTaskDone() bool

+ func (p *TestPlugin) IsTaskEnabled() bool

+ func (p *TestPlugin) IsTaskFailed() bool

+ func (p *TestPlugin) ResetError()

+ func (p *TestPlugin) Run(ctx context.Context, pipelineTask *task.Task, pipelineCtx *task.PipelineCtx, ...)

+ func (p *TestPlugin) SetAckFunc(func())

+ func (p *TestPlugin) SetEndTime()

+ func (p *TestPlugin) SetStartTime()

+ func (p *TestPlugin) SetStatus(status config.Status)

+ func (p *TestPlugin) SetTask(t map[string]interface{}) error

+ func (p *TestPlugin) Status() config.Status

+ func (p *TestPlugin) TaskTimeout() int

+ func (p *TestPlugin) Type() config.TaskType

+ func (p *TestPlugin) Wait(ctx context.Context)