Documentation
¶
Index ¶
- Variables
- type WorkflowStatusService
- type WorkflowStatusServiceImpl
- func (impl *WorkflowStatusServiceImpl) CheckAndSendArgoPipelineStatusSyncEventIfNeeded(pipelineId int, installedAppVersionId int, userId int32, ...)
- func (impl *WorkflowStatusServiceImpl) CheckArgoAppStatusPeriodicallyAndUpdateInDb(getPipelineDeployedBeforeMinutes int, getPipelineDeployedWithinHours int) error
- func (impl *WorkflowStatusServiceImpl) CheckArgoPipelineTimelineStatusPeriodicallyAndUpdateInDb(pendingSinceSeconds int, timeForDegradation int) error
- func (impl *WorkflowStatusServiceImpl) CheckHelmAppStatusPeriodicallyAndUpdateInDb(helmPipelineStatusCheckEligibleTime int, getPipelineDeployedWithinHours int) error
- func (impl *WorkflowStatusServiceImpl) UpdatePipelineTimelineAndStatusByLiveApplicationFetch(triggerContext bean3.TriggerContext, pipeline *pipelineConfig.Pipeline, ...) (error, bool)
Constants ¶
This section is empty.
Variables ¶
View Source
var WorkflowStatusWireSet = wire.NewSet( NewWorkflowStatusServiceImpl, wire.Bind(new(WorkflowStatusService), new(*WorkflowStatusServiceImpl)), )
Functions ¶
This section is empty.
Types ¶
type WorkflowStatusService ¶
type WorkflowStatusService interface {
CheckHelmAppStatusPeriodicallyAndUpdateInDb(helmPipelineStatusCheckEligibleTime int,
getPipelineDeployedWithinHours int) error
UpdatePipelineTimelineAndStatusByLiveApplicationFetch(triggerContext bean3.TriggerContext, pipeline *pipelineConfig.Pipeline, installedApp *installedAppReadBean.InstalledAppMin, userId int32) (error, bool)
CheckAndSendArgoPipelineStatusSyncEventIfNeeded(pipelineId int, installedAppVersionId int,
userId int32, isAppStoreApplication bool)
CheckArgoPipelineTimelineStatusPeriodicallyAndUpdateInDb(pendingSinceSeconds int, timeForDegradation int) error
CheckArgoAppStatusPeriodicallyAndUpdateInDb(getPipelineDeployedBeforeMinutes int, getPipelineDeployedWithinHours int) error
}
type WorkflowStatusServiceImpl ¶
type WorkflowStatusServiceImpl struct {
AppConfig *app.AppServiceConfig
// contains filtered or unexported fields
}
func NewWorkflowStatusServiceImpl ¶
func NewWorkflowStatusServiceImpl(logger *zap.SugaredLogger, workflowDagExecutor dag.WorkflowDagExecutor, pipelineStatusTimelineService status.PipelineStatusTimelineService, appService app.AppService, appStatusService app_status.AppStatusService, acdConfig *argocdServer.ACDConfig, AppConfig *app.AppServiceConfig, argoUserService argo.ArgoUserService, pipelineStatusSyncDetailService status.PipelineStatusSyncDetailService, argocdClientWrapperService argocdServer.ArgoClientWrapperService, cdPipelineEventPublishService out.CDPipelineEventPublishService, cdWorkflowRepository pipelineConfig.CdWorkflowRepository, pipelineOverrideRepository chartConfig.PipelineOverrideRepository, installedAppVersionHistoryRepository repository3.InstalledAppVersionHistoryRepository, appRepository appRepository.AppRepository, envRepository repository2.EnvironmentRepository, installedAppRepository repository3.InstalledAppRepository, installedAppReadService installedAppReader.InstalledAppReadService, pipelineStatusTimelineRepository pipelineConfig.PipelineStatusTimelineRepository, pipelineRepository pipelineConfig.PipelineRepository, application application.ServiceClient, appListingService app.AppListingService, deploymentConfigService common2.DeploymentConfigService, ) (*WorkflowStatusServiceImpl, error)
func (*WorkflowStatusServiceImpl) CheckAndSendArgoPipelineStatusSyncEventIfNeeded ¶
func (impl *WorkflowStatusServiceImpl) CheckAndSendArgoPipelineStatusSyncEventIfNeeded(pipelineId int, installedAppVersionId int, userId int32, isAppStoreApplication bool)
func (*WorkflowStatusServiceImpl) CheckArgoAppStatusPeriodicallyAndUpdateInDb ¶
func (impl *WorkflowStatusServiceImpl) CheckArgoAppStatusPeriodicallyAndUpdateInDb(getPipelineDeployedBeforeMinutes int, getPipelineDeployedWithinHours int) error
func (*WorkflowStatusServiceImpl) CheckArgoPipelineTimelineStatusPeriodicallyAndUpdateInDb ¶
func (impl *WorkflowStatusServiceImpl) CheckArgoPipelineTimelineStatusPeriodicallyAndUpdateInDb(pendingSinceSeconds int, timeForDegradation int) error
func (*WorkflowStatusServiceImpl) CheckHelmAppStatusPeriodicallyAndUpdateInDb ¶
func (impl *WorkflowStatusServiceImpl) CheckHelmAppStatusPeriodicallyAndUpdateInDb(helmPipelineStatusCheckEligibleTime int, getPipelineDeployedWithinHours int) error
func (*WorkflowStatusServiceImpl) UpdatePipelineTimelineAndStatusByLiveApplicationFetch ¶
func (impl *WorkflowStatusServiceImpl) UpdatePipelineTimelineAndStatusByLiveApplicationFetch(triggerContext bean3.TriggerContext, pipeline *pipelineConfig.Pipeline, installedApp *installedAppReadBean.InstalledAppMin, userId int32) (error, bool)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.