scheduler

type Job struct {
	Name     string
	Interval time.Duration
	Run      func(ctx context.Context) error
}

type LastRunProvider interface {
	LastFinished(ctx context.Context, jobName string) (time.Time, bool, error)
}

type Logger interface {
	Info(msg string, args ...any)
	Error(msg string, args ...any)
}

type Recorder interface {
	Record(ctx context.Context, jobName string, startedAt, finishedAt time.Time, success bool, errMsg string) error
}

type RecorderFunc func(ctx context.Context, jobName string, startedAt, finishedAt time.Time, success bool, errMsg string) error

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