cron

package
v0.6.24 Latest Latest
Warning

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

 Go to latest Published: Oct 29, 2023 License: Apache-2.0 Imports: 22 Imported by: 0

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()
	Subscribe() error
	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 {
	CdHandler       pipeline.CdHandler
	AppStatusConfig *app.AppServiceConfig
	// contains filtered or unexported fields
}

func NewCdApplicationStatusUpdateHandlerImpl added in v0.5.1 

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, installedAppVersionHistoryRepository repository2.InstalledAppVersionHistoryRepository,
	installedAppVersionRepository repository2.InstalledAppRepository) *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) Subscribe added in v0.6.4 

func (impl *CdApplicationStatusUpdateHandlerImpl) Subscribe() 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) *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) *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)

type CronLoggerImpl added in v0.6.17 

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

func (*CronLoggerImpl) Error added in v0.6.17 

func (impl *CronLoggerImpl) Error(err error, msg string, keysAndValues ...interface{})

func (*CronLoggerImpl) Info added in v0.6.17 

func (impl *CronLoggerImpl) Info(msg string, keysAndValues ...interface{})

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.