Versions in this module Expand all Collapse all v1 v1.2.9 Apr 12, 2021 v1.2.8 Apr 12, 2021 v0 v0.2.8 Mar 30, 2021 Changes in this version + const AFTER_DOCKER_BUILD + const AWSSecretsManager + const AWSSystemManager + const BEFORE_DOCKER_BUILD + const BLOB_STORAGE_AZURE + const BLOB_STORAGE_GCP + const BLOB_STORAGE_MINIO + const BLOB_STORAGE_S3 + const BULK_DEPLOY_DURABLE + const BULK_DEPLOY_GROUP + const BULK_DEPLOY_TOPIC + const BULK_HIBERNATE_DURABLE + const BULK_HIBERNATE_GROUP + const BULK_HIBERNATE_TOPIC + const CD_COMPLETE_DURABLE + const CD_COMPLETE_GROUP + const CD_STAGE_COMPLETE_TOPIC + const CD_WORKFLOW_NAME + const DevMode + const ExternalCiWebhookPath + const HashiCorpVault + const KubernetesSecret + const POST + const PRE + const ProdMode + const WorkflowAborted + const WorkflowCancel + const WorkflowFailed + const WorkflowStarting + var DefaultPipelineValue = []byte(...) + type AppBean struct + Id int + Name string + TeamId int + type AppConfigResponse struct + LatestAppConfig TemplateRequest + PreviousAppConfig TemplateRequest + type AppMetricEnableDisableRequest struct + AppId int + EnvironmentId int + IsAppMetricsEnabled bool + UserId int32 + type AppMetricsEnabled struct + AppMetrics bool + type AzureBlob struct + func (impl *AzureBlob) DownloadBlob(context context.Context, blobName string, config *AzureBlobConfig, ...) error + func (impl *AzureBlob) UploadBlob(context context.Context, blobName string, config *AzureBlobConfig, ...) error + type AzureBlobConfig struct + AccountKey string + AccountName string + BlobContainerCiCache string + BlobContainerCiLog string + Enabled bool + type BlueGreen struct + AutoPromotionEnabled bool + AutoPromotionSeconds int + PreviewReplicaCount int + ScaleDownDelaySeconds int + type BulkPatchFilter struct + AppNameExcludes string + AppNameIncludes string + EnvId int + type BulkPatchPayload struct + AppId int + EnvId int + type BulkPatchRequest struct + Filter *BulkPatchFilter + Global bool + Key string + Name string + PatchAction int + Payload []*BulkPatchPayload + ProjectId int + Type string + UserId int32 + Value string + type BulkTriggerRequest struct + CiArtifactId int + PipelineId int + type Canary struct + MaxSurge string + MaxUnavailable int + Steps []CanaryStep + type CanaryStep struct + Pause *RolloutPause + SetWeight *int32 + type CdConfig struct + CdArtifactLocationFormat string + ClusterConfig *rest.Config + DefaultArtifactKeyPrefix string + DefaultBuildLogsBucket string + DefaultBuildLogsKeyPrefix string + DefaultCdLogsBucketRegion string + DefaultImage string + DefaultNamespace string + DefaultTimeout int64 + LimitCpu string + LimitMem string + Mode string + OrchestratorHost string + OrchestratorToken string + ReqCpu string + ReqMem string + TaintKey string + TaintValue string + WfControllerInstanceID string + WorkflowServiceAccount string + func GetCdConfig() (*CdConfig, error) + type CdHandler interface + CancelStage func(workflowRunnerId int) (int, error) + DownloadCdWorkflowArtifacts func(pipelineId int, buildId int) (*os.File, error) + FetchAppWorkflowStatusForTriggerView func(pipelineId int) ([]*pipelineConfig.CdWorkflowStatus, error) + FetchCdPrePostStageStatus func(pipelineId int) ([]pipelineConfig.CdWorkflowWithArtifact, error) + FetchCdWorkflowDetails func(appId int, environmentId int, pipelineId int, buildId int) (WorkflowResponse, error) + GetCdBuildHistory func(appId int, environmentId int, pipelineId int, offset int, size int) ([]pipelineConfig.CdWorkflowWithArtifact, error) + GetRunningWorkflowLogs func(environmentId int, pipelineId int, workflowId int) (*bufio.Reader, func() error, error) + UpdateWorkflow func(workflowStatus v1alpha1.WorkflowStatus) (int, string, error) + type CdHandlerImpl struct + Logger *zap.SugaredLogger + func NewCdHandlerImpl(Logger *zap.SugaredLogger, cdConfig *CdConfig, userService user.UserService, ...) *CdHandlerImpl + func (impl *CdHandlerImpl) CancelStage(workflowRunnerId int) (int, error) + func (impl *CdHandlerImpl) DownloadCdWorkflowArtifacts(pipelineId int, buildId int) (*os.File, error) + func (impl *CdHandlerImpl) FetchAppWorkflowStatusForTriggerView(appId int) ([]*pipelineConfig.CdWorkflowStatus, error) + func (impl *CdHandlerImpl) FetchCdPrePostStageStatus(pipelineId int) ([]pipelineConfig.CdWorkflowWithArtifact, error) + func (impl *CdHandlerImpl) FetchCdWorkflowDetails(appId int, environmentId int, pipelineId int, buildId int) (WorkflowResponse, error) + func (impl *CdHandlerImpl) GetCdBuildHistory(appId int, environmentId int, pipelineId int, offset int, size int) ([]pipelineConfig.CdWorkflowWithArtifact, error) + func (impl *CdHandlerImpl) GetRunningWorkflowLogs(environmentId int, pipelineId int, wfrId int) (*bufio.Reader, func() error, error) + func (impl *CdHandlerImpl) UpdateWorkflow(workflowStatus v1alpha1.WorkflowStatus) (int, string, error) + type CdStageCompleteEvent struct + ArtifactLocation string + CdPipelineId int + CiArtifactDTO pipelineConfig.CiArtifactDTO + CiProjectDetails []CiProjectDetails + PipelineName string + StageYaml string + TriggeredBy int32 + WorkflowId int + WorkflowRunnerId int + type CdWorkflowRequest struct + AccessKey string + ActiveDeadlineSeconds int64 + AppId int + ArtifactLocation string + AwsRegion string + CdImage string + CdPipelineId int + CiArtifactDTO CiArtifactDTO + CiProjectDetails []CiProjectDetails + DockerPassword string + DockerRegistryType string + DockerRegistryURL string + DockerUsername string + EnvironmentId int + ExtraEnvironmentVariables map[string]string + IsExtRun bool + Namespace string + OrchestratorHost string + OrchestratorToken string + SecretKey string + StageType string + StageYaml string + TriggeredBy int32 + WorkflowId int + WorkflowNamePrefix string + WorkflowRunnerId int + type CdWorkflowService interface + DeleteWorkflow func(wfName string, namespace string) error + GetWorkflow func(name string, namespace string, url string, token string, isExtRun bool) (*v1alpha1.Workflow, error) + ListAllWorkflows func(namespace string) (*v1alpha1.WorkflowList, error) + SubmitWorkflow func(workflowRequest *CdWorkflowRequest, pipeline *pipelineConfig.Pipeline, ...) (*v1alpha1.Workflow, error) + TerminateWorkflow func(name string, namespace string, url string, token string, isExtRun bool) error + UpdateWorkflow func(wf *v1alpha1.Workflow) (*v1alpha1.Workflow, error) + type CdWorkflowServiceImpl struct + Logger *zap.SugaredLogger + func NewCdWorkflowServiceImpl(Logger *zap.SugaredLogger, envRepository cluster.EnvironmentRepository, ...) *CdWorkflowServiceImpl + func (impl *CdWorkflowServiceImpl) DeleteWorkflow(wfName string, namespace string) error + func (impl *CdWorkflowServiceImpl) GetWorkflow(name string, namespace string, url string, token string, isExtRun bool) (*v1alpha1.Workflow, error) + func (impl *CdWorkflowServiceImpl) ListAllWorkflows(namespace string) (*v1alpha1.WorkflowList, error) + func (impl *CdWorkflowServiceImpl) SubmitWorkflow(workflowRequest *CdWorkflowRequest, pipeline *pipelineConfig.Pipeline, ...) (*v1alpha1.Workflow, error) + func (impl *CdWorkflowServiceImpl) TerminateWorkflow(name string, namespace string, url string, token string, isExtRun bool) error + func (impl *CdWorkflowServiceImpl) UpdateWorkflow(wf *v1alpha1.Workflow) (*v1alpha1.Workflow, error) + type ChartService interface + AppMetricsEnableDisable func(appMetricRequest AppMetricEnableDisableRequest) (*AppMetricEnableDisableRequest, error) + ChartRefAutocomplete func() ([]chartRef, error) + ChartRefAutocompleteForAppOrEnv func(appId int, envId int) (*chartRefResponse, error) + Create func(templateRequest TemplateRequest, ctx context.Context) (chart *TemplateRequest, err error) + CreateChartFromEnvOverride func(templateRequest TemplateRequest, ctx context.Context) (chart *TemplateRequest, err error) + FindLatestChartForAppByAppId func(appId int) (chartTemplate *TemplateRequest, err error) + FindPreviousChartByAppId func(appId int) (chartTemplate *TemplateRequest, err error) + GetAppOverrideForDefaultTemplate func(chartRefId int) (map[string]json.RawMessage, error) + GetByAppIdAndChartRefId func(appId int, chartRefId int) (chartTemplate *TemplateRequest, err error) + IsReadyToTrigger func(appId int, envId int, pipelineId int) (IsReady, error) + UpdateAppOverride func(templateRequest *TemplateRequest) (*TemplateRequest, error) + UpgradeForApp func(appId int, chartRefId int, newAppOverride map[string]json.RawMessage, ...) (bool, error) + type ChartServiceImpl struct + func NewChartServiceImpl(chartRepository chartConfig.ChartRepository, logger *zap.SugaredLogger, ...) *ChartServiceImpl + func (impl ChartServiceImpl) AppMetricsEnableDisable(appMetricRequest AppMetricEnableDisableRequest) (*AppMetricEnableDisableRequest, error) + func (impl ChartServiceImpl) ChartRefAutocomplete() ([]chartRef, error) + func (impl ChartServiceImpl) ChartRefAutocompleteForAppOrEnv(appId int, envId int) (*chartRefResponse, error) + func (impl ChartServiceImpl) Create(templateRequest TemplateRequest, ctx context.Context) (*TemplateRequest, error) + func (impl ChartServiceImpl) CreateChartFromEnvOverride(templateRequest TemplateRequest, ctx context.Context) (*TemplateRequest, error) + func (impl ChartServiceImpl) FindLatestChartForAppByAppId(appId int) (chartTemplate *TemplateRequest, err error) + func (impl ChartServiceImpl) FindPreviousChartByAppId(appId int) (chartTemplate *TemplateRequest, err error) + func (impl ChartServiceImpl) GetAppOverrideForDefaultTemplate(chartRefId int) (map[string]json.RawMessage, error) + func (impl ChartServiceImpl) GetByAppIdAndChartRefId(appId int, chartRefId int) (chartTemplate *TemplateRequest, err error) + func (impl ChartServiceImpl) IsReadyToTrigger(appId int, envId int, pipelineId int) (IsReady, error) + func (impl ChartServiceImpl) UpdateAppOverride(templateRequest *TemplateRequest) (*TemplateRequest, error) + func (impl ChartServiceImpl) UpgradeForApp(appId int, chartRefId int, newAppOverride map[string]json.RawMessage, ...) (bool, error) + type ChartUpgradeRequest struct + All bool + AppIds []int + ChartRefId int + UserId int32 + type CiArtifactDTO struct + DataSource string + Id int + Image string + ImageDigest string + MaterialInfo string + PipelineId int + WorkflowId *int + type CiArtifactWebhookRequest struct + DataSource string + Image string + ImageDigest string + MaterialInfo json.RawMessage + PipelineName string + UserId int32 + WorkflowId *int + type CiCdTriggerEvent struct + CdRequest *CdWorkflowRequest + CiRequest *WorkflowRequest + Type string + type CiConfig struct + AzureAccountKey string + AzureAccountName string + AzureBlobContainerCiCache string + AzureBlobContainerCiLog string + CacheLimit int64 + CiArtifactLocationFormat string + CiLogsKeyPrefix string + CloudProvider string + ClusterConfig *rest.Config + DefaultArtifactKeyPrefix string + DefaultBuildLogsBucket string + DefaultBuildLogsKeyPrefix string + DefaultCacheBucket string + DefaultCacheBucketRegion string + DefaultImage string + DefaultNamespace string + DefaultTimeout int64 + ExternalCiApiSecret string + ExternalCiPayload string + ExternalCiWebhookUrl string + ImageScannerEndpoint string + LimitCpu string + LimitMem string + MinioAccessKey string + MinioEndpoint string + MinioSecretKey string + Mode string + NodeLabel map[string]string + NodeLabelSelector []string + ReqCpu string + ReqMem string + TaintKey string + TaintValue string + WorkflowServiceAccount string + func GetCiConfig() (*CiConfig, error) + type CiHandler interface + CancelBuild func(workflowId int) (int, error) + DownloadCiWorkflowArtifacts func(pipelineId int, buildId int) (*os.File, error) + FetchCiStatusForTriggerView func(appId int) ([]*pipelineConfig.CiWorkflowStatus, error) + FetchMaterialInfoByArtifactId func(ciArtifactId int) (*GitTriggerInfoResponse, error) + FetchMaterialsByPipelineId func(pipelineId int) ([]CiPipelineMaterialResponse, error) + FetchWorkflowDetails func(appId int, pipelineId int, buildId int) (WorkflowResponse, error) + GetBuildHistory func(pipelineId int, offset int, size int) ([]WorkflowResponse, error) + GetHistoricBuildLogs func(pipelineId int, workflowId int, ciWorkflow *pipelineConfig.CiWorkflow) (map[string]string, error) + GetRunningWorkflowLogs func(pipelineId int, workflowId int) (*bufio.Reader, func() error, error) + HandleCIManual func(ciTriggerRequest bean.CiTriggerRequest) (int, error) + HandleCIWebhook func(gitCiTriggerRequest bean.GitCiTriggerRequest) (int, error) + HandleGitCiTrigger func(ciGitTriggerRequest bean.CiGitWebhookTriggerRequest) error + RefreshMaterialByCiPipelineMaterialId func(gitMaterialId int) (refreshRes *gitSensor.RefreshGitMaterialResponse, err error) + UpdateWorkflow func(workflowStatus v1alpha1.WorkflowStatus) (int, error) + WriteToCreateTestSuites func(pipelineId int, buildId int, triggeredBy int) + type CiHandlerImpl struct + Logger *zap.SugaredLogger + func NewCiHandlerImpl(Logger *zap.SugaredLogger, ciService CiService, ...) *CiHandlerImpl + func (impl *CiHandlerImpl) BuildPayload(ciWorkflow *pipelineConfig.CiWorkflow) *client.Payload + func (impl *CiHandlerImpl) CancelBuild(workflowId int) (int, error) + func (impl *CiHandlerImpl) DownloadCiWorkflowArtifacts(pipelineId int, buildId int) (*os.File, error) + func (impl *CiHandlerImpl) FetchCiStatusForTriggerView(appId int) ([]*pipelineConfig.CiWorkflowStatus, error) + func (impl *CiHandlerImpl) FetchMaterialInfoByArtifactId(ciArtifactId int) (*GitTriggerInfoResponse, error) + func (impl *CiHandlerImpl) FetchMaterialsByPipelineId(pipelineId int) ([]CiPipelineMaterialResponse, error) + func (impl *CiHandlerImpl) FetchWorkflowDetails(appId int, pipelineId int, buildId int) (WorkflowResponse, error) + func (impl *CiHandlerImpl) GetBuildHistory(pipelineId int, offset int, size int) ([]WorkflowResponse, error) + func (impl *CiHandlerImpl) GetCiPipeline(ciMaterialId int) (*pipelineConfig.CiPipeline, error) + func (impl *CiHandlerImpl) GetHistoricBuildLogs(pipelineId int, workflowId int, ciWorkflow *pipelineConfig.CiWorkflow) (map[string]string, error) + func (impl *CiHandlerImpl) GetRunningWorkflowLogs(pipelineId int, workflowId int) (*bufio.Reader, func() error, error) + func (impl *CiHandlerImpl) HandleCIManual(ciTriggerRequest bean.CiTriggerRequest) (int, error) + func (impl *CiHandlerImpl) HandleCIWebhook(gitCiTriggerRequest bean.GitCiTriggerRequest) (int, error) + func (impl *CiHandlerImpl) HandleGitCiTrigger(ciGitTriggerRequest bean.CiGitWebhookTriggerRequest) error + func (impl *CiHandlerImpl) RefreshMaterialByCiPipelineMaterialId(gitMaterialId int) (refreshRes *gitSensor.RefreshGitMaterialResponse, err error) + func (impl *CiHandlerImpl) UpdateWorkflow(workflowStatus v1alpha1.WorkflowStatus) (int, error) + func (impl *CiHandlerImpl) WriteCIFailEvent(ciWorkflow *pipelineConfig.CiWorkflow, ciImage string) + func (impl *CiHandlerImpl) WriteToCreateTestSuites(pipelineId int, buildId int, triggeredBy int) + type CiLogRequest struct + AccessKey string + AzureBlobConfig *AzureBlobConfig + CloudProvider string + LogsBucket string + LogsFilePath string + MinioEndpoint string + Namespace string + PipelineId int + Region string + SecretKet string + WorkflowId int + WorkflowName string + type CiLogService interface + FetchLogs func(ciLogRequest CiLogRequest) (*os.File, func() error, error) + FetchRunningWorkflowLogs func(ciLogRequest CiLogRequest, token string, host string, isExt bool) (io.ReadCloser, func() error, error) + type CiLogServiceImpl struct + func NewCiLogServiceImpl(logger *zap.SugaredLogger, ciService CiService, ciConfig *CiConfig) *CiLogServiceImpl + func (impl *CiLogServiceImpl) FetchLogs(ciLogRequest CiLogRequest) (*os.File, func() error, error) + func (impl *CiLogServiceImpl) FetchRunningWorkflowLogs(ciLogRequest CiLogRequest, token string, host string, isExt bool) (io.ReadCloser, func() error, error) + type CiPipelineMaterialResponse struct + Active bool + BranchErrorMsg string + GitMaterialId int + GitMaterialName string + GitMaterialUrl string + History []*gitSensor.GitCommit + Id int + IsBranchError bool + IsRepoError bool + LastFetchTime time.Time + RepoErrorMsg string + Type string + Url string + Value string + type CiProjectDetails struct + Author string + CheckoutPath string + CommitHash string + CommitTime time.Time + GitOptions GitOptions + GitRepository string + GitTag string + MaterialName string + Message string + SourceType pipelineConfig.SourceType + SourceValue string + Type string + type CiService interface + GetCiMaterials func(pipelineId int, ciMaterials []*pipelineConfig.CiPipelineMaterial) ([]*pipelineConfig.CiPipelineMaterial, error) + TriggerCiPipeline func(trigger Trigger) (int, error) + type CiServiceImpl struct + Logger *zap.SugaredLogger + func NewCiServiceImpl(Logger *zap.SugaredLogger, workflowService WorkflowService, ...) *CiServiceImpl + func (impl *CiServiceImpl) BuildPayload(trigger Trigger, pipeline *pipelineConfig.CiPipeline, ...) *client.Payload + func (impl *CiServiceImpl) GetCiMaterials(pipelineId int, ciMaterials []*pipelineConfig.CiPipelineMaterial) ([]*pipelineConfig.CiPipelineMaterial, error) + func (impl *CiServiceImpl) TriggerCiPipeline(trigger Trigger) (int, error) + func (impl *CiServiceImpl) WriteCITriggerEvent(trigger Trigger, pipeline *pipelineConfig.CiPipeline, ...) + type ConfigData struct + Data json.RawMessage + DefaultData json.RawMessage + DefaultExternalSecret []ExternalSecret + DefaultMountPath string + External bool + ExternalSecret []ExternalSecret + ExternalSecretType string + Global bool + MountPath string + Name string + RoleARN string + Type string + type ConfigDataRequest struct + AppId int + ConfigData []*ConfigData + EnvironmentId int + Id int + UserId int32 + type ConfigMapRequest struct + AppId int + ConfigMapData json.RawMessage + EnvironmentId int + Id int + PipelineId int + SecretData json.RawMessage + UserId int32 + type ConfigMapSecretsResponse struct + Maps []bean2.Map + Secrets []bean2.Map + type ConfigMapService interface + CMEnvironmentAddUpdate func(configMapRequest *ConfigDataRequest) (*ConfigDataRequest, error) + CMEnvironmentDelete func(name string, id int, userId int32) (bool, error) + CMEnvironmentDeleteByAppIdAndEnvId func(name string, appId int, envId int, userId int32) (bool, error) + CMEnvironmentFetch func(appId int, envId int) (*ConfigDataRequest, error) + CMGlobalAddUpdate func(configMapRequest *ConfigDataRequest) (*ConfigDataRequest, error) + CMGlobalDelete func(name string, id int, userId int32) (bool, error) + CMGlobalDeleteByAppId func(name string, appId int, userId int32) (bool, error) + CMGlobalFetch func(appId int) (*ConfigDataRequest, error) + CSEnvironmentAddUpdate func(configMapRequest *ConfigDataRequest) (*ConfigDataRequest, error) + CSEnvironmentDelete func(name string, id int, userId int32) (bool, error) + CSEnvironmentDeleteByAppIdAndEnvId func(name string, appId int, envId int, userId int32) (bool, error) + CSEnvironmentFetch func(appId int, envId int) (*ConfigDataRequest, error) + CSEnvironmentFetchForEdit func(name string, id int, appId int, envId int, userId int32) (*ConfigDataRequest, error) + CSGlobalAddUpdate func(configMapRequest *ConfigDataRequest) (*ConfigDataRequest, error) + CSGlobalDelete func(name string, id int, userId int32) (bool, error) + CSGlobalDeleteByAppId func(name string, appId int, userId int32) (bool, error) + CSGlobalFetch func(appId int) (*ConfigDataRequest, error) + CSGlobalFetchForEdit func(name string, id int, userId int32) (*ConfigDataRequest, error) + ConfigSecretEnvironmentBulkPatch func(bulkPatchRequest *BulkPatchRequest) (*BulkPatchRequest, error) + ConfigSecretGlobalBulkPatch func(bulkPatchRequest *BulkPatchRequest) (*BulkPatchRequest, error) + type ConfigMapServiceImpl struct + func NewConfigMapServiceImpl(chartRepository chartConfig.ChartRepository, logger *zap.SugaredLogger, ...) *ConfigMapServiceImpl + func (impl ConfigMapServiceImpl) CMEnvironmentAddUpdate(configMapRequest *ConfigDataRequest) (*ConfigDataRequest, error) + func (impl ConfigMapServiceImpl) CMEnvironmentDelete(name string, id int, userId int32) (bool, error) + func (impl ConfigMapServiceImpl) CMEnvironmentDeleteByAppIdAndEnvId(name string, appId int, envId int, userId int32) (bool, error) + func (impl ConfigMapServiceImpl) CMEnvironmentFetch(appId int, envId int) (*ConfigDataRequest, error) + func (impl ConfigMapServiceImpl) CMGlobalAddUpdate(configMapRequest *ConfigDataRequest) (*ConfigDataRequest, error) + func (impl ConfigMapServiceImpl) CMGlobalDelete(name string, id int, userId int32) (bool, error) + func (impl ConfigMapServiceImpl) CMGlobalDeleteByAppId(name string, appId int, userId int32) (bool, error) + func (impl ConfigMapServiceImpl) CMGlobalFetch(appId int) (*ConfigDataRequest, error) + func (impl ConfigMapServiceImpl) CSEnvironmentAddUpdate(configMapRequest *ConfigDataRequest) (*ConfigDataRequest, error) + func (impl ConfigMapServiceImpl) CSEnvironmentDelete(name string, id int, userId int32) (bool, error) + func (impl ConfigMapServiceImpl) CSEnvironmentDeleteByAppIdAndEnvId(name string, appId int, envId int, userId int32) (bool, error) + func (impl ConfigMapServiceImpl) CSEnvironmentFetch(appId int, envId int) (*ConfigDataRequest, error) + func (impl ConfigMapServiceImpl) CSEnvironmentFetchForEdit(name string, id int, appId int, envId int, userId int32) (*ConfigDataRequest, error) + func (impl ConfigMapServiceImpl) CSGlobalAddUpdate(configMapRequest *ConfigDataRequest) (*ConfigDataRequest, error) + func (impl ConfigMapServiceImpl) CSGlobalDelete(name string, id int, userId int32) (bool, error) + func (impl ConfigMapServiceImpl) CSGlobalDeleteByAppId(name string, appId int, userId int32) (bool, error) + func (impl ConfigMapServiceImpl) CSGlobalFetch(appId int) (*ConfigDataRequest, error) + func (impl ConfigMapServiceImpl) CSGlobalFetchForEdit(name string, id int, userId int32) (*ConfigDataRequest, error) + func (impl ConfigMapServiceImpl) ConfigSecretEnvironmentBulkPatch(bulkPatchRequest *BulkPatchRequest) (*BulkPatchRequest, error) + func (impl ConfigMapServiceImpl) ConfigSecretGlobalBulkPatch(bulkPatchRequest *BulkPatchRequest) (*BulkPatchRequest, error) + type ConfigsList struct + ConfigData []*ConfigData + type ContainerResources struct + MaxCpu string + MaxEphStorage string + MaxMem string + MaxStorage string + MinCpu string + MinEphStorage string + MinMem string + MinStorage string + type DbConfigBean struct + Active bool + DbName string + Host string + Id int + Name string + Password string + Port string + Type string + UserId int32 + UserName string + type DbConfigService interface + GetAll func() (dbConfigs []*DbConfigBean, err error) + GetById func(id int) (dbConfig *DbConfigBean, err error) + GetForAutocomplete func() (dbConfigs []*DbConfigBean, err error) + Save func(dbConfigBean *DbConfigBean) (dbConfig *DbConfigBean, err error) + Update func(dbConfigBean *DbConfigBean) (dbConfig *DbConfigBean, err error) + type DbConfigServiceImpl struct + func NewDbConfigService(configRepo repository.DbConfigRepository, logger *zap.SugaredLogger) *DbConfigServiceImpl + func (impl DbConfigServiceImpl) GetAll() (dbConfigs []*DbConfigBean, err error) + func (impl DbConfigServiceImpl) GetById(id int) (dbConfig *DbConfigBean, err error) + func (impl DbConfigServiceImpl) GetForAutocomplete() (dbConfigs []*DbConfigBean, err error) + func (impl DbConfigServiceImpl) Save(dbConfigBean *DbConfigBean) (dbConfig *DbConfigBean, err error) + func (impl DbConfigServiceImpl) Update(dbConfigBean *DbConfigBean) (dbConfig *DbConfigBean, err error) + type DbMigrationConfigBean struct + Active bool + DbConfigId int + GitMaterialId int + Id int + MigrationTool string + PipelineId int + ScriptSource string + UserId int32 + type DbMigrationService interface + GetByPipelineId func(pipelineId int) (*DbMigrationConfigBean, error) + Save func(bean *DbMigrationConfigBean) (*DbMigrationConfigBean, error) + Update func(bean *DbMigrationConfigBean) (*DbMigrationConfigBean, error) + type DbMigrationServiceImpl struct + func NewDbMogrationService(logger *zap.SugaredLogger, ...) *DbMigrationServiceImpl + func (impl DbMigrationServiceImpl) GetByPipelineId(pipelineId int) (*DbMigrationConfigBean, error) + func (impl DbMigrationServiceImpl) Save(bean *DbMigrationConfigBean) (*DbMigrationConfigBean, error) + func (impl DbMigrationServiceImpl) Update(bean *DbMigrationConfigBean) (*DbMigrationConfigBean, error) + type DbPipelineOrchestrator interface + CreateApp func(createRequest *bean.CreateAppDTO) (*bean.CreateAppDTO, error) + CreateCDPipelines func(pipelineRequest *bean.CDPipelineConfigObject, appId int, userId int32, ...) (pipelineId int, err error) + CreateCiConf func(createRequest *bean.CiConfigRequest, templateId int) (*bean.CiConfigRequest, error) + CreateMaterials func(createMaterialRequest *bean.CreateMaterialDTO) (*bean.CreateMaterialDTO, error) + DeleteApp func(appId int, userId int32) error + DeleteCdPipeline func(pipelineId int, tx *pg.Tx) error + DeleteCiPipeline func(pipeline *pipelineConfig.CiPipeline, userId int32, tx *pg.Tx) error + GetByEnvOverrideId func(envOverrideId int) (*bean.CdPipelines, error) + GetCdPipelinesForApp func(appId int) (cdPipelines *bean.CdPipelines, err error) + GetCdPipelinesForAppAndEnv func(appId int, envId int) (cdPipelines *bean.CdPipelines, err error) + PatchMaterialValue func(createRequest *bean.CiPipeline, userId int32) (*bean.CiPipeline, error) + PipelineExists func(name string) (bool, error) + UpdateCDPipeline func(pipelineRequest *bean.CDPipelineConfigObject, userId int32, tx *pg.Tx) (err error) + UpdateMaterial func(updateMaterialRequest *bean.UpdateMaterialDTO) (*bean.UpdateMaterialDTO, error) + type DbPipelineOrchestratorImpl struct + CiPipelineMaterialRepository pipelineConfig.CiPipelineMaterialRepository + GitSensorClient gitSensor.GitSensorClient + func NewDbPipelineOrchestrator(pipelineGroupRepository pipelineConfig.AppRepository, ...) *DbPipelineOrchestratorImpl + func (impl DbPipelineOrchestratorImpl) CreateApp(createRequest *bean.CreateAppDTO) (*bean.CreateAppDTO, error) + func (impl DbPipelineOrchestratorImpl) CreateCDPipelines(pipelineRequest *bean.CDPipelineConfigObject, appId int, userId int32, ...) (pipelineId int, err error) + func (impl DbPipelineOrchestratorImpl) CreateCiConf(createRequest *bean.CiConfigRequest, templateId int) (*bean.CiConfigRequest, error) + func (impl DbPipelineOrchestratorImpl) CreateMaterials(createMaterialRequest *bean.CreateMaterialDTO) (*bean.CreateMaterialDTO, error) + func (impl DbPipelineOrchestratorImpl) DeleteApp(appId int, userId int32) error + func (impl DbPipelineOrchestratorImpl) DeleteCdPipeline(pipelineId int, tx *pg.Tx) error + func (impl DbPipelineOrchestratorImpl) DeleteCiPipeline(pipeline *pipelineConfig.CiPipeline, userId int32, tx *pg.Tx) error + func (impl DbPipelineOrchestratorImpl) GetByEnvOverrideId(envOverrideId int) (*bean.CdPipelines, error) + func (impl DbPipelineOrchestratorImpl) GetCdPipelinesForApp(appId int) (cdPipelines *bean.CdPipelines, err error) + func (impl DbPipelineOrchestratorImpl) GetCdPipelinesForAppAndEnv(appId int, envId int) (cdPipelines *bean.CdPipelines, err error) + func (impl DbPipelineOrchestratorImpl) PatchMaterialValue(createRequest *bean.CiPipeline, userId int32) (*bean.CiPipeline, error) + func (impl DbPipelineOrchestratorImpl) PipelineExists(name string) (bool, error) + func (impl DbPipelineOrchestratorImpl) UpdateCDPipeline(pipelineRequest *bean.CDPipelineConfigObject, userId int32, tx *pg.Tx) (err error) + func (impl DbPipelineOrchestratorImpl) UpdateMaterial(updateMaterialDTO *bean.UpdateMaterialDTO) (*bean.UpdateMaterialDTO, error) + type DefaultChart string + type Deployment struct + Strategy Strategy + type DeploymentGroupAppWithEnv struct + Active bool + AppId int + DeploymentGroupId int + EnvironmentId int + RequestType RequestType + UserId int32 + type DeploymentType struct + Deployment Deployment + type DockerArtifactStoreBean struct + AWSAccessKeyId string + AWSRegion string + AWSSecretAccessKey string + Active bool + Id string + IsDefault bool + Password string + PluginId string + RegistryType repository.RegistryType + RegistryURL string + User int32 + Username string + type DockerRegistryConfig interface + Create func(bean *DockerArtifactStoreBean) (*DockerArtifactStoreBean, error) + Delete func(storeId string) (string, error) + FetchAllDockerAccounts func() ([]DockerArtifactStoreBean, error) + FetchOneDockerAccount func(storeId string) (*DockerArtifactStoreBean, error) + ListAllActive func() ([]DockerArtifactStoreBean, error) + Update func(bean *DockerArtifactStoreBean) (*DockerArtifactStoreBean, error) + type DockerRegistryConfigImpl struct + func NewDockerRegistryConfigImpl(dockerArtifactStoreRepository repository.DockerArtifactStoreRepository, ...) *DockerRegistryConfigImpl + func (impl DockerRegistryConfigImpl) Create(bean *DockerArtifactStoreBean) (*DockerArtifactStoreBean, error) + func (impl DockerRegistryConfigImpl) Delete(storeId string) (string, error) + func (impl DockerRegistryConfigImpl) FetchAllDockerAccounts() ([]DockerArtifactStoreBean, error) + func (impl DockerRegistryConfigImpl) FetchOneDockerAccount(storeId string) (*DockerArtifactStoreBean, error) + func (impl DockerRegistryConfigImpl) ListAllActive() ([]DockerArtifactStoreBean, error) + func (impl DockerRegistryConfigImpl) Update(bean *DockerArtifactStoreBean) (*DockerArtifactStoreBean, error) + type EcrConfig struct + EcrPrefix string + func GetEcrConfig() (*EcrConfig, error) + type EnvironmentProperties struct + Active bool + AppMetrics *bool + ChartRefId int + EnvOverrideValues json.RawMessage + EnvironmentId int + EnvironmentName string + Id int + IsOverride bool + Latest bool + ManualReviewed bool + Namespace string + Status models.ChartStatus + UserId int32 + type EnvironmentPropertiesResponse struct + AppMetrics *bool + ChartRefId int + EnvironmentConfig EnvironmentProperties + GlobalChartRefId int + GlobalConfig json.RawMessage + IsOverride bool + Namespace string + type ExternalSecret struct + IsBinary bool + Key string + Name string + Property string + type GitOptions struct + AccessToken string + AuthMode repository.AuthMode + Password string + SSHKey string + UserName string + type GitRegistryConfig interface + Create func(request *GitRegistryRequest) (*GitRegistryRequest, error) + FetchAllGitProviders func() ([]GitRegistryRequest, error) + FetchOneGitProvider func(id string) (*GitRegistryRequest, error) + GetAll func() ([]GitRegistryRequest, error) + Update func(request *GitRegistryRequest) (*GitRegistryRequest, error) + type GitRegistryConfigImpl struct + GitSensorClient gitSensor.GitSensorClient + func NewGitRegistryConfigImpl(logger *zap.SugaredLogger, gitProviderRepo repository.GitProviderRepository, ...) *GitRegistryConfigImpl + func (impl GitRegistryConfigImpl) Create(request *GitRegistryRequest) (*GitRegistryRequest, error) + func (impl GitRegistryConfigImpl) FetchAllGitProviders() ([]GitRegistryRequest, error) + func (impl GitRegistryConfigImpl) FetchOneGitProvider(providerId string) (*GitRegistryRequest, error) + func (impl GitRegistryConfigImpl) GetAll() ([]GitRegistryRequest, error) + func (impl GitRegistryConfigImpl) Update(request *GitRegistryRequest) (*GitRegistryRequest, error) + func (impl GitRegistryConfigImpl) UpdateGitSensor(provider *repository.GitProvider) error + type GitRegistryRequest struct + AccessToken string + Active bool + AuthMode repository.AuthMode + Id int + Name string + Password string + SshKey string + Url string + UserId int32 + UserName string + type GitTriggerInfoResponse struct + AppId int + AppName string + CiMaterials []CiPipelineMaterialResponse + Default bool + EnvironmentId int + EnvironmentName string + LastDeployedTime string + TriggeredByEmail string + type IsReady struct + Flag bool + Message string + type PipelineBuilder interface + CreateApp func(request *bean.CreateAppDTO) (*bean.CreateAppDTO, error) + CreateCdPipelines func(cdPipelines *bean.CdPipelines, ctx context.Context) (*bean.CdPipelines, error) + CreateCiPipeline func(createRequest *bean.CiConfigRequest) (*bean.PipelineCreateResponse, error) + CreateMaterialsForApp func(request *bean.CreateMaterialDTO) (*bean.CreateMaterialDTO, error) + DeleteApp func(appId int, userId int32) error + FetchArtifactForRollback func(cdPipelineId int) (bean.CiArtifactResponse, error) + FetchCDPipelineStrategy func(appId int) (PipelineStrategiesResponse, error) + FetchConfigmapSecretsForCdStages func(appId, envId, cdPipelineId int) (ConfigMapSecretsResponse, error) + FindAppsByTeamId func(teamId int) ([]AppBean, error) + FindAppsByTeamName func(teamName string) ([]AppBean, error) + FindByIds func(ids []*int) ([]*AppBean, error) + FindPipelineById func(cdPipelineId int) (*pipelineConfig.Pipeline, error) + GetApp func(appId int) (application *bean.CreateAppDTO, err error) + GetAppList func() ([]AppBean, error) + GetAppListByTeamIds func(teamIds []int) ([]*TeamAppBean, error) + GetArtifactsByCDPipeline func(cdPipelineId int, stage bean2.CdWorkflowType) (bean.CiArtifactResponse, error) + GetCdPipelineById func(pipelineId int) (cdPipeline *bean.CDPipelineConfigObject, err error) + GetCdPipelinesForApp func(appId int) (cdPipelines *bean.CdPipelines, err error) + GetCdPipelinesForAppAndEnv func(appId int, envId int) (cdPipelines *bean.CdPipelines, err error) + GetCiPipeline func(appId int) (ciConfig *bean.CiConfigRequest, err error) + GetCiPipelineById func(pipelineId int) (ciPipeline *bean.CiPipeline, err error) + GetCiPipelineMin func(appId int) ([]*bean.CiPipelineMin, error) + PatchCdPipelines func(cdPipelines *bean.CDPatchRequest, ctx context.Context) (*bean.CdPipelines, error) + PatchCiPipeline func(request *bean.CiPatchRequest) (ciConfig *bean.CiConfigRequest, err error) + UpdateCiTemplate func(updateRequest *bean.CiConfigRequest) (*bean.CiConfigRequest, error) + UpdateMaterialsForApp func(request *bean.UpdateMaterialDTO) (*bean.UpdateMaterialDTO, error) + type PipelineBuilderImpl struct + ArgoK8sClient argocdServer.ArgoK8sClient + GitFactory *util.GitFactory + func NewPipelineBuilderImpl(logger *zap.SugaredLogger, dbPipelineOrchestrator DbPipelineOrchestrator, ...) *PipelineBuilderImpl + func (impl PipelineBuilderImpl) CreateApp(request *bean.CreateAppDTO) (*bean.CreateAppDTO, error) + func (impl PipelineBuilderImpl) CreateCdPipelines(cdPipelines *bean.CdPipelines, ctx context.Context) (*bean.CdPipelines, error) + func (impl PipelineBuilderImpl) CreateCiPipeline(createRequest *bean.CiConfigRequest) (*bean.PipelineCreateResponse, error) + func (impl PipelineBuilderImpl) CreateMaterialsForApp(request *bean.CreateMaterialDTO) (*bean.CreateMaterialDTO, error) + func (impl PipelineBuilderImpl) DeleteApp(appId int, userId int32) error + func (impl PipelineBuilderImpl) FetchArtifactForRollback(cdPipelineId int) (bean.CiArtifactResponse, error) + func (impl PipelineBuilderImpl) FetchCDPipelineStrategy(appId int) (PipelineStrategiesResponse, error) + func (impl PipelineBuilderImpl) FetchConfigmapSecretsForCdStages(appId, envId, cdPipelineId int) (ConfigMapSecretsResponse, error) + func (impl PipelineBuilderImpl) FindAppsByTeamId(teamId int) ([]AppBean, error) + func (impl PipelineBuilderImpl) FindAppsByTeamName(teamName string) ([]AppBean, error) + func (impl PipelineBuilderImpl) FindByIds(ids []*int) ([]*AppBean, error) + func (impl PipelineBuilderImpl) FindPipelineById(cdPipelineId int) (*pipelineConfig.Pipeline, error) + func (impl PipelineBuilderImpl) GetApp(appId int) (application *bean.CreateAppDTO, err error) + func (impl PipelineBuilderImpl) GetAppList() ([]AppBean, error) + func (impl PipelineBuilderImpl) GetAppListByTeamIds(teamIds []int) ([]*TeamAppBean, error) + func (impl PipelineBuilderImpl) GetArtifactsByCDPipeline(cdPipelineId int, stage bean2.CdWorkflowType) (bean.CiArtifactResponse, error) + func (impl PipelineBuilderImpl) GetCdPipelineById(pipelineId int) (cdPipeline *bean.CDPipelineConfigObject, err error) + func (impl PipelineBuilderImpl) GetCdPipelinesForApp(appId int) (cdPipelines *bean.CdPipelines, err error) + func (impl PipelineBuilderImpl) GetCdPipelinesForAppAndEnv(appId int, envId int) (cdPipelines *bean.CdPipelines, err error) + func (impl PipelineBuilderImpl) GetCiPipeline(appId int) (ciConfig *bean.CiConfigRequest, err error) + func (impl PipelineBuilderImpl) GetCiPipelineById(pipelineId int) (ciPipeline *bean.CiPipeline, err error) + func (impl PipelineBuilderImpl) GetCiPipelineMin(appId int) ([]*bean.CiPipelineMin, error) + func (impl PipelineBuilderImpl) PatchCdPipelines(cdPipelines *bean.CDPatchRequest, ctx context.Context) (*bean.CdPipelines, error) + func (impl PipelineBuilderImpl) PatchCiPipeline(request *bean.CiPatchRequest) (ciConfig *bean.CiConfigRequest, err error) + func (impl PipelineBuilderImpl) UpdateCiTemplate(updateRequest *bean.CiConfigRequest) (*bean.CiConfigRequest, error) + func (impl PipelineBuilderImpl) UpdateMaterialsForApp(request *bean.UpdateMaterialDTO) (*bean.UpdateMaterialDTO, error) + type PipelineConfigRequest struct + AppId int + EnvConfigOverrideId int + EnvId int + Id int + Latest bool + ManualReviewed bool + PipelineConfigValues json.RawMessage + PipelineId int + Previous bool + UserId int32 + type PipelineConfigRequestResponse struct + LatestPipelineConfigRequest PipelineConfigRequest + PreviousPipelineConfigRequest PipelineConfigRequest + type PipelineStrategiesResponse struct + PipelineStrategy []PipelineStrategy + type PipelineStrategy struct + Config json.RawMessage + Default bool + DeploymentTemplate pipelineConfig.DeploymentTemplate + type PropertiesConfigService interface + CreateEnvironmentProperties func(appId int, propertiesRequest *EnvironmentProperties) (*EnvironmentProperties, error) + CreateEnvironmentPropertiesWithNamespace func(appId int, propertiesRequest *EnvironmentProperties) (*EnvironmentProperties, error) + CreateIfRequired func(chart *chartConfig.Chart, environmentId int, userId int32, manualReviewed bool, ...) (*chartConfig.EnvConfigOverride, error) + EnvMetricsEnableDisable func(appMetricRequest *AppMetricEnableDisableRequest) (*AppMetricEnableDisableRequest, error) + GetAppIdByChartEnvId func(chartEnvId int) (*chartConfig.EnvConfigOverride, error) + GetEnvironmentProperties func(appId, environmentId int, chartRefId int) (environmentPropertiesResponse *EnvironmentPropertiesResponse, err error) + GetEnvironmentPropertiesById func(environmentId int) ([]EnvironmentProperties, error) + GetLatestEnvironmentProperties func(appId, environmentId int) (*EnvironmentProperties, error) + ResetEnvironmentProperties func(id int) (bool, error) + UpdateEnvironmentProperties func(appId int, propertiesRequest *EnvironmentProperties, userId int32) (*EnvironmentProperties, error) + type PropertiesConfigServiceImpl struct + func NewPropertiesConfigServiceImpl(logger *zap.SugaredLogger, ...) *PropertiesConfigServiceImpl + func (impl PropertiesConfigServiceImpl) CreateEnvironmentProperties(appId int, environmentProperties *EnvironmentProperties) (*EnvironmentProperties, error) + func (impl PropertiesConfigServiceImpl) CreateEnvironmentPropertiesWithNamespace(appId int, environmentProperties *EnvironmentProperties) (*EnvironmentProperties, error) + func (impl PropertiesConfigServiceImpl) CreateIfRequired(chart *chartConfig.Chart, environmentId int, userId int32, manualReviewed bool, ...) (*chartConfig.EnvConfigOverride, error) + func (impl PropertiesConfigServiceImpl) EnvMetricsEnableDisable(appMetricRequest *AppMetricEnableDisableRequest) (*AppMetricEnableDisableRequest, error) + func (impl PropertiesConfigServiceImpl) GetAppIdByChartEnvId(chartEnvId int) (*chartConfig.EnvConfigOverride, error) + func (impl PropertiesConfigServiceImpl) GetEnvironmentProperties(appId, environmentId int, chartRefId int) (environmentPropertiesResponse *EnvironmentPropertiesResponse, err error) + func (impl PropertiesConfigServiceImpl) GetEnvironmentPropertiesById(envId int) ([]EnvironmentProperties, error) + func (impl PropertiesConfigServiceImpl) GetLatestEnvironmentProperties(appId, environmentId int) (environmentProperties *EnvironmentProperties, err error) + func (impl PropertiesConfigServiceImpl) ResetEnvironmentProperties(id int) (bool, error) + func (impl PropertiesConfigServiceImpl) UpdateEnvironmentProperties(appId int, propertiesRequest *EnvironmentProperties, userId int32) (*EnvironmentProperties, error) + type Recreate struct + type RefChartDir string + type RequestType string + const START + const STOP + type Rolling struct + MaxSurge string + MaxUnavailable int + type RolloutPause struct + Duration *int32 + type SecretsList struct + ConfigData []*ConfigData + type StopAppRequest struct + AppId int + EnvironmentId int + RequestType RequestType + UserId int32 + type StopDeploymentGroupRequest struct + DeploymentGroupId int + RequestType RequestType + UserId int32 + type Strategy struct + BlueGreen *BlueGreen + Canary *Canary + Recreate *Recreate + Rolling *Rolling + type TeamAppBean struct + AppList []*AppBean + ProjectId int + ProjectName string + type TemplateRequest struct + AppId int + ChartRefId int + ChartRepositoryId int + DefaultAppOverride json.RawMessage + Id int + IsAppMetricsEnabled bool + Latest bool + RefChartTemplate string + RefChartTemplateVersion string + UserId int32 + ValuesOverride json.RawMessage + type Trigger struct + CiMaterials []*pipelineConfig.CiPipelineMaterial + CommitHashes map[int]bean.GitCommit + InvalidateCache bool + PipelineId int + TriggeredBy int32 + type WebhookService interface + AuthenticateExternalCiWebhook func(apiKey string) (int, error) + SaveCiArtifactWebhook func(ciPipelineId int, request *CiArtifactWebhookRequest) (id int, err error) + type WebhookServiceImpl struct + func NewWebhookServiceImpl(ciArtifactRepository repository.CiArtifactRepository, ...) *WebhookServiceImpl + func (impl *WebhookServiceImpl) BuildPayload(request *CiArtifactWebhookRequest, pipeline *pipelineConfig.CiPipeline) *client.Payload + func (impl *WebhookServiceImpl) WriteCISuccessEvent(request *CiArtifactWebhookRequest, pipeline *pipelineConfig.CiPipeline, ...) + func (impl WebhookServiceImpl) AuthenticateExternalCiWebhook(apiKey string) (int, error) + func (impl WebhookServiceImpl) SaveCiArtifactWebhook(ciPipelineId int, request *CiArtifactWebhookRequest) (id int, err error) + type WorkflowDagExecutor interface + HandleCiSuccessEvent func(artifact *repository.CiArtifact, applyAuth bool, async bool, triggeredBy int32) error + HandleDeploymentSuccessEvent func(gitHash string) error + HandlePreStageSuccessEvent func(cdStageCompleteEvent CdStageCompleteEvent) error + ManualCdTrigger func(overrideRequest *bean.ValuesOverrideRequest, ctx context.Context) (int, error) + StopStartApp func(stopRequest *StopAppRequest, ctx context.Context) (int, error) + Subscribe func() error + TriggerBulkDeploymentAsync func(requests []*BulkTriggerRequest, UserId int32) (interface{}, error) + TriggerBulkHibernateAsync func(request StopDeploymentGroupRequest, ctx context.Context) (interface{}, error) + TriggerDeployment func(cdWf *pipelineConfig.CdWorkflow, artifact *repository.CiArtifact, ...) error + TriggerPostStage func(cdWf *pipelineConfig.CdWorkflow, cdPipeline *pipelineConfig.Pipeline, ...) error + type WorkflowDagExecutorImpl struct + func NewWorkflowDagExecutorImpl(Logger *zap.SugaredLogger, ...) *WorkflowDagExecutorImpl + func (impl *WorkflowDagExecutorImpl) HandleCiSuccessEvent(artifact *repository.CiArtifact, applyAuth bool, async bool, triggeredBy int32) error + func (impl *WorkflowDagExecutorImpl) HandleDeploymentSuccessEvent(gitHash string) error + func (impl *WorkflowDagExecutorImpl) HandlePreStageSuccessEvent(cdStageCompleteEvent CdStageCompleteEvent) error + func (impl *WorkflowDagExecutorImpl) ManualCdTrigger(overrideRequest *bean.ValuesOverrideRequest, ctx context.Context) (int, error) + func (impl *WorkflowDagExecutorImpl) StopStartApp(stopRequest *StopAppRequest, ctx context.Context) (int, error) + func (impl *WorkflowDagExecutorImpl) Subscribe() error + func (impl *WorkflowDagExecutorImpl) TriggerBulkDeploymentAsync(requests []*BulkTriggerRequest, UserId int32) (interface{}, error) + func (impl *WorkflowDagExecutorImpl) TriggerBulkHibernateAsync(request StopDeploymentGroupRequest, ctx context.Context) (interface{}, error) + func (impl *WorkflowDagExecutorImpl) TriggerDeployment(cdWf *pipelineConfig.CdWorkflow, artifact *repository.CiArtifact, ...) error + func (impl *WorkflowDagExecutorImpl) TriggerPostStage(cdWf *pipelineConfig.CdWorkflow, cpipeline *pipelineConfig.Pipeline, ...) error + func (impl *WorkflowDagExecutorImpl) TriggerPreStage(cdWf *pipelineConfig.CdWorkflow, artifact *repository.CiArtifact, ...) error + type WorkflowRequest struct + AccessKey string + ActiveDeadlineSeconds int64 + AfterDockerBuildScripts []*bean.CiScript + AwsRegion string + AzureBlobConfig *AzureBlobConfig + BeforeDockerBuildScripts []*bean.CiScript + CacheLimit int64 + CiArtifactLocation string + CiCacheFileName string + CiCacheLocation string + CiCacheRegion string + CiImage string + CiProjectDetails []CiProjectDetails + CloudProvider string + ContainerResources ContainerResources + DockerBuildArgs string + DockerFileLocation string + DockerImageTag string + DockerPassword string + DockerRegistryType string + DockerRegistryURL string + DockerRepository string + DockerUsername string + InvalidateCache bool + MinioEndpoint string + Namespace string + PipelineId int + PipelineName string + ScanEnabled bool + SecretKey string + TriggeredBy int32 + WorkflowId int + WorkflowNamePrefix string + type WorkflowResponse struct + Artifact string + ArtifactId int + CiMaterials []CiPipelineMaterialResponse + CiPipelineId int + FinishedOn time.Time + GitTriggers map[int]pipelineConfig.GitCommit + Id int + LogLocation string + Message string + Name string + Namespace string + PodStatus string + Stage string + StartedOn time.Time + Status string + TriggeredBy int32 + TriggeredByEmail string + type WorkflowService interface + DeleteWorkflow func(wfName string, namespace string) error + GetWorkflow func(name string, namespace string) (*v1alpha1.Workflow, error) + ListAllWorkflows func(namespace string) (*v1alpha1.WorkflowList, error) + SubmitWorkflow func(workflowRequest *WorkflowRequest) (*v1alpha1.Workflow, error) + TerminateWorkflow func(name string, namespace string) error + UpdateWorkflow func(wf *v1alpha1.Workflow) (*v1alpha1.Workflow, error) + type WorkflowServiceImpl struct + Logger *zap.SugaredLogger + func NewWorkflowServiceImpl(Logger *zap.SugaredLogger, ciConfig *CiConfig) *WorkflowServiceImpl + func (impl *WorkflowServiceImpl) DeleteWorkflow(wfName string, namespace string) error + func (impl *WorkflowServiceImpl) GetWorkflow(name string, namespace string) (*v1alpha1.Workflow, error) + func (impl *WorkflowServiceImpl) ListAllWorkflows(namespace string) (*v1alpha1.WorkflowList, error) + func (impl *WorkflowServiceImpl) SubmitWorkflow(workflowRequest *WorkflowRequest) (*v1alpha1.Workflow, error) + func (impl *WorkflowServiceImpl) TerminateWorkflow(name string, namespace string) error + func (impl *WorkflowServiceImpl) UpdateWorkflow(wf *v1alpha1.Workflow) (*v1alpha1.Workflow, error) + type WorkflowStatus struct + LogLocation string + Message string + PodStatus string + Status string + WorkflowName string