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 repository3.InstalledApps, 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, pipelineStatusTimelineRepository pipelineConfig.PipelineStatusTimelineRepository, pipelineRepository pipelineConfig.PipelineRepository, application application.ServiceClient, appListingService app.AppListingService, ) (*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 repository3.InstalledApps, userId int32) (error, bool)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.