scheduler

package

v0.235.0 Latest Latest Go to latest Published: Sep 22, 2026 License: AGPL-3.0 Imports: 25 Imported by: 0

Details

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

This section is empty.

This section is empty.

This section is empty.

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

Manager contains data for managing a scheduler instance.

func NewManager(ctx context.Context) (*Manager, error)

NewManager will create a new manager object containing the scheduler and job queue.

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 (m *Manager) LoadUpdateFeedJobs(ctx context.Context, feedSvc *service.FeedService) error

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

Run starts the scheduler manager.

func (m *Manager) UpdateSerializedJob(ctx context.Context, job *jobs.SerializedJob) error

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.