mirror of https://github.com/dapr/kit.git
45 lines
1.7 KiB
Go
45 lines
1.7 KiB
Go
/*
|
|
Copyright 2022 The Dapr Authors
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
This package has been forked from https://github.com/robfig/cron available under the MIT license.
|
|
You can check the original license at:
|
|
https://github.com/robfig/cron/blob/master/LICENSE
|
|
*/
|
|
|
|
//nolint
|
|
package cron
|
|
|
|
import "time"
|
|
|
|
// ConstantDelaySchedule represents a simple recurring duty cycle, e.g. "Every 5 minutes".
|
|
// It does not support jobs more frequent than once a second.
|
|
type ConstantDelaySchedule struct {
|
|
Delay time.Duration
|
|
}
|
|
|
|
// Every returns a crontab Schedule that activates once every duration.
|
|
// Delays of less than a second are not supported (will round up to 1 second).
|
|
// Any fields less than a Second are truncated.
|
|
func Every(duration time.Duration) ConstantDelaySchedule {
|
|
if duration < time.Second {
|
|
duration = time.Second
|
|
}
|
|
return ConstantDelaySchedule{
|
|
Delay: duration - time.Duration(duration.Nanoseconds())%time.Second,
|
|
}
|
|
}
|
|
|
|
// Next returns the next time this should be run.
|
|
// This rounds so that the next activation time will be on the second.
|
|
func (schedule ConstantDelaySchedule) Next(t time.Time) time.Time {
|
|
return t.Add(schedule.Delay - time.Duration(t.Nanosecond())*time.Nanosecond)
|
|
}
|