scheduler

Oct 15, 2021

Changes in this version

+ func GetFactSituations(fact engine.Fact, t time.Time) ([]situation.HistoryRecord, error)

+ func ReplaceGlobalRepository(repository Repository) func()

+ func ReplaceGlobals(scheduler *InternalScheduler) func()

+ func UpdateSituations(situationsToUpdate map[string]situation.HistoryRecord) ([]evaluator.SituationToEvaluate, error)

+ type FactCalculationJob struct

+ Debug bool

+ FactIds []int64

+ From string

+ LastDailyValue bool

+ ScheduleID int64

+ To string

+ func NewFactCalculationJob(cronExpr string, factIds []int64) FactCalculationJob

+ func (job *FactCalculationJob) ResolveFromAndTo(t time.Time) (time.Time, time.Time, error)

+ func (job *FactCalculationJob) UnmarshalJSON(data []byte) error

+ func (job FactCalculationJob) IsValid() (bool, error)

+ func (job FactCalculationJob) Run()

+ type InternalJob interface

+ IsValid func() (bool, error)

+ func UnmarshalInternalJob(t string, b json.RawMessage, scheduleID int64) (InternalJob, error)

+ type InternalSchedule struct

+ CronExpr string

+ ID int64

+ Job InternalJob

+ JobType string

+ Name string

+ func (schedule *InternalSchedule) IsValid() (bool, error)

+ func (schedule *InternalSchedule) UnmarshalJSON(data []byte) error

+ type InternalScheduler struct

+ C *cron.Cron

+ Jobs map[int64]cron.EntryID

+ RuleEngine chan string

+ func NewScheduler() *InternalScheduler

+ func S() *InternalScheduler

+ func (s *InternalScheduler) AddJobSchedule(schedule InternalSchedule) error

+ func (s *InternalScheduler) AddRunningJob(scheduleID int64)

+ func (s *InternalScheduler) ExistingRunningJob(scheduleID int64) bool

+ func (s *InternalScheduler) Init() error

+ func (s *InternalScheduler) RemoveJobSchedule(scheduleID int64)

+ func (s *InternalScheduler) RemoveRunningJob(scheduleID int64)

+ type PostgresRepository struct

+ func (r *PostgresRepository) Create(schedule InternalSchedule) (int64, error)

+ func (r *PostgresRepository) Delete(id int64) error

+ func (r *PostgresRepository) Get(id int64) (InternalSchedule, bool, error)

+ func (r *PostgresRepository) GetAll() (map[int64]InternalSchedule, error)

+ func (r *PostgresRepository) Update(schedule InternalSchedule) error

+ type Repository interface

+ Create func(schedule InternalSchedule) (int64, error)

+ Delete func(id int64) error

+ Get func(id int64) (InternalSchedule, bool, error)

+ GetAll func() (map[int64]InternalSchedule, error)

+ Update func(schedule InternalSchedule) error

+ func NewPostgresRepository(dbClient *sqlx.DB) Repository

+ func R() Repository