job

package
v2.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 19, 2024 License: Apache-2.0 Imports: 58 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	VMOutputNameRegexString = "^[a-zA-Z0-9_]{1,64}$"
	OutputNameRegexString   = "^[a-zA-Z0-9_]{1,64}$"
	JobNameKey              = "job_name"
)
View Source 
const (
	IMAGEKEY    = "IMAGE"
	IMAGETAGKEY = "imageTag"
	PKGFILEKEY  = "PKG_FILE"
)
View Source 
const (
	DistributeTimeout int64 = 10

	// WorkflowInputImageTagVariable PreBuildImageTagVariable
	// These variables are not really workflow variables, will convert to real value or workflow variables
	// Not return from GetWorkflowGlobalVars function, instead of frontend
	WorkflowInputImageTagVariable = "{{.workflow.input.imageTag}}"
	PreBuildImageTagVariable      = "{{.job.preBuild.imageTag}}"
)
View Source 
const (
	ENVNAMEKEY = "envName"
)

Variables

View Source 
var (
	OutputNameRegex = regexp.MustCompile(OutputNameRegexString)
)

Functions

func ClearSelectionField added in v2.3.0 

func ClearSelectionField(job *commonmodels.Job, workflow *commonmodels.WorkflowV4) error

func FilterServiceVars added in v2.3.0 

func FilterServiceVars(serviceName string, deployContents []config.DeployContent, service *commonmodels.DeployServiceInfo, serviceEnv *commonservice.EnvService) (*commonmodels.DeployServiceInfo, error)
func GetLink(baseURI, projectKey, workflowName, workflowDisplayName string, taskID int64) string

func GetRepos 

func GetRepos(workflow *commonmodels.WorkflowV4) ([]*types.Repository, error)

func GetWorkflowOutputs 

func GetWorkflowOutputs(workflow *commonmodels.WorkflowV4, currentJobName string, log *zap.SugaredLogger) []string

func Instantiate 

func Instantiate(job *commonmodels.Job, workflow *commonmodels.WorkflowV4) error

func InstantiateWorkflow 

func InstantiateWorkflow(workflow *commonmodels.WorkflowV4) error

func JobPresetSkiped 

func JobPresetSkiped(job *commonmodels.Job)

func JobSkiped 

func JobSkiped(job *commonmodels.Job) bool

func LintJob 

func LintJob(job *commonmodels.Job, workflow *commonmodels.WorkflowV4) error

func MergeArgs 

func MergeArgs(workflow, workflowArgs *commonmodels.WorkflowV4) error

func MergeWebhookRepo 

func MergeWebhookRepo(workflow *commonmodels.WorkflowV4, repo *types.Repository) error

func PrepareDefaultWorkflowTaskEnvs 

func PrepareDefaultWorkflowTaskEnvs(projectKey, workflowName, workflowDisplayName, infrastructure string, taskID int64) []*commonmodels.KeyVal

PrepareDefaultWorkflowTaskEnvs System level default environment variables (every workflow type will have it)

func RemoveFixedValueMarks 

func RemoveFixedValueMarks(workflow *commonmodels.WorkflowV4) error

before workflowflow task was created, we need to remove the fixed mark from variables.

func RenderGlobalVariables 

func RenderGlobalVariables(workflow *commonmodels.WorkflowV4, taskID int64, creator, account string) error

func RenderKeyVals added in v2.3.0 

func RenderKeyVals(input, origin []*commonmodels.KeyVal) []*commonmodels.KeyVal

func RenderStageVariables 

func RenderStageVariables(workflow *commonmodels.WorkflowV4, taskID int64, creator string) error

func SetOptions added in v2.3.0 

func SetOptions(job *commonmodels.Job, workflow *commonmodels.WorkflowV4) error

func SetPreset 

func SetPreset(job *commonmodels.Job, workflow *commonmodels.WorkflowV4) error

func ToJobs 

func ToJobs(job *commonmodels.Job, workflow *commonmodels.WorkflowV4, taskID int64) ([]*commonmodels.JobTask, error)

func UpdateWithLatestSetting added in v2.3.0 

func UpdateWithLatestSetting(job *commonmodels.Job, workflow *commonmodels.WorkflowV4) error

Types

type ApolloJob 

type ApolloJob struct {
	// contains filtered or unexported fields
}

func (*ApolloJob) ClearSelectionField added in v2.3.0 

func (j *ApolloJob) ClearSelectionField() error

func (*ApolloJob) Instantiate 

func (j *ApolloJob) Instantiate() error

func (*ApolloJob) LintJob 

func (j *ApolloJob) LintJob() error

func (*ApolloJob) MergeArgs 

func (j *ApolloJob) MergeArgs(args *commonmodels.Job) error

func (*ApolloJob) SetOptions added in v2.3.0 

func (j *ApolloJob) SetOptions() error

func (*ApolloJob) SetPreset 

func (j *ApolloJob) SetPreset() error

func (*ApolloJob) ToJobs 

func (j *ApolloJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*ApolloJob) UpdateWithLatestSetting added in v2.3.0 

func (j *ApolloJob) UpdateWithLatestSetting() error

type BlueGreenDeployJob 

type BlueGreenDeployJob struct {
	// contains filtered or unexported fields
}

func (*BlueGreenDeployJob) Instantiate 

func (j *BlueGreenDeployJob) Instantiate() error

func (*BlueGreenDeployJob) LintJob 

func (j *BlueGreenDeployJob) LintJob() error

func (*BlueGreenDeployJob) MergeArgs 

func (j *BlueGreenDeployJob) MergeArgs(args *commonmodels.Job) error

func (*BlueGreenDeployJob) SetPreset 

func (j *BlueGreenDeployJob) SetPreset() error

func (*BlueGreenDeployJob) ToJobs 

func (j *BlueGreenDeployJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*BlueGreenDeployJob) UpdateWithLatestSetting added in v2.3.0 

func (j *BlueGreenDeployJob) UpdateWithLatestSetting() error

type BlueGreenDeployV2Job 

type BlueGreenDeployV2Job struct {
	// contains filtered or unexported fields
}

func (*BlueGreenDeployV2Job) ClearSelectionField added in v2.3.0 

func (j *BlueGreenDeployV2Job) ClearSelectionField() error

func (*BlueGreenDeployV2Job) Instantiate 

func (j *BlueGreenDeployV2Job) Instantiate() error

func (*BlueGreenDeployV2Job) LintJob 

func (j *BlueGreenDeployV2Job) LintJob() error

func (*BlueGreenDeployV2Job) MergeArgs 

func (j *BlueGreenDeployV2Job) MergeArgs(args *commonmodels.Job) error

func (*BlueGreenDeployV2Job) SetOptions added in v2.3.0 

func (j *BlueGreenDeployV2Job) SetOptions() error

func (*BlueGreenDeployV2Job) SetPreset 

func (j *BlueGreenDeployV2Job) SetPreset() error

func (*BlueGreenDeployV2Job) ToJobs 

func (j *BlueGreenDeployV2Job) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*BlueGreenDeployV2Job) UpdateWithLatestSetting added in v2.3.0 

func (j *BlueGreenDeployV2Job) UpdateWithLatestSetting() error

type BlueGreenReleaseJob 

type BlueGreenReleaseJob struct {
	// contains filtered or unexported fields
}

func (*BlueGreenReleaseJob) Instantiate 

func (j *BlueGreenReleaseJob) Instantiate() error

func (*BlueGreenReleaseJob) LintJob 

func (j *BlueGreenReleaseJob) LintJob() error

func (*BlueGreenReleaseJob) MergeArgs 

func (j *BlueGreenReleaseJob) MergeArgs(args *commonmodels.Job) error

func (*BlueGreenReleaseJob) SetPreset 

func (j *BlueGreenReleaseJob) SetPreset() error

func (*BlueGreenReleaseJob) ToJobs 

func (j *BlueGreenReleaseJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*BlueGreenReleaseJob) UpdateWithLatestSetting added in v2.3.0 

func (j *BlueGreenReleaseJob) UpdateWithLatestSetting() error

type BlueGreenReleaseV2Job 

type BlueGreenReleaseV2Job struct {
	// contains filtered or unexported fields
}

func (*BlueGreenReleaseV2Job) ClearSelectionField added in v2.3.0 

func (j *BlueGreenReleaseV2Job) ClearSelectionField() error

func (*BlueGreenReleaseV2Job) Instantiate 

func (j *BlueGreenReleaseV2Job) Instantiate() error

func (*BlueGreenReleaseV2Job) LintJob 

func (j *BlueGreenReleaseV2Job) LintJob() error

func (*BlueGreenReleaseV2Job) MergeArgs 

func (j *BlueGreenReleaseV2Job) MergeArgs(args *commonmodels.Job) error

func (*BlueGreenReleaseV2Job) SetOptions added in v2.3.0 

func (j *BlueGreenReleaseV2Job) SetOptions() error

func (*BlueGreenReleaseV2Job) SetPreset 

func (j *BlueGreenReleaseV2Job) SetPreset() error

func (*BlueGreenReleaseV2Job) ToJobs 

func (j *BlueGreenReleaseV2Job) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*BlueGreenReleaseV2Job) UpdateWithLatestSetting added in v2.3.0 

func (j *BlueGreenReleaseV2Job) UpdateWithLatestSetting() error

type BuildJob 

type BuildJob struct {
	// contains filtered or unexported fields
}

func (*BuildJob) ClearSelectionField added in v2.3.0 

func (j *BuildJob) ClearSelectionField() error

func (*BuildJob) GetOutPuts 

func (j *BuildJob) GetOutPuts(log *zap.SugaredLogger) []string

func (*BuildJob) GetRepos 

func (j *BuildJob) GetRepos() ([]*types.Repository, error)

func (*BuildJob) Instantiate 

func (j *BuildJob) Instantiate() error

func (*BuildJob) LintJob 

func (j *BuildJob) LintJob() error

func (*BuildJob) MergeArgs 

func (j *BuildJob) MergeArgs(args *commonmodels.Job) error

func (*BuildJob) MergeWebhookRepo 

func (j *BuildJob) MergeWebhookRepo(webhookRepo *types.Repository) error

func (*BuildJob) SetOptions added in v2.3.0 

func (j *BuildJob) SetOptions() error

func (*BuildJob) SetPreset 

func (j *BuildJob) SetPreset() error

SetPreset will clear the selected field (ServiceAndBuilds

func (*BuildJob) ToJobs 

func (j *BuildJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*BuildJob) UpdateWithLatestSetting added in v2.3.0 

func (j *BuildJob) UpdateWithLatestSetting() error

type CanaryDeployJob 

type CanaryDeployJob struct {
	// contains filtered or unexported fields
}

func (*CanaryDeployJob) ClearSelectionField added in v2.3.0 

func (j *CanaryDeployJob) ClearSelectionField() error

func (*CanaryDeployJob) Instantiate 

func (j *CanaryDeployJob) Instantiate() error

func (*CanaryDeployJob) LintJob 

func (j *CanaryDeployJob) LintJob() error

func (*CanaryDeployJob) MergeArgs 

func (j *CanaryDeployJob) MergeArgs(args *commonmodels.Job) error

func (*CanaryDeployJob) SetOptions added in v2.3.0 

func (j *CanaryDeployJob) SetOptions() error

func (*CanaryDeployJob) SetPreset 

func (j *CanaryDeployJob) SetPreset() error

func (*CanaryDeployJob) ToJobs 

func (j *CanaryDeployJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*CanaryDeployJob) UpdateWithLatestSetting added in v2.3.0 

func (j *CanaryDeployJob) UpdateWithLatestSetting() error

type CanaryReleaseJob 

type CanaryReleaseJob struct {
	// contains filtered or unexported fields
}

func (*CanaryReleaseJob) ClearSelectionField added in v2.3.0 

func (j *CanaryReleaseJob) ClearSelectionField() error

func (*CanaryReleaseJob) Instantiate 

func (j *CanaryReleaseJob) Instantiate() error

func (*CanaryReleaseJob) LintJob 

func (j *CanaryReleaseJob) LintJob() error

func (*CanaryReleaseJob) MergeArgs 

func (j *CanaryReleaseJob) MergeArgs(args *commonmodels.Job) error

func (*CanaryReleaseJob) SetOptions added in v2.3.0 

func (j *CanaryReleaseJob) SetOptions() error

func (*CanaryReleaseJob) SetPreset 

func (j *CanaryReleaseJob) SetPreset() error

func (*CanaryReleaseJob) ToJobs 

func (j *CanaryReleaseJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*CanaryReleaseJob) UpdateWithLatestSetting added in v2.3.0 

func (j *CanaryReleaseJob) UpdateWithLatestSetting() error

type CustomDeployJob 

type CustomDeployJob struct {
	// contains filtered or unexported fields
}

func (*CustomDeployJob) ClearSelectionField added in v2.3.0 

func (j *CustomDeployJob) ClearSelectionField() error

func (*CustomDeployJob) Instantiate 

func (j *CustomDeployJob) Instantiate() error

func (*CustomDeployJob) LintJob 

func (j *CustomDeployJob) LintJob() error

func (*CustomDeployJob) MergeArgs 

func (j *CustomDeployJob) MergeArgs(args *commonmodels.Job) error

func (*CustomDeployJob) SetOptions added in v2.3.0 

func (j *CustomDeployJob) SetOptions() error

SetOptions get the options from the original workflow regardless of the currently selected items

func (*CustomDeployJob) SetPreset 

func (j *CustomDeployJob) SetPreset() error

func (*CustomDeployJob) ToJobs 

func (j *CustomDeployJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*CustomDeployJob) UpdateWithLatestSetting added in v2.3.0 

func (j *CustomDeployJob) UpdateWithLatestSetting() error

type DeployJob 

type DeployJob struct {
	// contains filtered or unexported fields
}

func (*DeployJob) ClearSelectionField added in v2.3.0 

func (j *DeployJob) ClearSelectionField() error

func (*DeployJob) GetOutPuts 

func (j *DeployJob) GetOutPuts(log *zap.SugaredLogger) []string

func (*DeployJob) Instantiate 

func (j *DeployJob) Instantiate() error

func (*DeployJob) LintJob 

func (j *DeployJob) LintJob() error

func (*DeployJob) MergeArgs 

func (j *DeployJob) MergeArgs(args *commonmodels.Job) error

func (*DeployJob) SetOptions added in v2.3.0 

func (j *DeployJob) SetOptions() error

SetOptions get the service deployment info from ALL envs and set these information into the EnvOptions Field

func (*DeployJob) SetPreset 

func (j *DeployJob) SetPreset() error

SetPreset sets all info for the user-config env service.

func (*DeployJob) ToJobs 

func (j *DeployJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*DeployJob) UpdateWithLatestSetting added in v2.3.0 

func (j *DeployJob) UpdateWithLatestSetting() error

type FreeStyleJob 

type FreeStyleJob struct {
	// contains filtered or unexported fields
}

func (*FreeStyleJob) ClearSelectionField added in v2.3.0 

func (j *FreeStyleJob) ClearSelectionField() error

func (*FreeStyleJob) GetOutPuts 

func (j *FreeStyleJob) GetOutPuts(log *zap.SugaredLogger) []string

func (*FreeStyleJob) GetRepos 

func (j *FreeStyleJob) GetRepos() ([]*types.Repository, error)

func (*FreeStyleJob) Instantiate 

func (j *FreeStyleJob) Instantiate() error

func (*FreeStyleJob) LintJob 

func (j *FreeStyleJob) LintJob() error

func (*FreeStyleJob) MergeArgs 

func (j *FreeStyleJob) MergeArgs(args *commonmodels.Job) error

func (*FreeStyleJob) MergeWebhookRepo 

func (j *FreeStyleJob) MergeWebhookRepo(webhookRepo *types.Repository) error

func (*FreeStyleJob) SetOptions added in v2.3.0 

func (j *FreeStyleJob) SetOptions() error

func (*FreeStyleJob) SetPreset 

func (j *FreeStyleJob) SetPreset() error

func (*FreeStyleJob) ToJobs 

func (j *FreeStyleJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*FreeStyleJob) UpdateWithLatestSetting added in v2.3.0 

func (j *FreeStyleJob) UpdateWithLatestSetting() error

type GrafanaJob 

type GrafanaJob struct {
	// contains filtered or unexported fields
}

func (*GrafanaJob) ClearSelectionField added in v2.3.0 

func (j *GrafanaJob) ClearSelectionField() error

func (*GrafanaJob) Instantiate 

func (j *GrafanaJob) Instantiate() error

func (*GrafanaJob) LintJob 

func (j *GrafanaJob) LintJob() error

func (*GrafanaJob) MergeArgs 

func (j *GrafanaJob) MergeArgs(args *commonmodels.Job) error

func (*GrafanaJob) SetOptions added in v2.3.0 

func (j *GrafanaJob) SetOptions() error

func (*GrafanaJob) SetPreset 

func (j *GrafanaJob) SetPreset() error

func (*GrafanaJob) ToJobs 

func (j *GrafanaJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*GrafanaJob) UpdateWithLatestSetting added in v2.3.0 

func (j *GrafanaJob) UpdateWithLatestSetting() error

type GrayReleaseJob 

type GrayReleaseJob struct {
	// contains filtered or unexported fields
}

func (*GrayReleaseJob) ClearSelectionField added in v2.3.0 

func (j *GrayReleaseJob) ClearSelectionField() error

func (*GrayReleaseJob) Instantiate 

func (j *GrayReleaseJob) Instantiate() error

func (*GrayReleaseJob) LintJob 

func (j *GrayReleaseJob) LintJob() error

func (*GrayReleaseJob) MergeArgs 

func (j *GrayReleaseJob) MergeArgs(args *commonmodels.Job) error

func (*GrayReleaseJob) SetOptions added in v2.3.0 

func (j *GrayReleaseJob) SetOptions() error

func (*GrayReleaseJob) SetPreset 

func (j *GrayReleaseJob) SetPreset() error

func (*GrayReleaseJob) ToJobs 

func (j *GrayReleaseJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*GrayReleaseJob) UpdateWithLatestSetting added in v2.3.0 

func (j *GrayReleaseJob) UpdateWithLatestSetting() error

type GrayRollbackJob 

type GrayRollbackJob struct {
	// contains filtered or unexported fields
}

func (*GrayRollbackJob) ClearSelectionField added in v2.3.0 

func (j *GrayRollbackJob) ClearSelectionField() error

func (*GrayRollbackJob) Instantiate 

func (j *GrayRollbackJob) Instantiate() error

func (*GrayRollbackJob) LintJob 

func (j *GrayRollbackJob) LintJob() error

func (*GrayRollbackJob) MergeArgs 

func (j *GrayRollbackJob) MergeArgs(args *commonmodels.Job) error

func (*GrayRollbackJob) SetOptions added in v2.3.0 

func (j *GrayRollbackJob) SetOptions() error

func (*GrayRollbackJob) SetPreset 

func (j *GrayRollbackJob) SetPreset() error

func (*GrayRollbackJob) ToJobs 

func (j *GrayRollbackJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*GrayRollbackJob) UpdateWithLatestSetting added in v2.3.0 

func (j *GrayRollbackJob) UpdateWithLatestSetting() error

type GuanceyunCheckJob 

type GuanceyunCheckJob struct {
	// contains filtered or unexported fields
}

func (*GuanceyunCheckJob) ClearSelectionField added in v2.3.0 

func (j *GuanceyunCheckJob) ClearSelectionField() error

func (*GuanceyunCheckJob) Instantiate 

func (j *GuanceyunCheckJob) Instantiate() error

func (*GuanceyunCheckJob) LintJob 

func (j *GuanceyunCheckJob) LintJob() error

func (*GuanceyunCheckJob) MergeArgs 

func (j *GuanceyunCheckJob) MergeArgs(args *commonmodels.Job) error

func (*GuanceyunCheckJob) SetOptions added in v2.3.0 

func (j *GuanceyunCheckJob) SetOptions() error

func (*GuanceyunCheckJob) SetPreset 

func (j *GuanceyunCheckJob) SetPreset() error

func (*GuanceyunCheckJob) ToJobs 

func (j *GuanceyunCheckJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*GuanceyunCheckJob) UpdateWithLatestSetting added in v2.3.0 

func (j *GuanceyunCheckJob) UpdateWithLatestSetting() error

type HelmChartDeployJob 

type HelmChartDeployJob struct {
	// contains filtered or unexported fields
}

func (*HelmChartDeployJob) ClearSelectionField added in v2.3.0 

func (j *HelmChartDeployJob) ClearSelectionField() error

func (*HelmChartDeployJob) Instantiate 

func (j *HelmChartDeployJob) Instantiate() error

func (*HelmChartDeployJob) LintJob 

func (j *HelmChartDeployJob) LintJob() error

func (*HelmChartDeployJob) MergeArgs 

func (j *HelmChartDeployJob) MergeArgs(args *commonmodels.Job) error

func (*HelmChartDeployJob) SetOptions added in v2.3.0 

func (j *HelmChartDeployJob) SetOptions() error

SetOptions gets all helm chart info in all envs, and set it in EnvOptions field

func (*HelmChartDeployJob) SetPreset 

func (j *HelmChartDeployJob) SetPreset() error

func (*HelmChartDeployJob) ToJobs 

func (j *HelmChartDeployJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*HelmChartDeployJob) UpdateWithLatestSetting added in v2.3.0 

func (j *HelmChartDeployJob) UpdateWithLatestSetting() error

type ImageDistributeJob 

type ImageDistributeJob struct {
	// contains filtered or unexported fields
}

func (*ImageDistributeJob) ClearSelectionField added in v2.3.0 

func (j *ImageDistributeJob) ClearSelectionField() error

func (*ImageDistributeJob) GetOutPuts 

func (j *ImageDistributeJob) GetOutPuts(log *zap.SugaredLogger) []string

func (*ImageDistributeJob) Instantiate 

func (j *ImageDistributeJob) Instantiate() error

func (*ImageDistributeJob) LintJob 

func (j *ImageDistributeJob) LintJob() error

func (*ImageDistributeJob) MergeArgs 

func (j *ImageDistributeJob) MergeArgs(args *commonmodels.Job) error

func (*ImageDistributeJob) SetOptions added in v2.3.0 

func (j *ImageDistributeJob) SetOptions() error

func (*ImageDistributeJob) SetPreset 

func (j *ImageDistributeJob) SetPreset() error

func (*ImageDistributeJob) ToJobs 

func (j *ImageDistributeJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*ImageDistributeJob) UpdateWithLatestSetting added in v2.3.0 

func (j *ImageDistributeJob) UpdateWithLatestSetting() error

type IstioReleaseJob 

type IstioReleaseJob struct {
	// contains filtered or unexported fields
}

func (*IstioReleaseJob) ClearSelectionField added in v2.3.0 

func (j *IstioReleaseJob) ClearSelectionField() error

func (*IstioReleaseJob) Instantiate 

func (j *IstioReleaseJob) Instantiate() error

func (*IstioReleaseJob) LintJob 

func (j *IstioReleaseJob) LintJob() error

func (*IstioReleaseJob) MergeArgs 

func (j *IstioReleaseJob) MergeArgs(args *commonmodels.Job) error

func (*IstioReleaseJob) SetOptions added in v2.3.0 

func (j *IstioReleaseJob) SetOptions() error

func (*IstioReleaseJob) SetPreset 

func (j *IstioReleaseJob) SetPreset() error

func (*IstioReleaseJob) ToJobs 

func (j *IstioReleaseJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*IstioReleaseJob) UpdateWithLatestSetting added in v2.3.0 

func (j *IstioReleaseJob) UpdateWithLatestSetting() error

type IstioRollBackJob 

type IstioRollBackJob struct {
	// contains filtered or unexported fields
}

func (*IstioRollBackJob) ClearSelectionField added in v2.3.0 

func (j *IstioRollBackJob) ClearSelectionField() error

func (*IstioRollBackJob) Instantiate 

func (j *IstioRollBackJob) Instantiate() error

func (*IstioRollBackJob) LintJob 

func (j *IstioRollBackJob) LintJob() error

func (*IstioRollBackJob) MergeArgs 

func (j *IstioRollBackJob) MergeArgs(args *commonmodels.Job) error

func (*IstioRollBackJob) SetOptions added in v2.3.0 

func (j *IstioRollBackJob) SetOptions() error

func (*IstioRollBackJob) SetPreset 

func (j *IstioRollBackJob) SetPreset() error

func (*IstioRollBackJob) ToJobs 

func (j *IstioRollBackJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*IstioRollBackJob) UpdateWithLatestSetting added in v2.3.0 

func (j *IstioRollBackJob) UpdateWithLatestSetting() error

type JenkinsJob 

type JenkinsJob struct {
	// contains filtered or unexported fields
}

func (*JenkinsJob) ClearSelectionField added in v2.3.0 

func (j *JenkinsJob) ClearSelectionField() error

func (*JenkinsJob) Instantiate 

func (j *JenkinsJob) Instantiate() error

func (*JenkinsJob) LintJob 

func (j *JenkinsJob) LintJob() error

func (*JenkinsJob) MergeArgs 

func (j *JenkinsJob) MergeArgs(args *commonmodels.Job) error

func (*JenkinsJob) SetOptions added in v2.3.0 

func (j *JenkinsJob) SetOptions() error

func (*JenkinsJob) SetPreset 

func (j *JenkinsJob) SetPreset() error

func (*JenkinsJob) ToJobs 

func (j *JenkinsJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*JenkinsJob) UpdateWithLatestSetting added in v2.3.0 

func (j *JenkinsJob) UpdateWithLatestSetting() error

type JiraJob 

type JiraJob struct {
	// contains filtered or unexported fields
}

func (*JiraJob) ClearSelectionField added in v2.3.0 

func (j *JiraJob) ClearSelectionField() error

func (*JiraJob) Instantiate 

func (j *JiraJob) Instantiate() error

func (*JiraJob) LintJob 

func (j *JiraJob) LintJob() error

func (*JiraJob) MergeArgs 

func (j *JiraJob) MergeArgs(args *commonmodels.Job) error

func (*JiraJob) SetOptions added in v2.3.0 

func (j *JiraJob) SetOptions() error

func (*JiraJob) SetPreset 

func (j *JiraJob) SetPreset() error

func (*JiraJob) ToJobs 

func (j *JiraJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*JiraJob) UpdateWithLatestSetting added in v2.3.0 

func (j *JiraJob) UpdateWithLatestSetting() error

type JobCtl 

type JobCtl interface {
	Instantiate() error
	// SetPreset sets all the default values configured by user
	SetPreset() error
	// SetOptions sets all the possible options for the workflow
	SetOptions() error
	ClearSelectionField() error
	ToJobs(taskID int64) ([]*commonmodels.JobTask, error)
	// MergeArgs merge the current workflow with the user input: args
	MergeArgs(args *commonmodels.Job) error
	// UpdateWithLatestSetting update the current workflow arguments with the latest workflow settings.
	// it will also calculate if the user's args is still valid, returning error if it is invalid.
	UpdateWithLatestSetting() error
	LintJob() error
}

func InitJobCtl 

func InitJobCtl(job *commonmodels.Job, workflow *commonmodels.WorkflowV4) (JobCtl, error)

type K8sPacthJob 

type K8sPacthJob struct {
	// contains filtered or unexported fields
}

func (*K8sPacthJob) ClearSelectionField added in v2.3.0 

func (j *K8sPacthJob) ClearSelectionField() error

func (*K8sPacthJob) Instantiate 

func (j *K8sPacthJob) Instantiate() error

func (*K8sPacthJob) LintJob 

func (j *K8sPacthJob) LintJob() error

func (*K8sPacthJob) MergeArgs 

func (j *K8sPacthJob) MergeArgs(args *commonmodels.Job) error

func (*K8sPacthJob) SetOptions added in v2.3.0 

func (j *K8sPacthJob) SetOptions() error

func (*K8sPacthJob) SetPreset 

func (j *K8sPacthJob) SetPreset() error

func (*K8sPacthJob) ToJobs 

func (j *K8sPacthJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*K8sPacthJob) UpdateWithLatestSetting added in v2.3.0 

func (j *K8sPacthJob) UpdateWithLatestSetting() error

type MeegoTransitionJob 

type MeegoTransitionJob struct {
	// contains filtered or unexported fields
}

func (*MeegoTransitionJob) ClearSelectionField added in v2.3.0 

func (j *MeegoTransitionJob) ClearSelectionField() error

func (*MeegoTransitionJob) Instantiate 

func (j *MeegoTransitionJob) Instantiate() error

func (*MeegoTransitionJob) LintJob 

func (j *MeegoTransitionJob) LintJob() error

func (*MeegoTransitionJob) MergeArgs 

func (j *MeegoTransitionJob) MergeArgs(args *commonmodels.Job) error

func (*MeegoTransitionJob) SetOptions added in v2.3.0 

func (j *MeegoTransitionJob) SetOptions() error

func (*MeegoTransitionJob) SetPreset 

func (j *MeegoTransitionJob) SetPreset() error

func (*MeegoTransitionJob) ToJobs 

func (j *MeegoTransitionJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*MeegoTransitionJob) UpdateWithLatestSetting added in v2.3.0 

func (j *MeegoTransitionJob) UpdateWithLatestSetting() error

type MseGrayOfflineJob 

type MseGrayOfflineJob struct {
	// contains filtered or unexported fields
}

func (*MseGrayOfflineJob) ClearSelectionField added in v2.3.0 

func (j *MseGrayOfflineJob) ClearSelectionField() error

func (*MseGrayOfflineJob) Instantiate 

func (j *MseGrayOfflineJob) Instantiate() error

func (*MseGrayOfflineJob) LintJob 

func (j *MseGrayOfflineJob) LintJob() error

func (*MseGrayOfflineJob) MergeArgs 

func (j *MseGrayOfflineJob) MergeArgs(args *commonmodels.Job) error

func (*MseGrayOfflineJob) SetOptions added in v2.3.0 

func (j *MseGrayOfflineJob) SetOptions() error

func (*MseGrayOfflineJob) SetPreset 

func (j *MseGrayOfflineJob) SetPreset() error

func (*MseGrayOfflineJob) ToJobs 

func (j *MseGrayOfflineJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*MseGrayOfflineJob) UpdateWithLatestSetting added in v2.3.0 

func (j *MseGrayOfflineJob) UpdateWithLatestSetting() error

type MseGrayReleaseJob 

type MseGrayReleaseJob struct {
	// contains filtered or unexported fields
}

func (*MseGrayReleaseJob) ClearSelectionField added in v2.3.0 

func (j *MseGrayReleaseJob) ClearSelectionField() error

func (*MseGrayReleaseJob) Instantiate 

func (j *MseGrayReleaseJob) Instantiate() error

func (*MseGrayReleaseJob) LintJob 

func (j *MseGrayReleaseJob) LintJob() error

func (*MseGrayReleaseJob) MergeArgs 

func (j *MseGrayReleaseJob) MergeArgs(args *commonmodels.Job) error

func (*MseGrayReleaseJob) SetOptions added in v2.3.0 

func (j *MseGrayReleaseJob) SetOptions() error

func (*MseGrayReleaseJob) SetPreset 

func (j *MseGrayReleaseJob) SetPreset() error

func (*MseGrayReleaseJob) ToJobs 

func (j *MseGrayReleaseJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*MseGrayReleaseJob) UpdateWithLatestSetting added in v2.3.0 

func (j *MseGrayReleaseJob) UpdateWithLatestSetting() error

type NacosJob 

type NacosJob struct {
	// contains filtered or unexported fields
}

func (*NacosJob) ClearSelectionField added in v2.3.0 

func (j *NacosJob) ClearSelectionField() error

func (*NacosJob) Instantiate 

func (j *NacosJob) Instantiate() error

func (*NacosJob) LintJob 

func (j *NacosJob) LintJob() error

func (*NacosJob) MergeArgs 

func (j *NacosJob) MergeArgs(args *commonmodels.Job) error

func (*NacosJob) SetOptions added in v2.3.0 

func (j *NacosJob) SetOptions() error

func (*NacosJob) SetPreset 

func (j *NacosJob) SetPreset() error

func (*NacosJob) ToJobs 

func (j *NacosJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*NacosJob) UpdateWithLatestSetting added in v2.3.0 

func (j *NacosJob) UpdateWithLatestSetting() error

UpdateWithLatestSetting Special thing about this is that everytime it is called, it re-calculate the latest default values.

type OfflineServiceJob 

type OfflineServiceJob struct {
	// contains filtered or unexported fields
}

func (*OfflineServiceJob) ClearSelectionField added in v2.3.0 

func (j *OfflineServiceJob) ClearSelectionField() error

func (*OfflineServiceJob) Instantiate 

func (j *OfflineServiceJob) Instantiate() error

func (*OfflineServiceJob) LintJob 

func (j *OfflineServiceJob) LintJob() error

func (*OfflineServiceJob) MergeArgs 

func (j *OfflineServiceJob) MergeArgs(args *commonmodels.Job) error

func (*OfflineServiceJob) SetOptions added in v2.3.0 

func (j *OfflineServiceJob) SetOptions() error

func (*OfflineServiceJob) SetPreset 

func (j *OfflineServiceJob) SetPreset() error

func (*OfflineServiceJob) ToJobs 

func (j *OfflineServiceJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*OfflineServiceJob) UpdateWithLatestSetting added in v2.3.0 

func (j *OfflineServiceJob) UpdateWithLatestSetting() error

type PluginJob 

type PluginJob struct {
	// contains filtered or unexported fields
}

func (*PluginJob) ClearSelectionField added in v2.3.0 

func (j *PluginJob) ClearSelectionField() error

func (*PluginJob) GetOutPuts 

func (j *PluginJob) GetOutPuts(log *zap.SugaredLogger) []string

func (*PluginJob) Instantiate 

func (j *PluginJob) Instantiate() error

func (*PluginJob) LintJob 

func (j *PluginJob) LintJob() error

func (*PluginJob) MergeArgs 

func (j *PluginJob) MergeArgs(args *commonmodels.Job) error

func (*PluginJob) SetOptions added in v2.3.0 

func (j *PluginJob) SetOptions() error

func (*PluginJob) SetPreset 

func (j *PluginJob) SetPreset() error

func (*PluginJob) ToJobs 

func (j *PluginJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*PluginJob) UpdateWithLatestSetting added in v2.3.0 

func (j *PluginJob) UpdateWithLatestSetting() error

type RepoIndex 

type RepoIndex struct {
	JobName       string `json:"job_name"`
	ServiceName   string `json:"service_name"`
	ServiceModule string `json:"service_module"`
	RepoIndex     int    `json:"repo_index"`
}

func GetWorkflowRepoIndex 

func GetWorkflowRepoIndex(workflow *commonmodels.WorkflowV4, currentJobName string, log *zap.SugaredLogger) []*RepoIndex

type SQLJob 

type SQLJob struct {
	// contains filtered or unexported fields
}

func (*SQLJob) ClearSelectionField added in v2.3.0 

func (j *SQLJob) ClearSelectionField() error

func (*SQLJob) Instantiate 

func (j *SQLJob) Instantiate() error

func (*SQLJob) LintJob 

func (j *SQLJob) LintJob() error

func (*SQLJob) MergeArgs 

func (j *SQLJob) MergeArgs(args *commonmodels.Job) error

func (*SQLJob) SetOptions added in v2.3.0 

func (j *SQLJob) SetOptions() error

func (*SQLJob) SetPreset 

func (j *SQLJob) SetPreset() error

func (*SQLJob) ToJobs 

func (j *SQLJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*SQLJob) UpdateWithLatestSetting added in v2.3.0 

func (j *SQLJob) UpdateWithLatestSetting() error

type ScanningJob 

type ScanningJob struct {
	// contains filtered or unexported fields
}

func (*ScanningJob) ClearSelectionField added in v2.3.0 

func (j *ScanningJob) ClearSelectionField() error

func (*ScanningJob) GetOutPuts 

func (j *ScanningJob) GetOutPuts(log *zap.SugaredLogger) []string

func (*ScanningJob) GetRepos 

func (j *ScanningJob) GetRepos() ([]*types.Repository, error)

func (*ScanningJob) Instantiate 

func (j *ScanningJob) Instantiate() error

func (*ScanningJob) LintJob 

func (j *ScanningJob) LintJob() error

func (*ScanningJob) MergeArgs 

func (j *ScanningJob) MergeArgs(args *commonmodels.Job) error

func (*ScanningJob) MergeWebhookRepo 

func (j *ScanningJob) MergeWebhookRepo(webhookRepo *types.Repository) error

func (*ScanningJob) SetOptions added in v2.3.0 

func (j *ScanningJob) SetOptions() error

func (*ScanningJob) SetPreset 

func (j *ScanningJob) SetPreset() error

func (*ScanningJob) ToJobs 

func (j *ScanningJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*ScanningJob) UpdateWithLatestSetting added in v2.3.0 

func (j *ScanningJob) UpdateWithLatestSetting() error

type TestingJob 

type TestingJob struct {
	// contains filtered or unexported fields
}

func (*TestingJob) ClearSelectionField added in v2.3.0 

func (j *TestingJob) ClearSelectionField() error

func (*TestingJob) GetOutPuts 

func (j *TestingJob) GetOutPuts(log *zap.SugaredLogger) []string

func (*TestingJob) GetRepos 

func (j *TestingJob) GetRepos() ([]*types.Repository, error)

func (*TestingJob) Instantiate 

func (j *TestingJob) Instantiate() error

func (*TestingJob) LintJob 

func (j *TestingJob) LintJob() error

func (*TestingJob) MergeArgs 

func (j *TestingJob) MergeArgs(args *commonmodels.Job) error

func (*TestingJob) MergeWebhookRepo 

func (j *TestingJob) MergeWebhookRepo(webhookRepo *types.Repository) error

func (*TestingJob) SetOptions added in v2.3.0 

func (j *TestingJob) SetOptions() error

func (*TestingJob) SetPreset 

func (j *TestingJob) SetPreset() error

func (*TestingJob) ToJobs 

func (j *TestingJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*TestingJob) UpdateWithLatestSetting added in v2.3.0 

func (j *TestingJob) UpdateWithLatestSetting() error

type UpdateEnvIstioConfigJob added in v2.3.0 

type UpdateEnvIstioConfigJob struct {
	// contains filtered or unexported fields
}

func (*UpdateEnvIstioConfigJob) ClearSelectionField added in v2.3.0 

func (j *UpdateEnvIstioConfigJob) ClearSelectionField() error

func (*UpdateEnvIstioConfigJob) Instantiate added in v2.3.0 

func (j *UpdateEnvIstioConfigJob) Instantiate() error

func (*UpdateEnvIstioConfigJob) LintJob added in v2.3.0 

func (j *UpdateEnvIstioConfigJob) LintJob() error

func (*UpdateEnvIstioConfigJob) MergeArgs added in v2.3.0 

func (j *UpdateEnvIstioConfigJob) MergeArgs(args *commonmodels.Job) error

func (*UpdateEnvIstioConfigJob) SetOptions added in v2.3.0 

func (j *UpdateEnvIstioConfigJob) SetOptions() error

func (*UpdateEnvIstioConfigJob) SetPreset added in v2.3.0 

func (j *UpdateEnvIstioConfigJob) SetPreset() error

func (*UpdateEnvIstioConfigJob) ToJobs added in v2.3.0 

func (j *UpdateEnvIstioConfigJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*UpdateEnvIstioConfigJob) UpdateWithLatestSetting added in v2.3.0 

func (j *UpdateEnvIstioConfigJob) UpdateWithLatestSetting() error

type VMDeployJob 

type VMDeployJob struct {
	// contains filtered or unexported fields
}

func (*VMDeployJob) ClearSelectionField added in v2.3.0 

func (j *VMDeployJob) ClearSelectionField() error

func (*VMDeployJob) GetOutPuts 

func (j *VMDeployJob) GetOutPuts(log *zap.SugaredLogger) []string

func (*VMDeployJob) GetRepos 

func (j *VMDeployJob) GetRepos() ([]*types.Repository, error)

func (*VMDeployJob) Instantiate 

func (j *VMDeployJob) Instantiate() error

func (*VMDeployJob) LintJob 

func (j *VMDeployJob) LintJob() error

func (*VMDeployJob) MergeArgs 

func (j *VMDeployJob) MergeArgs(args *commonmodels.Job) error

func (*VMDeployJob) SetOptions added in v2.3.0 

func (j *VMDeployJob) SetOptions() error

func (*VMDeployJob) SetPreset 

func (j *VMDeployJob) SetPreset() error

func (*VMDeployJob) ToJobs 

func (j *VMDeployJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*VMDeployJob) UpdateWithLatestSetting added in v2.3.0 

func (j *VMDeployJob) UpdateWithLatestSetting() error

type WorkflowTriggerJob 

type WorkflowTriggerJob struct {
	// contains filtered or unexported fields
}

func (*WorkflowTriggerJob) ClearSelectionField added in v2.3.0 

func (j *WorkflowTriggerJob) ClearSelectionField() error

func (*WorkflowTriggerJob) Instantiate 

func (j *WorkflowTriggerJob) Instantiate() error

func (*WorkflowTriggerJob) LintJob 

func (j *WorkflowTriggerJob) LintJob() error

func (*WorkflowTriggerJob) MergeArgs 

func (j *WorkflowTriggerJob) MergeArgs(args *commonmodels.Job) error

func (*WorkflowTriggerJob) SetOptions added in v2.3.0 

func (j *WorkflowTriggerJob) SetOptions() error

func (*WorkflowTriggerJob) SetPreset 

func (j *WorkflowTriggerJob) SetPreset() error

func (*WorkflowTriggerJob) ToJobs 

func (j *WorkflowTriggerJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)

func (*WorkflowTriggerJob) UpdateWithLatestSetting added in v2.3.0 

func (j *WorkflowTriggerJob) UpdateWithLatestSetting() error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.