Method NextRetry

retry_policy.go:49–58

NextRetry gets the next retry given for the given job, accounting for when it was last attempted and what attempt number that was. Reschedules using a basic exponential backoff of `ATTEMPT^4`, so after the first failure a new try will be scheduled in 1 seconds, 16 seconds after the second, 1 minute

(job *rivertype.JobRow)

// equivalent of the maximum of time.Duration to each retry, about 292 years.
// The schedule is no longer exponential past this point.
func (p *DefaultClientRetryPolicy) NextRetry(job *rivertype.JobRow) time.Time {
	// In modern versions of River `len(job.Errors)` is the same number as
	// `attempt`.  However, in older version snoozing a job wouldn't restore its
	// attempt count to the pre-fetch value, and that would lead to incorrect
	// retry durations when jobs are first snoozed, then retried. To avoid this
	// and keep backward compatibility, the number of errors are used instead.
	errorCount := len(job.Errors) + 1

	return p.timeNowUTC().Add(timeutil.SecondsAsDuration(p.retrySeconds(errorCount)))
}

func (p *DefaultClientRetryPolicy) timeNowUTC() time.Time {
	if p.timeNowFunc != nil {