scheduler

type PostgresSchedulerRepository struct {
	Config *ScheduleQueryConfig
}

type Schedule struct {
	Id       int
	Name     string
	IsActive bool
	Cron     *string
	NextTs   *time.Time
	LastTs   *time.Time
	Message  *string
}

type ScheduleQueryConfig struct {
	TableName     string
	IdField       string
	NameField     string
	IsActiveField string
	CronField     string
	NextTsField   string
	LastTsField   string
	MessageField  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, name string, moment time.Time, message *string) error

type SchedulerRepository interface {
	FindAllActive(tx *sql.Tx) ([]*Schedule, error)
	FindAllActiveToProcess(tx *sql.Tx, moment time.Time) ([]*Schedule, error)
	FindOne(tx *sql.Tx, pk int) (*Schedule, error)
	Create(tx *sql.Tx, s *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 SchedulerRepository
	Cron       string
	Handler    SchedulerHandler
}