You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

27 lines
934 B

  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. }