scheduler

package

v0.250.1 Latest Latest Go to latest Published: Oct 15, 2026 License: AGPL-3.0 Imports: 27 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/immanent-tech/foragd

Links

Open Source Insights

Documentation ¶

Overview ¶

Package scheduler contains code for the scheduler backend that handles managing background jobs for the application.

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Manager ¶

type Manager struct {
	quartz.Scheduler
	// contains filtered or unexported fields
}

Manager contains data for managing a scheduler instance.

func New ¶ added in v0.244.2

func New() (*Manager, error)

New will create a Manager containing the scheduler and job queue. New does not start the scheduler; call Run() to start it. The returned Manager can however be used to manage jobs (schedule/delete/query jobs).

func (*Manager) InitAdminJobs ¶ added in v0.235.0

func (m *Manager) InitAdminJobs(ctx context.Context) error

InitAdminJobs loads the listed jobs into the scheduler. These are administrative jobs that should always be scheduled.

func (*Manager) LoadUpdateFeedJobs ¶ added in v0.235.0

func (m *Manager) LoadUpdateFeedJobs(ctx context.Context, feedSvc *service.FeedService) error

LoadUpdateFeedJobs will ensure that all feeds have an update job scheduled.

func (*Manager) Run ¶ added in v0.235.0

func (m *Manager) Run() error

Run starts the scheduler, including setting up background services, loading context for job queue and initialising admin jobs.

func (*Manager) Shutdown ¶ added in v0.244.2

func (m *Manager) Shutdown()

Shutdown performs shutdown logic for the scheduler, including safe shutdown of background services used by the scheduler and jobs.

Source Files ¶

View all Source files

scheduler.go

Directories ¶

Path	Synopsis
jobs Package jobs provides primitives to interact with the openapi HTTP API.	Package jobs provides primitives to interact with the openapi HTTP API.
queue Package queue implements a quartz.JobQueue using Elasticsearch as the storage backend.	Package queue implements a quartz.JobQueue using Elasticsearch as the storage backend.

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL