scheduler

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

type Schedule struct {
	Id        int
	Name      string
	IsActive  bool
	Cron      *string
	NextRunAt *time.Time
	LastRunAt *time.Time
	Payload   any
}

type ScheduleQueryConfig struct {
	TableName      string
	IdField        string
	NameField      string
	IsActiveField  string
	CronField      string
	NextRunAtField string
	LastRunAtField string
	PayloadField   string
}

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

type SchedulerConfig struct {
	Log        *slog.Logger
	Repository SchedulerRepository
	ReloadCron string
	Handler    SchedulerHandler
}

type SchedulerHandler func(tx *sql.Tx, schedule *Schedule) error

type SchedulerRepository interface {
	FindAllActive(tx *sql.Tx) ([]*Schedule, error)
	FindOne(tx *sql.Tx, pk int) (*Schedule, error)
	Save(tx *sql.Tx, s *Schedule) error
	Delete(tx *sql.Tx, pk int) error
}

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

type SimpleSchedulerConfig struct {
	Log        *slog.Logger
	Repository SimpleSchedulerRepository
	Cron       string
	Handler    SchedulerHandler
}

type SimpleSchedulerRepository interface {
	FindAllActiveAndUnprocessed(tx *sql.Tx, moment time.Time) ([]*Schedule, error)
	FindOne(tx *sql.Tx, pk int) (*Schedule, error)
	Save(tx *sql.Tx, s *Schedule) error
	Delete(tx *sql.Tx, pk int) error
}