Skip to content
Snippets Groups Projects
Verified Commit f4fdc7d6 authored by Volker Schukai's avatar Volker Schukai :alien:
Browse files

feat: new manager functions for create scheduler

parent b15e7994
No related branches found
No related tags found
No related merge requests found
......@@ -71,6 +71,35 @@ func (m *Manager) GetCronInstance() *cron.Cron {
return m.cronInstance
}
func (m *Manager) CreateCronScheduler(spec string) *CronScheduler {
return &CronScheduler{
Spec: spec,
cron: m.GetCronInstance(),
}
}
func (m *Manager) CreateInstantScheduler() *InstantScheduler {
return &InstantScheduler{}
}
func (m *Manager) CreateIntervalScheduler(interval time.Duration) *IntervalScheduler {
return &IntervalScheduler{
Interval: interval,
}
}
func (m *Manager) CreateDelayScheduler(delay time.Duration) *DelayScheduler {
return &DelayScheduler{
Delay: delay,
}
}
func (m *Manager) CreateEventScheduler(event EventName) *EventScheduler {
return &EventScheduler{
Event: event,
}
}
func (m *Manager) SetDB(db *gorm.DB) *Manager {
m.mu.Lock()
defer m.mu.Unlock()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment