constantdelay.go 934 B

12345678910111213141516171819202122232425262728
  1. package cron
  2. import "time"
  3. // ConstantDelaySchedule represents a simple recurring duty cycle, e.g. "Every 5 minutes".
  4. // It does not support jobs more frequent than once a second.
  5. type ConstantDelaySchedule struct {
  6. Delay time.Duration
  7. }
  8. // Every returns a crontab Schedule that activates once every duration.
  9. // Delays of less than a second are not supported (will round up to 1 second).
  10. // Any fields less than a Second are truncated.
  11. func Every(duration time.Duration) ConstantDelaySchedule {
  12. if duration < time.Second {
  13. duration = time.Second
  14. }
  15. return ConstantDelaySchedule{
  16. Delay: duration - time.Duration(duration.Nanoseconds())%time.Second,
  17. }
  18. }
  19. // Next returns the next time this should be run.
  20. // This rounds so that the next activation time will be on the second.
  21. func (schedule ConstantDelaySchedule) Next(t time.Time) time.Time {
  22. return t.Add(schedule.Delay - time.Duration(t.Nanosecond())*time.Nanosecond)
  23. }