cron

Documentation

Index

• func IsTerminalTimelineStatus(timeline pipelineConfig.TimelineStatus) bool
• 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) ArgoPipelineTimelineUpdate()
  • func (impl *CdApplicationStatusUpdateHandlerImpl) HelmApplicationStatusUpdate()
  • func (impl *CdApplicationStatusUpdateHandlerImpl) Subscribe() error
  • func (impl *CdApplicationStatusUpdateHandlerImpl) SyncPipelineStatusForResourceTreeCall(acdAppName string, appId, envId int) error

Functions

func IsTerminalTimelineStatus

func IsTerminalTimelineStatus(timeline pipelineConfig.TimelineStatus) bool

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()
	ArgoPipelineTimelineUpdate()
	Subscribe() error
	SyncPipelineStatusForResourceTreeCall(acdAppName string, appId, envId int) error
}

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, pubsubClient *pubsub.PubSubClient,
	pipelineStatusTimelineRepository pipelineConfig.PipelineStatusTimelineRepository,
	eventClient client2.EventClient) *CdApplicationStatusUpdateHandlerImpl

func (*CdApplicationStatusUpdateHandlerImpl) ArgoApplicationStatusUpdate

func (impl *CdApplicationStatusUpdateHandlerImpl) ArgoApplicationStatusUpdate()

func (*CdApplicationStatusUpdateHandlerImpl) ArgoPipelineTimelineUpdate

func (impl *CdApplicationStatusUpdateHandlerImpl) ArgoPipelineTimelineUpdate()

func (*CdApplicationStatusUpdateHandlerImpl) HelmApplicationStatusUpdate

func (impl *CdApplicationStatusUpdateHandlerImpl) HelmApplicationStatusUpdate()

func (*CdApplicationStatusUpdateHandlerImpl) Subscribe

func (impl *CdApplicationStatusUpdateHandlerImpl) Subscribe() error

func (*CdApplicationStatusUpdateHandlerImpl) SyncPipelineStatusForResourceTreeCall

func (impl *CdApplicationStatusUpdateHandlerImpl) SyncPipelineStatusForResourceTreeCall(acdAppName string, appId, envId int) error