retrypolicy

package

v0.41.1 Latest Latest Go to latest Published: Jul 29, 2026 License: MPL-2.0 Imports: 5 Imported by: 0

Details

Package retrypolicy contains River's internal retry policy implementations.

This section is empty.

This section is empty.

func NextRetryAt(now time.Time, job *rivertype.JobRow) time.Time

NextRetryAt calculates when the next retry for a failed job should take place relative to now.

type Default struct {
	// contains filtered or unexported fields
}

Default is River's clock-aware default retry policy for internal use.

func NewDefault(timeGenerator rivertype.TimeGenerator) *Default

NewDefault returns a default retry policy that derives retries from the given time generator.

func (p *Default) NextRetry(job *rivertype.JobRow) time.Time

NextRetry calculates when the next retry for a failed job should take place.