Documentation
¶
Overview ¶
Package retrypolicy contains River's internal retry policy implementations.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Default ¶
type Default struct {
// contains filtered or unexported fields
}
Default is River's clock-aware default retry policy for internal use.
func NewDefault ¶
func NewDefault(timeGenerator rivertype.TimeGenerator) *Default
NewDefault returns a default retry policy that derives retries from the given time generator.
Source Files
Click to show internal directories.
Click to hide internal directories.