pipeline

Apr 13, 2024

Changes in this version

type CiTemplateService

+ GetAppliedDockerConfigForCiPipeline func(ciPipelineId, appId int, isOverridden bool) (*types.DockerArtifactStoreBean, error)

+ GetBaseDockerConfigForCiPipeline func(appId int) (*types.DockerArtifactStoreBean, error)

type CiTemplateServiceImpl

+ func (impl CiTemplateServiceImpl) GetAppliedDockerConfigForCiPipeline(ciPipelineId, appId int, isOverridden bool) (*types.DockerArtifactStoreBean, error)

+ func (impl CiTemplateServiceImpl) GetBaseDockerConfigForCiPipeline(appId int) (*types.DockerArtifactStoreBean, error)

+ type ExternalCiWebhookDto struct

+ AppName string

+ CiProjectDetails []bean.CiProjectDetails

+ DataSource string

+ Digest string

+ DockerImage string

+ FailureReason string

+ ImageDetailsFromCR *ImageDetailsFromCR

+ IsArtifactUploaded bool

+ MaterialType string

+ Metrics util3.CIMetrics

+ PipelineId int

+ PipelineName string

+ PluginArtifactStage string

+ PluginRegistryArtifactDetails map[string][]string

+ TriggeredBy int32

+ WorkflowId *int

+ type ImageDetailsFromCR struct

+ ImageDetails []types.ImageDetail

+ Region string

Mar 13, 2024

Changes in this version

+ const ABORT_MESSAGE_AFTER_STARTING_STAGE

+ const ARGOCD_REFRESH_ERROR

+ const ARGOCD_SYNC_ERROR

+ func ExtractWorkflowStatus(workflowStatus v1alpha1.WorkflowStatus) (string, string, string, string, string, string)

+ func ReplaceImageTagWithDigest(image, digest string) string

type ArgoPipelineStatusSyncEvent

+ InstalledAppVersionId int

type CdHandlerImpl

+ AppConfig *app.AppServiceConfig

+ func (impl *CdHandlerImpl) SyncACDHelmApps(deployedBeforeMinutes int, installedAppVersionId int) error

+ type TriggerContext struct

+ Context context.Context

+ ReferenceId *string

+ type TriggerRequest struct

+ ApplyAuth bool

+ Artifact *repository.CiArtifact

+ CdWf *pipelineConfig.CdWorkflow

+ Pipeline *pipelineConfig.Pipeline

+ RefCdWorkflowRunnerId int

+ TriggeredBy int32

type WebhookService

+ GetTriggerValidateFuncs func() []pubsub.ValidateMsg

type WebhookServiceImpl

+ func (impl *WebhookServiceImpl) GetTriggerValidateFuncs() []pubsub.ValidateMsg

type WorkflowDagExecutor

+ GetTriggerValidateFuncs func() []pubsub.ValidateMsg

type WorkflowDagExecutorImpl

+ ACDConfig *argocdServer.ACDConfig

+ func (impl *WorkflowDagExecutorImpl) GetTriggerValidateFuncs() []pubsub.ValidateMsg

Dec 14, 2023

Changes in this version

+ const DESTINATION_INFO

+ const DEVTRON_SYSTEM_USER_ID

+ const SOURCE_REGISTRY_CREDENTIALS_KEY

+ const TERMINATE_MESSAGE

type AppArtifactManager

+ FetchArtifactForRollbackV2 func(cdPipelineId, appId, offset, limit int, searchString string, ...) (bean2.CiArtifactResponse, error)

+ RetrieveArtifactsByCDPipelineV2 func(pipeline *pipelineConfig.Pipeline, stage bean.WorkflowType, ...) (*bean2.CiArtifactResponse, error)

type AppArtifactManagerImpl

+ CiPipelineRepository pipelineConfig.CiPipelineRepository

+ func (impl *AppArtifactManagerImpl) BuildArtifactsForCIParentV2(listingFilterOpts *bean.ArtifactsListFilterOptions) ([]*bean2.CiArtifactBean, int, error)

+ func (impl *AppArtifactManagerImpl) BuildArtifactsForCdStageV2(listingFilterOpts *bean.ArtifactsListFilterOptions) ([]*bean2.CiArtifactBean, int, error)

+ func (impl *AppArtifactManagerImpl) BuildArtifactsList(listingFilterOpts *bean.ArtifactsListFilterOptions) ([]*bean2.CiArtifactBean, int, string, int, error)

+ func (impl *AppArtifactManagerImpl) BuildRollbackArtifactsList(artifactListingFilterOpts bean.ArtifactsListFilterOptions) ([]bean2.CiArtifactBean, []int, int, error)

+ func (impl *AppArtifactManagerImpl) FetchArtifactForRollbackV2(cdPipelineId, appId, offset, limit int, searchString string, ...) (bean2.CiArtifactResponse, error)

+ func (impl *AppArtifactManagerImpl) RetrieveArtifactsByCDPipelineV2(pipeline *pipelineConfig.Pipeline, stage bean.WorkflowType, ...) (*bean2.CiArtifactResponse, error)

+ type BuildPipelineSwitchService interface

+ SwitchToCiPipelineExceptExternal func(request *bean.CiPatchRequest, ciConfig *bean.CiConfigRequest) (*bean.CiConfigRequest, error)

+ SwitchToExternalCi func(tx *pg.Tx, appWorkflowMapping *appWorkflow.AppWorkflowMapping, ...) error

+ type BuildPipelineSwitchServiceImpl struct

+ func NewBuildPipelineSwitchServiceImpl(logger *zap.SugaredLogger, ...) *BuildPipelineSwitchServiceImpl

+ func (impl *BuildPipelineSwitchServiceImpl) DeleteCiMaterial(tx *pg.Tx, ciPipeline *pipelineConfig.CiPipeline) ([]*pipelineConfig.CiPipelineMaterial, error)

+ func (impl *BuildPipelineSwitchServiceImpl) SwitchToCiPipelineExceptExternal(request *bean.CiPatchRequest, ciConfig *bean.CiConfigRequest) (*bean.CiConfigRequest, error)

+ func (impl *BuildPipelineSwitchServiceImpl) SwitchToExternalCi(tx *pg.Tx, appWorkflowMapping *appWorkflow.AppWorkflowMapping, ...) error

type CdHandler

+ DeactivateImageReservationPathsOnFailure func(imagePathReservationIds []int) error

type CdHandlerImpl

+ func (impl *CdHandlerImpl) DeactivateImageReservationPathsOnFailure(imagePathReservationIds []int) error

type CdPipelineConfigServiceImpl

+ func (impl *CdPipelineConfigServiceImpl) CDPipelineCustomTagDBOperations(pipeline *bean.CDPipelineConfigObject) error

+ func (impl *CdPipelineConfigServiceImpl) DeleteCustomTag(pipeline *bean.CDPipelineConfigObject) error

+ func (impl *CdPipelineConfigServiceImpl) DeleteCustomTagByPipelineStageType(pipelineStageType *repository5.PipelineStageType, pipelineId int) error

+ func (impl *CdPipelineConfigServiceImpl) DisableCustomTag(pipeline *bean.CDPipelineConfigObject) error

+ func (impl *CdPipelineConfigServiceImpl) DisableCustomTagByPipelineStageType(pipelineStageType *repository5.PipelineStageType, pipelineId int) error

+ func (impl *CdPipelineConfigServiceImpl) ParseCustomTagPatchRequest(pipelineRequest *bean.CDPipelineConfigObject) (*bean2.CustomTag, error)

+ func (impl *CdPipelineConfigServiceImpl) SaveOrUpdateCustomTagForCDPipeline(pipeline *bean.CDPipelineConfigObject) error

type CdStageCompleteEvent

+ PluginRegistryArtifactDetails map[string][]string

type CiArtifactWebhookRequest

+ PluginArtifactStage string

+ PluginRegistryArtifactDetails map[string][]string

type CiCdPipelineOrchestrator

+ AddPipelineToTemplate func(createRequest *bean.CiConfigRequest, isSwitchCiPipelineRequest bool) (resp *bean.CiConfigRequest, err error)

+ CreateCiTemplateBean func(ciPipelineId int, dockerRegistryId string, dockerRepository string, ...) bean2.CiTemplateBean

+ DeleteCiPipelineAndCiEnvMappings func(tx *pg.Tx, ciPipeline *pipelineConfig.CiPipeline, userId int32) error

+ SaveHistoryOfBaseTemplate func(userId int32, pipeline *pipelineConfig.CiPipeline, ...) error

type CiCdPipelineOrchestratorImpl

+ CiArtifactRepository repository.CiArtifactRepository

+ func (impl CiCdPipelineOrchestratorImpl) AddPipelineToTemplate(createRequest *bean.CiConfigRequest, isSwitchCiPipelineRequest bool) (resp *bean.CiConfigRequest, err error)

+ func (impl CiCdPipelineOrchestratorImpl) CreateCiTemplateBean(ciPipelineId int, dockerRegistryId string, dockerRepository string, ...) bean2.CiTemplateBean

+ func (impl CiCdPipelineOrchestratorImpl) DeleteCiPipelineAndCiEnvMappings(tx *pg.Tx, ciPipeline *pipelineConfig.CiPipeline, userId int32) error

+ func (impl CiCdPipelineOrchestratorImpl) SaveHistoryOfBaseTemplate(userId int32, pipeline *pipelineConfig.CiPipeline, ...) error

type CiPipelineConfigService

+ CreateExternalCiAndAppWorkflowMapping func(appId, appWorkflowId int, userId int32, tx *pg.Tx) (int, *appWorkflow.AppWorkflowMapping, error)

type CiPipelineConfigServiceImpl

+ func (impl *CiPipelineConfigServiceImpl) CreateExternalCiAndAppWorkflowMapping(appId, appWorkflowId int, userId int32, tx *pg.Tx) (int, *appWorkflow.AppWorkflowMapping, error)

type CiServiceImpl

+ func (impl *CiServiceImpl) GetWorkflowRequestVariablesForCopyContainerImagePlugin(preCiSteps []*bean2.StepObject, postCiSteps []*bean2.StepObject, ...) (map[string][]string, map[string]plugin.RegistryCredentials, string, []int, ...)

+ func (impl *CiServiceImpl) ReserveImagesGeneratedAtPlugin(customTagId int, registryImageMap map[string][]string) ([]int, error)

+ type ConfigMapAndSecretJsonV2 struct

+ AppId int

+ ChartVersion string

+ DeploymentWithConfig bean.DeploymentConfigurationType

+ EnvId int

+ PipeLineId int

+ Scope resourceQualifiers.Scope

type CustomTagService

+ DeactivateImagePathReservationByImageIds func(imagePathReservationIds []int) error

+ DeactivateImagePathReservationByImagePath func(imagePaths []string) error

+ DisableCustomTagIfExist func(tag bean.CustomTag) error

+ GetCustomTag func(entityKey int, entityValue string) (*repository.CustomTag, string, error)

+ ReserveImagePath func(imagePath string, customTagId int) (*repository.ImagePathReservation, error)

type CustomTagServiceImpl

+ func (impl *CustomTagServiceImpl) DeactivateImagePathReservationByImageIds(imagePathReservationIds []int) error

+ func (impl *CustomTagServiceImpl) DeactivateImagePathReservationByImagePath(imagePaths []string) error

+ func (impl *CustomTagServiceImpl) DisableCustomTagIfExist(tag bean.CustomTag) error

+ func (impl *CustomTagServiceImpl) GetCustomTag(entityKey int, entityValue string) (*repository.CustomTag, string, error)

+ func (impl *CustomTagServiceImpl) ReserveImagePath(imagePath string, customTagId int) (*repository.ImagePathReservation, error)

+ type DevtronAppReleaseContextType struct

+ CancelContext context.CancelFunc

+ RunnerId int

+ type PipelineConfigListener interface

+ OnDeleteCdPipelineEvent func(pipelineId int, triggeredBy int32)

+ type PipelineConfigListenerService interface

+ HandleCdPipelineDelete func(pipelineId int, triggeredBy int32)

+ RegisterPipelineDeleteListener func(listener PipelineConfigListener)

+ type PipelineConfigListenerServiceImpl struct

+ func NewPipelineConfigListenerServiceImpl(logger *zap.SugaredLogger) *PipelineConfigListenerServiceImpl

+ func (impl *PipelineConfigListenerServiceImpl) HandleCdPipelineDelete(pipelineId int, triggeredBy int32)

+ func (impl *PipelineConfigListenerServiceImpl) RegisterPipelineDeleteListener(listener PipelineConfigListener)

+ type PluginInputVariableParser interface

+ HandleCopyContainerImagePluginInputVariables func(inputVariables []*bean.VariableObject, dockerImageTag string, ...) (registryDestinationImageMap map[string][]string, ...)

+ type PluginInputVariableParserImpl struct

+ func NewPluginInputVariableParserImpl(logger *zap.SugaredLogger, dockerRegistryConfig DockerRegistryConfig, ...) *PluginInputVariableParserImpl

+ func (impl *PluginInputVariableParserImpl) HandleCopyContainerImagePluginInputVariables(inputVariables []*bean.VariableObject, dockerImageTag string, ...) (registryDestinationImageMap map[string][]string, ...)

+ type RefPluginName = string

+ const COPY_CONTAINER_IMAGE

+ const EMPTY_STRING

+ type SwitchBuildPipelineValidationError string

type WorkflowDagExecutor

+ MarkCurrentDeploymentFailed func(runner *pipelineConfig.CdWorkflowRunner, releaseErr error, triggeredBy int32) error

+ MarkPipelineStatusTimelineFailed func(runner *pipelineConfig.CdWorkflowRunner, releaseErr error) error

+ OnDeleteCdPipelineEvent func(pipelineId int, triggeredBy int32)

+ UpdateTriggerCDMetricsOnFinish func(runner *pipelineConfig.CdWorkflowRunner)

+ UpdateWorkflowRunnerStatusForDeployment func(appIdentifier *client2.AppIdentifier, wfr *pipelineConfig.CdWorkflowRunner, ...) bool

type WorkflowDagExecutorImpl

+ func (impl *WorkflowDagExecutorImpl) HandleCDTriggerRelease(overrideRequest *bean.ValuesOverrideRequest, ctx context.Context, ...) (releaseNo int, manifest []byte, err error)

+ func (impl *WorkflowDagExecutorImpl) MarkCurrentDeploymentFailed(runner *pipelineConfig.CdWorkflowRunner, releaseErr error, triggeredBy int32) error

+ func (impl *WorkflowDagExecutorImpl) MarkPipelineStatusTimelineFailed(runner *pipelineConfig.CdWorkflowRunner, releaseErr error) error

+ func (impl *WorkflowDagExecutorImpl) OnDeleteCdPipelineEvent(pipelineId int, triggeredBy int32)

+ func (impl *WorkflowDagExecutorImpl) RemoveReleaseContextForPipeline(pipelineId int, triggeredBy int32)

+ func (impl *WorkflowDagExecutorImpl) ReserveImagesGeneratedAtPlugin(customTagId int, registryImageMap map[string][]string) ([]int, error)

+ func (impl *WorkflowDagExecutorImpl) SavePluginArtifacts(ciArtifact *repository.CiArtifact, pluginArtifactsDetail map[string][]string, ...) ([]*repository.CiArtifact, error)

+ func (impl *WorkflowDagExecutorImpl) SetCopyContainerImagePluginDataInWorkflowRequest(cdStageWorkflowRequest *types.WorkflowRequest, pipelineId int, ...) ([]int, error)

+ func (impl *WorkflowDagExecutorImpl) SubscribeDevtronAsyncHelmInstallRequest() error

+ func (impl *WorkflowDagExecutorImpl) TriggerHelmAsyncRelease(overrideRequest *bean.ValuesOverrideRequest, ctx context.Context, ...) (releaseNo int, manifest []byte, err error)

+ func (impl *WorkflowDagExecutorImpl) UpdateCDWorkflowRunnerStatus(ctx context.Context, overrideRequest *bean.ValuesOverrideRequest, ...) error

+ func (impl *WorkflowDagExecutorImpl) UpdatePreviousQueuedRunnerStatus(cdWfrId, pipelineId int, triggeredBy int32) error

+ func (impl *WorkflowDagExecutorImpl) UpdateReleaseContextForPipeline(pipelineId, cdWfrId int, cancel context.CancelFunc)

+ func (impl *WorkflowDagExecutorImpl) UpdateTriggerCDMetricsOnFinish(runner *pipelineConfig.CdWorkflowRunner)

+ func (impl *WorkflowDagExecutorImpl) UpdateWorkflowRunnerStatusForDeployment(appIdentifier *client2.AppIdentifier, wfr *pipelineConfig.CdWorkflowRunner, ...) bool

type WorkflowService

+ GetWorkflowStatus func(executorType pipelineConfig.WorkflowExecutorType, name string, ...) (*types.WorkflowStatus, error)

type WorkflowServiceImpl

+ func (impl *WorkflowServiceImpl) GetWorkflowStatus(executorType pipelineConfig.WorkflowExecutorType, name string, ...) (*types.WorkflowStatus, error)

Dec 7, 2023

Changes in this version

+ type BlobStorageConfigService interface

+ FetchCmAndSecretBlobConfigFromExternalCluster func(clusterConfig *k8s.ClusterConfig, namespace string) (*bean2.CmBlobStorageConfig, *bean2.SecretBlobStorageConfig, error)

+ type BlobStorageConfigServiceImpl struct

+ Logger *zap.SugaredLogger

+ func NewBlobStorageConfigServiceImpl(Logger *zap.SugaredLogger, k8sUtil *k8s.K8sUtil, ciCdConfig *types.CiCdConfig) *BlobStorageConfigServiceImpl

+ func (impl *BlobStorageConfigServiceImpl) FetchCmAndSecretBlobConfigFromExternalCluster(clusterConfig *k8s.ClusterConfig, namespace string) (*bean2.CmBlobStorageConfig, *bean2.SecretBlobStorageConfig, error)

+ type CustomTagService interface

+ CreateOrUpdateCustomTag func(tag *bean.CustomTag) error

+ DeactivateImagePathReservation func(id int) error

+ DeleteCustomTagIfExists func(tag bean.CustomTag) error

+ GenerateImagePath func(entityKey int, entityValue string, dockerRegistryURL string, dockerRepo string) (*repository.ImagePathReservation, error)

+ GetActiveCustomTagByEntityKeyAndValue func(entityKey int, entityValue string) (*repository.CustomTag, error)

+ GetCustomTagByEntityKeyAndValue func(entityKey int, entityValue string) (*repository.CustomTag, error)

+ type CustomTagServiceImpl struct

+ Logger *zap.SugaredLogger

+ func NewCustomTagService(logger *zap.SugaredLogger, customTagRepo repository.ImageTagRepository) *CustomTagServiceImpl

+ func (impl *CustomTagServiceImpl) CreateOrUpdateCustomTag(tag *bean.CustomTag) error

+ func (impl *CustomTagServiceImpl) DeactivateImagePathReservation(id int) error

+ func (impl *CustomTagServiceImpl) DeleteCustomTagIfExists(tag bean.CustomTag) error

+ func (impl *CustomTagServiceImpl) GenerateImagePath(entityKey int, entityValue string, dockerRegistryURL string, dockerRepo string) (*repository.ImagePathReservation, error)

+ func (impl *CustomTagServiceImpl) GetActiveCustomTagByEntityKeyAndValue(entityKey int, entityValue string) (*repository.CustomTag, error)

+ func (impl *CustomTagServiceImpl) GetCustomTagByEntityKeyAndValue(entityKey int, entityValue string) (*repository.CustomTag, error)

+ type EnvironmentOverride struct

+ Enabled bool

+ EnvValues []*KeyValue

+ type KeyValue struct

+ Key string

+ Value string

type WorkflowDagExecutorImpl

+ func (impl *WorkflowDagExecutorImpl) BuildManifestForTrigger(overrideRequest *bean.ValuesOverrideRequest, triggeredAt time.Time, ...) (valuesOverrideResponse *app.ValuesOverrideResponse, builtChartPath string, ...)

+ func (impl *WorkflowDagExecutorImpl) BuildManifestPushTemplate(overrideRequest *bean.ValuesOverrideRequest, ...) (*bean4.ManifestPushTemplate, error)

+ func (impl *WorkflowDagExecutorImpl) CreateHistoriesForDeploymentTrigger(pipeline *pipelineConfig.Pipeline, strategy *chartConfig.PipelineStrategy, ...) error

+ func (impl *WorkflowDagExecutorImpl) DeployApp(overrideRequest *bean.ValuesOverrideRequest, ...) error

+ func (impl *WorkflowDagExecutorImpl) DeployArgocdApp(overrideRequest *bean.ValuesOverrideRequest, ...) error

+ func (impl *WorkflowDagExecutorImpl) GetAppMetricsByTriggerType(overrideRequest *bean.ValuesOverrideRequest, ctx context.Context) (bool, error)

+ func (impl *WorkflowDagExecutorImpl) GetDeploymentStrategyByTriggerType(overrideRequest *bean.ValuesOverrideRequest, ctx context.Context) (*chartConfig.PipelineStrategy, error)

+ func (impl *WorkflowDagExecutorImpl) GetEnvOverrideByTriggerType(overrideRequest *bean.ValuesOverrideRequest, triggeredAt time.Time, ...) (*chartConfig.EnvConfigOverride, error)

+ func (impl *WorkflowDagExecutorImpl) GetManifestPushService(triggerEvent bean.TriggerEvent) app.ManifestPushService

+ func (impl *WorkflowDagExecutorImpl) GetTriggerEvent(deploymentAppType string, triggeredAt time.Time, deployedBy int32) bean.TriggerEvent

+ func (impl *WorkflowDagExecutorImpl) GetValuesOverrideForTrigger(overrideRequest *bean.ValuesOverrideRequest, triggeredAt time.Time, ...) (*app.ValuesOverrideResponse, error)

+ func (impl *WorkflowDagExecutorImpl) MarkImageScanDeployed(appId int, envId int, imageDigest string, clusterId int, isScanEnabled bool) error

+ func (impl *WorkflowDagExecutorImpl) SetPipelineFieldsInOverrideRequest(overrideRequest *bean.ValuesOverrideRequest, pipeline *pipelineConfig.Pipeline)

+ func (impl *WorkflowDagExecutorImpl) TriggerCD(artifact *repository.CiArtifact, cdWorkflowId, wfrId int, ...) error

+ func (impl *WorkflowDagExecutorImpl) TriggerPipeline(overrideRequest *bean.ValuesOverrideRequest, triggerEvent bean.TriggerEvent, ...) (releaseNo int, manifest []byte, err error)

+ func (impl *WorkflowDagExecutorImpl) TriggerRelease(overrideRequest *bean.ValuesOverrideRequest, ctx context.Context, ...) (releaseNo int, manifest []byte, err error)

+ func (impl *WorkflowDagExecutorImpl) ValidateTriggerEvent(triggerEvent bean.TriggerEvent) (bool, error)

+ func (impl *WorkflowDagExecutorImpl) WriteCDTriggerEvent(overrideRequest *bean.ValuesOverrideRequest, artifact *repository.CiArtifact, ...)

Oct 29, 2023

Changes in this version

+ const CdConfigType

+ const CiConfigType

+ const DEVTRON_WORKFLOW_LABEL_KEY

+ const DEVTRON_WORKFLOW_LABEL_VALUE

+ const POD_DELETED_MESSAGE

+ const RESOURCE_CREATE_ACTION

+ const S3_ENDPOINT_URL

+ const WORKFLOW_GENERATE_NAME_REGEX

+ const WORKFLOW_JOB_BACKOFF_LIMIT

+ const WORKFLOW_JOB_FINALIZER

+ var ACCESS_KEY_SELECTOR = &v12.SecretKeySelector

+ var SECRET_KEY_SELECTOR = &v12.SecretKeySelector

+ func CheckIfReTriggerRequired(status, message, workflowRunnerStatus string) bool

+ func GetClientInstance(config *rest.Config, namespace string) (v1alpha12.WorkflowInterface, error)

+ type AppArtifactManager interface

+ BuildArtifactsForCdStage func(pipelineId int, stageType bean.WorkflowType, ...) ([]bean2.CiArtifactBean, map[int]int, int, string, error)

+ BuildArtifactsForParentStage func(cdPipelineId int, parentId int, parentType bean.WorkflowType, ...) ([]bean2.CiArtifactBean, error)

+ FetchArtifactForRollback func(cdPipelineId, appId, offset, limit int) (bean2.CiArtifactResponse, error)

+ RetrieveArtifactsByCDPipeline func(pipeline *pipelineConfig.Pipeline, stage bean.WorkflowType) (*bean2.CiArtifactResponse, error)

+ type AppArtifactManagerImpl struct

+ func NewAppArtifactManagerImpl(logger *zap.SugaredLogger, ...) *AppArtifactManagerImpl

+ func (impl *AppArtifactManagerImpl) BuildArtifactsForCIParent(cdPipelineId int, parentId int, parentType bean.WorkflowType, ...) ([]bean2.CiArtifactBean, error)

+ func (impl *AppArtifactManagerImpl) BuildArtifactsForCdStage(pipelineId int, stageType bean.WorkflowType, ...) ([]bean2.CiArtifactBean, map[int]int, int, string, error)

+ func (impl *AppArtifactManagerImpl) BuildArtifactsForParentStage(cdPipelineId int, parentId int, parentType bean.WorkflowType, ...) ([]bean2.CiArtifactBean, error)

+ func (impl *AppArtifactManagerImpl) FetchArtifactForRollback(cdPipelineId, appId, offset, limit int) (bean2.CiArtifactResponse, error)

+ func (impl *AppArtifactManagerImpl) RetrieveArtifactsByCDPipeline(pipeline *pipelineConfig.Pipeline, stage bean.WorkflowType) (*bean2.CiArtifactResponse, error)

+ type AppDeploymentTypeChangeManager interface

+ ChangeDeploymentType func(ctx context.Context, request *bean.DeploymentAppTypeChangeRequest) (*bean.DeploymentAppTypeChangeResponse, error)

+ ChangePipelineDeploymentType func(ctx context.Context, request *bean.DeploymentAppTypeChangeRequest) (*bean.DeploymentAppTypeChangeResponse, error)

+ DeleteDeploymentApps func(ctx context.Context, pipelines []*pipelineConfig.Pipeline, userId int32) *bean.DeploymentAppTypeChangeResponse

+ DeleteDeploymentAppsForEnvironment func(ctx context.Context, environmentId int, ...) (*bean.DeploymentAppTypeChangeResponse, error)

+ TriggerDeploymentAfterTypeChange func(ctx context.Context, request *bean.DeploymentAppTypeChangeRequest) (*bean.DeploymentAppTypeChangeResponse, error)

+ type AppDeploymentTypeChangeManagerImpl struct

+ func NewAppDeploymentTypeChangeManagerImpl(logger *zap.SugaredLogger, ...) *AppDeploymentTypeChangeManagerImpl

+ func (impl *AppDeploymentTypeChangeManagerImpl) ChangeDeploymentType(ctx context.Context, request *bean.DeploymentAppTypeChangeRequest) (*bean.DeploymentAppTypeChangeResponse, error)

+ func (impl *AppDeploymentTypeChangeManagerImpl) ChangePipelineDeploymentType(ctx context.Context, request *bean.DeploymentAppTypeChangeRequest) (*bean.DeploymentAppTypeChangeResponse, error)

+ func (impl *AppDeploymentTypeChangeManagerImpl) DeleteDeploymentApps(ctx context.Context, pipelines []*pipelineConfig.Pipeline, userId int32) *bean.DeploymentAppTypeChangeResponse

+ func (impl *AppDeploymentTypeChangeManagerImpl) DeleteDeploymentAppsForEnvironment(ctx context.Context, environmentId int, ...) (*bean.DeploymentAppTypeChangeResponse, error)

+ func (impl *AppDeploymentTypeChangeManagerImpl) FetchDeletedApp(ctx context.Context, pipelines []*pipelineConfig.Pipeline) *bean.DeploymentAppTypeChangeResponse

+ func (impl *AppDeploymentTypeChangeManagerImpl) TriggerDeploymentAfterTypeChange(ctx context.Context, request *bean.DeploymentAppTypeChangeRequest) (*bean.DeploymentAppTypeChangeResponse, error)

type ArgoWorkflowExecutorImpl

+ func (impl *ArgoWorkflowExecutorImpl) TerminateWorkflow(workflowName string, namespace string, clusterConfig *rest.Config) error

+ type ArtifactsForCiJob struct

+ Artifacts []string

type CdHandler

+ HandleCdStageReTrigger func(runner *pipelineConfig.CdWorkflowRunner) error

type CdHandlerImpl

+ func (impl *CdHandlerImpl) HandleCdStageReTrigger(runner *pipelineConfig.CdWorkflowRunner) error

+ type CdPipelineConfigService interface

+ CreateCdPipelines func(cdPipelines *bean.CdPipelines, ctx context.Context) (*bean.CdPipelines, error)

+ CreateExternalCiAndAppWorkflowMapping func(appId, appWorkflowId int, userId int32, tx *pg.Tx) (int, error)

+ DeleteACDAppCdPipelineWithNonCascade func(pipeline *pipelineConfig.Pipeline, ctx context.Context, forceDelete bool, ...) (err error)

+ DeleteCdPipeline func(pipeline *pipelineConfig.Pipeline, ctx context.Context, deleteAction int, ...) (*bean.AppDeleteResponseDTO, error)

+ FindAppAndEnvDetailsByPipelineId func(cdPipelineId int) (*pipelineConfig.Pipeline, error)

+ FindPipelineById func(cdPipelineId int) (*pipelineConfig.Pipeline, error)

+ GetBulkActionImpactedPipelines func(dto *bean.CdBulkActionRequestDto) ([]*pipelineConfig.Pipeline, error)

+ GetCdPipelineById func(pipelineId int) (cdPipeline *bean.CDPipelineConfigObject, err error)

+ GetCdPipelinesByEnvironment func(request resourceGroup2.ResourceGroupingRequest) (cdPipelines *bean.CdPipelines, err error)

+ GetCdPipelinesByEnvironmentMin func(request resourceGroup2.ResourceGroupingRequest) (cdPipelines []*bean.CDPipelineConfigObject, err error)

+ GetCdPipelinesForApp func(appId int) (cdPipelines *bean.CdPipelines, err error)

+ GetCdPipelinesForAppAndEnv func(appId int, envId int) (cdPipelines *bean.CdPipelines, err error)

+ GetEnvironmentByCdPipelineId func(pipelineId int) (int, error)

+ GetEnvironmentListForAutocompleteFilter func(envName string, clusterIds []int, offset int, size int, emailId string, ...) (*cluster.ResourceGroupingResponse, error)

+ GetTriggerViewCdPipelinesForApp func(appId int) (cdPipelines *bean.CdPipelines, err error)

+ IsGitOpsRequiredForCD func(pipelineCreateRequest *bean.CdPipelines) bool

+ IsGitopsConfigured func() (bool, error)

+ MarkGitOpsDevtronAppsDeletedWhereArgoAppIsDeleted func(appId int, envId int, acdToken string, pipeline *pipelineConfig.Pipeline) (bool, error)

+ PatchCdPipelines func(cdPipelines *bean.CDPatchRequest, ctx context.Context) (*bean.CdPipelines, error)

+ PerformBulkActionOnCdPipelines func(dto *bean.CdBulkActionRequestDto, impactedPipelines []*pipelineConfig.Pipeline, ...) ([]*bean.CdBulkActionResponseDto, error)

+ RegisterInACD func(gitOpsRepoName string, chartGitAttr *util.ChartGitAttribute, userId int32, ...) error

+ RetrieveParentDetails func(pipelineId int) (parentId int, parentType bean2.WorkflowType, err error)

+ SetPipelineDeploymentAppType func(pipelineCreateRequest *bean.CdPipelines, isGitOpsConfigured bool, ...)

+ type CdPipelineConfigServiceImpl struct

+ func NewCdPipelineConfigServiceImpl(logger *zap.SugaredLogger, ...) *CdPipelineConfigServiceImpl

+ func (impl *CdPipelineConfigServiceImpl) BulkDeleteCdPipelines(impactedPipelines []*pipelineConfig.Pipeline, ctx context.Context, dryRun bool, ...) []*bean.CdBulkActionResponseDto

+ func (impl *CdPipelineConfigServiceImpl) CreateCdPipelines(pipelineCreateRequest *bean.CdPipelines, ctx context.Context) (*bean.CdPipelines, error)

+ func (impl *CdPipelineConfigServiceImpl) CreateExternalCiAndAppWorkflowMapping(appId, appWorkflowId int, userId int32, tx *pg.Tx) (int, error)

+ func (impl *CdPipelineConfigServiceImpl) DeleteACDAppCdPipelineWithNonCascade(pipeline *pipelineConfig.Pipeline, ctx context.Context, forceDelete bool, ...) error

+ func (impl *CdPipelineConfigServiceImpl) DeleteCdPipeline(pipeline *pipelineConfig.Pipeline, ctx context.Context, deleteAction int, ...) (*bean.AppDeleteResponseDTO, error)

+ func (impl *CdPipelineConfigServiceImpl) DeleteCdPipelinePartial(pipeline *pipelineConfig.Pipeline, ctx context.Context, deleteAction int, ...) (*bean.AppDeleteResponseDTO, error)

+ func (impl *CdPipelineConfigServiceImpl) FindAppAndEnvDetailsByPipelineId(cdPipelineId int) (*pipelineConfig.Pipeline, error)

+ func (impl *CdPipelineConfigServiceImpl) FindPipelineById(cdPipelineId int) (*pipelineConfig.Pipeline, error)

+ func (impl *CdPipelineConfigServiceImpl) GetBulkActionImpactedPipelines(dto *bean.CdBulkActionRequestDto) ([]*pipelineConfig.Pipeline, error)

+ func (impl *CdPipelineConfigServiceImpl) GetCdPipelineById(pipelineId int) (cdPipeline *bean.CDPipelineConfigObject, err error)

+ func (impl *CdPipelineConfigServiceImpl) GetCdPipelinesByEnvironment(request resourceGroup2.ResourceGroupingRequest) (cdPipelines *bean.CdPipelines, err error)

+ func (impl *CdPipelineConfigServiceImpl) GetCdPipelinesByEnvironmentMin(request resourceGroup2.ResourceGroupingRequest) (cdPipelines []*bean.CDPipelineConfigObject, err error)

+ func (impl *CdPipelineConfigServiceImpl) GetCdPipelinesForApp(appId int) (cdPipelines *bean.CdPipelines, err error)

+ func (impl *CdPipelineConfigServiceImpl) GetCdPipelinesForAppAndEnv(appId int, envId int) (cdPipelines *bean.CdPipelines, err error)

+ func (impl *CdPipelineConfigServiceImpl) GetEnvironmentByCdPipelineId(pipelineId int) (int, error)

+ func (impl *CdPipelineConfigServiceImpl) GetEnvironmentListForAutocompleteFilter(envName string, clusterIds []int, offset int, size int, emailId string, ...) (*cluster.ResourceGroupingResponse, error)

+ func (impl *CdPipelineConfigServiceImpl) GetTriggerViewCdPipelinesForApp(appId int) (cdPipelines *bean.CdPipelines, err error)

+ func (impl *CdPipelineConfigServiceImpl) IsGitOpsRequiredForCD(pipelineCreateRequest *bean.CdPipelines) bool

+ func (impl *CdPipelineConfigServiceImpl) IsGitopsConfigured() (bool, error)

+ func (impl *CdPipelineConfigServiceImpl) MarkGitOpsDevtronAppsDeletedWhereArgoAppIsDeleted(appId int, envId int, acdToken string, pipeline *pipelineConfig.Pipeline) (bool, error)

+ func (impl *CdPipelineConfigServiceImpl) PatchCdPipelines(cdPipelines *bean.CDPatchRequest, ctx context.Context) (*bean.CdPipelines, error)

+ func (impl *CdPipelineConfigServiceImpl) PerformBulkActionOnCdPipelines(dto *bean.CdBulkActionRequestDto, impactedPipelines []*pipelineConfig.Pipeline, ...) ([]*bean.CdBulkActionResponseDto, error)

+ func (impl *CdPipelineConfigServiceImpl) RegisterInACD(gitOpsRepoName string, chartGitAttr *util.ChartGitAttribute, userId int32, ...) error

+ func (impl *CdPipelineConfigServiceImpl) RetrieveParentDetails(pipelineId int) (parentId int, parentType bean2.WorkflowType, err error)

+ func (impl *CdPipelineConfigServiceImpl) SetPipelineDeploymentAppType(pipelineCreateRequest *bean.CdPipelines, isGitOpsConfigured bool, ...)

+ func (impl *CdPipelineConfigServiceImpl) ValidateCDPipelineRequest(pipelineCreateRequest *bean.CdPipelines, ...) (bool, error)

+ type CiCdConfig struct

+ AzureAccountKey string

+ AzureAccountName string

+ AzureBlobContainerCiCache string

+ AzureBlobContainerCiLog string

+ AzureGatewayConnectionInsecure bool

+ AzureGatewayUrl string

+ BaseLogLocationPath string

+ BlobStorageEnabled bool

+ BlobStorageGcpCredentialJson string

+ BlobStorageS3AccessKey string

+ BlobStorageS3BucketVersioned bool

+ BlobStorageS3Endpoint string

+ BlobStorageS3EndpointInsecure bool

+ BlobStorageS3SecretKey string

+ BuildLogTTLValue int

+ BuildPvcCachePath string

+ BuildxK8sDriverOptions string

+ BuildxProvenanceMode string

+ BuildxPvcCachePath string

+ CIAutoTriggerBatchSize int

+ CacheLimit int64

+ CdArtifactLocationFormat string

+ CdDefaultAddressPoolBaseCidr string

+ CdDefaultAddressPoolSize int

+ CdDefaultArtifactKeyPrefix string

+ CdDefaultBuildLogsBucket string

+ CdDefaultBuildLogsKeyPrefix string

+ CdDefaultCdLogsBucketRegion string

+ CdDefaultImage string

+ CdDefaultNamespace string

+ CdDefaultTimeout int64

+ CdLimitCpu string

+ CdLimitMem string

+ CdNodeLabelSelector []string

+ CdReqCpu string

+ CdReqMem string

+ CdTaintKey string

+ CdTaintValue string

+ CdWorkflowExecutorType pipelineConfig.WorkflowExecutorType

+ CdWorkflowServiceAccount string

+ CiArtifactLocationFormat string

+ CiDefaultAddressPoolBaseCidr string

+ CiDefaultAddressPoolSize int

+ CiDefaultArtifactKeyPrefix string

+ CiDefaultBuildLogsBucket string

+ CiDefaultBuildLogsKeyPrefix string

+ CiDefaultCdLogsBucketRegion string

+ CiDefaultImage string

+ CiDefaultNamespace string

+ CiDefaultTimeout int64

+ CiLimitCpu string

+ CiLimitMem string

+ CiLogsKeyPrefix string

+ CiNodeLabelSelector []string

+ CiReqCpu string

+ CiReqMem string

+ CiRunnerDockerMTUValue int

+ CiTaintKey string

+ CiTaintValue string

+ CiWorkflowExecutorType pipelineConfig.WorkflowExecutorType

+ CiWorkflowServiceAccount string

+ CloudProvider blob_storage.BlobStorageType

+ ClusterConfig *rest.Config

+ DefaultCacheBucket string

+ DefaultCacheBucketRegion string

+ DefaultPvcCachePath string

+ DefaultTargetPlatform string

+ EnableBuildContext bool

+ ExposeCDMetrics bool

+ ExternalCdNodeLabelSelector []string

+ ExternalCdTaintKey string

+ ExternalCdTaintValue string

+ ExternalCiApiSecret string

+ ExternalCiPayload string

+ ExternalCiWebhookUrl string

+ IgnoreDockerCacheForCI bool

+ ImageRetryCount int

+ ImageRetryInterval int

+ ImageScannerEndpoint string

+ InAppLoggingEnabled bool

+ MaxCdWorkflowRunnerRetries int

+ MaxCiWorkflowRetries int

+ Mode string

+ OrchestratorHost string

+ OrchestratorToken string

+ SkipCreatingEcrRepo bool

+ TerminationGracePeriod int

+ Type string

+ UseBlobStorageConfigInCdWorkflow bool

+ UseBlobStorageConfigInCiWorkflow bool

+ UseBuildx bool

+ UseExternalNode bool

+ VolumeMountsForCiJson string

+ WfControllerInstanceID string

+ func GetCiCdConfig() (*CiCdConfig, error)

+ func (impl *CiCdConfig) GetArtifactLocationFormat() string

+ func (impl *CiCdConfig) GetDefaultAddressPoolBaseCidr() string

+ func (impl *CiCdConfig) GetDefaultAddressPoolSize() int

+ func (impl *CiCdConfig) GetDefaultArtifactKeyPrefix() string

+ func (impl *CiCdConfig) GetDefaultBuildLogsBucket() string

+ func (impl *CiCdConfig) GetDefaultBuildLogsKeyPrefix() string

+ func (impl *CiCdConfig) GetDefaultCdLogsBucketRegion() string

+ func (impl *CiCdConfig) GetDefaultImage() string

+ func (impl *CiCdConfig) GetDefaultNamespace() string

+ func (impl *CiCdConfig) GetDefaultTimeout() int64

+ func (impl *CiCdConfig) GetLimitCpu() string

+ func (impl *CiCdConfig) GetLimitMem() string

+ func (impl *CiCdConfig) GetReqCpu() string

+ func (impl *CiCdConfig) GetReqMem() string

+ func (impl *CiCdConfig) GetTaintKey() string

+ func (impl *CiCdConfig) GetTaintValue() string

+ func (impl *CiCdConfig) GetWorkflowExecutorType() pipelineConfig.WorkflowExecutorType

+ func (impl *CiCdConfig) GetWorkflowServiceAccount() string

+ func (impl *CiCdConfig) GetWorkflowVolumeAndVolumeMounts() ([]v12.Volume, []v12.VolumeMount, error)

+ func (impl *CiCdConfig) WorkflowRetriesEnabled() bool

type CiCdPipelineOrchestrator

+ PatchCiMaterialSourceValue func(patchRequest *bean.CiMaterialValuePatchRequest, userId int32, value string, ...) (*pipelineConfig.CiPipelineMaterial, error)

+ UpdateCiPipelineMaterials func(materialsUpdate []*pipelineConfig.CiPipelineMaterial) error

type CiCdPipelineOrchestratorImpl

+ func (impl CiCdPipelineOrchestratorImpl) PatchCiMaterialSourceValue(patchRequest *bean.CiMaterialValuePatchRequest, userId int32, value string, ...) (*pipelineConfig.CiPipelineMaterial, error)

+ func (impl CiCdPipelineOrchestratorImpl) UpdateCiPipelineMaterials(materialsUpdate []*pipelineConfig.CiPipelineMaterial) error

type CiCdTriggerEvent

+ CommonWorkflowRequest *WorkflowRequest

type CiHandler

+ CheckAndReTriggerCI func(workflowStatus v1alpha1.WorkflowStatus) error

+ FetchArtifactsForCiJob func(buildId int) (*ArtifactsForCiJob, error)

type CiHandlerImpl

+ func (impl *CiHandlerImpl) CheckAndReTriggerCI(workflowStatus v1alpha1.WorkflowStatus) error

+ func (impl *CiHandlerImpl) FetchArtifactsForCiJob(buildId int) (*ArtifactsForCiJob, error)

+ type CiMaterialConfigService interface

+ BulkPatchCiMaterialSource func(ciPipelines *bean.CiMaterialBulkPatchRequest, userId int32, token string, ...) (*bean.CiMaterialBulkPatchResponse, error)

+ CreateMaterialsForApp func(request *bean.CreateMaterialDTO) (*bean.CreateMaterialDTO, error)

+ DeleteMaterial func(request *bean.UpdateMaterialDTO) error

+ GetMaterialsForAppId func(appId int) []*bean.GitMaterial

+ PatchCiMaterialSource func(ciPipeline *bean.CiMaterialPatchRequest, userId int32) (*bean.CiMaterialPatchRequest, error)

+ UpdateMaterialsForApp func(request *bean.UpdateMaterialDTO) (*bean.UpdateMaterialDTO, error)

+ type CiMaterialConfigServiceImpl struct

+ func NewCiMaterialConfigServiceImpl(logger *zap.SugaredLogger, materialRepo pipelineConfig.MaterialRepository, ...) *CiMaterialConfigServiceImpl

+ func (impl *CiMaterialConfigServiceImpl) BulkPatchCiMaterialSource(ciPipelines *bean.CiMaterialBulkPatchRequest, userId int32, token string, ...) (*bean.CiMaterialBulkPatchResponse, error)

+ func (impl *CiMaterialConfigServiceImpl) CreateMaterialsForApp(request *bean.CreateMaterialDTO) (*bean.CreateMaterialDTO, error)

+ func (impl *CiMaterialConfigServiceImpl) DeleteMaterial(request *bean.UpdateMaterialDTO) error

+ func (impl *CiMaterialConfigServiceImpl) GetMaterialsForAppId(appId int) []*bean.GitMaterial

+ func (impl *CiMaterialConfigServiceImpl) PatchCiMaterialSource(ciPipeline *bean.CiMaterialPatchRequest, userId int32) (*bean.CiMaterialPatchRequest, error)

+ func (impl *CiMaterialConfigServiceImpl) UpdateMaterialsForApp(request *bean.UpdateMaterialDTO) (*bean.UpdateMaterialDTO, error)

+ type CiPipelineConfigService interface

+ CreateCiPipeline func(createRequest *bean.CiConfigRequest) (*bean.PipelineCreateResponse, error)

+ DeleteCiPipeline func(request *bean.CiPatchRequest) (*bean.CiPipeline, error)

+ GetCiPipeline func(appId int) (ciConfig *bean.CiConfigRequest, err error)

+ GetCiPipelineByEnvironment func(request resourceGroup2.ResourceGroupingRequest) ([]*bean.CiConfigRequest, error)

+ GetCiPipelineByEnvironmentMin func(request resourceGroup2.ResourceGroupingRequest) ([]*bean.CiPipelineMinResponse, error)

+ GetCiPipelineById func(pipelineId int) (ciPipeline *bean.CiPipeline, err error)

+ GetCiPipelineMin func(appId int, envIds []int) ([]*bean.CiPipelineMin, error)

+ GetExternalCi func(appId int) (ciConfig []*bean.ExternalCiConfig, err error)

+ GetExternalCiByEnvironment func(request resourceGroup2.ResourceGroupingRequest) (ciConfig []*bean.ExternalCiConfig, err error)

+ GetExternalCiById func(appId int, externalCiId int) (ciConfig *bean.ExternalCiConfig, err error)

+ GetTriggerViewCiPipeline func(appId int) (*bean.TriggerViewCiConfig, error)

+ PatchCiPipeline func(request *bean.CiPatchRequest) (ciConfig *bean.CiConfigRequest, err error)

+ PatchRegexCiPipeline func(request *bean.CiRegexPatchRequest) (err error)

+ UpdateCiTemplate func(updateRequest *bean.CiConfigRequest) (*bean.CiConfigRequest, error)

+ type CiPipelineConfigServiceImpl struct

+ CiTemplateHistoryService history.CiTemplateHistoryService

+ func NewCiPipelineConfigServiceImpl(logger *zap.SugaredLogger, ciCdPipelineOrchestrator CiCdPipelineOrchestrator, ...) *CiPipelineConfigServiceImpl

+ func (impl *CiPipelineConfigServiceImpl) CreateCiPipeline(createRequest *bean.CiConfigRequest) (*bean.PipelineCreateResponse, error)

+ func (impl *CiPipelineConfigServiceImpl) DeleteCiPipeline(request *bean.CiPatchRequest) (*bean.CiPipeline, error)

+ func (impl *CiPipelineConfigServiceImpl) GetCiPipeline(appId int) (ciConfig *bean.CiConfigRequest, err error)

+ func (impl *CiPipelineConfigServiceImpl) GetCiPipelineByEnvironment(request resourceGroup2.ResourceGroupingRequest) ([]*bean.CiConfigRequest, error)

+ func (impl *CiPipelineConfigServiceImpl) GetCiPipelineByEnvironmentMin(request resourceGroup2.ResourceGroupingRequest) ([]*bean.CiPipelineMinResponse, error)

+ func (impl *CiPipelineConfigServiceImpl) GetCiPipelineById(pipelineId int) (ciPipeline *bean.CiPipeline, err error)

+ func (impl *CiPipelineConfigServiceImpl) GetCiPipelineMin(appId int, envIds []int) ([]*bean.CiPipelineMin, error)

+ func (impl *CiPipelineConfigServiceImpl) GetExternalCi(appId int) (ciConfig []*bean.ExternalCiConfig, err error)

+ func (impl *CiPipelineConfigServiceImpl) GetExternalCiByEnvironment(request resourceGroup2.ResourceGroupingRequest) (ciConfig []*bean.ExternalCiConfig, err error)

+ func (impl *CiPipelineConfigServiceImpl) GetExternalCiById(appId int, externalCiId int) (ciConfig *bean.ExternalCiConfig, err error)

+ func (impl *CiPipelineConfigServiceImpl) GetTriggerViewCiPipeline(appId int) (*bean.TriggerViewCiConfig, error)

+ func (impl *CiPipelineConfigServiceImpl) PatchCiPipeline(request *bean.CiPatchRequest) (ciConfig *bean.CiConfigRequest, err error)

+ func (impl *CiPipelineConfigServiceImpl) PatchRegexCiPipeline(request *bean.CiRegexPatchRequest) (err error)

+ func (impl *CiPipelineConfigServiceImpl) UpdateCiTemplate(updateRequest *bean.CiConfigRequest) (*bean.CiConfigRequest, error)

+ type DevtronAppCMCSService interface

+ FetchConfigmapSecretsForCdStages func(appId, envId, cdPipelineId int) (ConfigMapSecretsResponse, error)

+ GetDeploymentConfigMap func(environmentId int) (map[string]bool, error)

+ type DevtronAppCMCSServiceImpl struct

+ func NewDevtronAppCMCSServiceImpl(logger *zap.SugaredLogger, appService app.AppService, ...) *DevtronAppCMCSServiceImpl

+ func (impl *DevtronAppCMCSServiceImpl) FetchConfigmapSecretsForCdStages(appId, envId, cdPipelineId int) (ConfigMapSecretsResponse, error)

+ func (impl *DevtronAppCMCSServiceImpl) GetDeploymentConfigMap(environmentId int) (map[string]bool, error)

+ type DevtronAppConfigService interface

+ CreateApp func(request *bean.CreateAppDTO) (*bean.CreateAppDTO, error)

+ DeleteApp func(appId int, userId int32) error

+ FindAllMatchesByAppName func(appName string, appType helper.AppType) ([]*AppBean, error)

+ FindAppsByTeamId func(teamId int) ([]*AppBean, error)

+ FindAppsByTeamName func(teamName string) ([]AppBean, error)

+ FindByIds func(ids []*int) ([]*AppBean, error)

+ GetApp func(appId int) (application *bean.CreateAppDTO, err error)

+ GetAppList func() ([]AppBean, error)

+ GetAppListForEnvironment func(request resourceGroup.ResourceGroupingRequest) ([]*AppBean, error)

+ type DevtronAppConfigServiceImpl struct

+ func NewDevtronAppConfigServiceImpl(logger *zap.SugaredLogger, ciCdPipelineOrchestrator CiCdPipelineOrchestrator, ...) *DevtronAppConfigServiceImpl

+ func (impl *DevtronAppConfigServiceImpl) CreateApp(request *bean.CreateAppDTO) (*bean.CreateAppDTO, error)

+ func (impl *DevtronAppConfigServiceImpl) DeleteApp(appId int, userId int32) error

+ func (impl *DevtronAppConfigServiceImpl) FindAllMatchesByAppName(appName string, appType helper.AppType) ([]*AppBean, error)

+ func (impl *DevtronAppConfigServiceImpl) FindAppsByTeamId(teamId int) ([]*AppBean, error)

+ func (impl *DevtronAppConfigServiceImpl) FindAppsByTeamName(teamName string) ([]AppBean, error)

+ func (impl *DevtronAppConfigServiceImpl) FindByIds(ids []*int) ([]*AppBean, error)

+ func (impl *DevtronAppConfigServiceImpl) GetApp(appId int) (application *bean.CreateAppDTO, err error)

+ func (impl *DevtronAppConfigServiceImpl) GetAppList() ([]AppBean, error)

+ func (impl *DevtronAppConfigServiceImpl) GetAppListForEnvironment(request resourceGroup.ResourceGroupingRequest) ([]*AppBean, error)

+ type DevtronAppStrategyService interface

+ FetchCDPipelineStrategy func(appId int) (PipelineStrategiesResponse, error)

+ FetchDefaultCDPipelineStrategy func(appId int, envId int) (PipelineStrategy, error)

+ type DevtronAppStrategyServiceImpl struct

+ func NewDevtronAppStrategyServiceImpl(logger *zap.SugaredLogger, chartRepository chartRepoRepository.ChartRepository, ...) *DevtronAppStrategyServiceImpl

+ func (impl *DevtronAppStrategyServiceImpl) FetchCDPipelineStrategy(appId int) (PipelineStrategiesResponse, error)

+ func (impl *DevtronAppStrategyServiceImpl) FetchDefaultCDPipelineStrategy(appId int, envId int) (PipelineStrategy, error)

type PipelineStageService

+ GetCdStageByCdPipelineIdAndStageType func(cdPipelineId int, stageType repository.PipelineStageType) (*repository.PipelineStage, error)

type PipelineStageServiceImpl

+ func (impl *PipelineStageServiceImpl) GetCdStageByCdPipelineIdAndStageType(cdPipelineId int, stageType repository.PipelineStageType) (*repository.PipelineStage, error)

+ type SystemWorkflowExecutor interface

+ type SystemWorkflowExecutorImpl struct

+ func NewSystemWorkflowExecutorImpl(logger *zap.SugaredLogger, k8sUtil *k8s.K8sUtil) *SystemWorkflowExecutorImpl

+ func (impl *SystemWorkflowExecutorImpl) ExecuteWorkflow(workflowTemplate bean.WorkflowTemplate) (*unstructured.UnstructuredList, error)

+ func (impl *SystemWorkflowExecutorImpl) TerminateWorkflow(workflowName string, namespace string, clusterConfig *rest.Config) error

type Trigger

+ CiArtifactLastFetch time.Time

+ PipelineType string

+ ReferenceCiWorkflowId int

+ func (obj Trigger) BuildTriggerObject(refCiWorkflow *pipelineConfig.CiWorkflow, ...)

type WebhookService

+ HandleMultipleImagesFromEvent func(imageDetails []types.ImageDetail, ciWorkflowId int) (map[string]*pipelineConfig.CiWorkflow, error)

type WebhookServiceImpl

+ func (impl *WebhookServiceImpl) HandleMultipleImagesFromEvent(imageDetails []types.ImageDetail, ciWorkflowId int) (map[string]*pipelineConfig.CiWorkflow, error)

type WorkflowDagExecutor

+ TriggerPreStage func(ctx context.Context, cdWf *pipelineConfig.CdWorkflow, ...) error

type WorkflowExecutor

+ TerminateWorkflow func(workflowName string, namespace string, clusterConfig *rest.Config) error

type WorkflowRequest

+ AppLabels map[string]string

+ ArtifactLocation string

+ CdCacheLocation string

+ CdCacheRegion string

+ CdImage string

+ CdPipelineId int

+ CiArtifactDTO CiArtifactDTO

+ CiArtifactLastFetch time.Time

+ DeploymentReleaseCounter int

+ DeploymentTriggerTime time.Time

+ DeploymentTriggeredBy string

+ Env *repository2.Environment

+ Pipeline *pipelineConfig.Pipeline

+ PrePostDeploySteps []*bean.StepObject

+ StageType string

+ StageYaml string

+ Type bean.WorkflowPipelineType

+ WorkflowExecutor pipelineConfig.WorkflowExecutorType

+ WorkflowPrefixForLog string

+ WorkflowRunnerId int

+ func (workflowRequest *WorkflowRequest) AddNodeConstraintsFromConfig(workflowTemplate *bean.WorkflowTemplate, config *CiCdConfig)

+ func (workflowRequest *WorkflowRequest) CheckBlobStorageConfig(config *CiCdConfig) bool

+ func (workflowRequest *WorkflowRequest) CheckForJob() bool

+ func (workflowRequest *WorkflowRequest) GetBlobStorageLogsKey(config *CiCdConfig) string

+ func (workflowRequest *WorkflowRequest) GetConfiguredCmCs() (map[string]bool, map[string]bool, error)

+ func (workflowRequest *WorkflowRequest) GetEventTypeForWorkflowRequest() string

+ func (workflowRequest *WorkflowRequest) GetExistingCmCsNamePrefix() string

+ func (workflowRequest *WorkflowRequest) GetGlobalCmCsNamePrefix() string

+ func (workflowRequest *WorkflowRequest) GetLimitReqCpuMem(config *CiCdConfig) v12.ResourceRequirements

+ func (workflowRequest *WorkflowRequest) GetNodeConstraints(config *CiCdConfig) *bean.NodeConstraints

+ func (workflowRequest *WorkflowRequest) GetWorkflowJson(config *CiCdConfig) ([]byte, error)

+ func (workflowRequest *WorkflowRequest) GetWorkflowMainContainer(config *CiCdConfig, workflowJson []byte, ...) (v12.Container, error)

+ func (workflowRequest *WorkflowRequest) GetWorkflowTemplate(workflowJson []byte, config *CiCdConfig) bean.WorkflowTemplate

+ func (workflowRequest *WorkflowRequest) GetWorkflowTypeForWorkflowRequest() string

type WorkflowResponse

+ PipelineType string

+ ReferenceWorkflowId int

Oct 20, 2023

Changes in this version

type CdConfig

+ ExternalNodeLabel map[string]string

+ ExternalNodeLabelSelector []string

+ ExternalTaintKey string

+ ExternalTaintValue string

+ UseExternalNode bool

type CiConfig

+ BuildxProvenanceMode string

+ type DisabledFields string

+ const DISABLED_CHART_PULL

+ const DISABLED_CONTAINER

type DockerArtifactStoreBean

+ DisabledFields []DisabledFields

+ IsPublic bool

+ RepositoryList []string

type DockerRegistryConfig

+ ValidateRegistryCredentials func(bean *DockerArtifactStoreBean) bool

type DockerRegistryConfigImpl

+ func (impl DockerRegistryConfigImpl) ValidateRegistryCredentials(bean *DockerArtifactStoreBean) bool

type DockerRegistryIpsConfigBean

+ Active bool

type PipelineStageService

+ DeletePipelineStageIfReq func(stageReq *bean.PipelineStageDto, userId int32) (error, bool)

type PipelineStageServiceImpl

+ func (impl *PipelineStageServiceImpl) DeletePipelineStageIfReq(stageReq *bean.PipelineStageDto, userId int32) (error, bool)

Sep 14, 2023

Changes in this version

type ConfigMapService

+ CMEnvironmentFetchForEdit func(name string, id int, appId int, envId int) (*bean.ConfigDataRequest, error)

+ CMGlobalFetchForEdit func(name string, id int) (*bean.ConfigDataRequest, error)

type ConfigMapServiceImpl

+ func (impl ConfigMapServiceImpl) CMEnvironmentFetchForEdit(name string, id int, appId int, envId int) (*bean.ConfigDataRequest, error)

+ func (impl ConfigMapServiceImpl) CMGlobalFetchForEdit(name string, id int) (*bean.ConfigDataRequest, error)

Aug 23, 2023

Changes in this version

+ const APP_LABEL_METADATA

+ const APP_NAME

+ const CD_TRIGGERED_BY

+ const CD_TRIGGER_TIME

+ const CHILD_CD_METADATA

+ const DEPLOYMENT_RELEASE_ID

+ const DEPLOYMENT_UNIQUE_ID

+ const DEVTRON_CD_TRIGGERED_BY

+ const DEVTRON_CD_TRIGGER_TIME

+ const DOCKER_IMAGE

+ const GIT_METADATA

+ func ConvertStageYamlScriptsToPipelineStageSteps(cdPipeline *bean2.CDPipelineConfigObject) (*bean2.CDPipelineConfigObject, error)

+ func CreatePreAndPostStageResponse(cdPipeline *bean2.CDPipelineConfigObject, version string) (*bean2.CDPipelineConfigObject, error)

+ func StageStepsToCdStageAdapter(deployStage *bean.PipelineStageDto) (*bean2.CdStage, error)

+ func StageYamlToPipelineStageAdapter(stageConfig string, stageType repository2.PipelineStageType, ...) (*bean.PipelineStageDto, error)

+ type AppLabelMetadata struct

+ AppLabelKey string

+ AppLabelValue string

+ type CdPipelineConfig struct

+ AfterTasks []*Task

+ BeforeTasks []*Task

type CdWorkflowRequest

+ PrePostDeploySteps []*bean3.StepObject

+ RefPlugins []*bean3.RefPluginObject

+ type ChildCdMetadata struct

+ ChildCdClusterName string

+ ChildCdEnvName string

type CiCdPipelineOrchestrator

+ PatchCiMaterialSource func(ciPipeline *bean.CiMaterialPatchRequest, userId int32) (*bean.CiMaterialPatchRequest, error)

type CiCdPipelineOrchestratorImpl

+ func (impl CiCdPipelineOrchestratorImpl) PatchCiMaterialSource(patchRequest *bean.CiMaterialPatchRequest, userId int32) (*bean.CiMaterialPatchRequest, error)

type CiConfig

+ BuildxK8sDriverOptions string

+ OrchestratorHost string

+ OrchestratorToken string

type ConfigMapService

+ ConfigSecretEnvironmentClone func(appId int, cloneAppId int, userId int32) ([]chartConfig.ConfigMapEnvModel, error)

+ ConfigSecretEnvironmentCreate func(createJobEnvOverrideRequest *CreateJobEnvOverridePayload) (*CreateJobEnvOverridePayload, error)

+ ConfigSecretEnvironmentDelete func(createJobEnvOverrideRequest *CreateJobEnvOverridePayload) (*CreateJobEnvOverridePayload, error)

+ ConfigSecretEnvironmentGet func(appId int) ([]JobEnvOverrideResponse, error)

type ConfigMapServiceImpl

+ func (impl ConfigMapServiceImpl) ConfigSecretEnvironmentClone(appId int, cloneAppId int, userId int32) ([]chartConfig.ConfigMapEnvModel, error)

+ func (impl ConfigMapServiceImpl) ConfigSecretEnvironmentCreate(createJobEnvOverrideRequest *CreateJobEnvOverridePayload) (*CreateJobEnvOverridePayload, error)

+ func (impl ConfigMapServiceImpl) ConfigSecretEnvironmentDelete(createJobEnvOverrideRequest *CreateJobEnvOverridePayload) (*CreateJobEnvOverridePayload, error)

+ func (impl ConfigMapServiceImpl) ConfigSecretEnvironmentGet(appId int) ([]JobEnvOverrideResponse, error)

+ type CreateJobEnvOverridePayload struct

+ AppId int

+ EnvId int

+ UserId int32

+ type GitMetadata struct

+ GitCommitHash string

+ GitSourceType string

+ GitSourceValue string

+ type JobEnvOverrideResponse struct

+ AppId int

+ EnvironmentId int

+ EnvironmentName string

+ Id int

type PipelineBuilder

+ PatchCiMaterialSource func(ciPipeline *bean.CiMaterialPatchRequest, userId int32) (*bean.CiMaterialPatchRequest, error)

type PipelineBuilderImpl

+ func (impl *PipelineBuilderImpl) PatchCiMaterialSource(ciPipeline *bean.CiMaterialPatchRequest, userId int32) (*bean.CiMaterialPatchRequest, error)

type PipelineStageService

+ CreatePipelineStage func(stageReq *bean.PipelineStageDto, stageType repository.PipelineStageType, ...) error

+ DeletePipelineStage func(stageReq *bean.PipelineStageDto, userId int32, tx *pg.Tx) error

+ GetCdPipelineStageDataDeepCopy func(cdPipelineId int) (*bean.PipelineStageDto, *bean.PipelineStageDto, error)

+ GetCdPipelineStageDataDeepCopyForPipelineIds func(cdPipelineIds []int) (map[int][]*bean.PipelineStageDto, error)

+ UpdatePipelineStage func(stageReq *bean.PipelineStageDto, stageType repository.PipelineStageType, ...) error

type PipelineStageServiceImpl

+ func (impl *PipelineStageServiceImpl) BuildPipelineStageDataDeepCopy(pipelineStage *repository.PipelineStage) (*bean.PipelineStageDto, error)

+ func (impl *PipelineStageServiceImpl) BuildPipelineStageDataForWfRequest(pipelineStage *repository.PipelineStage) ([]*bean.StepObject, []int, error)

+ func (impl *PipelineStageServiceImpl) BuildPipelineStepDataForWfRequest(step *repository.PipelineStageStep) (*bean.StepObject, error)

+ func (impl *PipelineStageServiceImpl) CreatePipelineStage(stageReq *bean.PipelineStageDto, stageType repository.PipelineStageType, ...) error

+ func (impl *PipelineStageServiceImpl) DeletePipelineStage(stageReq *bean.PipelineStageDto, userId int32, tx *pg.Tx) error

+ func (impl *PipelineStageServiceImpl) FilterAndActOnStepsInPipelineStageUpdateRequest(stageReq *bean.PipelineStageDto, userId int32) error

+ func (impl *PipelineStageServiceImpl) GetCdPipelineStageDataDeepCopy(cdPipelineId int) (*bean.PipelineStageDto, *bean.PipelineStageDto, error)

+ func (impl *PipelineStageServiceImpl) GetCdPipelineStageDataDeepCopyForPipelineIds(cdPipelineIds []int) (map[int][]*bean.PipelineStageDto, error)

+ func (impl *PipelineStageServiceImpl) UpdatePipelineStage(stageReq *bean.PipelineStageDto, stageType repository.PipelineStageType, ...) error

type PropertiesConfigService

+ FetchEnvProperties func(appId, envId, chartRefId int) (*chartConfig.EnvConfigOverride, error)

+ FindEnvLevelAppMetricsByAppIdAndEnvId func(appId int, envId int) (*repository.EnvLevelAppMetrics, error)

type PropertiesConfigServiceImpl

+ func (impl PropertiesConfigServiceImpl) FetchEnvProperties(appId, envId, chartRefId int) (*chartConfig.EnvConfigOverride, error)

+ func (impl PropertiesConfigServiceImpl) FindEnvLevelAppMetricsByAppIdAndEnvId(appId int, envId int) (*repository.EnvLevelAppMetrics, error)

+ type Task struct

+ Id int

+ Index int

+ Name string

+ OutputLocation string

+ RunStatus bool

+ Script string

+ type TaskYaml struct

+ CdPipelineConfig []CdPipelineConfig

+ Version string

+ func ToTaskYaml(yamlFile []byte) (*TaskYaml, error)

type Trigger

+ EnvironmentId int

type WorkflowRequest

+ AppId int

+ EnvironmentId int

+ IsExtRun bool

+ OrchestratorHost string

+ OrchestratorToken string

type WorkflowResponse

+ EnvironmentId int

+ EnvironmentName string

Jul 17, 2023

Changes in this version

+ const CommentKey

+ const DuplicateTagsInAppError

+ const TagsKey

+ type ArtifactStoreType int

type CiConfig

+ DefaultTargetPlatform string

+ ImageRetryCount int

+ ImageRetryInterval int

+ UseBuildx bool

type DockerArtifactStoreBean

+ IsOCICompliantRegistry bool

+ OCIRegistryConfig map[string]string

type DockerRegistryConfig

+ ConfigureOCIRegistry func(dockerRegistryId string, ociRegistryConfigBean map[string]string, ...) error

+ CreateOrUpdateOCIRegistryConfig func(ociRegistryConfig *repository.OCIRegistryConfig, userId int32, tx *pg.Tx) error

+ FilterOCIRegistryConfigForSpecificRepoType func(ociRegistryConfigList []*repository.OCIRegistryConfig, repositoryType string) *repository.OCIRegistryConfig

+ FilterRegistryBeanListBasedOnStorageTypeAndAction func(bean []DockerArtifactStoreBean, storageType string, actionTypes ...string) []DockerArtifactStoreBean

+ ValidateRegistryStorageType func(registryId string, storageType string, storageActions ...string) bool

type DockerRegistryConfigImpl

+ func (impl DockerRegistryConfigImpl) ConfigureOCIRegistry(dockerRegistryId string, ociRegistryConfigBean map[string]string, ...) error

+ func (impl DockerRegistryConfigImpl) CreateOrUpdateOCIRegistryConfig(ociRegistryConfig *repository.OCIRegistryConfig, userId int32, tx *pg.Tx) error

+ func (impl DockerRegistryConfigImpl) FilterOCIRegistryConfigForSpecificRepoType(ociRegistryConfigList []*repository.OCIRegistryConfig, repositoryType string) *repository.OCIRegistryConfig

+ func (impl DockerRegistryConfigImpl) FilterRegistryBeanListBasedOnStorageTypeAndAction(bean []DockerArtifactStoreBean, storageType string, actionTypes ...string) []DockerArtifactStoreBean

+ func (impl DockerRegistryConfigImpl) PopulateOCIRegistryConfig(store *repository.DockerArtifactStore) map[string]string

+ func (impl DockerRegistryConfigImpl) ValidateRegistryStorageType(registryId string, storageType string, storageActions ...string) bool

type GitTriggerInfoResponse

+ Image string

+ ImageTaggingData ImageTaggingResponseDTO

+ type ImageTaggingRequestDTO struct

+ CreateTags []*repository.ImageTag

+ ExternalCi bool

+ HardDeleteTags []*repository.ImageTag

+ ImageComment repository.ImageComment

+ SoftDeleteTags []*repository.ImageTag

+ type ImageTaggingResponseDTO struct

+ AppReleaseTags []string

+ HideImageTaggingHardDelete bool

+ ImageComment *repository.ImageComment

+ ImageReleaseTags []*repository.ImageTag

+ ProdEnvExists bool

+ type ImageTaggingService interface

+ CreateOrUpdateImageTagging func(ciPipelineId, appId, artifactId, userId int, ...) (*ImageTaggingResponseDTO, error)

+ FindProdEnvExists func(externalCi bool, pipelineIds []int) (bool, error)

+ GetImageCommentsDataMapByArtifactIds func(artifactIds []int) (map[int]*repository.ImageComment, error)

+ GetImageTaggingServiceConfig func() ImageTaggingServiceConfig

+ GetProdEnvByCdPipelineId func(pipelineId int) (bool, error)

+ GetProdEnvFromParentAndLinkedWorkflow func(ciPipelineId int) (bool, error)

+ GetTagsByArtifactId func(artifactId int) ([]*repository.ImageTag, error)

+ GetTagsData func(ciPipelineId, appId, artifactId int, externalCi bool) (*ImageTaggingResponseDTO, error)

+ GetTagsDataMapByAppId func(appId int) (map[int][]*repository.ImageTag, error)

+ GetUniqueTagsByAppId func(appId int) ([]string, error)

+ ValidateImageTaggingRequest func(imageTaggingRequest *ImageTaggingRequestDTO, appId, artifactId int) (bool, error)

+ type ImageTaggingServiceConfig struct

+ HideImageTaggingHardDelete bool

+ type ImageTaggingServiceImpl struct

+ func NewImageTaggingServiceImpl(imageTaggingRepo repository.ImageTaggingRepository, ...) *ImageTaggingServiceImpl

+ func (impl ImageTaggingServiceImpl) CreateOrUpdateImageTagging(ciPipelineId, appId, artifactId, userId int, ...) (*ImageTaggingResponseDTO, error)

+ func (impl ImageTaggingServiceImpl) FindProdEnvExists(externalCi bool, pipelineIds []int) (bool, error)

+ func (impl ImageTaggingServiceImpl) GetImageCommentsDataMapByArtifactIds(artifactIds []int) (map[int]*repository.ImageComment, error)

+ func (impl ImageTaggingServiceImpl) GetImageTaggingServiceConfig() ImageTaggingServiceConfig

+ func (impl ImageTaggingServiceImpl) GetProdEnvByCdPipelineId(pipelineId int) (bool, error)

+ func (impl ImageTaggingServiceImpl) GetProdEnvFromParentAndLinkedWorkflow(ciPipelineId int) (bool, error)

+ func (impl ImageTaggingServiceImpl) GetTagsByArtifactId(artifactId int) ([]*repository.ImageTag, error)

+ func (impl ImageTaggingServiceImpl) GetTagsData(ciPipelineId, appId, artifactId int, externalCi bool) (*ImageTaggingResponseDTO, error)

+ func (impl ImageTaggingServiceImpl) GetTagsDataMapByAppId(appId int) (map[int][]*repository.ImageTag, error)

+ func (impl ImageTaggingServiceImpl) GetUniqueTagsByAppId(appId int) ([]string, error)

+ func (impl ImageTaggingServiceImpl) ValidateImageTaggingRequest(imageTaggingRequest *ImageTaggingRequestDTO, appId, artifactId int) (bool, error)

type PipelineBuilder

+ GetDeploymentConfigMap func(environmentId int) (map[string]bool, error)

+ IsGitopsConfigured func() (bool, error)

type PipelineBuilderImpl

+ func (impl PipelineBuilderImpl) GetDeploymentConfigMap(environmentId int) (map[string]bool, error)

type WorkflowRequest

+ ImageRetryCount int

+ ImageRetryInterval int

type WorkflowResponse

+ ImageComment *repository2.ImageComment

+ ImageReleaseTags []*repository2.ImageTag

Jul 3, 2023

Changes in this version

+ const DashboardConfigMap

+ const SECURITY_SCANNING

type CdConfig

+ InAppLoggingEnabled bool

type CdWorkflowRequest

+ BlobStorageLogsKey string

+ InAppLoggingEnabled bool

+ WorkflowPrefixForLog string

type CiConfig

+ InAppLoggingEnabled bool

type PipelineBuilder

+ DeleteACDAppCdPipelineWithNonCascade func(pipeline *pipelineConfig.Pipeline, ctx context.Context, forceDelete bool, ...) (err error)

type PipelineBuilderImpl

+ K8sUtil *util.K8sUtil

+ func (impl PipelineBuilderImpl) DeleteACDAppCdPipelineWithNonCascade(pipeline *pipelineConfig.Pipeline, ctx context.Context, forceDelete bool, ...) error

+ type SecurityConfig struct

+ ForceSecurityScanning bool

type WorkflowRequest

+ BlobStorageLogsKey string

+ InAppLoggingEnabled bool

type WorkflowResponse

+ PodName string

Jun 1, 2023

Changes in this version

+ const CRED_ACCESS_KEY

+ const CRED_SECRET_KEY

+ const CiStageFailErrorCode

+ const DEVTRON_APP_ARGO_PIPELINE_STATUS_UPDATE_CRON

+ const DEVTRON_APP_HELM_PIPELINE_STATUS_UPDATE_CRON

+ const HELM_APP_ARGO_PIPELINE_STATUS_UPDATE_CRON

+ const STEP_NAME_REGEX

+ const TEMPLATE_NAME_REGEX

+ const WORKFLOW_MINIO_CRED

+ var ArgoWorkflowOwnerRef = v1.OwnerReference

+ func AddTemplatesForGlobalSecretsInWorkflowTemplate(globalCmCsConfigs []*bean.GlobalCMCSDto, steps *[]v1alpha1.ParallelSteps, ...) error

+ func ExtractVolumesFromCmCs(configMaps []bean2.ConfigSecretMap, secrets []bean2.ConfigSecretMap) []v12.Volume

+ func GetConfigMapBody(configMapSecretDto ConfigMapSecretDto) v12.ConfigMap

+ func GetConfigMapJson(configMapSecretDto ConfigMapSecretDto) (string, error)

+ func GetFromGlobalCmCsDtos(globalCmCsConfigs []*bean.GlobalCMCSDto) ([]bean2.ConfigSecretMap, []bean2.ConfigSecretMap, error)

+ func GetSecretBody(configMapSecretDto ConfigMapSecretDto) v12.Secret

+ func GetSecretJson(configMapSecretDto ConfigMapSecretDto) (string, error)

+ func UpdateContainerEnvsFromCmCs(workflowMainContainer *v12.Container, configMaps []bean2.ConfigSecretMap, ...)

type ArgoPipelineStatusSyncEvent

+ IsAppStoreApplication bool

+ type ArgoWorkflowExecutor interface

+ type ArgoWorkflowExecutorImpl struct

+ func NewArgoWorkflowExecutorImpl(logger *zap.SugaredLogger) *ArgoWorkflowExecutorImpl

+ func (impl *ArgoWorkflowExecutorImpl) ExecuteWorkflow(workflowTemplate bean.WorkflowTemplate) error

type CdConfig

+ CdWorkflowExecutorType pipelineConfig.WorkflowExecutorType

type CdWorkflowRequest

+ WorkflowExecutor pipelineConfig.WorkflowExecutorType

type CiArtifactWebhookRequest

+ FailureReason string

type CiConfig

+ EnableBuildContext bool

type CiHandler

+ FetchCiStatusForTriggerViewV1 func(appId int) ([]*pipelineConfig.CiWorkflowStatus, error)

+ FetchMaterialsByPipelineIdAndGitMaterialId func(pipelineId int, gitMaterialId int, showAll bool) ([]CiPipelineMaterialResponse, error)

type CiHandlerImpl

+ func (impl *CiHandlerImpl) FetchCiStatusForTriggerViewV1(appId int) ([]*pipelineConfig.CiWorkflowStatus, error)

+ func (impl *CiHandlerImpl) FetchMaterialsByPipelineIdAndGitMaterialId(pipelineId int, gitMaterialId int, showAll bool) ([]CiPipelineMaterialResponse, error)

+ type ConfigMapSecretDto struct

+ Data map[string]string

+ Name string

+ OwnerRef v1.OwnerReference

type EnvironmentProperties

+ Description string

type GitRegistryConfigImpl

+ GitSensorGrpcClient gitSensor.Client

type PipelineBuilder

+ ChangePipelineDeploymentType func(ctx context.Context, request *bean.DeploymentAppTypeChangeRequest) (*bean.DeploymentAppTypeChangeResponse, error)

+ FetchDefaultCDPipelineStrategy func(appId int, envId int) (PipelineStrategy, error)

+ FindAppAndEnvDetailsByPipelineId func(cdPipelineId int) (*pipelineConfig.Pipeline, error)

+ GetCdPipelinesByEnvironmentMin func(request appGroup2.AppGroupingRequest) (cdPipelines []*bean.CDPipelineConfigObject, err error)

+ GetCiPipelineByEnvironmentMin func(request appGroup2.AppGroupingRequest) ([]*bean.CiPipelineMinResponse, error)

+ GetTriggerViewCdPipelinesForApp func(appId int) (cdPipelines *bean.CdPipelines, err error)

+ GetTriggerViewCiPipeline func(appId int) (*bean.TriggerViewCiConfig, error)

+ RetrieveArtifactsByCDPipeline func(pipeline *pipelineConfig.Pipeline, stage bean2.WorkflowType) (*bean.CiArtifactResponse, error)

+ RetrieveParentDetails func(pipelineId int) (parentId int, parentType bean2.WorkflowType, err error)

+ TriggerDeploymentAfterTypeChange func(ctx context.Context, request *bean.DeploymentAppTypeChangeRequest) (*bean.DeploymentAppTypeChangeResponse, error)

type PipelineBuilderImpl

+ func (impl PipelineBuilderImpl) ChangePipelineDeploymentType(ctx context.Context, request *bean.DeploymentAppTypeChangeRequest) (*bean.DeploymentAppTypeChangeResponse, error)

+ func (impl PipelineBuilderImpl) FetchDefaultCDPipelineStrategy(appId int, envId int) (PipelineStrategy, error)

+ func (impl PipelineBuilderImpl) FetchDeletedApp(ctx context.Context, pipelines []*pipelineConfig.Pipeline) *bean.DeploymentAppTypeChangeResponse

+ func (impl PipelineBuilderImpl) FindAppAndEnvDetailsByPipelineId(cdPipelineId int) (*pipelineConfig.Pipeline, error)

+ func (impl PipelineBuilderImpl) GetCdPipelinesByEnvironmentMin(request appGroup2.AppGroupingRequest) (cdPipelines []*bean.CDPipelineConfigObject, err error)

+ func (impl PipelineBuilderImpl) GetCiPipelineByEnvironmentMin(request appGroup2.AppGroupingRequest) ([]*bean.CiPipelineMinResponse, error)

+ func (impl PipelineBuilderImpl) GetTriggerViewCdPipelinesForApp(appId int) (cdPipelines *bean.CdPipelines, err error)

+ func (impl PipelineBuilderImpl) GetTriggerViewCiPipeline(appId int) (*bean.TriggerViewCiConfig, error)

+ func (impl PipelineBuilderImpl) RetrieveArtifactsByCDPipeline(pipeline *pipelineConfig.Pipeline, stage bean2.WorkflowType) (*bean.CiArtifactResponse, error)

+ func (impl PipelineBuilderImpl) RetrieveParentDetails(pipelineId int) (parentId int, parentType bean2.WorkflowType, err error)

+ func (impl PipelineBuilderImpl) TriggerDeploymentAfterTypeChange(ctx context.Context, request *bean.DeploymentAppTypeChangeRequest) (*bean.DeploymentAppTypeChangeResponse, error)

+ type PodRotateRequest struct

+ AppId int

+ EnvironmentId int

+ ResourceIdentifiers []application.ResourceIdentifier

+ UserId int32

type WebhookService

+ HandleCiStepFailedEvent func(ciPipelineId int, request *CiArtifactWebhookRequest) (err error)

type WebhookServiceImpl

+ func (impl *WebhookServiceImpl) WriteCIStepFailedEvent(pipeline *pipelineConfig.CiPipeline, request *CiArtifactWebhookRequest, ...)

+ func (impl WebhookServiceImpl) HandleCiStepFailedEvent(ciPipelineId int, request *CiArtifactWebhookRequest) (err error)

type WorkflowDagExecutor

+ RotatePods func(ctx context.Context, podRotateRequest *PodRotateRequest) (*k8s.RotatePodResponse, error)

type WorkflowDagExecutorImpl

+ func (impl *WorkflowDagExecutorImpl) GetArtifactVulnerabilityStatus(artifact *repository.CiArtifact, cdPipeline *pipelineConfig.Pipeline, ...) (bool, error)

+ func (impl *WorkflowDagExecutorImpl) RotatePods(ctx context.Context, podRotateRequest *PodRotateRequest) (*k8s.RotatePodResponse, error)

+ type WorkflowExecutor interface

+ ExecuteWorkflow func(workflowTemplate bean.WorkflowTemplate) error

type WorkflowRequest

+ EnableBuildContext bool

type WorkflowResponse

+ IsVirtualEnvironment bool

May 23, 2023

Changes in this version

type CiTemplateService

+ FindByAppIds func(appIds []int) (map[int]*bean.CiTemplateBean, error)

+ FindTemplateOverrideByCiPipelineIds func(ciPipelineIds []int) (ciTemplateBeans []*bean.CiTemplateBean, err error)

type CiTemplateServiceImpl

+ func (impl CiTemplateServiceImpl) FindByAppIds(appIds []int) (map[int]*bean.CiTemplateBean, error)

+ func (impl CiTemplateServiceImpl) FindTemplateOverrideByCiPipelineIds(ciPipelineIds []int) (ciTemplateBeans []*bean.CiTemplateBean, err error)

Apr 11, 2023

Changes in this version

+ const CD_WORKFLOW_WITH_STAGES

+ func NewDockerArtifactStore(bean *DockerArtifactStoreBean, isActive bool, createdOn time.Time, ...) *repository.DockerArtifactStore

type CdConfig

+ BaseLogLocationPath string

type CiArtifactWebhookRequest

+ IsArtifactUploaded bool

type CiConfig

+ BaseLogLocationPath string

type DockerRegistryConfig

+ CheckInActiveDockerAccount func(storeId string) (bool, error)

+ UpdateInactive func(bean *DockerArtifactStoreBean) (*DockerArtifactStoreBean, error)

type DockerRegistryConfigImpl

+ func (impl DockerRegistryConfigImpl) CheckInActiveDockerAccount(storeId string) (bool, error)

+ func (impl DockerRegistryConfigImpl) UpdateInactive(bean *DockerArtifactStoreBean) (*DockerArtifactStoreBean, error)

+ type GlobalCMCSDataUpdateDto struct

+ Data map[string]string

+ Id int

+ SecretIngestionFor string

+ UserId int32

type GlobalCMCSDto

+ SecretIngestionFor string

type GlobalCMCSService

+ AddTemplatesForGlobalSecretsInWorkflowTemplate func(globalCmCsConfigs []*GlobalCMCSDto, steps *[]v1alpha1.ParallelSteps, ...) error

+ DeleteById func(id int) error

+ FindAllActiveByPipelineType func(pipelineType string) ([]*GlobalCMCSDto, error)

+ GetGlobalCMCSDataByConfigTypeAndName func(configName string, configType string) (*GlobalCMCSDto, error)

+ UpdateDataById func(config *GlobalCMCSDataUpdateDto) (*GlobalCMCSDataUpdateDto, error)

type GlobalCMCSServiceImpl

+ func (impl *GlobalCMCSServiceImpl) AddTemplatesForGlobalSecretsInWorkflowTemplate(globalCmCsConfigs []*GlobalCMCSDto, steps *[]v1alpha1.ParallelSteps, ...) error

+ func (impl *GlobalCMCSServiceImpl) ConvertGlobalCmcsDbObjectToGlobalCmcsDto(GlobalCMCSDBObject []*repository.GlobalCMCS) []*GlobalCMCSDto

+ func (impl *GlobalCMCSServiceImpl) DeleteById(id int) error

+ func (impl *GlobalCMCSServiceImpl) FindAllActiveByPipelineType(pipelineType string) ([]*GlobalCMCSDto, error)

+ func (impl *GlobalCMCSServiceImpl) GetGlobalCMCSDataByConfigTypeAndName(configName string, configType string) (*GlobalCMCSDto, error)

+ func (impl *GlobalCMCSServiceImpl) UpdateDataById(config *GlobalCMCSDataUpdateDto) (*GlobalCMCSDataUpdateDto, error)

type WorkflowResponse

+ IsArtifactUploaded bool

Mar 28, 2023

Changes in this version

type CdConfig

+ ExposeCDMetrics bool

Feb 28, 2023

Changes in this version

+ const CI_NODE_PVC_ALL_ENV

+ const CI_NODE_PVC_PIPELINE_PREFIX

+ const NotDeployed

+ const NotTriggered

+ const WorklowTypeDeploy

+ const WorklowTypePost

+ const WorklowTypePre

type CdConfig

+ UseBlobStorageConfigInCdWorkflow bool

type CdHandler

+ FetchAppDeploymentStatusForEnvironments func(envId int, emailId string, ...) ([]*pipelineConfig.AppDeploymentStatus, error)

+ FetchAppWorkflowStatusForTriggerViewForEnvironment func(envId int, emailId string, ...) ([]*pipelineConfig.CdWorkflowStatus, error)

type CdHandlerImpl

+ func (impl *CdHandlerImpl) FetchAppDeploymentStatusForEnvironments(envId int, emailId string, ...) ([]*pipelineConfig.AppDeploymentStatus, error)

+ func (impl *CdHandlerImpl) FetchAppWorkflowStatusForTriggerViewForEnvironment(envId int, emailId string, ...) ([]*pipelineConfig.CdWorkflowStatus, error)

type CiCdPipelineOrchestrator

+ GetCdPipelinesForEnv func(envId int) (cdPipelines *bean.CdPipelines, err error)

type CiCdPipelineOrchestratorImpl

+ func (impl CiCdPipelineOrchestratorImpl) GetCdPipelinesForEnv(envId int) (cdPipelines *bean.CdPipelines, err error)

type CiConfig

+ BuildPvcCachePath string

+ BuildxPvcCachePath string

+ DefaultPvcCachePath string

+ UseBlobStorageConfigInCiWorkflow bool

type CiHandler

+ FetchCiStatusForTriggerViewForEnvironment func(envId int, emailId string, ...) ([]*pipelineConfig.CiWorkflowStatus, error)

type CiHandlerImpl

+ func (impl *CiHandlerImpl) FetchCiStatusForTriggerViewForEnvironment(envId int, emailId string, ...) ([]*pipelineConfig.CiWorkflowStatus, error)

type PipelineBuilder

+ ChangeDeploymentType func(ctx context.Context, request *bean.DeploymentAppTypeChangeRequest) (*bean.DeploymentAppTypeChangeResponse, error)

+ DeleteDeploymentApps func(ctx context.Context, pipelines []*pipelineConfig.Pipeline, userId int32) *bean.DeploymentAppTypeChangeResponse

+ DeleteDeploymentAppsForEnvironment func(ctx context.Context, environmentId int, ...) (*bean.DeploymentAppTypeChangeResponse, error)

+ GetAppListForEnvironment func(envId int, emailId string, ...) ([]*AppBean, error)

+ GetCdPipelinesByEnvironment func(envId int, emailId string, ...) (cdPipelines *bean.CdPipelines, err error)

+ GetCiPipelineByEnvironment func(envId int, emailId string, ...) ([]*bean.CiConfigRequest, error)

+ GetEnvironmentListForAutocompleteFilter func(envName string, clusterIds []int, offset int, size int, emailId string, ...) (*cluster.AppGroupingResponse, error)

+ GetExternalCiByEnvironment func(envId int, emailId string, ...) (ciConfig []*bean.ExternalCiConfig, err error)

+ MarkGitOpsDevtronAppsDeletedWhereArgoAppIsDeleted func(appId int, envId int, acdToken string, pipeline *pipelineConfig.Pipeline) (bool, error)

type PipelineBuilderImpl

+ ArgoUserService argo.ArgoUserService

+ func (impl PipelineBuilderImpl) ChangeDeploymentType(ctx context.Context, request *bean.DeploymentAppTypeChangeRequest) (*bean.DeploymentAppTypeChangeResponse, error)

+ func (impl PipelineBuilderImpl) DeleteCdPipelinePartial(pipeline *pipelineConfig.Pipeline, ctx context.Context, forceDelete bool, ...) (err error)

+ func (impl PipelineBuilderImpl) DeleteDeploymentApps(ctx context.Context, pipelines []*pipelineConfig.Pipeline, userId int32) *bean.DeploymentAppTypeChangeResponse

+ func (impl PipelineBuilderImpl) DeleteDeploymentAppsForEnvironment(ctx context.Context, environmentId int, ...) (*bean.DeploymentAppTypeChangeResponse, error)

+ func (impl PipelineBuilderImpl) GetAppListForEnvironment(envId int, emailId string, ...) ([]*AppBean, error)

+ func (impl PipelineBuilderImpl) GetCdPipelinesByEnvironment(envId int, emailId string, ...) (cdPipelines *bean.CdPipelines, err error)

+ func (impl PipelineBuilderImpl) GetCiPipelineByEnvironment(envId int, emailId string, ...) ([]*bean.CiConfigRequest, error)

+ func (impl PipelineBuilderImpl) GetEnvironmentListForAutocompleteFilter(envName string, clusterIds []int, offset int, size int, emailId string, ...) (*cluster.AppGroupingResponse, error)

+ func (impl PipelineBuilderImpl) GetExternalCiByEnvironment(envId int, emailId string, ...) (ciConfig []*bean.ExternalCiConfig, err error)

+ func (impl PipelineBuilderImpl) MarkGitOpsDevtronAppsDeletedWhereArgoAppIsDeleted(appId int, envId int, acdToken string, pipeline *pipelineConfig.Pipeline) (bool, error)

type Trigger

+ ExtraEnvironmentVariables map[string]string

type WorkflowRequest

+ CacheInvalidate bool

+ ExtraEnvironmentVariables map[string]string

+ IsPvcMounted bool

Feb 27, 2023

Changes in this version

type ESOSecretData

+ RefreshInterval string

+ SecretStoreRef json.RawMessage

Jan 31, 2023

Changes in this version

+ type ArgoPipelineStatusSyncEvent struct

+ PipelineId int

+ UserId int32

type CdHandler

+ CheckAndSendArgoPipelineStatusSyncEventIfNeeded func(pipelineId int, userId int32)

+ UpdatePipelineTimelineAndStatusByLiveApplicationFetch func(pipeline *pipelineConfig.Pipeline, userId int32) (err error, isTimelineUpdated bool)

type CdHandlerImpl

+ func (impl *CdHandlerImpl) CheckAndSendArgoPipelineStatusSyncEventIfNeeded(pipelineId int, userId int32)

+ func (impl *CdHandlerImpl) UpdatePipelineTimelineAndStatusByLiveApplicationFetch(pipeline *pipelineConfig.Pipeline, userId int32) (error, bool)

Jan 9, 2023

Changes in this version

+ const DefaultCiWorkflowNamespace

+ const Running

+ const Starting

type CiHandler

+ UpdateCiWorkflowStatusFailure func(timeoutForFailureCiBuild int) error

type CiHandlerImpl

+ K8sUtil *util.K8sUtil

+ func (impl *CiHandlerImpl) UpdateCiWorkflowStatusFailure(timeoutForFailureCiBuild int) error

Dec 14, 2022

Changes in this version

+ const APP_LABEL_COUNT

+ const APP_LABEL_KEY_PREFIX

+ const APP_LABEL_VALUE_PREFIX

+ const CD_PIPELINE_CLUSTER_NAME_KEY

+ const CD_PIPELINE_ENV_NAME_KEY

+ const CHILD_CD_CLUSTER_NAME_PREFIX

+ const CHILD_CD_COUNT

+ const CHILD_CD_ENV_NAME_PREFIX

+ const GIT_COMMIT_HASH_PREFIX

+ const GIT_SOURCE_COUNT

+ const GIT_SOURCE_TYPE_PREFIX

+ const GIT_SOURCE_VALUE_PREFIX

+ type CiCdPipelineOrchestrator interface

+ AddPipelineMaterialInGitSensor func(pipelineMaterials []*pipelineConfig.CiPipelineMaterial) error

+ BuildCiPipelineScript func(userId int32, ciScript *bean.CiScript, scriptStage string, ...) *pipelineConfig.CiPipelineScript

+ CheckStringMatchRegex func(regex string, value string) bool

+ 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)

+ CreateEcrRepo func(dockerRepository, AWSRegion, AWSAccessKeyId, AWSSecretAccessKey string) 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, request *bean.CiPatchRequest, 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 CiCdPipelineOrchestratorImpl struct

+ GitSensorClient gitSensor.GitSensorClient

+ func NewCiCdPipelineOrchestrator(pipelineGroupRepository app2.AppRepository, logger *zap.SugaredLogger, ...) *CiCdPipelineOrchestratorImpl

+ func (impl CiCdPipelineOrchestratorImpl) AddPipelineMaterialInGitSensor(pipelineMaterials []*pipelineConfig.CiPipelineMaterial) error

+ func (impl CiCdPipelineOrchestratorImpl) BuildCiPipelineScript(userId int32, ciScript *bean.CiScript, scriptStage string, ...) *pipelineConfig.CiPipelineScript

+ func (impl CiCdPipelineOrchestratorImpl) CheckStringMatchRegex(regex string, value string) bool

+ func (impl CiCdPipelineOrchestratorImpl) CreateApp(createRequest *bean.CreateAppDTO) (*bean.CreateAppDTO, error)

+ func (impl CiCdPipelineOrchestratorImpl) CreateCDPipelines(pipelineRequest *bean.CDPipelineConfigObject, appId int, userId int32, ...) (pipelineId int, err error)

+ func (impl CiCdPipelineOrchestratorImpl) CreateCiConf(createRequest *bean.CiConfigRequest, templateId int) (*bean.CiConfigRequest, error)

+ func (impl CiCdPipelineOrchestratorImpl) CreateEcrRepo(dockerRepository, AWSRegion, AWSAccessKeyId, AWSSecretAccessKey string) error

+ func (impl CiCdPipelineOrchestratorImpl) CreateMaterials(createMaterialRequest *bean.CreateMaterialDTO) (*bean.CreateMaterialDTO, error)

+ func (impl CiCdPipelineOrchestratorImpl) DeleteApp(appId int, userId int32) error

+ func (impl CiCdPipelineOrchestratorImpl) DeleteCdPipeline(pipelineId int, tx *pg.Tx) error

+ func (impl CiCdPipelineOrchestratorImpl) DeleteCiPipeline(pipeline *pipelineConfig.CiPipeline, request *bean.CiPatchRequest, tx *pg.Tx) error

+ func (impl CiCdPipelineOrchestratorImpl) GetByEnvOverrideId(envOverrideId int) (*bean.CdPipelines, error)

+ func (impl CiCdPipelineOrchestratorImpl) GetCdPipelinesForApp(appId int) (cdPipelines *bean.CdPipelines, err error)

+ func (impl CiCdPipelineOrchestratorImpl) GetCdPipelinesForAppAndEnv(appId int, envId int) (cdPipelines *bean.CdPipelines, err error)

+ func (impl CiCdPipelineOrchestratorImpl) PatchMaterialValue(createRequest *bean.CiPipeline, userId int32, ...) (*bean.CiPipeline, error)

+ func (impl CiCdPipelineOrchestratorImpl) PipelineExists(name string) (bool, error)

+ func (impl CiCdPipelineOrchestratorImpl) UpdateCDPipeline(pipelineRequest *bean.CDPipelineConfigObject, userId int32, tx *pg.Tx) (err error)

+ func (impl CiCdPipelineOrchestratorImpl) UpdateMaterial(updateMaterialDTO *bean.UpdateMaterialDTO) (*bean.UpdateMaterialDTO, error)

+ type DeploymentServiceTypeConfig struct

+ IsInternalUse bool

+ func GetDeploymentServiceTypeConfig() (*DeploymentServiceTypeConfig, error)

type PipelineBuilder

+ GetExternalCi func(appId int) (ciConfig []*bean.ExternalCiConfig, err error)

+ GetExternalCiById func(appId int, externalCiId int) (ciConfig *bean.ExternalCiConfig, err error)

+ IsGitOpsRequiredForCD func(pipelineCreateRequest *bean.CdPipelines) bool

+ SetPipelineDeploymentAppType func(pipelineCreateRequest *bean.CdPipelines, isGitOpsConfigured bool)

type PipelineBuilderImpl

+ func (impl PipelineBuilderImpl) GetExternalCi(appId int) (ciConfig []*bean.ExternalCiConfig, err error)

+ func (impl PipelineBuilderImpl) GetExternalCiById(appId int, externalCiId int) (ciConfig *bean.ExternalCiConfig, err error)

+ func (impl PipelineBuilderImpl) IsGitOpsRequiredForCD(pipelineCreateRequest *bean.CdPipelines) bool

+ func (impl PipelineBuilderImpl) IsGitopsConfigured() (bool, error)

+ func (impl PipelineBuilderImpl) RegisterInACD(app *app2.App, pipelineCreateRequest *bean.CdPipelines, ctx context.Context) error

+ func (impl PipelineBuilderImpl) SetPipelineDeploymentAppType(pipelineCreateRequest *bean.CdPipelines, isGitOpsConfigured bool)

+ func (impl PipelineBuilderImpl) ValidateCDPipelineRequest(pipelineCreateRequest *bean.CdPipelines, ...) (bool, error)

type WebhookService

+ HandleCiSuccessEvent func(ciPipelineId int, request *CiArtifactWebhookRequest) (id int, err error)

+ HandleExternalCiWebhook func(externalCiId int, request *CiArtifactWebhookRequest, ...) (id int, err error)

type WebhookServiceImpl

+ func (impl WebhookServiceImpl) HandleCiSuccessEvent(ciPipelineId int, request *CiArtifactWebhookRequest) (id int, err error)

+ func (impl WebhookServiceImpl) HandleExternalCiWebhook(externalCiId int, request *CiArtifactWebhookRequest, ...) (id int, err error)

type WorkflowDagExecutor

+ HandleWebhookExternalCiEvent func(artifact *repository.CiArtifact, triggeredBy int32, externalCiId int, ...) (bool, error)

type WorkflowDagExecutorImpl

+ CiTemplateRepository pipelineConfig.CiTemplateRepository

+ func (impl *WorkflowDagExecutorImpl) HandleWebhookExternalCiEvent(artifact *repository.CiArtifact, triggeredBy int32, externalCiId int, ...) (bool, error)

Nov 25, 2022

Changes in this version

type PipelineBuilderImpl

+ CiPipelineHistoryService history.CiPipelineHistoryService

+ CiTemplateHistoryService history.CiTemplateHistoryService

Nov 23, 2022

Changes in this version

type DockerArtifactStoreBean

+ DockerRegistryIpsConfig *DockerRegistryIpsConfigBean

+ type DockerRegistryIpsConfigBean struct

+ AppliedClusterIdsCsv string

+ CredentialType repository.DockerRegistryIpsCredentialType

+ CredentialValue string

+ Id int

+ IgnoredClusterIdsCsv string

Nov 10, 2022

Changes in this version

+ type CiBuildConfigService interface

+ Delete func(ciBuildConfigId int) error

+ GetCountByBuildType func() map[bean.CiBuildType]int

+ Save func(templateId int, overrideTemplateId int, ...) error

+ UpdateOrSave func(templateId int, overrideTemplateId int, ciBuildConfig *bean.CiBuildConfigBean, ...) (*bean.CiBuildConfigBean, error)

+ type CiBuildConfigServiceImpl struct

+ CiBuildConfigRepository pipelineConfig.CiBuildConfigRepository

+ Logger *zap.SugaredLogger

+ func NewCiBuildConfigServiceImpl(logger *zap.SugaredLogger, ...) *CiBuildConfigServiceImpl

+ func (impl *CiBuildConfigServiceImpl) Delete(ciBuildConfigId int) error

+ func (impl *CiBuildConfigServiceImpl) GetCountByBuildType() map[bean.CiBuildType]int

+ func (impl *CiBuildConfigServiceImpl) Save(templateId int, overrideTemplateId int, ...) error

+ func (impl *CiBuildConfigServiceImpl) UpdateOrSave(templateId int, overrideTemplateId int, ciBuildConfig *bean.CiBuildConfigBean, ...) (*bean.CiBuildConfigBean, error)

type CiConfig

+ CiRunnerDockerMTUValue int

+ type CiTemplateService interface

+ FindByAppId func(appId int) (ciTemplateBean *bean.CiTemplateBean, err error)

+ FindTemplateOverrideByAppId func(appId int) (ciTemplateBeans []*bean.CiTemplateBean, err error)

+ FindTemplateOverrideByCiPipelineId func(ciPipelineId int) (*bean.CiTemplateBean, error)

+ Save func(ciTemplateBean *bean.CiTemplateBean) error

+ Update func(ciTemplateBean *bean.CiTemplateBean) error

+ type CiTemplateServiceImpl struct

+ CiBuildConfigService CiBuildConfigService

+ CiTemplateOverrideRepository pipelineConfig.CiTemplateOverrideRepository

+ CiTemplateRepository pipelineConfig.CiTemplateRepository

+ Logger *zap.SugaredLogger

+ func NewCiTemplateServiceImpl(logger *zap.SugaredLogger, ciBuildConfigService CiBuildConfigService, ...) *CiTemplateServiceImpl

+ func (impl CiTemplateServiceImpl) FindByAppId(appId int) (ciTemplateBean *bean.CiTemplateBean, err error)

+ func (impl CiTemplateServiceImpl) FindTemplateOverrideByAppId(appId int) (ciTemplateBeans []*bean.CiTemplateBean, err error)

+ func (impl CiTemplateServiceImpl) FindTemplateOverrideByCiPipelineId(ciPipelineId int) (*bean.CiTemplateBean, error)

+ func (impl CiTemplateServiceImpl) Save(ciTemplateBean *bean.CiTemplateBean) error

+ func (impl CiTemplateServiceImpl) Update(ciTemplateBean *bean.CiTemplateBean) error

type PipelineBuilder

+ DeleteCdPipeline func(pipeline *pipelineConfig.Pipeline, ctx context.Context, forceDelete bool) (err error)

+ DeleteCiPipeline func(request *bean.CiPatchRequest) (*bean.CiPipeline, error)

type PipelineBuilderImpl

+ func (impl PipelineBuilderImpl) DeleteCdPipeline(pipeline *pipelineConfig.Pipeline, ctx context.Context, forceDelete bool) (err error)

+ func (impl PipelineBuilderImpl) DeleteCiPipeline(request *bean.CiPatchRequest) (*bean.CiPipeline, error)

type WorkflowRequest

+ CheckoutPath string

+ CiBuildConfig *bean2.CiBuildConfigBean

+ CiBuildDockerMtuValue int

Nov 3, 2022

Changes in this version

type CdWorkflowRequest

+ DeploymentReleaseCounter int

Nov 1, 2022

Changes in this version

+ const CI_NODE_SELECTOR_APP_LABEL_KEY

+ type ArgoPipelineStatusEvent struct

+ AppId int

+ ArgoAppName string

+ EnvId int

+ IgnoreFailedWorkflowStatus bool

type BulkUpdateService

+ BulkBuildTrigger func(request *BulkApplicationForEnvironmentPayload, ctx context.Context, ...) (*BulkApplicationForEnvironmentResponse, error)

type BulkUpdateServiceImpl

+ func (impl BulkUpdateServiceImpl) BulkBuildTrigger(request *BulkApplicationForEnvironmentPayload, ctx context.Context, ...) (*BulkApplicationForEnvironmentResponse, error)

type CdHandler

+ CheckArgoPipelineTimelineStatusPeriodicallyAndUpdateInDb func(pendingSinceSeconds int) error

+ UpdatePipelineTimelineAndStatusByLiveResourceTreeFetch func(argoAppName string, appId, envId int, ignoreFailedWorkflowStatus bool) error

type CdHandlerImpl

+ func (impl *CdHandlerImpl) CheckArgoPipelineTimelineStatusPeriodicallyAndUpdateInDb(pendingSinceSeconds int) error

+ func (impl *CdHandlerImpl) UpdatePipelineTimelineAndStatusByLiveResourceTreeFetch(argoAppName string, appId, envId int, ignoreFailedWorkflowStatus bool) error

type CiConfig

+ IgnoreDockerCacheForCI bool

+ VolumeMountsForCiJson string

+ type CiVolumeMount struct

+ ContainerMountPath string

+ HostMountPath string

+ Name string

type EnvironmentProperties

+ CurrentViewEditor models.ChartsViewEditorType

+ IsBasicViewLocked bool

type PipelineBuilder

+ GetBulkActionImpactedPipelines func(dto *bean.CdBulkActionRequestDto) ([]*pipelineConfig.Pipeline, error)

+ PerformBulkActionOnCdPipelines func(dto *bean.CdBulkActionRequestDto, impactedPipelines []*pipelineConfig.Pipeline, ...) ([]*bean.CdBulkActionResponseDto, error)

type PipelineBuilderImpl

+ func (impl PipelineBuilderImpl) BulkDeleteCdPipelines(impactedPipelines []*pipelineConfig.Pipeline, ctx context.Context, ...) []*bean.CdBulkActionResponseDto

+ func (impl PipelineBuilderImpl) GetBulkActionImpactedPipelines(dto *bean.CdBulkActionRequestDto) ([]*pipelineConfig.Pipeline, error)

+ func (impl PipelineBuilderImpl) PerformBulkActionOnCdPipelines(dto *bean.CdBulkActionRequestDto, impactedPipelines []*pipelineConfig.Pipeline, ...) ([]*bean.CdBulkActionResponseDto, error)

type WorkflowRequest

+ IgnoreDockerCachePull bool

+ IgnoreDockerCachePush bool

Oct 13, 2022

Changes in this version

+ type DeploymentConfigService interface

+ GetLatestDeploymentConfigurationByPipelineId func(pipelineId int, userHasAdminAccess bool) (*history.AllDeploymentConfigurationDetail, error)

+ type DeploymentConfigServiceImpl struct

+ func NewDeploymentConfigServiceImpl(logger *zap.SugaredLogger, ...) *DeploymentConfigServiceImpl

+ func (impl *DeploymentConfigServiceImpl) GetLatestCMCSConfig(pipeline *pipelineConfig.Pipeline, userHasAdminAccess bool) ([]*history.ComponentLevelHistoryDetailDto, ...)

+ func (impl *DeploymentConfigServiceImpl) GetLatestDeploymentConfigurationByPipelineId(pipelineId int, userHasAdminAccess bool) (*history.AllDeploymentConfigurationDetail, error)

+ func (impl *DeploymentConfigServiceImpl) GetLatestDeploymentTemplateConfig(pipeline *pipelineConfig.Pipeline) (*history.HistoryDetailDto, error)

+ func (impl *DeploymentConfigServiceImpl) GetLatestPipelineStrategyConfig(pipeline *pipelineConfig.Pipeline) (*history.HistoryDetailDto, error)

+ func (impl *DeploymentConfigServiceImpl) GetMergedCMCSConfigMap(appLevelConfig, envLevelConfig string, configType repository2.ConfigType) (map[string]*history.ConfigData, error)

Oct 8, 2022

Changes in this version

+ const CI_WORKFLOW_NAME

+ const CI_WORKFLOW_WITH_STAGES

type BuildLogRequest

+ PodName string

+ type BulkApplicationForEnvironmentPayload struct

+ AppIdExcludes []int

+ AppIdIncludes []int

+ EnvId int

+ UserId int32

+ type BulkApplicationForEnvironmentResponse struct

+ Response map[string]map[string]bool

type BulkUpdateService

+ BulkDeploy func(request *BulkApplicationForEnvironmentPayload, ctx context.Context, ...) (*BulkApplicationForEnvironmentResponse, error)

+ BulkHibernate func(request *BulkApplicationForEnvironmentPayload, ctx context.Context, ...) (*BulkApplicationForEnvironmentResponse, error)

+ BulkUnHibernate func(request *BulkApplicationForEnvironmentPayload, ctx context.Context, ...) (*BulkApplicationForEnvironmentResponse, error)

type BulkUpdateServiceImpl

+ func (impl BulkUpdateServiceImpl) BulkDeploy(request *BulkApplicationForEnvironmentPayload, ctx context.Context, ...) (*BulkApplicationForEnvironmentResponse, error)

+ func (impl BulkUpdateServiceImpl) BulkHibernate(request *BulkApplicationForEnvironmentPayload, ctx context.Context, ...) (*BulkApplicationForEnvironmentResponse, error)

+ func (impl BulkUpdateServiceImpl) BulkUnHibernate(request *BulkApplicationForEnvironmentPayload, ctx context.Context, ...) (*BulkApplicationForEnvironmentResponse, error)

+ type GlobalCMCSDto struct

+ ConfigType string

+ Data map[string]string

+ Deleted bool

+ Id int

+ MountPath string

+ Name string

+ Type string

+ UserId int32

+ type GlobalCMCSService interface

+ Create func(model *GlobalCMCSDto) (*GlobalCMCSDto, error)

+ FindAllActive func() ([]*GlobalCMCSDto, error)

+ type GlobalCMCSServiceImpl struct

+ func NewGlobalCMCSServiceImpl(logger *zap.SugaredLogger, ...) *GlobalCMCSServiceImpl

+ func (impl *GlobalCMCSServiceImpl) Create(config *GlobalCMCSDto) (*GlobalCMCSDto, error)

+ func (impl *GlobalCMCSServiceImpl) FindAllActive() ([]*GlobalCMCSDto, error)

type PipelineStageService

+ GetCiPipelineStageDataDeepCopy func(ciPipelineId int) (preCiStage *bean.PipelineStageDto, postCiStage *bean.PipelineStageDto, ...)

type PipelineStageServiceImpl

+ func (impl *PipelineStageServiceImpl) BuildCiStageDataDeepCopy(ciStage *repository.PipelineStage) (*bean.PipelineStageDto, error)

+ func (impl *PipelineStageServiceImpl) BuildInlineStepDataDeepCopy(step *repository.PipelineStageStep) (*bean.InlineStepDetailDto, error)

+ func (impl *PipelineStageServiceImpl) BuildRefPluginStepDataDeepCopy(step *repository.PipelineStageStep) (*bean.RefPluginStepDetailDto, error)

+ func (impl *PipelineStageServiceImpl) BuildVariableAndConditionDataByStepIdDeepCopy(stepId int) ([]*bean.StepVariableDto, []*bean.StepVariableDto, []*bean.ConditionDetailDto, ...)

+ func (impl *PipelineStageServiceImpl) GetCiPipelineStageDataDeepCopy(ciPipelineId int) (*bean.PipelineStageDto, *bean.PipelineStageDto, error)

type WorkflowRequest

+ DockerBuildOptions string

type WorkflowStatus

+ PodName string

Sep 24, 2022

Changes in this version

+ type BuildLogRequest struct

+ AwsS3BaseConfig *blob_storage.AwsS3BaseConfig

+ AzureBlobConfig *blob_storage.AzureBlobBaseConfig

+ CloudProvider blob_storage.BlobStorageType

+ GcpBlobBaseConfig *blob_storage.GcpBlobBaseConfig

+ LogsFilePath string

+ MinioEndpoint string

+ Namespace string

+ PipelineId int

+ WorkflowId int

+ WorkflowName string

type CdConfig

+ AzureGatewayConnectionInsecure bool

+ AzureGatewayUrl string

+ BlobStorageEnabled bool

+ BlobStorageGcpCredentialJson string

+ BlobStorageS3AccessKey string

+ BlobStorageS3BucketVersioned bool

+ BlobStorageS3Endpoint string

+ BlobStorageS3EndpointInsecure bool

+ BlobStorageS3SecretKey string

+ BuildLogTTLValue int

type CdWorkflowRequest

+ ArtifactBucket string

+ ArtifactFileName string

+ ArtifactRegion string

+ BlobStorageConfigured bool

+ BlobStorageS3Config *blob_storage.BlobStorageS3Config

+ GcpBlobConfig *blob_storage.GcpBlobConfig

type CiConfig

+ AzureGatewayConnectionInsecure bool

+ AzureGatewayUrl string

+ BlobStorageEnabled bool

+ BlobStorageGcpCredentialJson string

+ BlobStorageS3AccessKey string

+ BlobStorageS3BucketVersioned bool

+ BlobStorageS3Endpoint string

+ BlobStorageS3EndpointInsecure bool

+ BlobStorageS3SecretKey string

+ BuildLogTTLValue int

+ DefaultCdLogsBucketRegion string

type WorkflowRequest

+ BlobStorageConfigured bool

+ BlobStorageS3Config *blob_storage.BlobStorageS3Config

+ CiArtifactBucket string

+ CiArtifactFileName string

+ CiArtifactRegion string

+ GcpBlobConfig *blob_storage.GcpBlobConfig

type WorkflowResponse

+ BlobStorageEnabled bool

Sep 13, 2022

Changes in this version

type CdWorkflowRequest

+ DeploymentTriggerTime time.Time

+ DeploymentTriggeredBy string

type CiConfig

+ MinioRegion string

type ConfigData

+ DefaultESOSecretData ESOSecretData

+ ESOSecretData ESOSecretData

+ type ESOData struct

+ Key string

+ Property string

+ SecretKey string

+ type ESOSecretData struct

+ EsoData []ESOData

+ SecretStore json.RawMessage

Sep 1, 2022

Changes in this version

type CdHandler

+ CheckArgoAppStatusPeriodicallyAndUpdateInDb func(timeForDegradation int) error

type CdHandlerImpl

+ func (impl *CdHandlerImpl) CheckArgoAppStatusPeriodicallyAndUpdateInDb(timeForDegradation int) error

+ func (impl *CdHandlerImpl) GetAppStatusByResourceTreeFetchFromArgo(appName string) (timelineStatus pipelineConfig.TimelineStatus, appStatus, statusMessage string)

Aug 25, 2022

Changes in this version

+ const WorkflowInProgress

type CiPipelineMaterialResponse

+ Regex string

type DbPipelineOrchestrator

+ AddPipelineMaterialInGitSensor func(pipelineMaterials []*pipelineConfig.CiPipelineMaterial) error

+ CheckStringMatchRegex func(regex string, value string) bool

type DbPipelineOrchestratorImpl

+ func (impl DbPipelineOrchestratorImpl) AddPipelineMaterialInGitSensor(pipelineMaterials []*pipelineConfig.CiPipelineMaterial) error

+ func (impl DbPipelineOrchestratorImpl) CheckStringMatchRegex(regex string, value string) bool

type PipelineBuilder

+ PatchRegexCiPipeline func(request *bean.CiRegexPatchRequest) (err error)

type PipelineBuilderImpl

+ func (impl PipelineBuilderImpl) PatchRegexCiPipeline(request *bean.CiRegexPatchRequest) (err error)

Jul 22, 2022

Changes in this version

type WorkflowRequest

+ DockerBuildTargetPlatform string

Jun 22, 2022

Changes in this version

+ const DegradeTime

type CdHandler

+ CheckHelmAppStatusPeriodicallyAndUpdateInDb func() error

type CdHandlerImpl

+ func (impl *CdHandlerImpl) CheckHelmAppStatusPeriodicallyAndUpdateInDb() error

Jun 6, 2022

Changes in this version

type ChartDataInfo

+ Message string

+ type ChartDto struct

+ ChartDescription string

+ Name string

+ Version string

type ChartService

+ CheckCustomChartByAppId func(id int) (bool, error)

+ FetchChartInfoByFlag func(userUploaded bool) ([]*ChartDto, error)

type ChartServiceImpl

+ func (impl ChartServiceImpl) CheckCustomChartByAppId(id int) (bool, error)

+ func (impl ChartServiceImpl) FetchChartInfoByFlag(userUploaded bool) ([]*ChartDto, error)

May 30, 2022

Changes in this version

type PipelineBuilder

+ GetEnvironmentByCdPipelineId func(pipelineId int) (int, error)

type PipelineBuilderImpl

+ func (impl PipelineBuilderImpl) GetEnvironmentByCdPipelineId(pipelineId int) (int, error)

May 25, 2022

Changes in this version

type ChartService

+ RegisterInArgo func(chartGitAttribute *util.ChartGitAttribute, ctx context.Context) error

type ChartServiceImpl

+ func (impl ChartServiceImpl) RegisterInArgo(chartGitAttribute *util.ChartGitAttribute, ctx context.Context) error

type PipelineBuilder

+ FindAllMatchesByAppName func(appName string) ([]*AppBean, error)

type PipelineBuilderImpl

+ func (impl PipelineBuilderImpl) FindAllMatchesByAppName(appName string) ([]*AppBean, error)

May 17, 2022

Changes in this version

+ type PipelineStageService interface

+ BuildPrePostAndRefPluginStepsDataForWfRequest func(ciPipelineId int) ([]*bean.StepObject, []*bean.StepObject, []*bean.RefPluginObject, error)

+ CreateCiStage func(stageReq *bean.PipelineStageDto, stageType repository.PipelineStageType, ...) error

+ DeleteCiStage func(stageReq *bean.PipelineStageDto, userId int32, tx *pg.Tx) error

+ GetCiPipelineStageData func(ciPipelineId int) (preCiStage *bean.PipelineStageDto, postCiStage *bean.PipelineStageDto, ...)

+ UpdateCiStage func(stageReq *bean.PipelineStageDto, stageType repository.PipelineStageType, ...) error

+ type PipelineStageServiceImpl struct

+ func NewPipelineStageService(logger *zap.SugaredLogger, ...) *PipelineStageServiceImpl

+ func (impl *PipelineStageServiceImpl) BuildCiStageData(ciStage *repository.PipelineStage) (*bean.PipelineStageDto, error)

+ func (impl *PipelineStageServiceImpl) BuildCiStageDataForWfRequest(ciStage *repository.PipelineStage) ([]*bean.StepObject, []int, error)

+ func (impl *PipelineStageServiceImpl) BuildCiStepDataForWfRequest(step *repository.PipelineStageStep) (*bean.StepObject, error)

+ func (impl *PipelineStageServiceImpl) BuildInlineStepData(step *repository.PipelineStageStep) (*bean.InlineStepDetailDto, error)

+ func (impl *PipelineStageServiceImpl) BuildPluginStepDataForWfRequest(step *repository2.PluginStep) (*bean.StepObject, error)

+ func (impl *PipelineStageServiceImpl) BuildPluginVariableAndConditionDataForWfRequest(stepId int) ([]*bean.VariableObject, []*bean.VariableObject, []*bean.ConditionObject, ...)

+ func (impl *PipelineStageServiceImpl) BuildPrePostAndRefPluginStepsDataForWfRequest(ciPipelineId int) ([]*bean.StepObject, []*bean.StepObject, []*bean.RefPluginObject, error)

+ func (impl *PipelineStageServiceImpl) BuildRefPluginStepData(step *repository.PipelineStageStep) (*bean.RefPluginStepDetailDto, error)

+ func (impl *PipelineStageServiceImpl) BuildRefPluginStepDataForWfRequest(refPluginIds []int) ([]*bean.RefPluginObject, error)

+ func (impl *PipelineStageServiceImpl) BuildVariableAndConditionDataByStepId(stepId int) ([]*bean.StepVariableDto, []*bean.StepVariableDto, []*bean.ConditionDetailDto, ...)

+ func (impl *PipelineStageServiceImpl) BuildVariableAndConditionDataForWfRequest(stepId int) ([]*bean.VariableObject, []*bean.VariableObject, []*bean.ConditionObject, ...)

+ func (impl *PipelineStageServiceImpl) CreateCiStage(stageReq *bean.PipelineStageDto, stageType repository.PipelineStageType, ...) error

+ func (impl *PipelineStageServiceImpl) CreateConditions(stepId int, conditions []*bean.ConditionDetailDto, ...) error

+ func (impl *PipelineStageServiceImpl) CreateConditionsEntryInDb(stepId int, conditions []*bean.ConditionDetailDto, ...) ([]repository.PipelineStageStepCondition, error)

+ func (impl *PipelineStageServiceImpl) CreateInputAndOutputVariables(stepId int, inputVariables []*bean.StepVariableDto, ...) (inputVariablesRepo []repository.PipelineStageStepVariable, ...)

+ func (impl *PipelineStageServiceImpl) CreateScriptAndMappingForInlineStep(inlineStepDetail *bean.InlineStepDetailDto, userId int32) (scriptId int, err error)

+ func (impl *PipelineStageServiceImpl) CreateStageSteps(steps []*bean.PipelineStageStepDto, stageId int, userId int32, ...) error

+ func (impl *PipelineStageServiceImpl) CreateVariablesEntryInDb(stepId int, variables []*bean.StepVariableDto, ...) ([]repository.PipelineStageStepVariable, error)

+ func (impl *PipelineStageServiceImpl) DeleteCiStage(stageReq *bean.PipelineStageDto, userId int32, tx *pg.Tx) error

+ func (impl *PipelineStageServiceImpl) FilterAndActOnStepsInCiStageUpdateRequest(stageReq *bean.PipelineStageDto, userId int32) error

+ func (impl *PipelineStageServiceImpl) GetCiPipelineStageData(ciPipelineId int) (*bean.PipelineStageDto, *bean.PipelineStageDto, error)

+ func (impl *PipelineStageServiceImpl) GetRefPluginStepsByIds(refPluginIds []int, pluginIdsEvaluated map[int]bool) (map[int][]*bean.StepObject, error)

+ func (impl *PipelineStageServiceImpl) UpdateCiStage(stageReq *bean.PipelineStageDto, stageType repository.PipelineStageType, ...) error

+ func (impl *PipelineStageServiceImpl) UpdateInputAndOutputVariables(stepId int, inputVariables []*bean.StepVariableDto, ...) (inputVarNameIdMap map[string]int, outputVarNameIdMap map[string]int, err error)

+ func (impl *PipelineStageServiceImpl) UpdatePipelineStageStepConditions(stepId int, conditions []*bean.ConditionDetailDto, ...) ([]repository.PipelineStageStepCondition, error)

+ func (impl *PipelineStageServiceImpl) UpdatePipelineStageStepVariables(stepId int, variables []*bean.StepVariableDto, ...) (map[string]int, error)

+ func (impl *PipelineStageServiceImpl) UpdateScriptAndMappingForInlineStep(inlineStepDetail *bean.InlineStepDetailDto, scriptId int, userId int32) (err error)

+ func (impl *PipelineStageServiceImpl) UpdateStageSteps(steps []*bean.PipelineStageStepDto, userId int32, stageId int, ...) error

type WorkflowRequest

+ AppName string

+ PostCiSteps []*bean2.StepObject

+ PreCiSteps []*bean2.StepObject

+ RefPlugins []*bean2.RefPluginObject

+ TriggerByAuthor string

May 10, 2022

Changes in this version

type ChartDataInfo

+ Description string

type ChartYamlStruct

+ Description string

Mar 29, 2022

Changes in this version

+ type ChartDataInfo struct

+ ChartLocation string

+ ChartName string

+ ChartVersion string

+ TemporaryFolder string

type ChartService

+ CheckChartExists func(chartRefId int) error

+ ExtractChartIfMissing func(chartData []byte, refChartDir string, location string) (*ChartDataInfo, error)

+ GetLocationFromChartNameAndVersion func(chartName string, chartVersion string) string

+ ReadChartMetaDataForLocation func(chartDir string, fileName string) (string, string, error)

+ ValidateUploadedFileFormat func(fileName string) error

type ChartServiceImpl

+ func (impl *ChartServiceImpl) GetLocationFromChartNameAndVersion(chartName string, chartVersion string) string

+ func (impl *ChartServiceImpl) ValidateUploadedFileFormat(fileName string) error

+ func (impl ChartServiceImpl) CheckChartExists(chartRefId int) error

+ func (impl ChartServiceImpl) ExtractChartIfMissing(chartData []byte, refChartDir string, location string) (*ChartDataInfo, error)

+ func (impl ChartServiceImpl) ReadChartMetaDataForLocation(chartDir string, fileName string) (string, string, error)

+ type ChartYamlStruct struct

+ Name string

+ Version string

Mar 25, 2022

Changes in this version

type DbPipelineOrchestrator

+ BuildCiPipelineScript func(userId int32, ciScript *bean.CiScript, scriptStage string, ...) *pipelineConfig.CiPipelineScript

type DbPipelineOrchestratorImpl

+ func (impl DbPipelineOrchestratorImpl) BuildCiPipelineScript(userId int32, ciScript *bean.CiScript, scriptStage string, ...) *pipelineConfig.CiPipelineScript

Mar 4, 2022

Changes in this version

type ChartService

+ GetSchemaAndReadmeForTemplateByChartRefId func(chartRefId int) (schema []byte, readme []byte, err error)

type ChartServiceImpl

+ func (impl ChartServiceImpl) GetSchemaAndReadmeForTemplateByChartRefId(chartRefId int) ([]byte, []byte, error)

type EnvironmentPropertiesResponse

+ Readme string

+ Schema json.RawMessage

type TemplateRequest

+ Readme string

+ Schema json.RawMessage

Feb 14, 2022

Changes in this version

type CdConfig

+ DefaultAddressPoolBaseCidr string

+ DefaultAddressPoolSize int

type CdWorkflowRequest

+ DefaultAddressPoolBaseCidr string

+ DefaultAddressPoolSize int

type CiConfig

+ DefaultAddressPoolBaseCidr string

+ DefaultAddressPoolSize int

type DockerRegistryConfig

+ DeleteReg func(bean *DockerArtifactStoreBean) error

type DockerRegistryConfigImpl

+ func (impl DockerRegistryConfigImpl) DeleteReg(bean *DockerArtifactStoreBean) error

type GitRegistryConfig

+ Delete func(request *GitRegistry) error

type GitRegistryConfigImpl

+ func (impl GitRegistryConfigImpl) Delete(request *GitRegistry) error

type PipelineBuilder

+ DeleteMaterial func(request *bean.UpdateMaterialDTO) error

type PipelineBuilderImpl

+ func (impl PipelineBuilderImpl) DeleteMaterial(request *bean.UpdateMaterialDTO) error

type WorkflowRequest

+ DefaultAddressPoolBaseCidr string

+ DefaultAddressPoolSize int

Feb 7, 2022

Changes in this version

type WorkflowRequest

+ DockerRegistryId string

Dec 29, 2021

Changes in this version

type PipelineBuilderImpl

+ func (impl PipelineBuilderImpl) BuildArtifactsForCIParent(cdPipelineId int, ciArtifacts []bean.CiArtifactBean, artifactMap map[int]int, ...) ([]bean.CiArtifactBean, error)

+ func (impl PipelineBuilderImpl) BuildArtifactsForCdStage(pipelineId int, stageType bean2.WorkflowType, ...) ([]bean.CiArtifactBean, map[int]int, error)

+ func (impl PipelineBuilderImpl) BuildArtifactsForParentStage(cdPipelineId int, parentId int, parentType bean2.WorkflowType, ...) ([]bean.CiArtifactBean, error)

+ func (impl PipelineBuilderImpl) GetArtifactsForCdStage(cdPipelineId int, parentId int, parentType bean2.WorkflowType, ...) (bean.CiArtifactResponse, error)

+ func (impl PipelineBuilderImpl) GetCdParentDetails(cdPipelineId int) (parentId int, parentType bean2.WorkflowType, err error)

type WorkflowDagExecutor

+ HandlePostStageSuccessEvent func(cdWorkflowId int, cdPipelineId int, triggeredBy int32) error

type WorkflowDagExecutorImpl

+ func (impl *WorkflowDagExecutorImpl) HandlePostStageSuccessEvent(cdWorkflowId int, cdPipelineId int, triggeredBy int32) error

Dec 2, 2021

Changes in this version

type PipelineBuilder

+ GetMaterialsForAppId func(appId int) []*bean.GitMaterial

type PipelineBuilderImpl

+ func (impl PipelineBuilderImpl) GetMaterialsForAppId(appId int) []*bean.GitMaterial

Nov 18, 2021

Changes in this version

type ChartService

+ DeploymentTemplateValidate func(templatejson interface{}, chartRefId int) (bool, error)

+ JsonSchemaExtractFromFile func(chartRefId int) (map[string]interface{}, error)

type ChartServiceImpl

+ func (impl ChartServiceImpl) DeploymentTemplateValidate(templatejson interface{}, chartRefId int) (bool, error)

+ func (impl ChartServiceImpl) JsonSchemaExtractFromFile(chartRefId int) (map[string]interface{}, error)

Nov 11, 2021

Changes in this version

+ func SetGitCommitValuesForBuildingCommitHash(ciMaterial *pipelineConfig.CiPipelineMaterial, oldGitCommit bean.GitCommit) bean.GitCommit

Oct 10, 2021

Changes in this version

+ func ModifySshPrivateKey(sshPrivateKey string, authMode repository.AuthMode) string

type CdWorkflowRequest

+ DockerCert string

+ DockerConnection string

type CiProjectDetails

+ FetchSubmodules bool

type DockerArtifactStoreBean

+ Cert string

+ Connection string

type GitOptions

+ SshPrivateKey string

+ type GitRegistry struct

+ AccessToken string

+ Active bool

+ AuthMode repository.AuthMode

+ GitHostId int

+ Id int

+ Name string

+ Password string

+ SshPrivateKey string

+ Url string

+ UserId int32

+ UserName string

type WorkflowRequest

+ DockerCert string

+ DockerConnection string

Sep 9, 2021

Changes in this version

type WebhookEventDataConfig

+ GetById func(payloadId int) (*WebhookEventDataRequest, error)

type WebhookEventDataConfigImpl

+ func (impl WebhookEventDataConfigImpl) GetById(payloadId int) (*WebhookEventDataRequest, error)

type WebhookEventDataRequest

+ PayloadId int

Aug 20, 2021

Changes in this version

type BulkUpdatePayload

+ ConfigMap *CmAndSecretTask

+ Secret *CmAndSecretTask

type BulkUpdateResponse

+ ConfigMap *CmAndSecretBulkUpdateResponse

+ DeploymentTemplate *DeploymentTemplateBulkUpdateResponse

+ Secret *CmAndSecretBulkUpdateResponse

type BulkUpdateService

+ BulkUpdate func(bulkUpdateRequest *BulkUpdatePayload) (bulkUpdateResponse *BulkUpdateResponse)

+ BulkUpdateConfigMap func(bulkUpdatePayload *BulkUpdatePayload) *CmAndSecretBulkUpdateResponse

+ BulkUpdateSecret func(bulkUpdatePayload *BulkUpdatePayload) *CmAndSecretBulkUpdateResponse

type BulkUpdateServiceImpl

+ func (impl BulkUpdateServiceImpl) BulkUpdate(bulkUpdatePayload *BulkUpdatePayload) *BulkUpdateResponse

+ func (impl BulkUpdateServiceImpl) BulkUpdateConfigMap(bulkUpdatePayload *BulkUpdatePayload) *CmAndSecretBulkUpdateResponse

+ func (impl BulkUpdateServiceImpl) BulkUpdateSecret(bulkUpdatePayload *BulkUpdatePayload) *CmAndSecretBulkUpdateResponse

type CiHandlerImpl

+ func (impl *CiHandlerImpl) BuildManualTriggerCommitHashesForSourceTypeBranchFix(ciPipelineMaterial bean.CiPipelineMaterial) (bean.GitCommit, error)

+ func (impl *CiHandlerImpl) BuildManualTriggerCommitHashesForSourceTypeWebhook(ciPipelineMaterial bean.CiPipelineMaterial) (bean.GitCommit, error)

type CiProjectDetails

+ WebhookData pipelineConfig.WebhookData

+ type CmAndSecretBulkUpdateResponse struct

+ Failure []*CmAndSecretBulkUpdateResponseForOneApp

+ Message []string

+ Successful []*CmAndSecretBulkUpdateResponseForOneApp

+ type CmAndSecretBulkUpdateResponseForOneApp struct

+ AppId int

+ AppName string

+ EnvId int

+ Message string

+ Names []string

+ type CmAndSecretImpactedObjectsResponseForOneApp struct

+ AppId int

+ AppName string

+ EnvId int

+ Names []string

+ type CmAndSecretSpec struct

+ Names []string

+ PatchJson string

+ type CmAndSecretTask struct

+ Spec *CmAndSecretSpec

+ type DeploymentTemplateBulkUpdateResponse struct

+ Failure []*DeploymentTemplateBulkUpdateResponseForOneApp

+ Message []string

+ Successful []*DeploymentTemplateBulkUpdateResponseForOneApp

+ type DeploymentTemplateBulkUpdateResponseForOneApp struct

+ AppId int

+ AppName string

+ EnvId int

+ Message string

+ type DeploymentTemplateImpactedObjectsResponseForOneApp struct

+ AppId int

+ AppName string

+ EnvId int

+ type DeploymentTemplateSpec struct

+ PatchJson string

+ type DeploymentTemplateTask struct

+ Spec *DeploymentTemplateSpec

+ type GitHostConfig interface

+ Create func(request *GitHostRequest) (int, error)

+ GetAll func() ([]GitHostRequest, error)

+ GetById func(id int) (*GitHostRequest, error)

+ type GitHostConfigImpl struct

+ func NewGitHostConfigImpl(gitHostRepo repository.GitHostRepository, logger *zap.SugaredLogger, ...) *GitHostConfigImpl

+ func (impl GitHostConfigImpl) Create(request *GitHostRequest) (int, error)

+ func (impl GitHostConfigImpl) GetAll() ([]GitHostRequest, error)

+ func (impl GitHostConfigImpl) GetById(id int) (*GitHostRequest, error)

+ type GitHostRequest struct

+ Active bool

+ EventTypeHeader string

+ Id int

+ Name string

+ SecretHeader string

+ SecretValidator string

+ UserId int32

+ WebhookSecret string

+ WebhookUrl string

type GitRegistryRequest

+ GitHostId int

type ImpactedObjectsResponse

+ ConfigMap []*CmAndSecretImpactedObjectsResponseForOneApp

+ DeploymentTemplate []*DeploymentTemplateImpactedObjectsResponseForOneApp

+ Secret []*CmAndSecretImpactedObjectsResponseForOneApp

+ type WebhookEventDataConfig interface

+ Save func(webhookEventDataRequest *WebhookEventDataRequest) error

+ type WebhookEventDataConfigImpl struct

+ func NewWebhookEventDataConfigImpl(logger *zap.SugaredLogger, ...) *WebhookEventDataConfigImpl

+ func (impl WebhookEventDataConfigImpl) Save(webhookEventDataRequest *WebhookEventDataRequest) error

+ type WebhookEventDataRequest struct

+ CreatedOn time.Time

+ EventType string

+ GitHostId int

+ RequestPayloadJson string

Aug 13, 2021

Changes in this version

type CdConfig

+ AzureAccountKey string

+ AzureAccountName string

+ AzureBlobContainerCiCache string

+ AzureBlobContainerCiLog string

+ CloudProvider string

+ MinioAccessKey string

+ MinioEndpoint string

+ MinioSecretKey string

type CdWorkflowRequest

+ AzureBlobConfig *AzureBlobConfig

+ CdCacheLocation string

+ CdCacheRegion string

+ CloudProvider string

+ MinioEndpoint string

Jul 16, 2021

Changes in this version

+ type BulkUpdatePayload struct

+ DeploymentTemplate Tasks

+ EnvIds []int

+ Excludes NameIncludesExcludes

+ Global bool

+ Includes NameIncludesExcludes

+ type BulkUpdateResponse struct

+ Failure []*BulkUpdateResponseStatusForOneApp

+ Message []string

+ Successful []*BulkUpdateResponseStatusForOneApp

+ type BulkUpdateResponseStatusForOneApp struct

+ AppId int

+ AppName string

+ EnvId int

+ Message string

+ type BulkUpdateScript struct

+ ApiVersion string

+ Kind string

+ Spec BulkUpdatePayload

+ type BulkUpdateSeeExampleResponse struct

+ Operation string

+ ReadMe string

+ Script BulkUpdateScript

+ type BulkUpdateService interface

+ ApplyJsonPatch func(patch jsonpatch.Patch, target string) (string, error)

+ BulkUpdateDeploymentTemplate func(bulkUpdateRequest BulkUpdatePayload) (bulkUpdateResponse BulkUpdateResponse)

+ FindBulkUpdateReadme func(operation string) (response BulkUpdateSeeExampleResponse, err error)

+ GetBulkAppName func(bulkUpdateRequest BulkUpdatePayload) ([]*ImpactedObjectsResponse, error)

+ type BulkUpdateServiceImpl struct

+ func NewBulkUpdateServiceImpl(bulkUpdateRepository bulkUpdate.BulkUpdateRepository, ...) *BulkUpdateServiceImpl

+ func (impl BulkUpdateServiceImpl) ApplyJsonPatch(patch jsonpatch.Patch, target string) (string, error)

+ func (impl BulkUpdateServiceImpl) BulkUpdateDeploymentTemplate(bulkUpdatePayload BulkUpdatePayload) BulkUpdateResponse

+ func (impl BulkUpdateServiceImpl) FindBulkUpdateReadme(operation string) (BulkUpdateSeeExampleResponse, error)

+ func (impl BulkUpdateServiceImpl) GetBulkAppName(bulkUpdatePayload BulkUpdatePayload) ([]*ImpactedObjectsResponse, error)

+ type ImpactedObjectsResponse struct

+ AppId int

+ AppName string

+ EnvId int

+ type NameIncludesExcludes struct

+ Names []string

+ type Spec struct

+ PatchJson string

+ type Tasks struct

+ Spec Spec

Jul 9, 2021

Changes in this version

type CdConfig

+ NodeLabel map[string]string

+ NodeLabelSelector []string

Apr 23, 2021

Changes in this version

type ConfigData

+ FilePermission string

+ SubPath bool

Mar 15, 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