devtronApps

package
v1.8.1 Latest Latest
Warning

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

 Go to latest Published: Sep 15, 2025 License: Apache-2.0 Imports: 114 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DevtronAppsDeployTriggerWireSet = wire.NewSet(
	userDeploymentRequest.WireSet,
	NewHandlerServiceImpl,
	wire.Bind(new(HandlerService), new(*HandlerServiceImpl)),
)

Functions

func ReplaceImageTagWithDigest 

func ReplaceImageTagWithDigest(image, digest string) string

Types

type FeasibilityManager added in v0.7.0 

type FeasibilityManager interface {
	CheckFeasibility(triggerRequirementRequest *bean.TriggerRequirementRequestDto) error
}

type HandlerService added in v1.5.1 

type HandlerService interface {
	TriggerPostStage(request bean.CdTriggerRequest) (*bean4.ManifestPushTemplate, error)
	TriggerPreStage(request bean.CdTriggerRequest) (*bean4.ManifestPushTemplate, error)

	TriggerAutoCDOnPreStageSuccess(triggerContext bean.TriggerContext, cdPipelineId, ciArtifactId, workflowId int) error

	TriggerStageForBulk(triggerRequest bean.CdTriggerRequest) error

	ManualCdTrigger(triggerContext bean.TriggerContext, overrideRequest *bean3.ValuesOverrideRequest, userMetadata *userBean.UserMetadata) (int, string, *bean4.ManifestPushTemplate, error)
	TriggerAutomaticDeployment(request bean.CdTriggerRequest) error

	TriggerRelease(ctx context.Context, overrideRequest *bean3.ValuesOverrideRequest, envDeploymentConfig *bean9.DeploymentConfig, triggeredAt time.Time, triggeredBy int32) (releaseNo int, manifestPushTemplate *bean4.ManifestPushTemplate, err error)

	CancelStage(workflowRunnerId int, forceAbort bool, userId int32) (int, error)
	DownloadCdWorkflowArtifacts(buildId int) (*os.File, error)
	GetRunningWorkflowLogs(environmentId int, pipelineId int, workflowId int, followLogs bool) (*bufio.Reader, func() error, error)
}

type HandlerServiceImpl added in v1.5.1 

type HandlerServiceImpl struct {
	ACDConfig *argocdServer.ACDConfig

	K8sUtil *util5.K8sServiceImpl
	// contains filtered or unexported fields
}

func NewHandlerServiceImpl added in v1.5.1 

func NewHandlerServiceImpl(logger *zap.SugaredLogger,
	cdWorkflowCommonService cd.CdWorkflowCommonService,
	gitOpsManifestPushService publish.GitOpsPushService,
	gitOpsConfigReadService config.GitOpsConfigReadService,
	argoK8sClient argocdServer.ArgoK8sClient,
	ACDConfig *argocdServer.ACDConfig,
	argoClientWrapperService argocdServer.ArgoClientWrapperService,
	pipelineStatusTimelineService status.PipelineStatusTimelineService,
	chartTemplateService util.ChartTemplateService,
	workflowEventPublishService out.WorkflowEventPublishService,
	manifestCreationService manifest.ManifestCreationService,
	deployedConfigurationHistoryService history.DeployedConfigurationHistoryService,
	pipelineStageService pipeline.PipelineStageService,
	globalPluginService plugin.GlobalPluginService,
	customTagService pipeline.CustomTagService,
	pluginInputVariableParser pipeline.PluginInputVariableParser,
	prePostCdScriptHistoryService history.PrePostCdScriptHistoryService,
	scopedVariableManager variables.ScopedVariableCMCSManager,
	imageDigestPolicyService imageDigestPolicy.ImageDigestPolicyService,
	userService user.UserService,
	helmAppService client2.HelmAppService,
	enforcerUtil rbac.EnforcerUtil,
	userDeploymentRequestService service.UserDeploymentRequestService,
	helmAppClient gRPC.HelmAppClient,
	eventFactory client.EventFactory,
	eventClient client.EventClient,
	envVariables *globalUtil.EnvironmentVariables,
	appRepository appRepository.AppRepository,
	ciPipelineMaterialRepository pipelineConfig.CiPipelineMaterialRepository,
	imageScanHistoryReadService read2.ImageScanHistoryReadService,
	imageScanDeployInfoReadService read2.ImageScanDeployInfoReadService,
	imageScanDeployInfoService security2.ImageScanDeployInfoService,
	pipelineRepository pipelineConfig.PipelineRepository,
	pipelineOverrideRepository chartConfig.PipelineOverrideRepository,
	manifestPushConfigRepository repository.ManifestPushConfigRepository,
	chartRepository chartRepoRepository.ChartRepository,
	envRepository repository2.EnvironmentRepository,
	cdWorkflowRepository pipelineConfig.CdWorkflowRepository,
	ciWorkflowRepository pipelineConfig.CiWorkflowRepository,
	ciArtifactRepository repository3.CiArtifactRepository,
	ciTemplateService pipeline2.CiTemplateReadService,
	gitMaterialReadService read.GitMaterialReadService,
	appLabelRepository pipelineConfig.AppLabelRepository,
	ciPipelineRepository pipelineConfig.CiPipelineRepository,
	appWorkflowRepository appWorkflow.AppWorkflowRepository,
	dockerArtifactStoreRepository repository4.DockerArtifactStoreRepository,
	imageScanService security2.ImageScanService,
	K8sUtil *util5.K8sServiceImpl,
	transactionUtilImpl *sql.TransactionUtilImpl,
	deploymentConfigService common.DeploymentConfigService,
	ciCdPipelineOrchestrator pipeline.CiCdPipelineOrchestrator,
	gitOperationService git.GitOperationService,
	attributeService attributes.AttributesService,
	clusterRepository repository5.ClusterRepository,
	cdWorkflowRunnerService cd.CdWorkflowRunnerService,
	clusterService cluster.ClusterService,
	ciLogService pipeline.CiLogService,
	workflowService executor.WorkflowService,
	blobConfigStorageService pipeline.BlobStorageConfigService,
	deploymentEventHandler app.DeploymentEventHandler,
	asyncRunnable *async.Runnable,
	workflowTriggerAuditService service2.WorkflowTriggerAuditService,
	fluxCdDeploymentService fluxcd.DeploymentService,
	workflowStatusLatestService workflowStatusLatest.WorkflowStatusLatestService) (*HandlerServiceImpl, error)

func (*HandlerServiceImpl) CancelStage added in v1.5.1 

func (impl *HandlerServiceImpl) CancelStage(workflowRunnerId int, forceAbort bool, userId int32) (int, error)

func (*HandlerServiceImpl) CheckFeasibility added in v1.5.1 

func (impl *HandlerServiceImpl) CheckFeasibility(triggerRequirementRequest *bean.TriggerRequirementRequestDto) error

func (*HandlerServiceImpl) DownloadCdWorkflowArtifacts added in v1.5.1 

func (impl *HandlerServiceImpl) DownloadCdWorkflowArtifacts(buildId int) (*os.File, error)

func (*HandlerServiceImpl) GetRunningWorkflowLogs added in v1.5.1 

func (impl *HandlerServiceImpl) GetRunningWorkflowLogs(environmentId int, pipelineId int, wfrId int, followLogs bool) (*bufio.Reader, func() error, error)

func (*HandlerServiceImpl) ManualCdTrigger added in v1.5.1 

func (impl *HandlerServiceImpl) ManualCdTrigger(triggerContext bean.TriggerContext, overrideRequest *bean3.ValuesOverrideRequest, userMetadata *userBean.UserMetadata) (int, string, *bean4.ManifestPushTemplate, error)

TODO: write a wrapper to handle auto and manual trigger

func (*HandlerServiceImpl) ReserveImagesGeneratedAtPlugin added in v1.5.1 

func (impl *HandlerServiceImpl) ReserveImagesGeneratedAtPlugin(customTagId int, destinationImages []string) ([]int, error)

func (*HandlerServiceImpl) TriggerAutoCDOnPreStageSuccess added in v1.5.1 

func (impl *HandlerServiceImpl) TriggerAutoCDOnPreStageSuccess(triggerContext bean.TriggerContext, cdPipelineId, ciArtifactId, workflowId int) error

func (*HandlerServiceImpl) TriggerAutomaticDeployment added in v1.5.1 

func (impl *HandlerServiceImpl) TriggerAutomaticDeployment(request bean.CdTriggerRequest) error

TODO: write a wrapper to handle auto and manual trigger

func (*HandlerServiceImpl) TriggerCD added in v1.5.1 

func (impl *HandlerServiceImpl) TriggerCD(ctx context.Context, artifact *repository3.CiArtifact, cdWorkflowId, wfrId int, pipeline *pipelineConfig.Pipeline, envDeploymentConfig *bean9.DeploymentConfig, triggeredAt time.Time, triggeredBy int32) error

func (*HandlerServiceImpl) TriggerPostStage added in v1.5.1 

func (impl *HandlerServiceImpl) TriggerPostStage(request bean.CdTriggerRequest) (*bean4.ManifestPushTemplate, error)

func (*HandlerServiceImpl) TriggerPreStage added in v1.5.1 

func (impl *HandlerServiceImpl) TriggerPreStage(request bean.CdTriggerRequest) (*bean6.ManifestPushTemplate, error)

func (*HandlerServiceImpl) TriggerRelease added in v1.5.1 

func (impl *HandlerServiceImpl) TriggerRelease(ctx context.Context, overrideRequest *bean3.ValuesOverrideRequest,
	envDeploymentConfig *bean9.DeploymentConfig, triggeredAt time.Time, triggeredBy int32) (releaseNo int, manifestPushTemplate *bean4.ManifestPushTemplate, err error)

TriggerRelease will trigger Install/Upgrade request for Devtron App releases synchronously

func (*HandlerServiceImpl) TriggerStageForBulk added in v1.5.1 

func (impl *HandlerServiceImpl) TriggerStageForBulk(triggerRequest bean.CdTriggerRequest) error

Source Files

View all Source files

Directories

Path Synopsis
adapter
repository
service

Jump to

Keyboard shortcuts

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