Documentation ¶
Index ¶
- Constants
- Variables
- func GetRepos(workflow *commonmodels.WorkflowV4) ([]*types.Repository, error)
- func GetWorkflowOutputs(workflow *commonmodels.WorkflowV4, currentJobName string, ...) []string
- func Instantiate(job *commonmodels.Job, workflow *commonmodels.WorkflowV4) error
- func InstantiateWorkflow(workflow *commonmodels.WorkflowV4) error
- func JobPresetSkiped(job *commonmodels.Job)
- func JobSkiped(job *commonmodels.Job) bool
- func LintJob(job *commonmodels.Job, workflow *commonmodels.WorkflowV4) error
- func MergeArgs(workflow, workflowArgs *commonmodels.WorkflowV4) error
- func MergeWebhookRepo(workflow *commonmodels.WorkflowV4, repo *types.Repository) error
- func RemoveFixedValueMarks(workflow *commonmodels.WorkflowV4) error
- func RenderGlobalVariables(workflow *commonmodels.WorkflowV4, taskID int64, creator string) error
- func SetPreset(job *commonmodels.Job, workflow *commonmodels.WorkflowV4) error
- func ToJobs(job *commonmodels.Job, workflow *commonmodels.WorkflowV4, taskID int64) ([]*commonmodels.JobTask, error)
- type ApolloJob
- type BlueGreenDeployJob
- type BlueGreenReleaseJob
- type BuildJob
- func (j *BuildJob) GetOutPuts(log *zap.SugaredLogger) []string
- func (j *BuildJob) GetRepos() ([]*types.Repository, error)
- func (j *BuildJob) Instantiate() error
- func (j *BuildJob) LintJob() error
- func (j *BuildJob) MergeArgs(args *commonmodels.Job) error
- func (j *BuildJob) MergeWebhookRepo(webhookRepo *types.Repository) error
- func (j *BuildJob) SetPreset() error
- func (j *BuildJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)
- type CanaryDeployJob
- type CanaryReleaseJob
- type CustomDeployJob
- type DeployJob
- type FreeStyleJob
- func (j *FreeStyleJob) GetOutPuts(log *zap.SugaredLogger) []string
- func (j *FreeStyleJob) GetRepos() ([]*types.Repository, error)
- func (j *FreeStyleJob) Instantiate() error
- func (j *FreeStyleJob) LintJob() error
- func (j *FreeStyleJob) MergeArgs(args *commonmodels.Job) error
- func (j *FreeStyleJob) MergeWebhookRepo(webhookRepo *types.Repository) error
- func (j *FreeStyleJob) SetPreset() error
- func (j *FreeStyleJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)
- type GrayReleaseJob
- type GrayRollbackJob
- type ImageDistributeJob
- func (j *ImageDistributeJob) GetOutPuts(log *zap.SugaredLogger) []string
- func (j *ImageDistributeJob) Instantiate() error
- func (j *ImageDistributeJob) LintJob() error
- func (j *ImageDistributeJob) MergeArgs(args *commonmodels.Job) error
- func (j *ImageDistributeJob) SetPreset() error
- func (j *ImageDistributeJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)
- type IstioReleaseJob
- type IstioRollBackJob
- type JiraJob
- type JobCtl
- type K8sPacthJob
- type MeegoTransitionJob
- type NacosJob
- type PluginJob
- func (j *PluginJob) GetOutPuts(log *zap.SugaredLogger) []string
- func (j *PluginJob) Instantiate() error
- func (j *PluginJob) LintJob() error
- func (j *PluginJob) MergeArgs(args *commonmodels.Job) error
- func (j *PluginJob) SetPreset() error
- func (j *PluginJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)
- type RepoIndex
- type ScanningJob
- func (j *ScanningJob) GetOutPuts(log *zap.SugaredLogger) []string
- func (j *ScanningJob) GetRepos() ([]*types.Repository, error)
- func (j *ScanningJob) Instantiate() error
- func (j *ScanningJob) LintJob() error
- func (j *ScanningJob) MergeArgs(args *commonmodels.Job) error
- func (j *ScanningJob) MergeWebhookRepo(webhookRepo *types.Repository) error
- func (j *ScanningJob) SetPreset() error
- func (j *ScanningJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)
- type TestingJob
- func (j *TestingJob) GetOutPuts(log *zap.SugaredLogger) []string
- func (j *TestingJob) GetRepos() ([]*types.Repository, error)
- func (j *TestingJob) Instantiate() error
- func (j *TestingJob) LintJob() error
- func (j *TestingJob) MergeArgs(args *commonmodels.Job) error
- func (j *TestingJob) MergeWebhookRepo(webhookRepo *types.Repository) error
- func (j *TestingJob) SetPreset() error
- func (j *TestingJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)
- type WorkflowTriggerJob
Constants ¶
View Source
const ( OutputNameRegexString = "^[a-zA-Z0-9_]{1,64}$" JobNameKey = "job_name" )
View Source
const ( IMAGEKEY = "IMAGE" PKGFILEKEY = "PKG_FILE" )
View Source
const (
DistributeTimeout int64 = 10
)
Variables ¶
View Source
var (
OutputNameRegex = regexp.MustCompile(OutputNameRegexString)
)
Functions ¶
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 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 string) 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)
Types ¶
type ApolloJob ¶
type ApolloJob struct {
// contains filtered or unexported fields
}
func (*ApolloJob) Instantiate ¶
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)
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)
type BuildJob ¶
type BuildJob struct {
// contains filtered or unexported fields
}
func (*BuildJob) GetOutPuts ¶
func (j *BuildJob) GetOutPuts(log *zap.SugaredLogger) []string
func (*BuildJob) Instantiate ¶
func (*BuildJob) MergeWebhookRepo ¶
func (j *BuildJob) MergeWebhookRepo(webhookRepo *types.Repository) error
type CanaryDeployJob ¶
type CanaryDeployJob struct {
// contains filtered or unexported fields
}
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) SetPreset ¶
func (j *CanaryDeployJob) SetPreset() error
func (*CanaryDeployJob) ToJobs ¶
func (j *CanaryDeployJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)
type CanaryReleaseJob ¶
type CanaryReleaseJob struct {
// contains filtered or unexported fields
}
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) SetPreset ¶
func (j *CanaryReleaseJob) SetPreset() error
func (*CanaryReleaseJob) ToJobs ¶
func (j *CanaryReleaseJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)
type CustomDeployJob ¶
type CustomDeployJob struct {
// contains filtered or unexported fields
}
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) SetPreset ¶
func (j *CustomDeployJob) SetPreset() error
func (*CustomDeployJob) ToJobs ¶
func (j *CustomDeployJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)
type DeployJob ¶
type DeployJob struct {
// contains filtered or unexported fields
}
func (*DeployJob) Instantiate ¶
type FreeStyleJob ¶
type FreeStyleJob struct {
// contains filtered or unexported fields
}
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) SetPreset ¶
func (j *FreeStyleJob) SetPreset() error
func (*FreeStyleJob) ToJobs ¶
func (j *FreeStyleJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)
type GrayReleaseJob ¶
type GrayReleaseJob struct {
// contains filtered or unexported fields
}
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) SetPreset ¶
func (j *GrayReleaseJob) SetPreset() error
func (*GrayReleaseJob) ToJobs ¶
func (j *GrayReleaseJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)
type GrayRollbackJob ¶
type GrayRollbackJob struct {
// contains filtered or unexported fields
}
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) SetPreset ¶
func (j *GrayRollbackJob) SetPreset() error
func (*GrayRollbackJob) ToJobs ¶
func (j *GrayRollbackJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)
type ImageDistributeJob ¶
type ImageDistributeJob struct {
// contains filtered or unexported fields
}
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) SetPreset ¶
func (j *ImageDistributeJob) SetPreset() error
func (*ImageDistributeJob) ToJobs ¶
func (j *ImageDistributeJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)
type IstioReleaseJob ¶
type IstioReleaseJob struct {
// contains filtered or unexported fields
}
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) SetPreset ¶
func (j *IstioReleaseJob) SetPreset() error
func (*IstioReleaseJob) ToJobs ¶
func (j *IstioReleaseJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)
type IstioRollBackJob ¶
type IstioRollBackJob struct {
// contains filtered or unexported fields
}
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) SetPreset ¶
func (j *IstioRollBackJob) SetPreset() error
func (*IstioRollBackJob) ToJobs ¶
func (j *IstioRollBackJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)
type JiraJob ¶
type JiraJob struct {
// contains filtered or unexported fields
}
func (*JiraJob) Instantiate ¶
type JobCtl ¶
type JobCtl interface { Instantiate() error SetPreset() error ToJobs(taskID int64) ([]*commonmodels.JobTask, error) MergeArgs(args *commonmodels.Job) 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) 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) SetPreset ¶
func (j *K8sPacthJob) SetPreset() error
func (*K8sPacthJob) ToJobs ¶
func (j *K8sPacthJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)
type MeegoTransitionJob ¶
type MeegoTransitionJob struct {
// contains filtered or unexported fields
}
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) SetPreset ¶
func (j *MeegoTransitionJob) SetPreset() error
func (*MeegoTransitionJob) ToJobs ¶
func (j *MeegoTransitionJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)
type NacosJob ¶
type NacosJob struct {
// contains filtered or unexported fields
}
func (*NacosJob) Instantiate ¶
type PluginJob ¶
type PluginJob struct {
// contains filtered or unexported fields
}
func (*PluginJob) GetOutPuts ¶
func (j *PluginJob) GetOutPuts(log *zap.SugaredLogger) []string
func (*PluginJob) Instantiate ¶
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 ScanningJob ¶
type ScanningJob struct {
// contains filtered or unexported fields
}
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) SetPreset ¶
func (j *ScanningJob) SetPreset() error
func (*ScanningJob) ToJobs ¶
func (j *ScanningJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)
type TestingJob ¶
type TestingJob struct {
// contains filtered or unexported fields
}
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) SetPreset ¶
func (j *TestingJob) SetPreset() error
func (*TestingJob) ToJobs ¶
func (j *TestingJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)
type WorkflowTriggerJob ¶
type WorkflowTriggerJob struct {
// contains filtered or unexported fields
}
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) SetPreset ¶
func (j *WorkflowTriggerJob) SetPreset() error
func (*WorkflowTriggerJob) ToJobs ¶
func (j *WorkflowTriggerJob) ToJobs(taskID int64) ([]*commonmodels.JobTask, error)
Source Files ¶
- job.go
- job_apollo.go
- job_blue_green_deploy.go
- job_blue_green_release.go
- job_build.go
- job_canary_deploy.go
- job_canary_release.go
- job_custom_deploy.go
- job_deploy.go
- job_distribute_image.go
- job_freestyle.go
- job_gray_release.go
- job_gray_rollback.go
- job_istio_release.go
- job_istio_rollback.go
- job_jira.go
- job_k8s_patch.go
- job_meego_transition.go
- job_nacos.go
- job_plugin.go
- job_scanning.go
- job_testing.go
- job_workflow_trigger.go
Click to show internal directories.
Click to hide internal directories.