cron

package
v0.7.2-rc.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 11, 2024 License: Apache-2.0 Imports: 26 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CdApplicationStatusUpdateHandler added in v0.5.1 

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

type CdApplicationStatusUpdateHandlerImpl added in v0.5.1 

type CdApplicationStatusUpdateHandlerImpl struct {
	AppStatusConfig *app.AppServiceConfig
	// contains filtered or unexported fields
}

func NewCdApplicationStatusUpdateHandlerImpl added in v0.5.1 

func NewCdApplicationStatusUpdateHandlerImpl(logger *zap.SugaredLogger, appService app.AppService,
	workflowDagExecutor dag.WorkflowDagExecutor, installedAppService EAMode.InstalledAppDBService,
	AppStatusConfig *app.AppServiceConfig,
	pipelineStatusTimelineRepository pipelineConfig.PipelineStatusTimelineRepository,
	eventClient client2.EventClient, appListingRepository repository.AppListingRepository,
	cdWorkflowRepository pipelineConfig.CdWorkflowRepository,
	pipelineRepository pipelineConfig.PipelineRepository, installedAppVersionHistoryRepository repository2.InstalledAppVersionHistoryRepository,
	installedAppVersionRepository repository2.InstalledAppRepository, cronLogger *cron2.CronLoggerImpl,
	cdWorkflowCommonService cd.CdWorkflowCommonService,
	workflowStatusService status.WorkflowStatusService) *CdApplicationStatusUpdateHandlerImpl

func (*CdApplicationStatusUpdateHandlerImpl) ArgoApplicationStatusUpdate added in v0.5.1 

func (impl *CdApplicationStatusUpdateHandlerImpl) ArgoApplicationStatusUpdate()

func (*CdApplicationStatusUpdateHandlerImpl) ArgoPipelineTimelineUpdate added in v0.6.4 

func (impl *CdApplicationStatusUpdateHandlerImpl) ArgoPipelineTimelineUpdate()

func (*CdApplicationStatusUpdateHandlerImpl) HelmApplicationStatusUpdate added in v0.5.1 

func (impl *CdApplicationStatusUpdateHandlerImpl) HelmApplicationStatusUpdate()

func (*CdApplicationStatusUpdateHandlerImpl) ManualSyncPipelineStatus added in v0.6.11 

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

func (*CdApplicationStatusUpdateHandlerImpl) SyncPipelineStatusForAppStoreForResourceTreeCall added in v0.6.17 

func (impl *CdApplicationStatusUpdateHandlerImpl) SyncPipelineStatusForAppStoreForResourceTreeCall(installedAppVersion *repository2.InstalledAppVersions) error

func (*CdApplicationStatusUpdateHandlerImpl) SyncPipelineStatusForResourceTreeCall added in v0.6.4 

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

type CiStatusUpdateCron added in v0.6.10 

type CiStatusUpdateCron interface {
	UpdateCiWorkflowStatusFailedCron()
}

type CiStatusUpdateCronImpl added in v0.6.10 

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

func NewCiStatusUpdateCronImpl added in v0.6.10 

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

func (*CiStatusUpdateCronImpl) UpdateCiWorkflowStatusFailedCron added in v0.6.10 

func (impl *CiStatusUpdateCronImpl) UpdateCiWorkflowStatusFailedCron()

UpdateCiWorkflowStatusFailedCron this function will execute periodically

type CiTriggerCron added in v0.6.24 

type CiTriggerCron interface {
	TriggerCiCron()
}

type CiTriggerCronConfig added in v0.6.24 

type CiTriggerCronConfig struct {
	SourceControllerCronTime int    `env:"CI_TRIGGER_CRON_TIME" envDefault:"2"`
	PluginName               string `env:"PLUGIN_NAME"  envDefault:"Pull images from container repository"`
}

func GetCiTriggerCronConfig added in v0.6.24 

func GetCiTriggerCronConfig() (*CiTriggerCronConfig, error)

type CiTriggerCronImpl added in v0.6.24 

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

func NewCiTriggerCronImpl added in v0.6.24 

func NewCiTriggerCronImpl(logger *zap.SugaredLogger, cfg *CiTriggerCronConfig, pipelineStageRepository repository.PipelineStageRepository,
	ciHandler pipeline.CiHandler, ciArtifactRepository repository2.CiArtifactRepository, globalPluginRepository repository3.GlobalPluginRepository, cronLogger *cron2.CronLoggerImpl) *CiTriggerCronImpl

func (*CiTriggerCronImpl) TriggerCiCron added in v0.6.24 

func (impl *CiTriggerCronImpl) TriggerCiCron()

UpdateCiWorkflowStatusFailedCron this function will execute periodically

type CiWorkflowStatusUpdateConfig added in v0.6.10 

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 added in v0.6.10 

func GetCiWorkflowStatusUpdateConfig() (*CiWorkflowStatusUpdateConfig, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.