cron

Documentation

Index

• type AppStatusConfig
  • func GetAppStatusConfig() (*AppStatusConfig, error)
• type CdApplicationStatusUpdateHandler
• type CdApplicationStatusUpdateHandlerImpl
  • func NewCdApplicationStatusUpdateHandlerImpl(logger *zap.SugaredLogger, appService app.AppService, ...) *CdApplicationStatusUpdateHandlerImpl
  • func (impl *CdApplicationStatusUpdateHandlerImpl) ArgoApplicationStatusUpdate()
  • func (impl *CdApplicationStatusUpdateHandlerImpl) HelmApplicationStatusUpdate()

Types

type AppStatusConfig

type AppStatusConfig struct {
	CdPipelineStatusCronTime string `env:"CD_PIPELINE_STATUS_CRON_TIME" envDefault:"*/2 * * * *"`
	PipelineDegradedTime     string `env:"PIPELINE_DEGRADED_TIME" envDefault:"10"` //in minutes
}

func GetAppStatusConfig

func GetAppStatusConfig() (*AppStatusConfig, error)

type CdApplicationStatusUpdateHandler

type CdApplicationStatusUpdateHandler interface {
	HelmApplicationStatusUpdate()
	ArgoApplicationStatusUpdate()
}

type CdApplicationStatusUpdateHandlerImpl

type CdApplicationStatusUpdateHandlerImpl struct {
	CdHandler       pipeline.CdHandler
	AppStatusConfig *AppStatusConfig
	// contains filtered or unexported fields
}

func NewCdApplicationStatusUpdateHandlerImpl

func NewCdApplicationStatusUpdateHandlerImpl(logger *zap.SugaredLogger, appService app.AppService,
	workflowDagExecutor pipeline.WorkflowDagExecutor, installedAppService service.InstalledAppService,
	CdHandler pipeline.CdHandler, AppStatusConfig *AppStatusConfig) *CdApplicationStatusUpdateHandlerImpl

func (*CdApplicationStatusUpdateHandlerImpl) ArgoApplicationStatusUpdate

func (impl *CdApplicationStatusUpdateHandlerImpl) ArgoApplicationStatusUpdate()

func (*CdApplicationStatusUpdateHandlerImpl) HelmApplicationStatusUpdate

func (impl *CdApplicationStatusUpdateHandlerImpl) HelmApplicationStatusUpdate()