scheduler

package
v1.15.3 Latest Latest
Warning

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

 Go to latest Published: Feb 20, 2026 License: BSD-3-Clause Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	AnalyticsJobName = "analytics-heartbeat"
)
View Source 
const EventCleanupJobName = "event-cleanup"
View Source 
const ScheduledPruneJobName = "scheduled-prune"
View Source 
const VulnerabilityScanJobName = "vulnerability-scan"

Variables

This section is empty.

Functions

This section is empty.

Types

type AnalyticsJob 

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

func NewAnalyticsJob 

func NewAnalyticsJob(
	settingsService *services.SettingsService,
	httpClient *http.Client,
	cfg *config.Config,
) *AnalyticsJob

func (*AnalyticsJob) Name 

func (j *AnalyticsJob) Name() string

func (*AnalyticsJob) Reschedule 

func (j *AnalyticsJob) Reschedule(ctx context.Context) error

func (*AnalyticsJob) Run 

func (j *AnalyticsJob) Run(ctx context.Context)

func (*AnalyticsJob) Schedule 

func (j *AnalyticsJob) Schedule(ctx context.Context) string

type AutoUpdateJob 

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

func NewAutoUpdateJob 

func NewAutoUpdateJob(updaterService *services.UpdaterService, settingsService *services.SettingsService) *AutoUpdateJob

func (*AutoUpdateJob) Name 

func (j *AutoUpdateJob) Name() string

func (*AutoUpdateJob) Reschedule 

func (j *AutoUpdateJob) Reschedule(ctx context.Context) error

func (*AutoUpdateJob) Run 

func (j *AutoUpdateJob) Run(ctx context.Context)

func (*AutoUpdateJob) Schedule 

func (j *AutoUpdateJob) Schedule(ctx context.Context) string

type EnvironmentHealthJob 

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

func NewEnvironmentHealthJob 

func NewEnvironmentHealthJob(environmentService *services.EnvironmentService, settingsService *services.SettingsService) *EnvironmentHealthJob

func (*EnvironmentHealthJob) Name 

func (j *EnvironmentHealthJob) Name() string

func (*EnvironmentHealthJob) Reschedule 

func (j *EnvironmentHealthJob) Reschedule(ctx context.Context) error

func (*EnvironmentHealthJob) Run 

func (j *EnvironmentHealthJob) Run(ctx context.Context)

func (*EnvironmentHealthJob) Schedule 

func (j *EnvironmentHealthJob) Schedule(ctx context.Context) string

type EventCleanupJob 

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

func NewEventCleanupJob 

func NewEventCleanupJob(eventService *services.EventService, settingsService *services.SettingsService) *EventCleanupJob

func (*EventCleanupJob) Name 

func (j *EventCleanupJob) Name() string

func (*EventCleanupJob) Reschedule 

func (j *EventCleanupJob) Reschedule(ctx context.Context) error

func (*EventCleanupJob) Run 

func (j *EventCleanupJob) Run(ctx context.Context)

func (*EventCleanupJob) Schedule 

func (j *EventCleanupJob) Schedule(ctx context.Context) string

type FilesystemWatcherJob 

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

func NewFilesystemWatcherJob 

func NewFilesystemWatcherJob(
	projectService *services.ProjectService,
	templateService *services.TemplateService,
	settingsService *services.SettingsService,
) *FilesystemWatcherJob

func RegisterFilesystemWatcherJob 

func RegisterFilesystemWatcherJob(ctx context.Context, projectService *services.ProjectService, templateService *services.TemplateService, settingsService *services.SettingsService) (*FilesystemWatcherJob, error)

func (*FilesystemWatcherJob) RestartProjectsWatcher 

func (j *FilesystemWatcherJob) RestartProjectsWatcher(ctx context.Context) error

func (*FilesystemWatcherJob) Start 

func (j *FilesystemWatcherJob) Start(ctx context.Context) error

func (*FilesystemWatcherJob) Stop 

func (j *FilesystemWatcherJob) Stop() error

type GitOpsSyncJob 

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

func NewGitOpsSyncJob 

func NewGitOpsSyncJob(syncService *services.GitOpsSyncService, settingsService *services.SettingsService) *GitOpsSyncJob

func (*GitOpsSyncJob) Name 

func (j *GitOpsSyncJob) Name() string

func (*GitOpsSyncJob) Run 

func (j *GitOpsSyncJob) Run(ctx context.Context)

func (*GitOpsSyncJob) Schedule 

func (j *GitOpsSyncJob) Schedule(ctx context.Context) string

type ImagePollingJob 

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

func NewImagePollingJob 

func NewImagePollingJob(imageUpdateService *services.ImageUpdateService, settingsService *services.SettingsService, environmentService *services.EnvironmentService) *ImagePollingJob

func (*ImagePollingJob) Name 

func (j *ImagePollingJob) Name() string

func (*ImagePollingJob) Reschedule 

func (j *ImagePollingJob) Reschedule(ctx context.Context) error

func (*ImagePollingJob) Run 

func (j *ImagePollingJob) Run(ctx context.Context)

func (*ImagePollingJob) Schedule 

func (j *ImagePollingJob) Schedule(ctx context.Context) string

type JobScheduler 

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

func NewJobScheduler 

func NewJobScheduler(ctx context.Context, location *time.Location) *JobScheduler

NewJobScheduler creates a new job scheduler with the specified timezone location. The location is used for interpreting cron expressions. If location is nil, UTC is used.

func (*JobScheduler) GetJob 

func (js *JobScheduler) GetJob(jobID string) (schedulertypes.Job, bool)

func (*JobScheduler) GetLocation 

func (js *JobScheduler) GetLocation() *time.Location

GetLocation returns the timezone location used by the scheduler for cron expressions.

func (*JobScheduler) RegisterJob 

func (js *JobScheduler) RegisterJob(job schedulertypes.Job)

func (*JobScheduler) RescheduleJob 

func (js *JobScheduler) RescheduleJob(ctx context.Context, job schedulertypes.Job) error

func (*JobScheduler) Run 

func (js *JobScheduler) Run(ctx context.Context) error

func (*JobScheduler) StartScheduler 

func (js *JobScheduler) StartScheduler()

type ScheduledPruneJob 

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

func NewScheduledPruneJob 

func NewScheduledPruneJob(systemService *services.SystemService, settingsService *services.SettingsService, notificationService *services.NotificationService) *ScheduledPruneJob

func (*ScheduledPruneJob) Name 

func (j *ScheduledPruneJob) Name() string

func (*ScheduledPruneJob) Reschedule 

func (j *ScheduledPruneJob) Reschedule(ctx context.Context) error

func (*ScheduledPruneJob) Run 

func (j *ScheduledPruneJob) Run(ctx context.Context)

func (*ScheduledPruneJob) Schedule 

func (j *ScheduledPruneJob) Schedule(ctx context.Context) string

type VulnerabilityScanJob 

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

VulnerabilityScanJob periodically scans all Docker images for vulnerabilities using Trivy. It is opt-in via the "vulnerabilityScanEnabled" setting.

func NewVulnerabilityScanJob 

func NewVulnerabilityScanJob(vulnerabilityService *services.VulnerabilityService, settingsService *services.SettingsService) *VulnerabilityScanJob

NewVulnerabilityScanJob creates a new VulnerabilityScanJob.

func (*VulnerabilityScanJob) Name 

func (j *VulnerabilityScanJob) Name() string

func (*VulnerabilityScanJob) Run 

func (j *VulnerabilityScanJob) Run(ctx context.Context)

func (*VulnerabilityScanJob) Schedule 

func (j *VulnerabilityScanJob) Schedule(ctx context.Context) string

Schedule returns the cron expression for the job. Defaults to daily at midnight.

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.