worker

Documentation

Overview

Package worker provides a background job scheduler for running periodic maintenance tasks. Jobs are registered at startup and run according to their defined schedules.

Index

• func Start(ctx context.Context) error
• type Job

Functions

func Start

func Start(ctx context.Context) error

Start initializes and starts the background worker scheduler. It sets up the database connection, tracer, and registers all defined jobs. The scheduler runs until the provided context is canceled.

Types

type Job

type Job interface {
	// Name returns the unique name of the job.
	Name() string

	// Schedule defines when the job should run.
	Schedule() gocron.JobDefinition

	// Do executes the job's task.
	Do(ctx context.Context, s *service.Service, db *app.DB) error
}

Job defines the interface for a background worker job. Each job must provide a name, a schedule, and an execution function.