cron

Documentation

Index

• 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) ManualSyncPipelineStatus(appId, envId int, userId int32) error
  • func (impl *CdApplicationStatusUpdateHandlerImpl) Subscribe() error
  • func (impl *CdApplicationStatusUpdateHandlerImpl) SyncPipelineStatusForResourceTreeCall(pipeline *pipelineConfig.Pipeline) error
• type CiStatusUpdateCron
• type CiStatusUpdateCronImpl
  • func NewCiStatusUpdateCronImpl(logger *zap.SugaredLogger, appService app.AppService, ...) *CiStatusUpdateCronImpl
  • func (impl *CiStatusUpdateCronImpl) UpdateCiWorkflowStatusFailedCron()
• type CiWorkflowStatusUpdateConfig
  • func GetCiWorkflowStatusUpdateConfig() (*CiWorkflowStatusUpdateConfig, error)

Types

type CdApplicationStatusUpdateHandler

type CdApplicationStatusUpdateHandler interface {
	HelmApplicationStatusUpdate()
	ArgoApplicationStatusUpdate()
	ArgoPipelineTimelineUpdate()
	Subscribe() error
	SyncPipelineStatusForResourceTreeCall(pipeline *pipelineConfig.Pipeline) error
	ManualSyncPipelineStatus(appId, envId int, userId int32) error
}

type CdApplicationStatusUpdateHandlerImpl

type CdApplicationStatusUpdateHandlerImpl struct {
	CdHandler       pipeline.CdHandler
	AppStatusConfig *app.AppServiceConfig
	// 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 *app.AppServiceConfig, pubsubClient *pubsub.PubSubClientServiceImpl,
	pipelineStatusTimelineRepository pipelineConfig.PipelineStatusTimelineRepository,
	eventClient client2.EventClient, appListingRepository repository.AppListingRepository,
	cdWorkflowRepository pipelineConfig.CdWorkflowRepository,
	pipelineRepository pipelineConfig.PipelineRepository) *CdApplicationStatusUpdateHandlerImpl

func (*CdApplicationStatusUpdateHandlerImpl) ArgoApplicationStatusUpdate

func (impl *CdApplicationStatusUpdateHandlerImpl) ArgoApplicationStatusUpdate()

func (*CdApplicationStatusUpdateHandlerImpl) ArgoPipelineTimelineUpdate

func (impl *CdApplicationStatusUpdateHandlerImpl) ArgoPipelineTimelineUpdate()

func (*CdApplicationStatusUpdateHandlerImpl) HelmApplicationStatusUpdate

func (impl *CdApplicationStatusUpdateHandlerImpl) HelmApplicationStatusUpdate()

func (*CdApplicationStatusUpdateHandlerImpl) ManualSyncPipelineStatus

func (impl *CdApplicationStatusUpdateHandlerImpl) ManualSyncPipelineStatus(appId, envId int, userId int32) error

func (*CdApplicationStatusUpdateHandlerImpl) Subscribe

func (impl *CdApplicationStatusUpdateHandlerImpl) Subscribe() error

func (*CdApplicationStatusUpdateHandlerImpl) SyncPipelineStatusForResourceTreeCall

func (impl *CdApplicationStatusUpdateHandlerImpl) SyncPipelineStatusForResourceTreeCall(pipeline *pipelineConfig.Pipeline) error

type CiStatusUpdateCron

type CiStatusUpdateCron interface {
	UpdateCiWorkflowStatusFailedCron()
}

type CiStatusUpdateCronImpl

type CiStatusUpdateCronImpl struct {
	// contains filtered or unexported fields
}

func NewCiStatusUpdateCronImpl

func NewCiStatusUpdateCronImpl(logger *zap.SugaredLogger, appService app.AppService,
	ciWorkflowStatusUpdateConfig *CiWorkflowStatusUpdateConfig, ciPipelineRepository pipelineConfig.CiPipelineRepository,
	ciHandler pipeline.CiHandler) *CiStatusUpdateCronImpl

func (*CiStatusUpdateCronImpl) UpdateCiWorkflowStatusFailedCron

func (impl *CiStatusUpdateCronImpl) UpdateCiWorkflowStatusFailedCron()

UpdateCiWorkflowStatusFailedCron this function will execute periodically

type CiWorkflowStatusUpdateConfig

type CiWorkflowStatusUpdateConfig struct {
	CiWorkflowStatusUpdateCron string `env:"CI_WORKFLOW_STATUS_UPDATE_CRON" envDefault:"*/5 * * * *"`
	TimeoutForFailedCiBuild    string `env:"TIMEOUT_FOR_FAILED_CI_BUILD" envDefault:"15"` //in minutes
}

func GetCiWorkflowStatusUpdateConfig

func GetCiWorkflowStatusUpdateConfig() (*CiWorkflowStatusUpdateConfig, error)