Versions in this module Expand all Collapse all v0 v0.0.1 Jun 14, 2024 Changes in this version + var Occur = occur + var Recur = recur + var Until = until + type ClockHealth struct + Enabled bool + MaxClockSkew time.Duration + PollPeriod time.Duration + type Details struct + DispatchedAt utc.UTC + DispatchedCount int + RescheduledCount int + ScheduledAt utc.UTC + type Entry interface + S func() *Schedule + type Logger = *elog.Log + type Nexter interface + Next func(now utc.UTC, s *Schedule) utc.UTC + type NexterFn func(now utc.UTC, s *Schedule) utc.UTC + func (f NexterFn) Next(now utc.UTC, s *Schedule) utc.UTC + type NexterTime interface + Next func(now time.Time, s *Schedule) time.Time + type NexterTimeFn func(now time.Time, s *Schedule) time.Time + func (f NexterTimeFn) Next(now time.Time, s *Schedule) time.Time + type OnChannelFull struct + MaxWait time.Duration + type Options struct + ChannelSize uint + ClockHealth ClockHealth + Logger Logger + OnChannelFull OnChannelFull + func NewOptions() *Options + type Schedule struct + func MustSchedule(id string, o interface{}, opts ...ScheduleOpt) *Schedule + func NewSchedule(id string, o interface{}, opts ...ScheduleOpt) (*Schedule, error) + func (s *Schedule) Details() Details + func (s *Schedule) Fn() func() + func (s *Schedule) FnE() func() error + func (s *Schedule) ID() ScheduleID + func (s *Schedule) Object() interface{} + func (s *Schedule) RescheduleAt(t utc.UTC, o ...interface{}) bool + func (s *Schedule) RescheduleIn(d time.Duration, o ...interface{}) bool + func (s *Schedule) S() *Schedule + func (s *Schedule) Str() string + func (s *Schedule) String() string + func (s *Schedule) Time() utc.UTC + type ScheduleID string + type ScheduleOpt func(s *Schedule) error + type Scheduler struct + func New() *Scheduler + func NewScheduler(opts *Options) *Scheduler + func (s *Scheduler) Add(sc *Schedule) bool + func (s *Scheduler) At(at utc.UTC, o interface{}) ScheduleID + func (s *Scheduler) C() chan Entry + func (s *Scheduler) Dump() []*Schedule + func (s *Scheduler) DumpStop() ([]*Schedule, error) + func (s *Scheduler) In(d time.Duration, o interface{}) ScheduleID + func (s *Scheduler) Outlet() []*Schedule + func (s *Scheduler) Remove(id ScheduleID) bool + func (s *Scheduler) Run(schedules []*Schedule) error + func (s *Scheduler) Running() bool + func (s *Scheduler) Start() error + func (s *Scheduler) Stop() error + type Schedules []*Schedule + func (s Schedules) Len() int + func (s Schedules) Less(i, j int) bool + func (s Schedules) Swap(i, j int)
Go to main page