scheduler

package

v0.0.40 Latest Latest Go to latest Published: Oct 7, 2025 License: GPL-3.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Job struct {
	Name     string
	Schedule string
	Run      func(context.Context) error
}

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

func NewMetrics(namespace string) *Metrics

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

func NewScheduler(log *logrus.Logger, metrics *Metrics) *Scheduler

func (s *Scheduler) AddJob(name, schedule string, run func(context.Context) error) error

func (s *Scheduler) RemoveJob(name string)

func (s *Scheduler) Start()

func (s *Scheduler) Stop()