schedule_manager

Documentation

Index

• Variables
• type CronEntry
• type ScheduleManager

Variables

var NewScheduleManager = func() *scheduleManager {
	sm := &scheduleManager{
		ScheduleCh: make(chan string, 1),
		cron:       cron.New(),
		Entries:    make(map[string]CronEntry),
	}
	return sm
}

Types

type CronEntry

type CronEntry struct {
	EntryID cron.EntryID
	Ids     map[string]bool
}

type ScheduleManager

type ScheduleManager interface {
	WithContext(ctx context.Context)
	Stop()
	Start()
	Add(entry ScheduleEntry)
	Remove(entry ScheduleEntry)
	Ch() chan string
}